redis

Oct 24, 2026

Changes in this version

+ const DefaultMigrationBatchSize

+ var ErrDelayedUnsupported = errors.New("babelqueue/redis: delayed publish needs the Laravel-compatible layout")

+ var ErrInvalidRetryAfter = errors.New("babelqueue/redis: retry_after must not be negative")

type Option

+ func WithMigrationBatchSize(n int) Option

+ func WithoutRetryAfter() Option

type Transport

+ func (t *Transport) DeadLetter(ctx context.Context, msg *babelqueue.ReceivedMessage, dlqQueue, body string) error

+ func (t *Transport) PublishDelayed(ctx context.Context, queue string, env babelqueue.Envelope, ...) error

+ func (t *Transport) Release(ctx context.Context, msg *babelqueue.ReceivedMessage, delay time.Duration) error

Oct 20, 2026

Changes in this version

+ const DefaultKeyPrefix

+ const DefaultRetryAfter

+ type Keys struct

+ Delayed string

+ Notify string

+ Ready string

+ Reserved string

+ func LaravelKeys(prefix, queue string) Keys

type Option

+ func WithLaravelLayout(prefix string) Option

+ func WithRetryAfter(d time.Duration) Option

type Transport

+ func (t *Transport) Keys(queue string) Keys

Jun 20, 2026

Changes in this version

type Transport

+ func (t *Transport) PublishWithHeaders(ctx context.Context, queue, body string, headers map[string]string) error

Jun 6, 2026

Changes in this version

+ type Option func(*Transport)

+ func WithProcessingSuffix(suffix string) Option

+ type Transport struct

+ func New(url string, opts ...Option) (*Transport, error)

+ func NewWithClient(client *goredis.Client, opts ...Option) *Transport

+ func (t *Transport) Ack(ctx context.Context, msg *babelqueue.ReceivedMessage) error

+ func (t *Transport) Close() error

+ func (t *Transport) Pop(ctx context.Context, queue string, timeout time.Duration) (*babelqueue.ReceivedMessage, error)

+ func (t *Transport) Publish(ctx context.Context, queue, body string) error