edu.iu.dsc.tws.dashboard.services

Class WorkerService

java.lang.Object

edu.iu.dsc.tws.dashboard.services.WorkerService

public class WorkerService
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
WorkerService()

Method Summary

Modifier and Type	Method and Description
void	changeState(java.lang.String jobId, java.lang.Long workerId, StateChangeRequest<WorkerState> stateChangeRequest)
int	changeStateOfAllWorkers(java.lang.String jobId, WorkerState state)
Worker	createWorker(WorkerCreateRequest workerCreateRequest)
java.lang.Iterable<Worker>	getAllForJob(java.lang.String jobId)
java.lang.Iterable<Worker>	getAllWorkers()
java.lang.Object	getStateStats()
Worker	getWorkerById(java.lang.String jobId, java.lang.Long workerId)
void	heartbeat(java.lang.String jobId, java.lang.Long workerId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkerService

public WorkerService()

Method Detail

getAllForJob

public java.lang.Iterable<Worker> getAllForJob(java.lang.String jobId)

getAllWorkers

public java.lang.Iterable<Worker> getAllWorkers()

createWorker

public Worker createWorker(WorkerCreateRequest workerCreateRequest)

changeState

public void changeState(java.lang.String jobId,
                        java.lang.Long workerId,
                        StateChangeRequest<WorkerState> stateChangeRequest)

changeStateOfAllWorkers

public int changeStateOfAllWorkers(java.lang.String jobId,
                                   WorkerState state)

heartbeat

public void heartbeat(java.lang.String jobId,
                      java.lang.Long workerId)

getWorkerById

public Worker getWorkerById(java.lang.String jobId,
                            java.lang.Long workerId)

getStateStats

public java.lang.Object getStateStats()