Versions in this module Expand all Collapse all v0 v0.0.2 May 7, 2024 v0.0.1 May 7, 2024 Changes in this version + type ContextPool struct + func (p *ContextPool) Go(f func(ctx context.Context) error) + func (p *ContextPool) Wait() error + func (p *ContextPool) WithCancelOnError() *ContextPool + func (p *ContextPool) WithFailFast() *ContextPool + func (p *ContextPool) WithFirstError() *ContextPool + func (p *ContextPool) WithMaxGoroutines(n int) *ContextPool + type ErrorPool struct + func (p *ErrorPool) Go(f func() error) + func (p *ErrorPool) Wait() error + func (p *ErrorPool) WithContext(ctx context.Context) *ContextPool + func (p *ErrorPool) WithFirstError() *ErrorPool + func (p *ErrorPool) WithMaxGoroutines(n int) *ErrorPool + type Pool struct + func New() *Pool + func (p *Pool) Go(f func()) + func (p *Pool) MaxGoroutines() int + func (p *Pool) Wait() + func (p *Pool) WithContext(ctx context.Context) *ContextPool + func (p *Pool) WithErrors() *ErrorPool + func (p *Pool) WithMaxGoroutines(n int) *Pool + type ResultContextPool struct + func (p *ResultContextPool[T]) Go(f func(context.Context) (T, error)) + func (p *ResultContextPool[T]) Wait() ([]T, error) + func (p *ResultContextPool[T]) WithCancelOnError() *ResultContextPool[T] + func (p *ResultContextPool[T]) WithCollectErrored() *ResultContextPool[T] + func (p *ResultContextPool[T]) WithFailFast() *ResultContextPool[T] + func (p *ResultContextPool[T]) WithFirstError() *ResultContextPool[T] + func (p *ResultContextPool[T]) WithMaxGoroutines(n int) *ResultContextPool[T] + type ResultErrorPool struct + func (p *ResultErrorPool[T]) Go(f func() (T, error)) + func (p *ResultErrorPool[T]) Wait() ([]T, error) + func (p *ResultErrorPool[T]) WithCollectErrored() *ResultErrorPool[T] + func (p *ResultErrorPool[T]) WithContext(ctx context.Context) *ResultContextPool[T] + func (p *ResultErrorPool[T]) WithFirstError() *ResultErrorPool[T] + func (p *ResultErrorPool[T]) WithMaxGoroutines(n int) *ResultErrorPool[T] + type ResultPool struct + func NewWithResults[T any]() *ResultPool[T] + func (p *ResultPool[T]) Go(f func() T) + func (p *ResultPool[T]) MaxGoroutines() int + func (p *ResultPool[T]) Wait() []T + func (p *ResultPool[T]) WithContext(ctx context.Context) *ResultContextPool[T] + func (p *ResultPool[T]) WithErrors() *ResultErrorPool[T] + func (p *ResultPool[T]) WithMaxGoroutines(n int) *ResultPool[T]
Go to main page