update.go 1.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. package swarm
  2. import (
  3. "fmt"
  4. "golang.org/x/net/context"
  5. "github.com/docker/docker/api/types/swarm"
  6. "github.com/docker/docker/cli"
  7. "github.com/docker/docker/cli/command"
  8. "github.com/spf13/cobra"
  9. "github.com/spf13/pflag"
  10. )
  11. func newUpdateCommand(dockerCli *command.DockerCli) *cobra.Command {
  12. opts := swarmOptions{}
  13. cmd := &cobra.Command{
  14. Use: "update [OPTIONS]",
  15. Short: "Update the swarm",
  16. Args: cli.NoArgs,
  17. RunE: func(cmd *cobra.Command, args []string) error {
  18. return runUpdate(dockerCli, cmd.Flags(), opts)
  19. },
  20. }
  21. addSwarmFlags(cmd.Flags(), &opts)
  22. return cmd
  23. }
  24. func runUpdate(dockerCli *command.DockerCli, flags *pflag.FlagSet, opts swarmOptions) error {
  25. client := dockerCli.Client()
  26. ctx := context.Background()
  27. var updateFlags swarm.UpdateFlags
  28. swarm, err := client.SwarmInspect(ctx)
  29. if err != nil {
  30. return err
  31. }
  32. opts.mergeSwarmSpec(&swarm.Spec, flags)
  33. err = client.SwarmUpdate(ctx, swarm.Version, swarm.Spec, updateFlags)
  34. if err != nil {
  35. return err
  36. }
  37. fmt.Fprintln(dockerCli.Out(), "Swarm updated.")
  38. return nil
  39. }