redis

Documentation

Index

• func NewClient(cfg config.Configuration) (*redis.Client, taskq.Factory, error)
• func NewQueue(c *redis.Client, factory taskq.Factory, name string) queue.Queuer
• type RedisQueue
  • func (q *RedisQueue) Close() error
  • func (q *RedisQueue) Consumer() taskq.QueueConsumer
  • func (q *RedisQueue) Write(ctx context.Context, name convoy.TaskName, msg *convoy.Message, ...) error

Functions

func NewClient

func NewClient(cfg config.Configuration) (*redis.Client, taskq.Factory, error)

func NewQueue

func NewQueue(c *redis.Client, factory taskq.Factory, name string) queue.Queuer

Types

type RedisQueue

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

func (*RedisQueue) Close

func (q *RedisQueue) Close() error

func (*RedisQueue) Consumer

func (q *RedisQueue) Consumer() taskq.QueueConsumer

func (*RedisQueue) Write

func (q *RedisQueue) Write(ctx context.Context, name convoy.TaskName, msg *convoy.Message, delay time.Duration) error