Struct HealthChecker 

pub struct HealthChecker { /* private fields */ }

In-memory health checker

Implementations

impl HealthChecker

pub fn new(config: HealthConfig) -> Self

pub fn register_node(&self, node_id: NodeId)

Register a node for health tracking

pub fn deregister_node(&self, node_id: &NodeId)

Remove a node from health tracking

pub fn report_success(&self, node_id: &NodeId, latency: Duration)

Report a successful request (passive health update)

pub fn report_failure(&self, node_id: &NodeId)

Report a failed request (passive health update)

pub fn all_statuses(&self) -> Vec<HealthStatus>

Get all health statuses

pub fn is_monitoring(&self) -> bool

Check if monitoring is active

pub fn healthy_count(&self) -> usize

Get count of healthy nodes

pub fn total_count(&self) -> usize

Get total node count

Trait Implementations

impl Default for HealthChecker

fn default() -> Self

Returns the “default value” for a type.

impl HealthCheckerTrait for HealthChecker

fn check_node( &self, node_id: &NodeId, ) -> BoxFuture<'_, FederationResult<NodeHealth>>

Check health of a specific node

fn get_cached_health(&self, node_id: &NodeId) -> Option<NodeHealth>

Get cached health status (non-blocking)

fn start_monitoring(&self, _interval: Duration) -> BoxFuture<'_, ()>

Start background health monitoring

fn stop_monitoring(&self) -> BoxFuture<'_, ()>

Stop health monitoring