Function getActiveNodes

cli/command/service/progress/progress.go:219–232

getActiveNodes returns all nodes that are currently not in status [swarm.NodeStateDown]. TODO(thaJeztah): this should really be a filter on [apiClient.NodeList] instead of being filtered on the client side.

(ctx context.Context, apiClient client.NodeAPIClient)

//
// TODO(thaJeztah): this should really be a filter on [apiClient.NodeList] instead of being filtered on the client side.
func getActiveNodes(ctx context.Context, apiClient client.NodeAPIClient) (map[string]struct{}, error) {
	res, err := apiClient.NodeList(ctx, client.NodeListOptions{})
	if err != nil {
		return nil, err
	}

	activeNodes := make(map[string]struct{})
	for _, n := range res.Items {
		if n.Status.State != swarm.NodeStateDown {
			activeNodes[n.ID] = struct{}{}
		}
	}
	return activeNodes, nil
}

func initializeUpdater(service swarm.Service, progressOut progress.Output) (progressUpdater, error) {
	if service.Spec.Mode.Replicated != nil && service.Spec.Mode.Replicated.Replicas != nil {