worker

Documentation

Index

• func ProcessEventDeliveryBatches(ctx context.Context, status datastore.EventDeliveryStatus, ...)
• func RegisterNewGroupTask(applicationRepo datastore.ApplicationRepository, ...)
• func RegisterWorkerMetrics(q queue.Queuer, cfg config.Configuration)
• func RequeueEventDeliveries(status string, timeInterval string, ...) error
• 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 ProcessEventDeliveryBatches

func ProcessEventDeliveryBatches(ctx context.Context, status datastore.EventDeliveryStatus, eventDeliveryRepo datastore.EventDeliveryRepository, groupRepo datastore.GroupRepository, deliveryChan <-chan []datastore.EventDelivery, q *redisqueue.RedisQueue, wg *sync.WaitGroup)

func RegisterNewGroupTask

func RegisterNewGroupTask(applicationRepo datastore.ApplicationRepository, eventDeliveryRepo datastore.EventDeliveryRepository, groupRepo datastore.GroupRepository, rateLimiter limiter.RateLimiter, eventRepo datastore.EventRepository, cache cache.Cache, eventQueue queue.Queuer)

func RegisterWorkerMetrics

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

func RequeueEventDeliveries

func RequeueEventDeliveries(status string, timeInterval string, eventDeliveryRepo datastore.EventDeliveryRepository, groupRepo datastore.GroupRepository, eventQueue queue.Queuer) error

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)
}