worker

Sep 18, 2023

Changes in this version

+ var ErrConcurrencyFactorNotSet = errors.New("concurrency factor not set")

+ var ErrInstrumentationClientNotSet = errors.New("instrumentation client not set")

+ var ErrRedisAddressNotSet = errors.New("redis address not set")

+ var ErrRedisPasswordNotSet = errors.New("redis password not set")

+ var ErrTaskHandlerNotSet = errors.New("task handler not set")

+ type Option func(*Worker)

+ func WithConcurrencyFactor(concurrencyFactor int) Option

+ func WithInstrumentationClient(instrumentationClient *instrumentation.Client) Option

+ func WithRedisAddress(address string) Option

+ func WithTaskHandler(taskHandler taskhandler.ITaskHandler) Option

+ type Worker struct

+ func NewWorker(opts ...Option) (*Worker, error)

+ func (w *Worker) Start() error

+ func (w *Worker) Stop()

+ func (w *Worker) Validate() error