edu.iu.dsc.tws.dashboard.repositories

Interface WorkerRepository

public interface WorkerRepository

Method Summary

Modifier and Type	Method and Description
int	changeStateOfAllWorkers(java.lang.String jobId, WorkerState workerState, WorkerState excludeState)
int	changeWorkerState(java.lang.String jobId, java.lang.Long workerId, WorkerState workerState)
java.lang.Iterable<Worker>	findAllByJob_JobID(java.lang.String jobId)
java.util.List<java.lang.Object[]>	getStateStats()
int	heartbeat(java.lang.String jobId, java.lang.Long workerId, java.util.Date now)

Method Detail

findAllByJob_JobID

java.lang.Iterable<Worker> findAllByJob_JobID(java.lang.String jobId)

changeWorkerState

int changeWorkerState(java.lang.String jobId,
                      java.lang.Long workerId,
                      WorkerState workerState)

changeStateOfAllWorkers

int changeStateOfAllWorkers(java.lang.String jobId,
                            WorkerState workerState,
                            WorkerState excludeState)

heartbeat

int heartbeat(java.lang.String jobId,
              java.lang.Long workerId,
              java.util.Date now)

getStateStats

java.util.List<java.lang.Object[]> getStateStats()