86c30e6a0d
Wording and documentation still need to be updated, but will do so in a follow-up. Also removing the default "10 seconds" from the timeout flags, as this default is not actually used, and may not match the actual default (which is defined on the daemon side). Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
71 lines
1.8 KiB
Go
71 lines
1.8 KiB
Go
package container
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"strings"
|
|
|
|
"github.com/docker/cli/cli"
|
|
"github.com/docker/cli/cli/command"
|
|
"github.com/docker/cli/cli/command/completion"
|
|
"github.com/docker/docker/api/types/container"
|
|
"github.com/pkg/errors"
|
|
"github.com/spf13/cobra"
|
|
)
|
|
|
|
type stopOptions struct {
|
|
signal string
|
|
timeout int
|
|
timeoutChanged bool
|
|
|
|
containers []string
|
|
}
|
|
|
|
// NewStopCommand creates a new cobra.Command for `docker stop`
|
|
func NewStopCommand(dockerCli command.Cli) *cobra.Command {
|
|
var opts stopOptions
|
|
|
|
cmd := &cobra.Command{
|
|
Use: "stop [OPTIONS] CONTAINER [CONTAINER...]",
|
|
Short: "Stop one or more running containers",
|
|
Args: cli.RequiresMinArgs(1),
|
|
RunE: func(cmd *cobra.Command, args []string) error {
|
|
opts.containers = args
|
|
opts.timeoutChanged = cmd.Flags().Changed("time")
|
|
return runStop(dockerCli, &opts)
|
|
},
|
|
ValidArgsFunction: completion.ContainerNames(dockerCli, false),
|
|
}
|
|
|
|
flags := cmd.Flags()
|
|
flags.StringVarP(&opts.signal, "signal", "s", "", "Signal to send to the container")
|
|
flags.IntVarP(&opts.timeout, "time", "t", 0, "Seconds to wait before killing the container")
|
|
return cmd
|
|
}
|
|
|
|
func runStop(dockerCli command.Cli, opts *stopOptions) error {
|
|
var timeout *int
|
|
if opts.timeoutChanged {
|
|
timeout = &opts.timeout
|
|
}
|
|
|
|
errChan := parallelOperation(context.Background(), opts.containers, func(ctx context.Context, id string) error {
|
|
return dockerCli.Client().ContainerStop(ctx, id, container.StopOptions{
|
|
Signal: opts.signal,
|
|
Timeout: timeout,
|
|
})
|
|
})
|
|
var errs []string
|
|
for _, ctr := range opts.containers {
|
|
if err := <-errChan; err != nil {
|
|
errs = append(errs, err.Error())
|
|
continue
|
|
}
|
|
_, _ = fmt.Fprintln(dockerCli.Out(), ctr)
|
|
}
|
|
if len(errs) > 0 {
|
|
return errors.New(strings.Join(errs, "\n"))
|
|
}
|
|
return nil
|
|
}
|