redis

Documentation

Index

• func NewRedisQueue(opts Options, logger *zap.SugaredLogger) (queue.Queue, error)
• type Options
• type RedisQueue
  • func (q *RedisQueue) Enqueue(ctx context.Context, message *queue.Message) error
  • func (q *RedisQueue) StartListen(ctx context.Context, handler queue.HandlerFunc)
  • func (q *RedisQueue) Stats() map[string]interface{}

Functions

func NewRedisQueue

func NewRedisQueue(opts Options, logger *zap.SugaredLogger) (queue.Queue, error)

Types

type Options

type Options struct {
	StreamName        string
	ConsumerGroupName string
	ConsumerName      string
	VisibilityTimeout time.Duration
	Listeners         int

	Client *redis.Client
}

type RedisQueue

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

func (*RedisQueue) Enqueue

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

func (*RedisQueue) StartListen

func (q *RedisQueue) StartListen(ctx context.Context, handler queue.HandlerFunc)

func (*RedisQueue) Stats

func (q *RedisQueue) Stats() map[string]interface{}