Versions in this module Expand all Collapse all v5 v5.12.1 Jan 2, 2026 v5.12.0 Dec 29, 2025 Changes in this version + func DefaultMaxConcurrency() int64 + type Executor struct + func NewExecutor(maxConcurrency int64) *Executor + func (executor *Executor) Execute(ctx context.Context, tasks ...Task) error + type Results struct + func NewResults[T any]() *Results[T] + func (results *Results[T]) Add(value T) + func (results *Results[T]) AddError(err error) + func (results *Results[T]) Errors() []error + func (results *Results[T]) HasErrors() bool + func (results *Results[T]) Values() []T + type SyncWriter struct + func NewSyncWriter(writer io.Writer) *SyncWriter + func (syncWriter *SyncWriter) Write(data []byte) (int, error) + type Task func(ctx context.Context) error
Go to main page