Package-level declarations
Types
Link copied to clipboard
data class HeartbeatConfig(val interval: Duration = 5.seconds, val timeout: Duration = 15.seconds, val reconnectWindow: Duration = 60.seconds)
Configuration for HeartbeatPartitionDetector.
Link copied to clipboard
class HeartbeatPartitionDetector(link: Seam, peerId: PeerId, config: HeartbeatConfig = HeartbeatConfig(), clock: () -> Instant) : PartitionDetector
Application-level heartbeat-based implementation of PartitionDetector.
Link copied to clipboard
interface PartitionDetector
Detects when a peer has become unresponsive and emits PartitionEvents for the layer above to act on.
Link copied to clipboard
An event emitted by PartitionDetector describing a peer's reachability state change.