Struct StorageHealthMonitor 

pub struct StorageHealthMonitor { /* private fields */ }

Production-grade storage-subsystem health monitor.

Manages a collection of named probes, records check outcomes (success/failure + latency), computes EWMA metrics, fires alerts, and maintains a rolling history of health snapshots.

Implementations

impl StorageHealthMonitor

pub fn new(config: ShmMonitorConfig) -> Self

Create a new monitor with the given configuration.

pub fn default_config() -> Self

Create a monitor with default configuration.

pub fn register_probe( &mut self, name: impl Into<String>, category: ShmCategory, metadata: HashMap<String, String>, ) -> ShmProbeId

Register a new probe and return its unique ShmProbeId.

pub fn record_check( &mut self, probe_id: ShmProbeId, success: bool, latency_ms: f64, ) -> Result<(), String>

Record the outcome of a health check for probe_id.

Updates EWMA success rate and latency, transitions probe status, and fires alerts when thresholds are crossed.

Returns an error string if the probe does not exist.

pub fn record_check_at( &mut self, probe_id: ShmProbeId, success: bool, latency_ms: f64, now_ts: u64, ) -> Result<(), String>

Same as record_check but with an explicit Unix-epoch timestamp.

pub fn run_health_check(&mut self) -> ShmHealthSnapshot

Compute an overall ShmHealthSnapshot and push it to the history.

pub fn run_health_check_at(&mut self, now_ts: u64) -> ShmHealthSnapshot

Same as run_health_check but with an explicit timestamp.

pub fn resolve_alert(&mut self, alert_id: usize) -> Result<(), String>

Mark an alert as resolved by its index in the internal deque.

pub fn expire_alerts(&mut self, now_ts: u64)

Expire all unresolved alerts whose auto_resolve_at timestamp ≤ now_ts.

pub fn active_alerts(&self) -> Vec<&ShmAlert>

Return active (unresolved) alerts.

pub fn all_alerts(&self) -> Vec<&ShmAlert>

Return all alerts (resolved and unresolved).

pub fn probes_by_category(&self, cat: ShmCategory) -> Vec<&ShmProbe>

Return all probes belonging to the given category.

pub fn probe(&self, id: ShmProbeId) -> Option<&ShmProbe>

Return a reference to a probe by id.

pub fn health_trend(&self, window: usize) -> Vec<f64>

Return the last window overall health scores from history (oldest first).

pub fn history_window(&self, window: usize) -> Vec<&ShmHealthSnapshot>

Return the last window snapshots from history (oldest first).

pub fn suggest_recovery(&self, probe_id: ShmProbeId) -> Result<String, String>

Produce a human-readable recovery suggestion for the given probe.

pub fn monitor_stats(&self) -> ShmMonitorStats

Return aggregate statistics for the monitor.

pub fn config(&self) -> &ShmMonitorConfig

Return the current configuration.

pub fn set_config(&mut self, config: ShmMonitorConfig)

Update the configuration at runtime.

pub fn probe_count(&self) -> usize

Return the number of registered probes.

pub fn history_len(&self) -> usize

Return the number of stored history snapshots.