Versions in this module Expand all Collapse all v1 v1.0.1 Aug 28, 2026 v1.0.0 Aug 26, 2026 Changes in this version + type Acknowledger interface + Ack func() error + AcknowledgementRequired func() bool + Nack func() error + type DeliveryValidator interface + ValidateDelivery func(TaskMessage) error + type FailureAcknowledger interface + NackFailure func(error) error + type QueuedMessage interface + Bytes func() []byte + type TaskMessage interface + Payload func() []byte + type Worker interface + Queue func(task TaskMessage) error + Request func() (TaskMessage, error) + Run func(ctx context.Context, task TaskMessage) error + Shutdown func() error + type WorkerMetadata interface + BackendName func() string + QueueName func() string
Go to main page