Function runRemove

cli/command/stack/remove.go:48–97

runRemove is the swarm implementation of docker stack remove.

(ctx context.Context, dockerCli command.Cli, opts removeOptions)

// runRemove is the swarm implementation of docker stack remove.
func runRemove(ctx context.Context, dockerCli command.Cli, opts removeOptions) error {
	apiClient := dockerCli.Client()

	var errs []error
	for _, namespace := range opts.namespaces {
		services, err := getStackServices(ctx, apiClient, namespace)
		if err != nil {
			return err
		}

		networks, err := getStackNetworks(ctx, apiClient, namespace)
		if err != nil {
			return err
		}

		secrets, err := getStackSecrets(ctx, apiClient, namespace)
		if err != nil {
			return err
		}

		configs, err := getStackConfigs(ctx, apiClient, namespace)
		if err != nil {
			return err
		}

		if len(services.Items)+len(networks.Items)+len(secrets.Items)+len(configs.Items) == 0 {
			_, _ = fmt.Fprintln(dockerCli.Err(), "Nothing found in stack:", namespace)
			continue
		}

		// TODO(thaJeztah): change this "hasError" boolean to return a (multi-)error for each of these functions instead.
		hasError := removeServices(ctx, dockerCli, services.Items)
		hasError = removeSecrets(ctx, dockerCli, secrets.Items) || hasError
		hasError = removeConfigs(ctx, dockerCli, configs.Items) || hasError
		hasError = removeNetworks(ctx, dockerCli, networks.Items) || hasError

		if hasError {
			errs = append(errs, errors.New("failed to remove some resources from stack: "+namespace))
			continue
		}

		if !opts.detach {
			err = waitOnTasks(ctx, apiClient, namespace)
			if err != nil {
				errs = append(errs, fmt.Errorf("failed to wait on tasks of stack: %s: %w", namespace, err))
			}
		}
	}
	return errors.Join(errs...)
}

func sortServiceByName(services []swarm.Service) func(i, j int) bool {
	return func(i, j int) bool {