Struct PartitionDetector 

pub struct PartitionDetector { /* private fields */ }

Partition detector

Implementations

impl PartitionDetector

pub fn new(config: PartitionConfig) -> Self

pub fn update_last_seen(&self, node_name: &str)

Update last seen time for a node

pub fn detect_partition( &self, cluster_state: &BTreeMap<String, NodeState>, ) -> PartitionState

Detect partition based on current cluster state

pub fn current_state(&self) -> PartitionState

Get current partition state

pub fn has_quorum(&self, reachable_count: usize) -> bool

Check if we have quorum

pub fn get_unreachable_nodes( &self, cluster_state: &BTreeMap<String, NodeState>, ) -> Vec<String>

Get unreachable nodes

pub fn should_serve(&self) -> bool

Check if we should continue serving (have quorum)

Trait Implementations

impl Debug for PartitionDetector

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PartitionDetector

fn default() -> Self

Returns the “default value” for a type.