worker

Documentation

Index

• type Worker
  • func NewWorker(config config.WorkerConfig, store db.Store, executor *hooks.Executor, ...) (*Worker, error)
  • func (w *Worker) GetWorkerId() uuid.UUID
  • func (w *Worker) Register() error
  • func (w *Worker) Work()

Types

type Worker

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

func NewWorker

func NewWorker(config config.WorkerConfig, store db.Store, executor *hooks.Executor, killSwitch chan struct{}) (*Worker, error)

func (*Worker) GetWorkerId

func (w *Worker) GetWorkerId() uuid.UUID

func (*Worker) Register

func (w *Worker) Register() error

func (*Worker) Work

func (w *Worker) Work()