Function buildMysqlDestTaskDetail

api/handler/v2/job.go:1058–1089

(taskName string, internalTaskConfig common.DtleTaskConfig, allocsFromNomad []nomadApi.Allocation)

}

func buildMysqlDestTaskDetail(taskName string, internalTaskConfig common.DtleTaskConfig, allocsFromNomad []nomadApi.Allocation) (destTaskDetail models.MysqlDestTaskDetail) {
	mysqlConnectionConfig := &models.DatabaseConnectionConfig{
		Host:         internalTaskConfig.DestConnectionConfig.Host,
		Port:         internalTaskConfig.DestConnectionConfig.Port,
		User:         internalTaskConfig.DestConnectionConfig.User,
		Password:     internalTaskConfig.DestConnectionConfig.Password,
		DatabaseType: "MySQL",
	}
	mysqlDestTaskConfig := &models.MysqlDestTaskConfig{
		ParallelWorkers:       internalTaskConfig.ParallelWorkers,
		UseMySQLDependency:    internalTaskConfig.UseMySQLDependency,
		DependencyHistorySize: internalTaskConfig.DependencyHistorySize,
		BulkInsert1:           internalTaskConfig.BulkInsert1,
		BulkInsert2:           internalTaskConfig.BulkInsert2,
		RetryTxLimit:          internalTaskConfig.RetryTxLimit,
		SetGtidNext:           internalTaskConfig.SetGtidNext,
	}
	destTaskDetail.TaskConfig = models.DestTaskConfig{
		TaskName:            taskName,
		ConnectionConfig:    mysqlConnectionConfig,
		MysqlDestTaskConfig: mysqlDestTaskConfig,
	}

	allocs := []models.AllocationDetail{}
	for _, a := range allocsFromNomad {
		newAlloc := getTaskDetailStatusFromAllocInfo(a, taskName)
		allocs = append(allocs, newAlloc)
	}
	destTaskDetail.Allocations = allocs

	return destTaskDetail
}

func getTaskDetailStatusFromAllocInfo(nomadAllocation nomadApi.Allocation, taskName string) models.AllocationDetail {
	newAlloc := models.AllocationDetail{}