Function runUpdate

cli/command/swarm/update.go:43–76

(ctx context.Context, dockerCLI command.Cli, flags *pflag.FlagSet, opts swarmOptions)

}

func runUpdate(ctx context.Context, dockerCLI command.Cli, flags *pflag.FlagSet, opts swarmOptions) error {
	apiClient := dockerCLI.Client()

	sw, err := apiClient.SwarmInspect(ctx, client.SwarmInspectOptions{})
	if err != nil {
		return err
	}

	prevAutoLock := sw.Swarm.Spec.EncryptionConfig.AutoLockManagers

	opts.mergeSwarmSpec(&sw.Swarm.Spec, flags, &sw.Swarm.ClusterInfo.TLSInfo.TrustRoot)

	curAutoLock := sw.Swarm.Spec.EncryptionConfig.AutoLockManagers

	_, err = apiClient.SwarmUpdate(ctx, client.SwarmUpdateOptions{
		Version: sw.Swarm.Version,
		Spec:    sw.Swarm.Spec,
	})
	if err != nil {
		return err
	}

	_, _ = fmt.Fprintln(dockerCLI.Out(), "Swarm updated.")

	if curAutoLock && !prevAutoLock {
		resp, err := apiClient.SwarmGetUnlockKey(ctx)
		if err != nil {
			return fmt.Errorf("could not fetch unlock key: %w", err)
		}
		printUnlockCommand(dockerCLI.Out(), resp.Key)
	}

	return nil
}