pgworkerpool

Documentation

Index

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

Types

type JobHandler

type JobHandler[I pgqueue.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 pgqueue.Job, err error)
}

type WorkerPool

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

func NewPool

func NewPool(inputQueue pgqueue.Queue, options *Options) (*WorkerPool, error)

func (*WorkerPool) AddHandler

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

func (*WorkerPool) Start

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