package container import ( "fmt" "strings" "golang.org/x/net/context" "github.com/docker/docker/api/types" "github.com/docker/docker/cli" "github.com/docker/docker/cli/command" "github.com/spf13/cobra" ) type rmOptions struct { rmVolumes bool rmLink bool force bool containers []string } // NewRmCommand creates a new cobra.Command for `docker rm` func NewRmCommand(dockerCli *command.DockerCli) *cobra.Command { var opts rmOptions cmd := &cobra.Command{ Use: "rm [OPTIONS] CONTAINER [CONTAINER...]", Short: "Remove one or more containers", Args: cli.RequiresMinArgs(1), RunE: func(cmd *cobra.Command, args []string) error { opts.containers = args return runRm(dockerCli, &opts) }, } flags := cmd.Flags() flags.BoolVarP(&opts.rmVolumes, "volumes", "v", false, "Remove the volumes associated with the container") flags.BoolVarP(&opts.rmLink, "link", "l", false, "Remove the specified link") flags.BoolVarP(&opts.force, "force", "f", false, "Force the removal of a running container (uses SIGKILL)") return cmd } func runRm(dockerCli *command.DockerCli, opts *rmOptions) error { ctx := context.Background() var errs []string for _, name := range opts.containers { if name == "" { return fmt.Errorf("Container name cannot be empty") } name = strings.Trim(name, "/") if err := removeContainer(dockerCli, ctx, name, opts.rmVolumes, opts.rmLink, opts.force); err != nil { errs = append(errs, err.Error()) } else { fmt.Fprintf(dockerCli.Out(), "%s\n", name) } } if len(errs) > 0 { return fmt.Errorf("%s", strings.Join(errs, "\n")) } return nil } func removeContainer(dockerCli *command.DockerCli, ctx context.Context, container string, removeVolumes, removeLinks, force bool) error { options := types.ContainerRemoveOptions{ RemoveVolumes: removeVolumes, RemoveLinks: removeLinks, Force: force, } if err := dockerCli.Client().ContainerRemove(ctx, container, options); err != nil { return err } return nil }