workerpool

Documentation

Index

• func AddHandler[T queue.JobData](workerPool *WorkerPool, handler JobHandler[T])
• type JobHandler
• type Options
• type WorkerPool
  • func NewPool(inputQueue queue.Queue, options *Options) (worker *WorkerPool, err error)
  • func (workerPool *WorkerPool) Start(ctx context.Context)

Functions

func AddHandler

func AddHandler[T queue.JobData](workerPool *WorkerPool, handler JobHandler[T])

Types

type JobHandler

type JobHandler[I queue.JobData] func(ctx context.Context, input I) (err error)

type Options

type Options struct {
	// default: 200
	ConcurrencyMax uint32
	Logger         *slog.Logger
	// The default OnError handler is to log the error
	OnError func(ctx context.Context, job queue.Job, err error)
}

type WorkerPool

type WorkerPool struct {
	// contains filtered or unexported fields
}

func NewPool

func NewPool(inputQueue queue.Queue, options *Options) (worker *WorkerPool, err error)

func (*WorkerPool) Start

func (workerPool *WorkerPool) Start(ctx context.Context)