worker

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

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

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