Versions in this module Expand all Collapse all v1 v1.0.0 Jul 3, 2026 Changes in this version + const DefaultVisibility + type Memory struct + Visibility time.Duration + func NewMemory() *Memory + func (m *Memory) Ack(_ context.Context, p *queue.Payload) error + func (m *Memory) Dead(_ context.Context, p *queue.Payload) error + func (m *Memory) DeadLetters() []*queue.Payload + func (m *Memory) InFlight() int + func (m *Memory) Pop(ctx context.Context, q string) (*queue.Payload, error) + func (m *Memory) Push(_ context.Context, q string, p *queue.Payload) error + func (m *Memory) Release(_ context.Context, p *queue.Payload, delay time.Duration) error + func (m *Memory) Size(q string) int + type Redis struct + Visibility time.Duration + func NewRedis(redisURL string) (*Redis, error) + func NewRedisFromClient(c *redis.Client) *Redis + func (r *Redis) Ack(ctx context.Context, p *queue.Payload) error + func (r *Redis) Dead(ctx context.Context, p *queue.Payload) error + func (r *Redis) DeadLetters(ctx context.Context, n int64) ([]*queue.Payload, error) + func (r *Redis) Pop(ctx context.Context, q string) (*queue.Payload, error) + func (r *Redis) Push(ctx context.Context, q string, p *queue.Payload) error + func (r *Redis) Release(ctx context.Context, p *queue.Payload, delay time.Duration) error
Go to main page