worker

Documentation

Index

• type Worker
  • func NewWorker(cfg *config.WorkerConfig, db *db.DB, queue queue.TaskQueue) *Worker
  • func (w *Worker) Start() error
  • func (w *Worker) Stop() error

Types

type Worker

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

func NewWorker

func NewWorker(cfg *config.WorkerConfig, db *db.DB, queue queue.TaskQueue) *Worker

func (*Worker) Start

func (w *Worker) Start() error

Start starts worker

func (*Worker) Stop

func (w *Worker) Stop() error

Stop stops worker