Function buildJobDetailResp

api/handler/v2/job.go:1123–1153

(nomadJob nomadApi.Job, nomadAllocations []nomadApi.Allocation)

}

func buildJobDetailResp(nomadJob nomadApi.Job, nomadAllocations []nomadApi.Allocation) (destTaskDetail models.MysqlDestTaskDetail, srcTaskDetail models.SrcTaskDetail, err error) {
	taskGroupToNomadAlloc := make(map[string][]nomadApi.Allocation)
	for _, a := range nomadAllocations {
		taskGroupToNomadAlloc[a.TaskGroup] = append(taskGroupToNomadAlloc[a.TaskGroup], a)
	}

	for _, tg := range nomadJob.TaskGroups {
		for _, t := range tg.Tasks {
			internalTaskConfig, err := convertTaskConfigMapToInternalTaskConfig(t.Config)
			if err != nil {
				return models.MysqlDestTaskDetail{}, models.SrcTaskDetail{}, fmt.Errorf("convert task config failed: %v", err)
			}

			taskType := common.TaskTypeFromString(t.Name)
			switch taskType {
			case common.TaskTypeSrc:
				srcTaskDetail = buildSrcTaskDetail(
					common.TaskTypeSrc, internalTaskConfig, taskGroupToNomadAlloc[common.TaskTypeSrc])
				destTaskDetail = buildMysqlDestTaskDetail(
					common.TaskTypeDest, internalTaskConfig, taskGroupToNomadAlloc[common.TaskTypeDest])
				break
			case common.TaskTypeDest:
				break
			case common.TaskTypeUnknown:
				break
			}
		}
	}

	return destTaskDetail, srcTaskDetail, nil
}

func CreateOrUpdateSyncJobV2(c echo.Context, create bool) error {
	logger := handler.NewLogger().Named("CreateOrUpdateSyncJobV2")