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, val resumeTimeout: Duration = timeout)
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.
Link copied to clipboard
class SoloDeadlineDetector(minimumMembers: Int, deadline: Duration, clock: Clock, scope: CoroutineScope)
Notices when a session nobody else ever joined has been waiting long enough to give up on.
Link copied to clipboard
What happened to a session that started out with nobody else in it.