queue

Documentation

Index

• func WithRouteByLatency(enable bool) func(cache *RedisQueue)
• func WithRouteRandomly(enable bool) func(cache *RedisQueue)
• type RedisQueue
  • func NewRedisQueue(Addrs []string, opts ...redisQueueOpts) (*RedisQueue, error)
  • func (r *RedisQueue) Close()
  • func (r *RedisQueue) Pop(ctx context.Context, key string) (string, error)
  • func (r *RedisQueue) PopWait(ctx context.Context, wait time.Duration, key string) (string, []string, error)
  • func (r *RedisQueue) Push(ctx context.Context, key string, values ...any) error
• type RedisUniversalClient

Functions

func WithRouteByLatency

func WithRouteByLatency(enable bool) func(cache *RedisQueue)

func WithRouteRandomly

func WithRouteRandomly(enable bool) func(cache *RedisQueue)

Types

type RedisQueue

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

func NewRedisQueue

func NewRedisQueue(Addrs []string, opts ...redisQueueOpts) (*RedisQueue, error)

func (*RedisQueue) Close

func (r *RedisQueue) Close()

func (*RedisQueue) Pop

func (r *RedisQueue) Pop(ctx context.Context, key string) (string, error)

func (*RedisQueue) PopWait

func (r *RedisQueue) PopWait(ctx context.Context, wait time.Duration, key string) (string, []string, error)

func (*RedisQueue) Push

func (r *RedisQueue) Push(ctx context.Context, key string, values ...any) error

Push will populate a value to the left side of the queue with a given key and value

type RedisUniversalClient

type RedisUniversalClient interface {
	Ping(ctx context.Context) *redis.StatusCmd
	LPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd
	RPop(ctx context.Context, key string) *redis.StringCmd
	BLMPop(ctx context.Context, timeout time.Duration, direction string, count int64, keys ...string) *redis.KeyValuesCmd
	Close() error
}