Commit 168c0b89 authored by duanjinfei's avatar duanjinfei

add nm heartbeat time monitor

parent 4e5379f1
...@@ -80,8 +80,8 @@ func StartMonitor() { ...@@ -80,8 +80,8 @@ func StartMonitor() {
select { select {
case <-ticker.C: case <-ticker.C:
log.Info("Monitoring node manager client thread start......") log.Info("Monitoring node manager client thread start......")
log.WithField("usedNodeManagerClient", usedNodeManagerClient).Info("Monitoring node manager client thread")
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 {
sub := time.Now().Sub(managerClient.GetLastHeartTime()).Seconds() sub := time.Now().Sub(managerClient.GetLastHeartTime()).Seconds()
log.WithField("time(uint seconds)", sub).Info("Main thread monitor nm heartbeat time") log.WithField("time(uint seconds)", sub).Info("Main thread monitor nm heartbeat 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