Struct HealthTracker 

pub struct HealthTracker<Id: Eq + Hash + Clone> { /* private fields */ }

Tracks health state for a set of nodes identified by Id.

Thread-safe — all methods take &self and synchronise internally via RwLock.

Examples

use loadwise::{HealthTracker, HealthStatus, ConsecutiveFailurePolicy};

let tracker = HealthTracker::new(ConsecutiveFailurePolicy::default());

// Unknown nodes are considered healthy.
assert_eq!(tracker.status(&"node-1"), HealthStatus::Healthy);

// Three consecutive failures → Unhealthy (default threshold = 3).
tracker.report_failure(&"node-1");
tracker.report_failure(&"node-1");
tracker.report_failure(&"node-1");
assert_eq!(tracker.status(&"node-1"), HealthStatus::Unhealthy);

// One success → Recovering.
tracker.report_success(&"node-1");
assert_eq!(tracker.status(&"node-1"), HealthStatus::Recovering);

// Second success → Healthy again (default recovery_successes = 2).
tracker.report_success(&"node-1");
assert_eq!(tracker.status(&"node-1"), HealthStatus::Healthy);

Implementations

impl<Id: Eq + Hash + Clone> HealthTracker<Id>

pub fn new(policy: impl HealthPolicy + 'static) -> Self

Creates a new tracker with the given HealthPolicy.

pub fn report_success(&self, id: &Id)

Record a successful request to the node identified by id.

pub fn report_failure(&self, id: &Id)

Record a failed request to the node identified by id.

pub fn report_outcome(&self, id: &Id, outcome: &Outcome)

Report a classified request outcome. See Outcome for details.

pub fn status(&self, id: &Id) -> HealthStatus

Returns the current HealthStatus (defaults to Healthy for unknown nodes).

pub fn should_probe(&self, id: &Id) -> bool

Whether the node should receive a probe request (delegates to the policy).

pub fn get_health(&self, id: &Id) -> NodeHealth

Returns a snapshot of the full NodeHealth for the given node.

Trait Implementations

impl<Id: Eq + Hash + Clone> Debug for HealthTracker<Id>

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

Formats the value using the given formatter.