From 36696c317df954209bb391c44db4cb0d8bc3ffb9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Wed, 1 Mar 2023 15:51:09 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/tasks/health_check_executor.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/tasks/health_check_executor.go b/internal/tasks/health_check_executor.go index d46b65d2..045e4434 100644 --- a/internal/tasks/health_check_executor.go +++ b/internal/tasks/health_check_executor.go @@ -212,10 +212,10 @@ func (this *HealthCheckExecutor) runNode(healthCheckConfig *serverconfigs.Health } else if isChanged { // 通知恢复或下线 if result.IsOk { - message := "健康检查成功，节点\"" + result.Node.Name + "\"已恢复上线" + var message = "健康检查成功，节点\"" + result.Node.Name + "\"已恢复上线" err = models.NewMessageDAO().CreateNodeMessage(nil, nodeconfigs.NodeRoleNode, this.clusterId, int64(result.Node.Id), models.MessageTypeHealthCheckNodeUp, models.MessageLevelSuccess, message, message, nil, false) } else { - message := "健康检查失败，节点\"" + result.Node.Name + "\"已自动下线" + var message = "健康检查失败，节点\"" + result.Node.Name + "\"已自动下线" err = models.NewMessageDAO().CreateNodeMessage(nil, nodeconfigs.NodeRoleNode, this.clusterId, int64(result.Node.Id), models.MessageTypeHealthCheckNodeDown, models.MessageLevelError, message, message, nil, false) } if err != nil {