89d8c8a2a7
We transitioned most functionality of docker/errdefs to containerd errdefs module, and the docker/errdefs package should no longer be used. Because of that, there will no longer be ambiguity, so we can remove the aliases for this package, and use it as "errdefs". Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
105 lines
2.8 KiB
Go
105 lines
2.8 KiB
Go
package image
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
|
|
"github.com/containerd/errdefs"
|
|
"github.com/containerd/platforms"
|
|
"github.com/docker/cli/cli"
|
|
"github.com/docker/cli/cli/command"
|
|
"github.com/docker/cli/cli/command/completion"
|
|
"github.com/moby/moby/api/types/image"
|
|
"github.com/spf13/cobra"
|
|
)
|
|
|
|
type removeOptions struct {
|
|
force bool
|
|
noPrune bool
|
|
platforms []string
|
|
}
|
|
|
|
// NewRemoveCommand creates a new `docker remove` command
|
|
func NewRemoveCommand(dockerCLI command.Cli) *cobra.Command {
|
|
var options removeOptions
|
|
|
|
cmd := &cobra.Command{
|
|
Use: "rmi [OPTIONS] IMAGE [IMAGE...]",
|
|
Short: "Remove one or more images",
|
|
Args: cli.RequiresMinArgs(1),
|
|
RunE: func(cmd *cobra.Command, args []string) error {
|
|
return runRemove(cmd.Context(), dockerCLI, options, args)
|
|
},
|
|
ValidArgsFunction: completion.ImageNames(dockerCLI, -1),
|
|
Annotations: map[string]string{
|
|
"aliases": "docker image rm, docker image remove, docker rmi",
|
|
},
|
|
}
|
|
|
|
flags := cmd.Flags()
|
|
|
|
flags.BoolVarP(&options.force, "force", "f", false, "Force removal of the image")
|
|
flags.BoolVar(&options.noPrune, "no-prune", false, "Do not delete untagged parents")
|
|
|
|
// TODO(thaJeztah): create a "platforms" option for this (including validation / parsing).
|
|
flags.StringSliceVar(&options.platforms, "platform", nil, `Remove only the given platform variant. Formatted as "os[/arch[/variant]]" (e.g., "linux/amd64")`)
|
|
_ = flags.SetAnnotation("platform", "version", []string{"1.50"})
|
|
|
|
_ = cmd.RegisterFlagCompletionFunc("platform", completion.Platforms)
|
|
return cmd
|
|
}
|
|
|
|
func newRemoveCommand(dockerCli command.Cli) *cobra.Command {
|
|
cmd := *NewRemoveCommand(dockerCli)
|
|
cmd.Aliases = []string{"rmi", "remove"}
|
|
cmd.Use = "rm [OPTIONS] IMAGE [IMAGE...]"
|
|
return &cmd
|
|
}
|
|
|
|
func runRemove(ctx context.Context, dockerCLI command.Cli, opts removeOptions, images []string) error {
|
|
apiClient := dockerCLI.Client()
|
|
|
|
options := image.RemoveOptions{
|
|
Force: opts.force,
|
|
PruneChildren: !opts.noPrune,
|
|
}
|
|
|
|
for _, v := range opts.platforms {
|
|
p, err := platforms.Parse(v)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
options.Platforms = append(options.Platforms, p)
|
|
}
|
|
|
|
// TODO(thaJeztah): this logic can likely be simplified: do we want to print "not found" errors at all when using "force"?
|
|
fatalErr := false
|
|
var errs []error
|
|
for _, img := range images {
|
|
dels, err := apiClient.ImageRemove(ctx, img, options)
|
|
if err != nil {
|
|
if !errdefs.IsNotFound(err) {
|
|
fatalErr = true
|
|
}
|
|
errs = append(errs, err)
|
|
} else {
|
|
for _, del := range dels {
|
|
if del.Deleted != "" {
|
|
_, _ = fmt.Fprintln(dockerCLI.Out(), "Deleted:", del.Deleted)
|
|
} else {
|
|
_, _ = fmt.Fprintln(dockerCLI.Out(), "Untagged:", del.Untagged)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if err := errors.Join(errs...); err != nil {
|
|
if !opts.force || fatalErr {
|
|
return err
|
|
}
|
|
_, _ = fmt.Fprintln(dockerCLI.Err(), err)
|
|
}
|
|
return nil
|
|
}
|