Merge pull request #192 from chehongshu/feature/20221227_add_InnerAlertPub_func

add function : publish alert event

Author: shabicheng

Diff for: client_alert.go

@@ -549,3 +549,18 @@ func (c *Client) ListAlert(project, alertName, dashboard string, offset, size in
 	}
 	return listAlert.Results, listAlert.Total, listAlert.Count, err
 }
+
+func (c *Client) PublishAlertEvent(project string, alertResult []byte) error {
+	h := map[string]string{
+		"x-log-bodyrawsize": fmt.Sprintf("%v", len(alertResult)),
+		"Content-Type":      "application/json",
+	}
+
+	uri := "/event/alerthub?type=raw"
+	r, err := c.request(project, "POST", uri, h, alertResult)
+	if err != nil {
+		return err
+	}
+	r.Body.Close()
+	return nil
+}

Diff for: client_interface.go

@@ -348,4 +348,7 @@ type ClientInterface interface {
 	DeleteProjectPolicy(project string) error
 	// GetProjectPolicy return project's policy.
 	GetProjectPolicy(project string) (string, error)
+
+	// #################### AlertPub Msg  #####################
+	PublishAlertEvent(project string, alertResult []byte) error
 }

Diff for: token_auto_update_client.go

@@ -1755,3 +1755,14 @@ func (c *TokenAutoUpdateClient) GetProjectPolicy(project string) (policy string,
 	}
 	return
 }
+
+func (c *TokenAutoUpdateClient) PublishAlertEvent(project string, alertResult []byte) error {
+	var err error = nil
+	for i := 0; i < c.maxTryTimes; i++ {
+		err = c.logClient.PublishAlertEvent(project, alertResult)
+		if err == nil {
+			break
+		}
+	}
+	return err
+}