Package ch.so.agi.gretl.control.server.run

Class WorkerService

java.lang.Object

ch.so.agi.gretl.control.server.run.WorkerService

@Service
public class WorkerService
extends Object

Constructor Summary

Constructors

Constructor	Description
WorkerService(WorkerRepository repository, GretlControlProperties properties)

Method Summary

Modifier and Type	Method	Description
void	heartbeat(ch.so.agi.gretl.control.api.WorkerHeartbeatRequest request)
void	markOfflineWorkers()
ch.so.agi.gretl.control.api.WorkerRegistrationResponse	register(ch.so.agi.gretl.control.api.WorkerRegistrationRequest request)
List<WorkerRecord>	workers()

Methods inherited from class java.lang.Object

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

Constructor Details

WorkerService

public WorkerService(WorkerRepository repository,
 GretlControlProperties properties)

Method Details

register

public ch.so.agi.gretl.control.api.WorkerRegistrationResponse register(ch.so.agi.gretl.control.api.WorkerRegistrationRequest request)

heartbeat

public void heartbeat(ch.so.agi.gretl.control.api.WorkerHeartbeatRequest request)

workers

public List<WorkerRecord> workers()

markOfflineWorkers

@Scheduled(fixedDelay=30000L)
public void markOfflineWorkers()