otq

Documentation

Index

• func AddHandler(taskTypeName string, handler asynq.HandlerFunc)
• func AddScheduledTask(cronExpression string, task *asynq.Task)
• func Close()
• func Enqueue(task *asynq.Task, opts ...asynq.Option)
• func Start()
• type Logger
• type Otq
  • func NewOtq(redisAddress string, redisUsername string, redisPassword string, db int, ...) *Otq
  • func (o *Otq) AddHandler(taskTypeName string, handler asynq.HandlerFunc) *Otq
  • func (o *Otq) AddScheduledTask(cronExpression string, task *asynq.Task) *Otq
  • func (o *Otq) Close()
  • func (o *Otq) Enqueue(task *asynq.Task, opts ...asynq.Option) *Otq
  • func (o *Otq) Start()

Functions

func AddHandler

func AddHandler(taskTypeName string, handler asynq.HandlerFunc)

func AddScheduledTask

func AddScheduledTask(cronExpression string, task *asynq.Task)

func Close

func Close()

func Enqueue

func Enqueue(task *asynq.Task, opts ...asynq.Option)

func Start

func Start()

Types

type Logger

type Logger interface {
	Debug(args ...interface{})
	Info(args ...interface{})
	Warn(args ...interface{})
	Error(args ...interface{})
	Panic(args ...interface{})
	Fatal(args ...interface{})
}

type Otq

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

func NewOtq

func NewOtq(redisAddress string, redisUsername string, redisPassword string, db int, logger ...Logger) *Otq

func (*Otq) AddHandler

func (o *Otq) AddHandler(taskTypeName string, handler asynq.HandlerFunc) *Otq

func (*Otq) AddScheduledTask

func (o *Otq) AddScheduledTask(cronExpression string, task *asynq.Task) *Otq

func (*Otq) Close

func (o *Otq) Close()

func (*Otq) Enqueue

func (o *Otq) Enqueue(task *asynq.Task, opts ...asynq.Option) *Otq

func (*Otq) Start

func (o *Otq) Start()