From 48802cc4329a0700ce96ab7f079ec692d6bfa0c2 Mon Sep 17 00:00:00 2001 From: Akkia Date: Sat, 15 Apr 2023 19:04:04 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8A=A5=E8=AD=A6=E4=BB=BB=E5=8A=A1=E7=8A=B6?= =?UTF-8?q?=E6=80=81=E6=94=B9=E5=8F=98=E6=97=B6=20=E6=B8=85=E9=99=A4?= =?UTF-8?q?=E5=8F=A6=E4=B8=80=E4=B8=AA=E7=8A=B6=E6=80=81=E7=9A=84muteLabel?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- service/singleton/alertsentinel.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/service/singleton/alertsentinel.go b/service/singleton/alertsentinel.go index 8b30e2e..4df2687 100644 --- a/service/singleton/alertsentinel.go +++ b/service/singleton/alertsentinel.go @@ -164,6 +164,9 @@ func checkStatus() { }), server.Name, IPDesensitize(server.Host.IP), alert.Name) go SendTriggerTasks(alert.FailTriggerTasks, curServer.ID) go SendNotification(alert.NotificationTag, message, NotificationMuteLabel.ServerIncident(server.ID, alert.ID), &curServer) + // 清除恢复通知的静音缓存 + resolvedMuteLabel := fmt.Sprintf("%s:%s", *NotificationMuteLabel.ServerIncidentResolved(server.ID, alert.ID), alert.NotificationTag) + Cache.Delete(resolvedMuteLabel) } } else { // 本次通过检查但上一次的状态为失败，则发送恢复通知 @@ -173,6 +176,9 @@ func checkStatus() { }), server.Name, IPDesensitize(server.Host.IP), alert.Name) go SendTriggerTasks(alert.RecoverTriggerTasks, curServer.ID) go SendNotification(alert.NotificationTag, message, NotificationMuteLabel.ServerIncidentResolved(server.ID, alert.ID), &curServer) + // 清除失败通知的静音缓存 + incidentMuteLabel := fmt.Sprintf("%s:%s", *NotificationMuteLabel.ServerIncident(server.ID, alert.ID), alert.NotificationTag) + Cache.Delete(incidentMuteLabel) } alertsPrevState[alert.ID][server.ID] = _RuleCheckPass }