update struct name

nm/msg_handler.go

@@ -15,10 +15,10 @@ type NodeManagerHandler struct {
 	nodeManager   *models.NodeManagerClient
 	worker        nodeManagerV1.NodeManagerService_RegisterWorkerClient
 	msgRespWorker *RespMsgWorker
-	taskMsgWorker *TaskHandler
+	taskMsgWorker *TaskWorker
 }
 
-func NewNodeManagerHandler(nodeManager *models.NodeManagerClient, worker nodeManagerV1.NodeManagerService_RegisterWorkerClient, msgRespWorker *RespMsgWorker, taskMsgWorker *TaskHandler) *NodeManagerHandler {
+func NewNodeManagerHandler(nodeManager *models.NodeManagerClient, worker nodeManagerV1.NodeManagerService_RegisterWorkerClient, msgRespWorker *RespMsgWorker, taskMsgWorker *TaskWorker) *NodeManagerHandler {
 	return &NodeManagerHandler{
 		nodeManager:   nodeManager,
 		worker:        worker,
@@ -51,7 +51,7 @@ func (n *NodeManagerHandler) DistributionMsgWorker(nodeManagerMsgChan chan *node
 					params := utils.BuildParams(taskMsg.TaskId)
 					n.msgRespWorker.RegisterMsgResp(n.nodeManager, n.worker, RespTaskAck, params)
 					go func(msgRespWorker *RespMsgWorker,
-						taskMsgWorker *TaskHandler, taskMsg *nodeManagerV1.PushTaskMessage) {
+						taskMsgWorker *TaskWorker, taskMsg *nodeManagerV1.PushTaskMessage) {
 						if !taskMsgWorker.DockerOp.IsHealthy {
 							//params := utils.BuildParams(taskMsgWorker.DockerOp.Reason)
 							//msgRespWorker.RegisterMsgResp(nodeManager, worker, GoodbyeResp, params)