queue

Apr 9, 2026

Changes in this version

+ var ErrQueueClosed = errors.New("queue: queue is closed")

+ func NewMemoryQueue() foxhound.Queue

+ type RedisQueue struct

+ func NewRedis(addr, password string, db int, queueKey string) (*RedisQueue, error)

+ func NewRedisFromClient(client *redis.Client, queueKey string) *RedisQueue

+ func (q *RedisQueue) Close() error

+ func (q *RedisQueue) Len() int

+ func (q *RedisQueue) Pop(ctx context.Context) (*foxhound.Job, error)

+ func (q *RedisQueue) Push(ctx context.Context, job *foxhound.Job) error

+ type ReliableConfig struct

+ AckTimeout time.Duration

+ MaxRetries int

+ StaleCheckInterval time.Duration

+ func DefaultReliableConfig() ReliableConfig

+ type ReliableQueue struct

+ func NewReliable(inner foxhound.Queue, cfg ReliableConfig) *ReliableQueue

+ func (rq *ReliableQueue) Ack(job *foxhound.Job)

+ func (rq *ReliableQueue) Close() error

+ func (rq *ReliableQueue) DLQ() []*foxhound.Job

+ func (rq *ReliableQueue) DLQLen() int

+ func (rq *ReliableQueue) InFlightLen() int

+ func (rq *ReliableQueue) Len() int

+ func (rq *ReliableQueue) Nack(ctx context.Context, job *foxhound.Job)

+ func (rq *ReliableQueue) Pop(ctx context.Context) (*foxhound.Job, error)

+ func (rq *ReliableQueue) Push(ctx context.Context, job *foxhound.Job) error

+ func (rq *ReliableQueue) RetryDLQ(ctx context.Context) (int, error)

+ type SQLiteQueue struct

+ func NewSQLite(dbPath string) (*SQLiteQueue, error)

+ func (q *SQLiteQueue) Close() error

+ func (q *SQLiteQueue) Len() int

+ func (q *SQLiteQueue) Pop(ctx context.Context) (*foxhound.Job, error)

+ func (q *SQLiteQueue) Push(_ context.Context, job *foxhound.Job) error