workers

Documentation

Index

• type BaseWorker
  • func (w *BaseWorker) Consume() error
• type HandleFunc
  • func (f HandleFunc) Handle(body []byte)
• type Worker
  • func NewSend(ctx *handlers.GatewayContext) Worker

Types

type BaseWorker

type BaseWorker struct {
	RB gateways.RabbitI
	HandleFunc
}

func (*BaseWorker) Consume

func (w *BaseWorker) Consume() error

Consume starts a channel that consumes messages from the front of the queue

type HandleFunc

type HandleFunc func([]byte)

func (HandleFunc) Handle

func (f HandleFunc) Handle(body []byte)

type Worker

type Worker interface {
	Consume() error
	Handle([]byte)
}

Worker describes the functions a queue worker uses

func NewSend

func NewSend(ctx *handlers.GatewayContext) Worker

NewSend creates and returns a new SendWorker