server

type Metrics interface {
	IncConnections()
}

type Runtime interface {
	Listen() error
	HandleConnections()
	ControlLoop()
	Close()
	AddWorker(conn net.Conn) *WorkerConnection
	HandleJob(rw http.ResponseWriter, req *http.Request)
	HandleListJobQueue(rw http.ResponseWriter, req *http.Request)
	HandleListWorkers(rw http.ResponseWriter, req *http.Request)
}

type WorkerConnection struct {
	Conn     net.Conn
	ID       string
	Capacity uint
	// State
	// - new
	// - hello
	// - alive
	State    string
	LastSeen time.Time
	// Server assigned jobs that have not been accepted or sent
	JobQueue []proto.Job
	// Server assigned jobs that have not been accepted
	AssignJobQueue []proto.Job
	// Jobs accepted by the worker
	AcceptedJobs []proto.Job
	// contains filtered or unexported fields
}