worker

Documentation

Index

• type MessageData
• type Worker
  • func NewWorker(opts WorkerOptions, db *db.DB, deliverer deliverer.Deliverer, ...) *Worker
  • func (w *Worker) Start() error
  • func (w *Worker) Stop() error
• type WorkerOptions

Types

type MessageData

type MessageData struct {
	EventID    string `json:"event_id"`
	EndpointId string `json:"endpoint_id"`
	Attempt    int    `json:"attempt"`
	Event      string `json:"event"`
}

type Worker

type Worker struct {
	DB *db.DB
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(
	opts WorkerOptions,
	db *db.DB,
	deliverer deliverer.Deliverer,
	queue taskqueue.TaskQueue,
	metrics *metrics.Metrics,
	tracer *tracing.Tracer,
	bus eventbus.Bus) *Worker

func (*Worker) Start

func (w *Worker) Start() error

Start starts worker

func (*Worker) Stop

func (w *Worker) Stop() error

Stop stops worker

type WorkerOptions

type WorkerOptions struct {
	RequeueJobBatch    int
	RequeueJobInterval time.Duration
	PoolSize           int
	PoolConcurrency    int
}