redis

Documentation

Index

• func NewRedisQueue(opts RedisQueueOptions, logger *zap.SugaredLogger, metrics *metrics.Metrics) (queue.Queue, error)
• type RedisQueue
  • func (q *RedisQueue) Delete(ctx context.Context, messages []*queue.Message) error
  • func (q *RedisQueue) Dequeue(ctx context.Context, opt *queue.Options) ([]*queue.Message, error)
  • func (q *RedisQueue) Enqueue(ctx context.Context, message *queue.Message) error
  • func (q *RedisQueue) Size(ctx context.Context) (int64, error)
• type RedisQueueOptions

Functions

func NewRedisQueue

func NewRedisQueue(opts RedisQueueOptions, logger *zap.SugaredLogger, metrics *metrics.Metrics) (queue.Queue, error)

Types

type RedisQueue

type RedisQueue struct {
	// contains filtered or unexported fields
}

func (*RedisQueue) Delete

func (q *RedisQueue) Delete(ctx context.Context, messages []*queue.Message) error

func (*RedisQueue) Dequeue

func (q *RedisQueue) Dequeue(ctx context.Context, opt *queue.Options) ([]*queue.Message, error)

func (*RedisQueue) Enqueue

func (q *RedisQueue) Enqueue(ctx context.Context, message *queue.Message) error

func (*RedisQueue) Size

func (q *RedisQueue) Size(ctx context.Context) (int64, error)

type RedisQueueOptions

type RedisQueueOptions struct {
	StreamName        string
	GroupName         string
	ConsumerName      string
	VisibilityTimeout time.Duration

	Client *redis.Client
}