parallel

Oct 9, 2024

Changes in this version

type WorkerPanic

+ func (wp WorkerPanic) Error() string

Sep 25, 2024

Changes in this version

+ var GroupDoneError = errGroupDone

+ type WorkerPanic struct

+ Panic any

+ Stacktraces []string

May 6, 2024

Changes in this version

+ func HedgedRequest[T any](ctx context.Context, requester func(context.Context) (T, error), ...) (T, error)

+ type HedgedRequestConfig struct

+ func (h *HedgedRequestConfig) Apply(opts ...HedgedRequestOpt)

+ type HedgedRequestOpt func(config *HedgedRequestConfig)

+ func WithDelay(delay time.Duration) HedgedRequestOpt

+ func WithNumHedgedRequests(numHedgedRequests int) HedgedRequestOpt

Oct 18, 2023

Changes in this version

+ type AllErrsExecutor interface

+ Go func(func(context.Context) error)

+ Wait func() MultiError

+ func GatherErrs(executor Executor) AllErrsExecutor

+ type CollectingAllErrsExecutor interface

+ Go func(func(context.Context) (T, error))

+ Wait func() ([]T, MultiError)

+ func CollectWithErrs(executor Executor) CollectingAllErrsExecutor[T]

+ type CollectingExecutor interface

+ Go func(func(context.Context) (T, error))

+ Wait func() ([]T, error)

+ func Collect(executor Executor) CollectingExecutor[T]

+ type ErrGroupExecutor interface

+ Go func(func(context.Context) error)

+ Wait func() error

+ func ErrGroup(executor Executor) ErrGroupExecutor

+ type Executor interface

+ Go func(func(context.Context))

+ Wait func()

+ func Limited(ctx context.Context, maxGoroutines int) Executor

+ func Unlimited(ctx context.Context) Executor

+ type FeedingAllErrsExecutor interface

+ Go func(func(context.Context) (T, error))

+ Wait func() MultiError

+ func FeedWithErrs(executor Executor, receiver func(context.Context, T) error) FeedingAllErrsExecutor[T]

+ type FeedingExecutor interface

+ Go func(func(context.Context) (T, error))

+ Wait func() error

+ func Feed(executor Executor, receiver func(context.Context, T) error) FeedingExecutor[T]

+ type MultiError interface

+ One func() error

+ Unwrap func() []error

+ func CombineErrors(errs ...error) MultiError

+ func NewMultiError(errs ...error) MultiError