use std::time::Duration;
use crate::health::{HealthCheck, HealthStatus};
use crate::metrics::MetricsCollector;
pub struct MetricsHealthCheck {
collector: MetricsCollector,
}
impl MetricsHealthCheck {
pub fn new(collector: MetricsCollector) -> Self {
Self { collector }
}
pub fn error_counter_exists(&self, name: &str) -> bool {
self.collector.snapshot().counters.contains_key(name)
}
fn has_errors(&self) -> bool {
self.collector
.snapshot()
.counters
.values()
.any(|&v| v > 0)
}
}
impl HealthCheck for MetricsHealthCheck {
fn name(&self) -> &str {
"metrics"
}
fn check(&self) -> std::pin::Pin<Box<dyn std::future::Future<Output = HealthStatus> + Send + '_>> {
let has_errors = self.has_errors();
Box::pin(async move {
if has_errors {
HealthStatus::Unhealthy
} else {
HealthStatus::Ok
}
})
}
}
pub struct MetricsBridge {
collector: MetricsCollector,
}
impl MetricsBridge {
pub fn new(collector: MetricsCollector) -> Self {
Self { collector }
}
pub fn emit_now(&self) {
let snap = self.collector.snapshot();
let mut counters: Vec<_> = snap.counters.into_iter().collect();
counters.sort_by(|a, b| a.0.cmp(&b.0));
let mut gauges: Vec<_> = snap.gauges.into_iter().collect();
gauges.sort_by(|a, b| a.0.cmp(&b.0));
tracing::debug!(
task_count = snap.task_count,
active_threads = snap.active_threads,
queue_capacity_total = snap.queue_capacity_total,
queue_capacity_remaining = snap.queue_capacity_remaining,
"metrics snapshot"
);
for (name, value) in &counters {
tracing::info!(name, value, "metric counter");
}
for (name, value) in &gauges {
tracing::info!(name, value, "metric gauge");
}
}
pub fn emit_periodic(self, interval: Duration) -> tokio::task::JoinHandle<()> {
tokio::spawn(async move {
let mut ticker = tokio::time::interval(interval);
loop {
ticker.tick().await;
self.emit_now();
}
})
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::metrics::MetricsCollector;
use crate::shutdown::ShutdownManager;
#[test]
fn metrics_health_ok_when_no_counters() {
let collector = MetricsCollector::new();
let check = MetricsHealthCheck::new(collector);
let fut = check.check();
drop(fut);
}
#[tokio::test]
async fn metrics_health_unhealthy_when_errors_exist() {
let collector = MetricsCollector::new();
collector.inc_counter("errors", 1);
let check = MetricsHealthCheck::new(collector);
let status = check.check().await;
assert_eq!(status, HealthStatus::Unhealthy);
}
#[tokio::test]
async fn metrics_health_ok_when_no_errors() {
let collector = MetricsCollector::new();
collector.set_gauge("load", 0.5);
let check = MetricsHealthCheck::new(collector);
let status = check.check().await;
assert_eq!(status, HealthStatus::Ok);
}
#[tokio::test]
async fn bridge_emit_now_runs() {
let collector = MetricsCollector::new();
collector.set_gauge("temp", 42.0);
let bridge = MetricsBridge::new(collector);
bridge.emit_now();
}
#[tokio::test]
async fn lifecycle_manager_with_metrics_bridge() {
let collector = MetricsCollector::new();
collector.set_gauge("load", 0.1);
let mgr = crate::lifecycle::AsyncLifecycleManager::new();
let bridge = MetricsBridge::new(collector);
let _handle = bridge.emit_periodic(Duration::from_millis(50));
mgr.request_shutdown();
mgr.await_shutdown(Duration::from_secs(1)).await;
}
}