(taskName string, internalTaskKafkaConfig common.KafkaConfig, allocsFromNomad []nomadApi.Allocation)
| 1438 | } |
| 1439 | |
| 1440 | func buildKafkaDestTaskDetail(taskName string, internalTaskKafkaConfig common.KafkaConfig, allocsFromNomad []nomadApi.Allocation) (destTaskDetail models.KafkaDestTaskDetail) { |
| 1441 | destTaskDetail.TaskConfig = models.KafkaDestTaskConfig{ |
| 1442 | TaskName: taskName, |
| 1443 | BrokerAddrs: internalTaskKafkaConfig.Brokers, |
| 1444 | Topic: internalTaskKafkaConfig.Topic, |
| 1445 | MessageGroupMaxSize: internalTaskKafkaConfig.MessageGroupMaxSize, |
| 1446 | MessageGroupTimeout: internalTaskKafkaConfig.MessageGroupTimeout, |
| 1447 | DateTimeZone: internalTaskKafkaConfig.DateTimeZone, |
| 1448 | } |
| 1449 | |
| 1450 | for _, a := range allocsFromNomad { |
| 1451 | alloc := getTaskDetailStatusFromAllocInfo(a, taskName) |
| 1452 | destTaskDetail.Allocations = append(destTaskDetail.Allocations, alloc) |
| 1453 | } |
| 1454 | |
| 1455 | return destTaskDetail |
| 1456 | } |
| 1457 | |
| 1458 | // @Id PauseMigrationJobV2 |
| 1459 | // @Description pause migration job. |
no test coverage detected