worker

Documentation

Index

• type Options
• type Worker
  • func NewWorker(opts Options) *Worker
  • func (w *Worker) ProcessRequeue()
  • func (w *Worker) Start() error
  • func (w *Worker) Stop() error

Types

type Options

type Options struct {
	RequeueJobBatch    int
	RequeueJobInterval time.Duration
	PoolSize           int
	PoolConcurrency    int

	DB          *db.DB
	Deliverer   deliverer.Deliverer
	Metrics     *metrics.Metrics
	Tracer      *tracing.Tracer
	EventBus    eventbus.Bus
	Srv         *service.Service
	RedisClient *redis.Client
}

type Worker

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

func NewWorker

func NewWorker(opts Options) *Worker

func (*Worker) ProcessRequeue

func (w *Worker) ProcessRequeue()

func (*Worker) Start

func (w *Worker) Start() error

Start starts worker

func (*Worker) Stop

func (w *Worker) Stop() error

Stop stops worker