worker

Documentation

Index

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