проверка ip на актуальность

Author: anton.voskresensky

commands/indexpatterns.go

@@ -68,6 +68,13 @@ func runIndexPatterns(cmd *cobra.Command, args []string) error {
 				logger.Info(fmt.Sprintf("Skipping index-pattern %s:%s - no matching indices found in cluster", ip_id, ip_title))
 				continue
 			}
+			exists, err := kb.CheckIndexPatternExists(ip_id)
+			if err != nil {
+				logger.Warn(fmt.Sprintf("Failed to check if index-pattern exists %s:%s: %v, will try to refresh anyway", ip_id, ip_title, err))
+			} else if !exists {
+				logger.Info(fmt.Sprintf("Index-pattern %s:%s not found in Kibana, skipping refresh", ip_id, ip_title))
+				continue
+			}
 			if cfg.GetDryRun() {
 				logger.Info(fmt.Sprintf("DRY RUN: Would refresh index-pattern %s:%s (matches %d indices)", ip_id, ip_title, len(indices)))
 				refreshedPatterns = append(refreshedPatterns, ip_title)

pkg/kibana/service.go

@@ -136,6 +136,26 @@ func (c *Client) GetActualMappingForIndexPattern(title string) ([]byte, error) {
 	return fields_string, nil
 }
 
+func (c *Client) CheckIndexPatternExists(id string) (bool, error) {
+	u := fmt.Sprintf("%s/api/saved_objects/index-pattern/%s", c.baseURL, id)
+	req, err := http.NewRequest("GET", u, nil)
+	if err != nil {
+		return false, err
+	}
+	resp, err := c.do(req)
+	if err != nil {
+		return false, err
+	}
+	defer resp.Body.Close()
+	if resp.StatusCode == 404 {
+		return false, nil
+	}
+	if resp.StatusCode >= 300 {
+		return false, fmt.Errorf("kibana check index pattern failed: %s", resp.Status)
+	}
+	return true, nil
+}
+
 func (c *Client) RefreshIndexPattern(id string, title string) error {
 	if id == "" {
 		return fmt.Errorf("index pattern id cannot be empty")