floraachy
/
console
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add name and tags config

This commit is contained in:
liugq 2023-10-08 11:00:04 +08:00
parent 4356ac4ddf
commit 97731564c1
2 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugin/task_manager/cluster_comparison/orm.go
View File

@ -105,6 +105,7 @@ func buildTask(config *migration_model.ClusterComparisonTaskConfig, creator *rba
"source_total_docs": sourceTotalDocs, "source_total_docs": sourceTotalDocs,
"target_total_docs": targetTotalDocs, "target_total_docs": targetTotalDocs,
"permit_nodes": config.Settings.Execution.Nodes.Permit, "permit_nodes": config.Settings.Execution.Nodes.Permit,
"name": config.Name,
}, },
}, },
Cancellable: true, Cancellable: true,
@ -112,6 +113,9 @@ func buildTask(config *migration_model.ClusterComparisonTaskConfig, creator *rba
Status: task.StatusInit, Status: task.StatusInit,
ConfigString: util.MustToJSON(config), ConfigString: util.MustToJSON(config),
} }
if len(config.Tags) > 0 {
t.Metadata.Labels["tags"] = config.Tags
}
t.ID = util.GetUUID() t.ID = util.GetUUID()
return &t, nil return &t, nil
} }

3
plugin/task_manager/model/comparison.go
View File

@ -5,6 +5,8 @@ import (
) )
type ClusterComparisonTaskConfig struct { type ClusterComparisonTaskConfig struct {
Name string `json:"name"`
Tags []string `json:"tags"`
Cluster struct { Cluster struct {
Source ClusterInfo `json:"source"` Source ClusterInfo `json:"source"`
Target ClusterInfo `json:"target"` Target ClusterInfo `json:"target"`
@ -31,6 +33,7 @@ type ClusterComparisonIndexConfig struct {
// only used in API // only used in API
ScrollPercent float64 `json:"scroll_percent,omitempty"` ScrollPercent float64 `json:"scroll_percent,omitempty"`
ErrorPartitions int `json:"error_partitions,omitempty"` ErrorPartitions int `json:"error_partitions,omitempty"`
RunningChildren int `json:"running_children,omitempty"`
} }
type IndexComparisonTaskConfig struct { type IndexComparisonTaskConfig struct {