Versions in this module Expand all Collapse all v1 v1.0.0 Mar 7, 2026 Changes in this version + func NewRedisQueueWithConfig(config QueueConfig) (port.QueuePort, error) + type QueueConfig struct + Client redis.UniversalClient + QueueCapacity int + QueueName string + RedisAddr string + type RedisQueue struct + func (rq *RedisQueue) Dequeue(ctx context.Context, priority entity.Priority) (*entity.Job, error) + func (rq *RedisQueue) Enqueue(ctx context.Context, job *entity.Job) error + func (rq *RedisQueue) GetDepth(priority entity.Priority) int + func (rq *RedisQueue) GetStats() *port.QueueStats + func (rq *RedisQueue) Start(ctx context.Context) error + func (rq *RedisQueue) Stop(ctx context.Context) error
Go to main page