add nm heartbeat time monitor

nm/start.go

@@ -8,7 +8,6 @@ import (
 	"example.com/m/operate"
 	"example.com/m/utils"
 	"example.com/m/validator"
-	"fmt"
 	nodeManagerV1 "github.com/odysseus/odysseus-protocol/gen/proto/go/nodemanager/v1"
 	"google.golang.org/grpc"
 	"time"
@@ -100,7 +99,7 @@ func StartMonitor() {
 					if !managerClient.IsDel {
 						// TODO: 重试连接三次
 						isSuccess := inputNodeManagerChan(manager, managerClient, managerClient.IsSelected)
-						log.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 {
 							log.Info("Connect node manager client success:", manager.Info.Endpoint)
 							continue
@@ -209,8 +208,8 @@ func monitorWorker(op *operate.DockerOp) {
 					rev, err := worker.Recv()
 					if int64(sub) > conf.GetConfig().HeartRespTimeSecond || err != nil {
 						log.Error("Rev failed:", err)
-						params := buildParams(fmt.Sprint("Rev failed:", err))
-						msgRespWorker.RegisterMsgResp(nodeManager, worker, GoodbyeResp, params)
+						//params := buildParams(fmt.Sprint("Rev failed:", err))
+						//msgRespWorker.RegisterMsgResp(nodeManager, worker, GoodbyeResp, params)
 						nodeManager.UpdateStatus(false)
 						log.Error("Node manager heartbeat is over")
 						return
@@ -273,8 +272,8 @@ func handlerMsg(nodeManager *models.NodeManagerClient,
 					go func(msgRespWorker *RespMsgWorker,
 						taskMsgWorker *TaskHandler, taskMsg *nodeManagerV1.PushTaskMessage) {
 						if !taskMsgWorker.DockerOp.IsHealthy {
-							params := buildParams(taskMsgWorker.DockerOp.Reason)
-							msgRespWorker.RegisterMsgResp(nodeManager, worker, GoodbyeResp, params)
+							//params := buildParams(taskMsgWorker.DockerOp.Reason)
+							//msgRespWorker.RegisterMsgResp(nodeManager, worker, GoodbyeResp, params)
 							return
 						}
 						taskMsgWorker.Wg.Add(1)