Versions in this module Expand all Collapse all v0 v0.0.6 Aug 15, 2021 Changes in this version + type Option func(*Worker) + func WithAddr(addr string) Option + func WithChannel(channel string) Option + func WithLogger(l queue.Logger) Option + func WithMaxInFlight(num int) Option + func WithRunFunc(fn func(context.Context, queue.QueuedMessage) error) Option + func WithTopic(topic string) Option + type Worker struct + func NewWorker(opts ...Option) *Worker + func (s *Worker) AfterRun() error + func (s *Worker) BeforeRun() error + func (s *Worker) Capacity() int + func (s *Worker) Queue(job queue.QueuedMessage) error + func (s *Worker) Run() error + func (s *Worker) Shutdown() error + func (s *Worker) Usage() int
Go to main page