public interface IWorkerEventSender
Modifier and Type | Method and Description |
---|---|
void |
allJoined()
all workers joined the job
|
void |
jobScaled(int change,
int numberOfWorkers)
job scaled up or down
|
void |
workerFailed(int workerID)
the worker with the provided workerID failed
|
void |
workerRestarted(JobMasterAPI.WorkerInfo workerInfo)
the worker with the provided workerInfo restarted
|
void workerFailed(int workerID)
workerID
- void workerRestarted(JobMasterAPI.WorkerInfo workerInfo)
workerInfo
- void allJoined()
void jobScaled(int change, int numberOfWorkers)