123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051 |
- package container
- import (
- "fmt"
- "strings"
- "golang.org/x/net/context"
- "github.com/docker/docker/api/client"
- "github.com/docker/docker/cli"
- "github.com/spf13/cobra"
- )
- type unpauseOptions struct {
- containers []string
- }
- // NewUnpauseCommand creates a new cobra.Command for `docker unpause`
- func NewUnpauseCommand(dockerCli *client.DockerCli) *cobra.Command {
- var opts unpauseOptions
- cmd := &cobra.Command{
- Use: "unpause CONTAINER [CONTAINER...]",
- Short: "Unpause all processes within one or more containers",
- Args: cli.RequiresMinArgs(1),
- RunE: func(cmd *cobra.Command, args []string) error {
- opts.containers = args
- return runUnpause(dockerCli, &opts)
- },
- }
- cmd.SetFlagErrorFunc(flagErrorFunc)
- return cmd
- }
- func runUnpause(dockerCli *client.DockerCli, opts *unpauseOptions) error {
- ctx := context.Background()
- var errs []string
- for _, container := range opts.containers {
- if err := dockerCli.Client().ContainerUnpause(ctx, container); err != nil {
- errs = append(errs, err.Error())
- } else {
- fmt.Fprintf(dockerCli.Out(), "%s\n", container)
- }
- }
- if len(errs) > 0 {
- return fmt.Errorf("%s", strings.Join(errs, "\n"))
- }
- return nil
- }
|