Struct PartitionDetector 

pub struct PartitionDetector { /* private fields */ }

Partition detection coordinator

Tracks heartbeat state for all peers and detects network partitions.

Implementations

impl PartitionDetector

pub fn new() -> PartitionDetector

Create a new partition detector with default config

pub fn with_config(config: PartitionConfig) -> PartitionDetector

Create a new partition detector with custom config

pub fn config(&self) -> &PartitionConfig

Get partition config

pub fn register_peer(&self, peer_id: PublicKey)

Register a new peer for heartbeat tracking

pub fn unregister_peer(&self, peer_id: &PublicKey)

Remove a peer from heartbeat tracking

pub fn record_heartbeat_success( &self, peer_id: &PublicKey, ) -> Option<PartitionEvent>

Record a successful heartbeat for a peer

Returns an optional partition event if a state transition occurred

pub fn record_heartbeat_failure( &self, peer_id: &PublicKey, ) -> Option<PartitionEvent>

Record a heartbeat failure for a peer

Returns an optional partition event if partition was detected or failure occurred

pub fn get_peer_state(&self, peer_id: &PublicKey) -> Option<PeerPartitionState>

Get the partition state for a peer

pub fn get_peer_heartbeat(&self, peer_id: &PublicKey) -> Option<PeerHeartbeat>

Get heartbeat info for a peer

pub fn get_partitioned_peers(&self) -> Vec<PublicKey>

Get all partitioned peers

pub fn check_timeouts(&self) -> Vec<PartitionEvent>

Check all peers for timeout-based partition detection

Returns a list of partition events for newly partitioned peers

pub fn peer_count(&self) -> usize

Get number of tracked peers

Trait Implementations

impl Default for PartitionDetector

fn default() -> PartitionDetector

Returns the “default value” for a type.