redis

Documentation

Index

• Variables
• func NewQueue(opts queue.QueueOptions) queue.Queuer
• type Formatter
  • func (f Formatter) FormatPayload(_ string, payload []byte) string
  • func (f Formatter) FormatResult(_ string, payload []byte) string
• 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

Variables

var (
	ErrTaskNotFound  = fmt.Errorf("asynq: %w", asynq.ErrTaskNotFound)
	ErrQueueNotFound = fmt.Errorf("asynq: %w", asynq.ErrQueueNotFound)
)

Functions

func NewQueue

func NewQueue(opts queue.QueueOptions) queue.Queuer

Types

type Formatter

type Formatter struct {
}

func (Formatter) FormatPayload

func (f Formatter) FormatPayload(_ string, payload []byte) string

func (Formatter) FormatResult

func (f Formatter) FormatResult(_ string, payload []byte) string

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