|
@@ -0,0 +1,52 @@
|
|
|
|
+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 waitOptions struct {
|
|
|
|
+ containers []string
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// NewWaitCommand creats a new cobra.Command for `docker wait`
|
|
|
|
+func NewWaitCommand(dockerCli *client.DockerCli) *cobra.Command {
|
|
|
|
+ var opts waitOptions
|
|
|
|
+
|
|
|
|
+ cmd := &cobra.Command{
|
|
|
|
+ Use: "wait CONTAINER [CONTAINER...]",
|
|
|
|
+ Short: "Block until a container stops, then print its exit code",
|
|
|
|
+ Args: cli.RequiresMinArgs(1),
|
|
|
|
+ RunE: func(cmd *cobra.Command, args []string) error {
|
|
|
|
+ opts.containers = args
|
|
|
|
+ return runWait(dockerCli, &opts)
|
|
|
|
+ },
|
|
|
|
+ }
|
|
|
|
+ cmd.SetFlagErrorFunc(flagErrorFunc)
|
|
|
|
+
|
|
|
|
+ return cmd
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+func runWait(dockerCli *client.DockerCli, opts *waitOptions) error {
|
|
|
|
+ ctx := context.Background()
|
|
|
|
+
|
|
|
|
+ var errs []string
|
|
|
|
+ for _, container := range opts.containers {
|
|
|
|
+ status, err := dockerCli.Client().ContainerWait(ctx, container)
|
|
|
|
+ if err != nil {
|
|
|
|
+ errs = append(errs, err.Error())
|
|
|
|
+ } else {
|
|
|
|
+ fmt.Fprintf(dockerCli.Out(), "%d\n", status)
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if len(errs) > 0 {
|
|
|
|
+ return fmt.Errorf("%s", strings.Join(errs, "\n"))
|
|
|
|
+ }
|
|
|
|
+ return nil
|
|
|
|
+}
|