Struct HealthChecker 

pub struct HealthChecker {
    pub failure_threshold: u32,
    pub recovery_cooldown: Duration,
    /* private fields */
}

Health checker: tracks each slave’s health status and supports failover

Fields

failure_threshold: u32

Consecutive failure count threshold; when reached, the slave is marked Unhealthy

recovery_cooldown: Duration

Auto failover recovery cooldown (how long after health check recovery before rejoining the cluster)

Implementations

impl HealthChecker

pub fn new(failure_threshold: u32) -> Self

pub fn register(&self, slave: &str)

Register a slave with initial state Healthy

pub fn set_health(&self, slave: &str, health: SlaveHealth)

Mark slave with the specified health status

pub fn record_failure(&self, slave: &str) -> bool

Record a failure; when threshold is reached, automatically mark as Unhealthy Returns true if failover was triggered

pub fn record_success(&self, slave: &str)

Record a success, resetting the failure count

pub fn health(&self, slave: &str) -> Option<SlaveHealth>

Query slave health status; returns None if not registered

pub fn list_by_health(&self, health: SlaveHealth) -> Vec<String>

List all slaves in the specified state

pub fn healthy_slaves(&self) -> Vec<String>

Return the list of all healthy slaves

pub fn unhealthy_slaves(&self) -> Vec<String>

Return the list of all unhealthy slaves

pub fn failure_count(&self, slave: &str) -> u32

Return the current consecutive failure count

Trait Implementations

impl Default for HealthChecker

fn default() -> Self

Returns the “default value” for a type.