Versions in this module Expand all Collapse all v1 v1.1.0 Nov 6, 2026 v1.0.0 Nov 6, 2026 Changes in this version + type Config struct + Concurrency int + Observer instrument.Hook + Queue int + Report func(error) + Retry *retry.Policy + type Job func(context.Context) error + type Pool struct + func New(ctx context.Context, concurrency, queue int, report func(error)) (*Pool, error) + func NewWithConfig(ctx context.Context, c Config) (*Pool, error) + func (p *Pool) Cancel() + func (p *Pool) Register(name string, job Job) error + func (p *Pool) Shutdown(ctx context.Context) error + func (p *Pool) Stats() Stats + func (p *Pool) Submit(ctx context.Context, job Job) error + func (p *Pool) SubmitNamed(ctx context.Context, name string) error + type Stats struct + Active int64 + Completed int64 + Failed int64 + Panics int64 + Queued int + Started int64 + Submitted int64 + Succeeded int64
Go to main page