redis

Documentation

Index

• func NewClient(cfg config.Configuration) (*asynq.Client, error)
• func NewQueue(opts queue.QueueOptions) queue.Queuer
• type RedisQueue
  • func (q *RedisQueue) DeleteEventDeliveriesfromQueue(queuename convoy.QueueName, ids []string) error
  • func (q *RedisQueue) Inspector() *asynq.Inspector
  • func (q *RedisQueue) Monitor() *asynqmon.HTTPHandler
  • func (q *RedisQueue) Options() queue.QueueOptions
  • func (q *RedisQueue) Write(taskName convoy.TaskName, queueName convoy.QueueName, job *queue.Job) error

Functions

func NewClient

func NewClient(cfg config.Configuration) (*asynq.Client, error)

func NewQueue

func NewQueue(opts queue.QueueOptions) queue.Queuer

Types

type RedisQueue

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

func (*RedisQueue) DeleteEventDeliveriesfromQueue

func (q *RedisQueue) DeleteEventDeliveriesfromQueue(queuename convoy.QueueName, ids []string) error

func (*RedisQueue) Inspector

func (q *RedisQueue) Inspector() *asynq.Inspector

func (*RedisQueue) Monitor

func (q *RedisQueue) Monitor() *asynqmon.HTTPHandler

func (*RedisQueue) Options

func (q *RedisQueue) Options() queue.QueueOptions

func (*RedisQueue) Write

func (q *RedisQueue) Write(taskName convoy.TaskName, queueName convoy.QueueName, job *queue.Job) error