workerpool

Apr 8, 2023

Changes in this version

+ var ErrNoWorkersAvailable = fmt.Errorf("workerpool: not workers available")

Apr 7, 2023

Changes in this version

+ var ErrPipelineFrozen = fmt.Errorf("workerpool: pipeline is frozed")

+ func GoSpawn(ctx context.Context, fn Func) error

+ func Wrap(p *WorkerPool, f func(context.Context, In) (Out, error)) func(context.Context, In) (Out, error)

+ type AsyncExecutor func(ctx context.Context, fn Func) error

+ type None struct

+ type Pipeline struct

+ func NewPipeline() *Pipeline[In, Out]

+ func NewPipelineWith(opts PipelineOptions) *Pipeline[In, Out]

+ func (p *Pipeline[In, Out]) Join() <-chan Out

+ func (p *Pipeline[In, Out]) ProcessedCount() int

+ func (p *Pipeline[In, Out]) StartFeeder(ctx context.Context, items []In) error

+ func (p *Pipeline[In, Out]) StartFeederFunc(ctx context.Context, feedLoop func(context.Context, chan<- In)) error

+ func (p *Pipeline[In, Out]) StartWorker(ctx context.Context, workOne func(context.Context, In) Out) error

+ func (p *Pipeline[In, Out]) StartWorkerN(ctx context.Context, concurrency int, workOne func(context.Context, In) Out) error

+ type PipelineOptions struct

+ FeederAsyncExecutor AsyncExecutor

+ InputBufferSize int

+ OutputBufferSize int

+ WorkerAsyncExecutor AsyncExecutor

May 15, 2021

Changes in this version

+ var ErrInvalidWorkerPool = fmt.Errorf("workerpool: invalid worker pool")

+ var ErrNoWorkersAvaiable = fmt.Errorf("workerpool: not workers available")

+ func WorkerID(ctx context.Context) (uint32, bool)

+ type Func func(context.Context)

+ type Options struct

+ Capacity uint32

+ CreateIfNoWorkersAvailable bool

+ CreateWorkerID bool

+ IdleTimeout time.Duration

+ ResetInterval time.Duration

+ WaitIfNoWorkersAvailable bool

+ type Stats struct

+ EphemeralWorkers uint32

+ IdleWorkers uint32

+ PendingSubmits uint32

+ ResidentWorkers uint32

+ type WorkerPool struct

+ func New(opts Options) *WorkerPool

+ func (p *WorkerPool) Stats() Stats

+ func (p *WorkerPool) Submit(ctx context.Context, fn Func) error

+ func (p *WorkerPool) SubmitConcurrentDependent(ctx context.Context, fns ...Func) error

+ func (p *WorkerPool) WaitDone(ctx context.Context) error