Commit 1234b5fc authored by duanjinfei's avatar duanjinfei

add nm client monitor log

parent 0ed0c6d6
...@@ -83,6 +83,7 @@ func StartMonitor() { ...@@ -83,6 +83,7 @@ func StartMonitor() {
case <-ticker.C: case <-ticker.C:
log.Info("Monitoring node manager client thread start......") log.Info("Monitoring node manager client thread start......")
for _, managerClient := range usedNodeManagerClient { for _, managerClient := range usedNodeManagerClient {
log.WithField("Status", managerClient.Status).WithField("Is Del", managerClient.IsDel).WithField("EndPoint", managerClient.Endpoint).Info("Monitoring node manager client thread")
if !managerClient.GetStatus() && !managerClient.IsDel { if !managerClient.GetStatus() && !managerClient.IsDel {
log.Warn("The Node manager client is failed:", managerClient.Endpoint) log.Warn("The Node manager client is failed:", managerClient.Endpoint)
manager := getNodeManager(managerClient.Endpoint) manager := getNodeManager(managerClient.Endpoint)
...@@ -100,6 +101,7 @@ func StartMonitor() { ...@@ -100,6 +101,7 @@ func StartMonitor() {
} }
} }
managerClient.IsDel = true managerClient.IsDel = true
log.WithField("Endpoint", managerClient.Endpoint).Warn("Node manager client is deleted")
unUsedNodeManagers := getUnUsedNodeManagers() unUsedNodeManagers := getUnUsedNodeManagers()
if unUsedNodeManagers == nil || len(unUsedNodeManagers) == 0 { if unUsedNodeManagers == nil || len(unUsedNodeManagers) == 0 {
log.Warn("There is no node manager available at this time") log.Warn("There is no node manager available at this time")
......
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