starred/cli
1
0
Fork 0
mirror of https://github.com/docker/cli.git synced 2026-09-26 01:10:35 -04:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #27751 from stevvooe/task-naming-correction

Browse Source 
cluster/container: correctly name swarm tasks
Upstream-commit: 3dabad7992e7c75e880ae7b097cc6e119110a947
Component: engine
This commit is contained in:
Vincent Demeester
2016-10-25 15:56:46 -07:00
committed by GitHub
parent 62c252366f ad6d3e7a11
commit 4e3a88d804
1 changed files with 7 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
components/engine/daemon/cluster/executor/container/container.go
+7 -10
View File
@@ -104,8 +104,13 @@ func (c *containerConfig) name() string {
return c.task.Annotations.Name
}
slot := fmt.Sprint(c.task.Slot)
if slot == "" || c.task.Slot == 0 {
slot = c.task.NodeID
}
// fallback to service.slot.id.
return strings.Join([]string{c.task.ServiceAnnotations.Name, fmt.Sprint(c.task.Slot), c.task.ID}, ".")
return fmt.Sprintf("%s.%s.%s", c.task.ServiceAnnotations.Name, slot, c.task.ID)
}
func (c *containerConfig) image() string {
@@ -143,19 +148,11 @@ func (c *containerConfig) config() *enginecontainer.Config {
}
func (c *containerConfig) labels() map[string]string {
taskName := c.task.Annotations.Name
if taskName == "" {
if c.task.Slot != 0 {
taskName = fmt.Sprintf("%v.%v.%v", c.task.ServiceAnnotations.Name, c.task.Slot, c.task.ID)
} else {
taskName = fmt.Sprintf("%v.%v.%v", c.task.ServiceAnnotations.Name, c.task.NodeID, c.task.ID)
}
}
var (
system = map[string]string{
"task": "", // mark as cluster task
"task.id": c.task.ID,
"task.name": taskName,
"task.name": c.name(),
"node.id": c.task.NodeID,
"service.id": c.task.ServiceID,
"service.name": c.task.ServiceAnnotations.Name,