update protocol

server/node.go

@@ -112,9 +112,9 @@ func (n *Node) Loop(idx int) {
 	}
 	postReceipt := func(task *odysseus.TaskContent, result *odysseus.TaskResponse, err error) error {
 		receipt := new(odysseus.TaskReceipt)
-		receipt.TaskUuid = task.TaskUuid
-		receipt.TaskTimestamp = task.TaskTimestamp
 		receipt.TaskId = task.TaskId
+		receipt.TaskTimestamp = task.TaskTimestamp
+		receipt.TaskType = task.TaskType
 		receipt.TaskUid = task.TaskUid
 		receipt.TaskWorkload = task.TaskWorkload
 		receipt.TaskDuration = (time.Now().UnixNano() - int64(task.TaskTimestamp)) / 1000
@@ -144,13 +144,14 @@ func (n *Node) Loop(idx int) {
 
 		case t := <-taskCh:
 			go func(task *odysseus.TaskContent) {
-				l := log.WithField("task-uuid", task.TaskUuid)
+				l := log.WithField("task-id", task.TaskId)
 				l.WithField("task", task).Info("get task")
+				// todo: add parameter for re-dispatch count.
 				for {
 					worker, err := PopWorker(n.rdb)
 					if err == ErrNoWorker {
 						result := &odysseus.TaskResponse{
-							TaskUuid:      task.TaskUuid,
+							TaskId:        task.TaskId,
 							TaskUid:       task.TaskUid,
 							TaskFee:       task.TaskFee,
 							TaskIsSucceed: false,

server/worker.go

@@ -72,7 +72,7 @@ func newManagerClient(endpoint string) (omanager.NodeManagerServiceClient, error
 
 }
 func DispatchTask(worker Worker, task *odysseus.TaskContent) error {
-	l := log.WithField("task-uuid", task.TaskUuid)
+	l := log.WithField("task-id", task.TaskId)
 	l.WithFields(log.Fields{
 		"worker":      worker.workerid,
 		"managerList": worker.managers,