Versions in this module Expand all Collapse all v1 v1.0.0 Aug 28, 2026 Changes in this version + const ExchangeDirect + const ExchangeFanout + const ExchangeHeaders + const ExchangeTopic + type DeadLetterConfig struct + Exchange string + MaxDeliveryAttempts uint32 + Queue string + RoutingKey string + type NativeConfig struct + Connection rabbitmqqueue.ConnectionConfig + Consumer rabbitmqqueue.ConsumerConfig + DeliveryMessageID func(rabbitmqqueue.Delivery, *job.Message) (string, error) + MessageID func(core.TaskMessage) (string, error) + Producer rabbitmqqueue.ProducerConfig + type Option func(*options) + func WithAddr(addr string) Option + func WithAutoAck(val bool) Option + func WithDeadLetter(config DeadLetterConfig) Option + func WithExchangeName(val string) Option + func WithExchangeType(val string) Option + func WithLogger(l queue.Logger) Option + func WithNativeConfig(config NativeConfig) Option + func WithPublishTimeout(timeout time.Duration) Option + func WithQueue(val string) Option + func WithReconnectConfig(config ReconnectConfig) Option + func WithRequestTimeout(timeout time.Duration) Option + func WithRoutingKey(val string) Option + func WithRunFunc(fn func(context.Context, core.TaskMessage) error) Option + func WithTag(val string) Option + type ReconnectConfig struct + InitialDelay time.Duration + MaxDelay time.Duration + MaxRetries int + type Worker struct + func NewWorker(opts ...Option) *Worker + func NewWorkerE(opts ...Option) (*Worker, error) + func (*Worker) BackendName() string + func (worker *Worker) Queue(task core.TaskMessage) error + func (worker *Worker) QueueName() string + func (worker *Worker) Request() (core.TaskMessage, error) + func (worker *Worker) Run(ctx context.Context, task core.TaskMessage) error + func (worker *Worker) Shutdown() error Other modules containing this package github.com/faustbrian/go-queue
Go to main page