worker

Documentation

Index

• Variables
• type JobWorker
  • func NewJobWorker(log zerolog.Logger, metrics Metrics, j proto.Job) JobWorker
  • func (jw *JobWorker) HandleJob()
• type Metrics
  • func NewMetricsStore() Metrics
• type WorkerRuntime
  • func NewRuntime(m Metrics, logger zerolog.Logger, host string, port int) WorkerRuntime

Variables

var (
	JobIDLabel         = "job_id"
	JobStatusCodeLabel = "status_code"
)

Types

type JobWorker

type JobWorker struct {
	Done    bool
	Results map[int]int
	Job     proto.Job
	// contains filtered or unexported fields
}

func NewJobWorker

func NewJobWorker(log zerolog.Logger, metrics Metrics, j proto.Job) JobWorker

func (*JobWorker) HandleJob

func (jw *JobWorker) HandleJob()

type Metrics

type Metrics interface {
	IncJobs()
	IncJobRequestCount(id string, status int)
	ObserveJobRequestDurations(id string, status int, duration time.Duration)
}

func NewMetricsStore

func NewMetricsStore() Metrics

type WorkerRuntime

type WorkerRuntime interface {
	Connect() error
	Handle()
	Close()
}

func NewRuntime

func NewRuntime(m Metrics, logger zerolog.Logger, host string, port int) WorkerRuntime