core

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