queue

Documentation

Index

• func NewClient(cfg config.Configuration) (*asynq.Client, error)
• type Job
• type QueueOptions
• type Queuer
  • func NewQueue(opts QueueOptions) Queuer
• type Redis
  • func NewRedis(dsn string) (*Redis, error)
  • func (r *Redis) Client() *redis.Client
  • func (r *Redis) MakeRedisClient() interface{}
• type RedisQueue
  • func (q *RedisQueue) Inspector() *asynq.Inspector
  • func (q *RedisQueue) Monitor() *asynqmon.HTTPHandler
  • func (q *RedisQueue) Options() QueueOptions
  • func (q *RedisQueue) Write(taskName util.TaskName, queueName util.QueueName, job *Job) error

Functions

func NewClient

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

Types

type Job

type Job struct {
	ID      string          `json:"id"`
	Payload json.RawMessage `json:"payload"`
	Delay   time.Duration   `json:"delay"`
}

type QueueOptions

type QueueOptions struct {
	RedisAddress string
	RedisClient  *Redis
	Names        map[string]int
}

type Queuer

type Queuer interface {
	Write(util.TaskName, util.QueueName, *Job) error
	Options() QueueOptions
}

func NewQueue

func NewQueue(opts QueueOptions) Queuer

type Redis

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

Redis is our wrapper logic to instrument redis calls

func NewRedis

func NewRedis(dsn string) (*Redis, error)

NewClient is used to create new Redis type. This type encapsulates our interaction with redis and provides instrumentation with new relic.

func (*Redis) Client

func (r *Redis) Client() *redis.Client

Client is to return underlying redis interface

func (*Redis) MakeRedisClient

func (r *Redis) MakeRedisClient() interface{}

MakeRedisClient is used to fulfill asynq's interface

type RedisQueue

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

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() QueueOptions

func (*RedisQueue) Write

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