INNER CODE UNIT · Go

run

buildpacks-community/kpack · cmd/controller/main.go:276

func run(ctrl *controller.Impl, threadiness int) doneFunc {
	return func(ctx context.Context) error {
		return ctrl.RunContext(ctx, threadiness)
	}
}

type doneFunc func(ctx context.Context) error

func runGroup(ctx context.Context, fns ...func(ctx context.Context) error) error {
	eg, egCtx := errgroup.WithContext(ctx)
	for _, fn := range fns {
		fnCopy := fn
		eg.Go(func() error {
			return fnCopy(egCtx)
		})
	}

	return eg.Wait()

View source record →