Commit 3a867ee0 authored by duanjinfei's avatar duanjinfei

change monitor nm

parent aa3f3228
...@@ -96,11 +96,11 @@ func StartMonitor() { ...@@ -96,11 +96,11 @@ func StartMonitor() {
} }
if !managerClient.IsDel { if !managerClient.IsDel {
// TODO: 重试连接三次 // TODO: 重试连接三次
managerClient.UpdateLastHeartTime(time.Now())
isSuccess := inputNodeManagerChan(manager, managerClient, managerClient.IsSelected, monitorNm) isSuccess := inputNodeManagerChan(manager, managerClient, managerClient.IsSelected, monitorNm)
log.WithField("is success", isSuccess).Warn("Try to connect node manager client:", manager.Info.Endpoint) log.WithField("is success", isSuccess).Warn("Try to connect node manager client:", manager.Info.Endpoint)
if isSuccess { if isSuccess {
log.Info("Connect node manager client success:", manager.Info.Endpoint) log.Info("Connect node manager client success:", manager.Info.Endpoint)
managerClient.UpdateLastHeartTime(time.Now())
continue continue
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment