Struct FailoverManager 

pub struct FailoverManager { /* private fields */ }

Manages automatic failover and health monitoring

Implementations

impl FailoverManager

pub fn new(replica_set: Arc<RwLock<ReplicaSet>>) -> Self

Create a new failover manager

pub fn with_policy( replica_set: Arc<RwLock<ReplicaSet>>, policy: FailoverPolicy, ) -> Self

Create with custom policy

pub fn set_policy(&self, policy: FailoverPolicy)

Set the failover policy

pub fn policy(&self) -> FailoverPolicy

Get the current policy

pub async fn start_monitoring(&self)

Start health monitoring

pub async fn manual_failover( &self, target_replica_id: Option<String>, ) -> Result<()>

Manually trigger failover

pub fn health_history(&self) -> Vec<HealthCheck>

Get health check history

pub fn recent_health(&self, replica_id: &str, limit: usize) -> Vec<HealthCheck>

Get recent health status for a replica

pub fn is_failover_in_progress(&self) -> bool

Check if failover is currently in progress

pub fn failure_count(&self, replica_id: &str) -> usize

Get failure count for a replica