Versions in this module Expand all Collapse all v0 v0.1.0 Jan 21, 2025 Changes in this version + const ExchangeDirect + const ExchangeFanout + const ExchangeHeaders + const ExchangeTopic + type Option func(*options) + func WithAddr(addr string) Option + func WithAutoAck(val bool) Option + func WithExchangeName(val string) Option + func WithExchangeType(val string) Option + func WithLogger(l queue.Logger) Option + func WithQueue(val string) Option + func WithRoutingKey(val string) Option + func WithRunFunc(fn func(context.Context, core.TaskMessage) error) Option + func WithTag(val string) Option + type Worker struct + func NewWorker(opts ...Option) *Worker + func (w *Worker) Queue(job core.TaskMessage) error + func (w *Worker) Request() (core.TaskMessage, error) + func (w *Worker) Run(ctx context.Context, task core.TaskMessage) error + func (w *Worker) Shutdown() (err error)
Go to main page