Package org.apache.flink.runtime.heartbeat

Interface Summary

Interface	Description
HeartbeatListener<I,O>	Interface for the interaction with the HeartbeatManager.
HeartbeatManager<I,O>	A heartbeat manager has to be able to start/stop monitoring a HeartbeatTarget, and report heartbeat timeouts for this target.
HeartbeatMonitor<O>	Heartbeat monitor which manages the heartbeat state of the associated heartbeat target.
HeartbeatMonitor.Factory<O>	This factory provides an indirection way to create HeartbeatMonitor.
HeartbeatTarget<I>	Interface for components which can be sent heartbeats and from which one can request a heartbeat response.

Class Summary

Class	Description
HeartbeatManagerImpl<I,O>	Heartbeat manager implementation.
HeartbeatManagerSenderImpl<I,O>	HeartbeatManager implementation which regularly requests a heartbeat response from its monitored HeartbeatTarget.
HeartbeatMonitorImpl<O>	The default implementation of HeartbeatMonitor.
HeartbeatReceiver<I>	The receiver implementation of HeartbeatTarget, which mutes the HeartbeatTarget#requestHeartbeat(ResourceID, I).
HeartbeatSender<I>	The sender implementation of HeartbeatTarget, which mutes the HeartbeatTarget#receiveHeartbeat(ResourceID, I).
HeartbeatServices	HeartbeatServices gives access to all services needed for heartbeating.
NoOpHeartbeatManager<I,O>	HeartbeatManager implementation which does nothing.