worker

Documentation

Index

• func RegisterNewGroupTask(applicationRepo datastore.ApplicationRepository, ...)
• func RegisterWorkerMetrics(q queue.Queuer, cfg config.Configuration)
• type Cleaner
  • func NewCleaner(queue queue.Queuer) *Cleaner
  • func (p *Cleaner) Close() error
  • func (c *Cleaner) Start()
• type Producer
  • func NewProducer(queue queue.Queuer) *Producer
  • func (p *Producer) Close() error
  • func (p *Producer) Start(ctx context.Context)
• type Worker

Functions

func RegisterNewGroupTask

func RegisterNewGroupTask(applicationRepo datastore.ApplicationRepository, eventDeliveryRepo datastore.EventDeliveryRepository, groupRepo datastore.GroupRepository)

func RegisterWorkerMetrics

func RegisterWorkerMetrics(q queue.Queuer, cfg config.Configuration)

Types

type Cleaner

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

func NewCleaner

func NewCleaner(queue queue.Queuer) *Cleaner

func (*Cleaner) Close

func (p *Cleaner) Close() error

func (*Cleaner) Start

func (c *Cleaner) Start()

type Producer

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

func NewProducer

func NewProducer(queue queue.Queuer) *Producer

func (*Producer) Close

func (p *Producer) Close() error

func (*Producer) Start

func (p *Producer) Start(ctx context.Context)

type Worker

type Worker interface {
	Start(context.Context)
}