Function forEachContainerConcurrent

pkg/compose/containers.go:181–189

forEachContainerConcurrent runs fn for every container concurrently and waits for all goroutines.

(ctx context.Context, containers Containers, fn func(context.Context, container.Summary) error)

// forEachContainerConcurrent runs fn for every container concurrently and waits for all goroutines.
func forEachContainerConcurrent(ctx context.Context, containers Containers, fn func(context.Context, container.Summary) error) error {
	eg, ctx := errgroup.WithContext(ctx)
	for _, ctr := range containers {
		eg.Go(func() error {
			return fn(ctx, ctr)
		})
	}
	return eg.Wait()
}

// sorted sorts containers in place by canonical name and returns the (same) slice.
func (containers Containers) sorted() Containers {