operonx 0.6.2

High-performance Rust execution backend for Operon workflows
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

//! `HealthCheckResult` — result aggregator for [`ResourceHub::health_check`].
//!
//! Mirrors Python [`operonx/core/registry/shortcuts/health.py`](../../../../../../operonx/core/registry/shortcuts/health.py).
//!
//! [`ResourceHub::health_check`]: crate::core::registry::resource_hub::ResourceHub::health_check

use std::collections::HashMap;

/// Per-resource pass/fail summary returned by `ResourceHub::health_check`.
#[derive(Debug, Clone)]
pub struct HealthCheckResult {
    /// Key → healthy (`true`) / unhealthy (`false`).
    pub results: HashMap<String, bool>,
    /// Key → error message (only populated for failures).
    pub errors: HashMap<String, String>,
}

impl HealthCheckResult {
    /// `true` when every resource passed.
    pub fn healthy(&self) -> bool {
        !self.results.is_empty() && self.results.values().all(|v| *v)
    }

    /// Keys of resources that passed.
    pub fn passed(&self) -> Vec<&str> {
        self.results
            .iter()
            .filter_map(|(k, v)| if *v { Some(k.as_str()) } else { None })
            .collect()
    }

    /// Keys of resources that failed.
    pub fn failed(&self) -> Vec<&str> {
        self.results
            .iter()
            .filter_map(|(k, v)| if !*v { Some(k.as_str()) } else { None })
            .collect()
    }
}

impl std::fmt::Display for HealthCheckResult {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        let total = self.results.len();
        let passed = self.passed().len();
        let status = if self.healthy() {
            "HEALTHY"
        } else {
            "UNHEALTHY"
        };
        write!(f, "<HealthCheckResult {} {}/{}>", status, passed, total)
    }
}