queue

Documentation

Index

• type RedisQueue
  • func NewRedisQueue(config *rcconfig.Redis) (queue *RedisQueue)
  • func (q *RedisQueue) Close(ctx context.Context) error
  • func (q *RedisQueue) Connect(ctx context.Context) error
  • func (q *RedisQueue) ConsumeMessage(ctx context.Context) (*model.Job, error)
  • func (q *RedisQueue) GetQueueName() string
  • func (q *RedisQueue) IsConnected(ctx context.Context) bool
  • func (q *RedisQueue) ProduceMessage(ctx context.Context, job *model.Job) error
  • func (q *RedisQueue) QueueLength(ctx context.Context) (int, error)

Types

type RedisQueue

type RedisQueue struct {
	Client *redis.Client
}

func NewRedisQueue

func NewRedisQueue(config *rcconfig.Redis) (queue *RedisQueue)

func (*RedisQueue) Close

func (q *RedisQueue) Close(ctx context.Context) error

func (*RedisQueue) Connect

func (q *RedisQueue) Connect(ctx context.Context) error

func (*RedisQueue) ConsumeMessage

func (q *RedisQueue) ConsumeMessage(ctx context.Context) (*model.Job, error)

func (*RedisQueue) GetQueueName

func (q *RedisQueue) GetQueueName() string

func (*RedisQueue) IsConnected

func (q *RedisQueue) IsConnected(ctx context.Context) bool

func (*RedisQueue) ProduceMessage

func (q *RedisQueue) ProduceMessage(ctx context.Context, job *model.Job) error

func (*RedisQueue) QueueLength

func (q *RedisQueue) QueueLength(ctx context.Context) (int, error)