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>
77 lines
2.0 KiB
Go
77 lines
2.0 KiB
Go
package network
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"strconv"
|
|
|
|
"github.com/containerd/errdefs"
|
|
"github.com/docker/cli/cli"
|
|
"github.com/docker/cli/cli/command"
|
|
"github.com/docker/cli/cli/command/completion"
|
|
"github.com/docker/cli/internal/prompt"
|
|
"github.com/moby/moby/api/types/network"
|
|
"github.com/spf13/cobra"
|
|
)
|
|
|
|
type removeOptions struct {
|
|
force bool
|
|
}
|
|
|
|
func newRemoveCommand(dockerCli command.Cli) *cobra.Command {
|
|
var opts removeOptions
|
|
|
|
cmd := &cobra.Command{
|
|
Use: "rm NETWORK [NETWORK...]",
|
|
Aliases: []string{"remove"},
|
|
Short: "Remove one or more networks",
|
|
Args: cli.RequiresMinArgs(1),
|
|
RunE: func(cmd *cobra.Command, args []string) error {
|
|
return runRemove(cmd.Context(), dockerCli, args, &opts)
|
|
},
|
|
ValidArgsFunction: completion.NetworkNames(dockerCli),
|
|
}
|
|
|
|
flags := cmd.Flags()
|
|
flags.BoolVarP(&opts.force, "force", "f", false, "Do not error if the network does not exist")
|
|
return cmd
|
|
}
|
|
|
|
const ingressWarning = "WARNING! Before removing the routing-mesh network, " +
|
|
"make sure all the nodes in your swarm run the same docker engine version. " +
|
|
"Otherwise, removal may not be effective and functionality of newly create " +
|
|
"ingress networks will be impaired.\nAre you sure you want to continue?"
|
|
|
|
func runRemove(ctx context.Context, dockerCLI command.Cli, networks []string, opts *removeOptions) error {
|
|
apiClient := dockerCLI.Client()
|
|
|
|
status := 0
|
|
|
|
for _, name := range networks {
|
|
nw, _, err := apiClient.NetworkInspectWithRaw(ctx, name, network.InspectOptions{})
|
|
if err == nil && nw.Ingress {
|
|
r, err := prompt.Confirm(ctx, dockerCLI.In(), dockerCLI.Out(), ingressWarning)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if !r {
|
|
continue
|
|
}
|
|
}
|
|
if err := apiClient.NetworkRemove(ctx, name); err != nil {
|
|
if opts.force && errdefs.IsNotFound(err) {
|
|
continue
|
|
}
|
|
_, _ = fmt.Fprintln(dockerCLI.Err(), err)
|
|
status = 1
|
|
continue
|
|
}
|
|
_, _ = fmt.Fprintln(dockerCLI.Out(), name)
|
|
}
|
|
|
|
if status != 0 {
|
|
return cli.StatusError{StatusCode: status, Status: "exit status " + strconv.Itoa(status)}
|
|
}
|
|
return nil
|
|
}
|