Struct HealthMonitor 

pub struct HealthMonitor<L: LifecycleDaemon> { /* private fields */ }

Background driver for LifecycleGroup auto-respawn. Construct via HealthMonitor::spawn; stop via HealthMonitor::stop.

Implementations

impl<L: LifecycleDaemon> HealthMonitor<L>

pub fn spawn<F>( group: Arc<AsyncMutex<Option<LifecycleGroup<L>>>>, factory: F, interval: Duration, ) -> Self

where F: FnMut(u8) -> Arc<L> + Send + 'static,

Spawn a background task that polls group.health() every interval and calls group.replace(index, factory(index)) for each replica reporting unhealthy.

The group is an Arc<AsyncMutex<Option<LifecycleGroup<L>>>> so the registry’s unregister path can take the group out without disturbing the monitor — the monitor’s poll becomes a no-op once the Option is None. Pure-RAII callers wrap their group with Some(...) at construction.

pub fn stats(&self) -> &Arc<HealthMonitorStats>

Borrow the runtime counters for operator tooling.

pub async fn stop(&self)

Signal the monitor loop to stop and await its teardown. Idempotent — calling twice is a no-op the second time.