mirror of
https://github.com/moby/moby.git
synced 2022-11-09 12:21:53 -05:00
Merge pull request #29732 from vdemeester/29676-deploy-indempotent
[1.13.x] Make docker stack deploy a little bit more idempotent
This commit is contained in:
commit
3fc246ded2
1 changed files with 26 additions and 2 deletions
|
@ -2,6 +2,7 @@ package convert
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"sort"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/docker/docker/api/types/container"
|
"github.com/docker/docker/api/types/container"
|
||||||
|
@ -98,9 +99,9 @@ func convertService(
|
||||||
Command: service.Entrypoint,
|
Command: service.Entrypoint,
|
||||||
Args: service.Command,
|
Args: service.Command,
|
||||||
Hostname: service.Hostname,
|
Hostname: service.Hostname,
|
||||||
Hosts: convertExtraHosts(service.ExtraHosts),
|
Hosts: sortStrings(convertExtraHosts(service.ExtraHosts)),
|
||||||
Healthcheck: healthcheck,
|
Healthcheck: healthcheck,
|
||||||
Env: convertEnvironment(service.Environment),
|
Env: sortStrings(convertEnvironment(service.Environment)),
|
||||||
Labels: AddStackLabel(namespace, service.Labels),
|
Labels: AddStackLabel(namespace, service.Labels),
|
||||||
Dir: service.WorkingDir,
|
Dir: service.WorkingDir,
|
||||||
User: service.User,
|
User: service.User,
|
||||||
|
@ -125,6 +126,17 @@ func convertService(
|
||||||
return serviceSpec, nil
|
return serviceSpec, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func sortStrings(strs []string) []string {
|
||||||
|
sort.Strings(strs)
|
||||||
|
return strs
|
||||||
|
}
|
||||||
|
|
||||||
|
type byNetworkTarget []swarm.NetworkAttachmentConfig
|
||||||
|
|
||||||
|
func (a byNetworkTarget) Len() int { return len(a) }
|
||||||
|
func (a byNetworkTarget) Swap(i, j int) { a[i], a[j] = a[j], a[i] }
|
||||||
|
func (a byNetworkTarget) Less(i, j int) bool { return a[i].Target < a[j].Target }
|
||||||
|
|
||||||
func convertServiceNetworks(
|
func convertServiceNetworks(
|
||||||
networks map[string]*composetypes.ServiceNetworkConfig,
|
networks map[string]*composetypes.ServiceNetworkConfig,
|
||||||
networkConfigs networkMap,
|
networkConfigs networkMap,
|
||||||
|
@ -160,6 +172,9 @@ func convertServiceNetworks(
|
||||||
Aliases: append(aliases, name),
|
Aliases: append(aliases, name),
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
sort.Sort(byNetworkTarget(nets))
|
||||||
|
|
||||||
return nets, nil
|
return nets, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -294,6 +309,12 @@ func convertResources(source composetypes.Resources) (*swarm.ResourceRequirement
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type byPublishedPort []swarm.PortConfig
|
||||||
|
|
||||||
|
func (a byPublishedPort) Len() int { return len(a) }
|
||||||
|
func (a byPublishedPort) Swap(i, j int) { a[i], a[j] = a[j], a[i] }
|
||||||
|
func (a byPublishedPort) Less(i, j int) bool { return a[i].PublishedPort < a[j].PublishedPort }
|
||||||
|
|
||||||
func convertEndpointSpec(source []string) (*swarm.EndpointSpec, error) {
|
func convertEndpointSpec(source []string) (*swarm.EndpointSpec, error) {
|
||||||
portConfigs := []swarm.PortConfig{}
|
portConfigs := []swarm.PortConfig{}
|
||||||
ports, portBindings, err := nat.ParsePortSpecs(source)
|
ports, portBindings, err := nat.ParsePortSpecs(source)
|
||||||
|
@ -307,6 +328,9 @@ func convertEndpointSpec(source []string) (*swarm.EndpointSpec, error) {
|
||||||
opts.ConvertPortToPortConfig(port, portBindings)...)
|
opts.ConvertPortToPortConfig(port, portBindings)...)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Sorting to make sure these are always in the same order
|
||||||
|
sort.Sort(byPublishedPort(portConfigs))
|
||||||
|
|
||||||
return &swarm.EndpointSpec{Ports: portConfigs}, nil
|
return &swarm.EndpointSpec{Ports: portConfigs}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue