worker

Documentation

Index

• type Consumer
  • func NewConsumer(q queue.Queuer) (*Consumer, error)
  • func (c *Consumer) RegisterHandlers(taskName convoy.TaskName, handler func(context.Context, *asynq.Task) error)
  • func (c *Consumer) Start()
  • func (c *Consumer) Stop()
• type Scheduler
  • func NewScheduler(queue queue.Queuer) *Scheduler
  • func (s *Scheduler) RegisterTask(cronspec string, queue convoy.QueueName, taskName convoy.TaskName)
  • func (s *Scheduler) Start()
  • func (s *Scheduler) Stop()
• type Worker

Types

type Consumer

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

func NewConsumer

func NewConsumer(q queue.Queuer) (*Consumer, error)

func (*Consumer) RegisterHandlers

func (c *Consumer) RegisterHandlers(taskName convoy.TaskName, handler func(context.Context, *asynq.Task) error)

func (*Consumer) Start

func (c *Consumer) Start()

func (*Consumer) Stop

func (c *Consumer) Stop()

type Scheduler

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

func NewScheduler

func NewScheduler(queue queue.Queuer) *Scheduler

func (*Scheduler) RegisterTask

func (s *Scheduler) RegisterTask(cronspec string, queue convoy.QueueName, taskName convoy.TaskName)

func (*Scheduler) Start

func (s *Scheduler) Start()

func (*Scheduler) Stop

func (s *Scheduler) Stop()

type Worker

type Worker interface {
	Start()
	Stop()
}