pause.go 1.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. package container
  2. import (
  3. "fmt"
  4. "strings"
  5. "golang.org/x/net/context"
  6. "github.com/docker/docker/api/client"
  7. "github.com/docker/docker/cli"
  8. "github.com/spf13/cobra"
  9. )
  10. type pauseOptions struct {
  11. containers []string
  12. }
  13. // NewPauseCommand creates a new cobra.Command for `docker pause`
  14. func NewPauseCommand(dockerCli *client.DockerCli) *cobra.Command {
  15. var opts pauseOptions
  16. cmd := &cobra.Command{
  17. Use: "pause CONTAINER [CONTAINER...]",
  18. Short: "Pause all processes within one or more containers",
  19. Args: cli.RequiresMinArgs(1),
  20. RunE: func(cmd *cobra.Command, args []string) error {
  21. opts.containers = args
  22. return runPause(dockerCli, &opts)
  23. },
  24. }
  25. cmd.SetFlagErrorFunc(flagErrorFunc)
  26. return cmd
  27. }
  28. func runPause(dockerCli *client.DockerCli, opts *pauseOptions) error {
  29. ctx := context.Background()
  30. var errs []string
  31. for _, container := range opts.containers {
  32. if err := dockerCli.Client().ContainerPause(ctx, container); err != nil {
  33. errs = append(errs, err.Error())
  34. } else {
  35. fmt.Fprintf(dockerCli.Out(), "%s\n", container)
  36. }
  37. }
  38. if len(errs) > 0 {
  39. return fmt.Errorf("%s", strings.Join(errs, "\n"))
  40. }
  41. return nil
  42. }