public class WorkerController
extends java.lang.Object
Constructor and Description |
---|
WorkerController(WorkerService workerService) |
Modifier and Type | Method and Description |
---|---|
void |
changeState(java.lang.String jobId,
java.lang.Long workerId,
StateChangeRequest<WorkerState> stateChangeRequest) |
Worker |
createWorker(WorkerCreateRequest workerCreateRequest) |
java.lang.Iterable<Worker> |
getAllWorkers() |
Worker |
getAllWorkers(java.lang.String jobId,
java.lang.Long workerId) |
java.lang.Object |
getStateStats() |
void |
heartbeat(java.lang.String jobId,
java.lang.Long workerId) |
public WorkerController(WorkerService workerService)
public java.lang.Iterable<Worker> getAllWorkers()
public Worker createWorker(WorkerCreateRequest workerCreateRequest)
public Worker getAllWorkers(java.lang.String jobId, java.lang.Long workerId)
public void changeState(java.lang.String jobId, java.lang.Long workerId, StateChangeRequest<WorkerState> stateChangeRequest)
public void heartbeat(java.lang.String jobId, java.lang.Long workerId)
public java.lang.Object getStateStats()