(nomadAllocation nomadApi.Allocation, taskName string)
| 1089 | } |
| 1090 | |
| 1091 | func getTaskDetailStatusFromAllocInfo(nomadAllocation nomadApi.Allocation, taskName string) models.AllocationDetail { |
| 1092 | newAlloc := models.AllocationDetail{} |
| 1093 | if nomadTaskState, ok := nomadAllocation.TaskStates[taskName]; ok { |
| 1094 | newAlloc.AllocationId = nomadAllocation.ID |
| 1095 | newAlloc.NodeId = nomadAllocation.NodeID |
| 1096 | for _, e := range nomadTaskState.Events { |
| 1097 | newAlloc.TaskStatus.TaskEvents = append(newAlloc.TaskStatus.TaskEvents, models.TaskEvent{ |
| 1098 | EventType: e.Type, |
| 1099 | SetupError: e.SetupError, |
| 1100 | Message: e.DisplayMessage, |
| 1101 | Time: time.Unix(0, e.Time).In(time.Local).Format(time.RFC3339), |
| 1102 | }) |
| 1103 | } |
| 1104 | newAlloc.TaskStatus.Status = nomadTaskState.State |
| 1105 | newAlloc.DesiredStatus = nomadAllocation.DesiredStatus |
| 1106 | newAlloc.TaskStatus.StartedAt = nomadTaskState.StartedAt.In(time.Local) |
| 1107 | newAlloc.TaskStatus.FinishedAt = nomadTaskState.FinishedAt.In(time.Local) |
| 1108 | } |
| 1109 | return newAlloc |
| 1110 | } |
| 1111 | |
| 1112 | func convertTaskConfigMapToInternalTaskConfig(m map[string]interface{}) (internalConfig common.DtleTaskConfig, err error) { |
| 1113 | bs, err := json.Marshal(m) |
no outgoing calls
no test coverage detected