Struct FaultToleranceManager 

pub struct FaultToleranceManager { /* private fields */ }

Fault tolerance manager

Implementations

impl FaultToleranceManager

pub fn failures( detection_strategy: FaultDetectionStrategy, maxfailures: usize, ) -> Self

Create a new fault tolerance manager

pub fn new( detection_strategy: FaultDetectionStrategy, maxfailures: usize, ) -> Self

Create a new fault tolerance manager (alias for failures)

pub fn info(&mut self, nodeinfo: NodeInfo) -> CoreResult<()>

Register a node for monitoring

pub fn update_node_health( &mut self, nodeid: &str, health: NodeHealth, ) -> CoreResult<()>

Update node health status

pub fn get_healthy_nodes(&self) -> CoreResult<Vec<NodeInfo>>

Get all healthy nodes

pub fn get_failed_nodes(&self) -> CoreResult<Vec<NodeInfo>>

Get all failed nodes

pub fn detect_failures(&self) -> CoreResult<Vec<String>>

Detect failed nodes based on timeout

pub fn id_2(&self, nodeid: &str) -> CoreResult<()>

Initiate recovery for failed nodes

pub fn is_cluster_healthy(&self) -> CoreResult<bool>

Check if the cluster has sufficient healthy nodes

pub fn get_cluster_health_summary(&self) -> CoreResult<ClusterHealthSummary>

Get cluster health summary

pub fn register_node(&self, node: NodeInfo) -> Result<(), FaultToleranceError>

Register a node with the fault tolerance manager

Trait Implementations

impl Debug for FaultToleranceManager

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

Formats the value using the given formatter.