org.maestro.worker.common.watchdog

Interface WatchdogObserver

All Known Implementing Classes:

CleanupObserver, DrainObserver, LatencyWriterObserver, RateWriterObserver, StaleObserver, WorkerShutdownObserver

public interface WatchdogObserver

Actions that are run when the watchdog change state. For now it handles only start and stop state changes

Method Summary

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

Method Detail

onStart

default boolean onStart()

Actions that run on watchdog start

Returns:

true if it should continue or false otherwise

onStop

default boolean onStop(List<WorkerRuntimeInfo> workerRuntimeInfos)

Actions that run on watchdog stop

Parameters:

workerRuntimeInfos - a list of active workers and their information

Returns:

true if processing should continue or false otherwise