org.maestro.worker.common.watchdog

Class StaleObserver

java.lang.Object

org.maestro.worker.common.watchdog.StaleObserver

All Implemented Interfaces:

WatchdogObserver

public class StaleObserver
extends Object
implements WatchdogObserver

An observer that checks if the workers have stopped sending data

Constructor Summary

Constructors

Constructor and Description
StaleObserver(WorkerStaleChecker workerStaleChecker)

Method Summary

Modifier and Type	Method and Description
boolean	onStart() Actions that run on watchdog start
boolean	onStop(List<WorkerRuntimeInfo> workerRuntimeInfos) Actions that run on watchdog stop

Methods inherited from class java.lang.Object

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

Constructor Detail

StaleObserver

public StaleObserver(WorkerStaleChecker workerStaleChecker)

Method Detail

onStart

public boolean onStart()

Description copied from interface: WatchdogObserver

Actions that run on watchdog start

Specified by:

onStart in interface WatchdogObserver

Returns:

true if it should continue or false otherwise

onStop

public boolean onStop(List<WorkerRuntimeInfo> workerRuntimeInfos)

Description copied from interface: WatchdogObserver

Actions that run on watchdog stop

Specified by:

onStop in interface WatchdogObserver

Parameters:

workerRuntimeInfos - a list of active workers and their information

Returns:

true if processing should continue or false otherwise