忽略告警 aaa、 vcc-talos

service/node-check/node_check.go

@@ -19,12 +19,17 @@ const (
 var HandlerMap = new(sync.Map)
 var HttpGetRetryCount = 3
 var HttpTimeOut = time.Second * 10
+var IgnoreServiceMap = make(map[string]struct{})
 
 func init() {
+	//TODO 灵活配置
 	HandlerMap.Store("aaaa", "http://www.baidasdfasdfasdfasdfu.com/")
+	HandlerMap.Store("heimdallr", "http://172.20.6.33:8989/service-down")
 	//	HandlerMap.Store("aaaa", "http://172.20.6.33:8989/service-down")
+
 	//TODO 灵活配置
-	HandlerMap.Store("heimdallr", "http://172.20.6.33:8989/service-down")
+	IgnoreServiceMap["vcc-talos"] = struct{}{}
+	IgnoreServiceMap["aaaa"] = struct{}{}
 }
 
 func httpGet(url string, timeout time.Duration) (*http.Response, error) {
@@ -95,7 +100,9 @@ func (w watch) UpdateNodes(service *registry.Service) {
 			if oldNode, ok := oldService.NodeMap[node.Id]; ok {
 				if oldNode.Status == Passing && node.Status == Critical {
 					logger.Warning.Print(service.Name, " ", node.Id, "---!!!node critical!!!---")
-					_ = dingding.SenderDingDing(service.Name+" "+node.Id+" "+"---!!!node critical!!!---", dingding.DefaultDingURL)
+					if _, ok := IgnoreServiceMap[service.Name]; !ok {
+						_ = dingding.SenderDingDing(service.Name+" "+node.Id+" "+"---!!!node critical!!!---", dingding.DefaultDingURL)
+					}
 				}
 			}
 		}
@@ -106,7 +113,9 @@ func (w watch) UpdateNodes(service *registry.Service) {
 	serviceString := serviceStr(service)
 	if oldService, ok := servicesStatus[service.Name]; ok && serviceStatus(oldService) && !serviceStatus(service) {
 		logger.Warning.Print(serviceString, "---!!!service critical!!!---")
-		_ = dingding.SenderDingDing(serviceString+"---!!!service critical!!!---", dingding.DefaultDingURL)
+		if _, ok := IgnoreServiceMap[service.Name]; !ok {
+			_ = dingding.SenderDingDing(serviceString+"---!!!service critical!!!---", dingding.DefaultDingURL)
+		}
 		handler(service.Name)
 	} else {
 		logger.Info.Print(serviceString)