redis

Documentation

Index

• type RedisMessageQueue
  • func New(db int) *RedisMessageQueue
  • func (msgQueue *RedisMessageQueue) Count(ctx context.Context, queue string) (int, error)
  • func (msgQueue *RedisMessageQueue) Delete(ctx context.Context, queue string, id string) error
  • func (msgQueue *RedisMessageQueue) Dequeue(ctx context.Context, queue string, options ...types.DequeueOptions) ([]types.DequeuedMessage, error)
  • func (msgQueue *RedisMessageQueue) Enqueue(ctx context.Context, queue string, payload string, ...) error

Types

type RedisMessageQueue

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

func New

func New(db int) *RedisMessageQueue

func (*RedisMessageQueue) Count

func (msgQueue *RedisMessageQueue) Count(ctx context.Context, queue string) (int, error)

func (*RedisMessageQueue) Delete

func (msgQueue *RedisMessageQueue) Delete(ctx context.Context, queue string, id string) error

func (*RedisMessageQueue) Dequeue

func (msgQueue *RedisMessageQueue) Dequeue(ctx context.Context, queue string, options ...types.DequeueOptions) ([]types.DequeuedMessage, error)

func (*RedisMessageQueue) Enqueue

func (msgQueue *RedisMessageQueue) Enqueue(ctx context.Context, queue string, payload string, options ...types.EnqueueOptions) error