darpan 0.2.4

Linux developer service monitoring utility with auto-detection, real-time health checks, and interactive TUI for databases, APIs, Docker containers, and more
Documentation 
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

use crate::health::{HealthCheckerTrait, http::HttpHealthChecker, port::PortHealthChecker, process::ProcessHealthChecker, traffic::TrafficBasedHealthChecker};
use crate::models::{HealthResult, Service};
use std::time::Duration;

#[cfg(feature = "db-health-checks")]
use crate::health::database::DatabaseHealthChecker;

pub struct HealthChecker {
    checkers: Vec<Box<dyn HealthCheckerTrait>>,
    default_checker: PortHealthChecker,
}

impl HealthChecker {
    pub fn new(timeout: Duration, _retry_count: u32) -> Self {
        let mut checkers: Vec<Box<dyn HealthCheckerTrait>> = Vec::new();
        
        // Add traffic-based checker first (for Frontend/Backend services)
        // This avoids HTTP health check spam
        checkers.push(Box::new(TrafficBasedHealthChecker::new()));
        
        // Add other health checkers
        checkers.push(Box::new(HttpHealthChecker::new(timeout)));
        checkers.push(Box::new(ProcessHealthChecker::new()));
        
        #[cfg(feature = "db-health-checks")]
        checkers.push(Box::new(DatabaseHealthChecker::new(timeout)));
        
        Self {
            checkers,
            default_checker: PortHealthChecker::new(timeout),
        }
    }

    pub async fn check(&self, service: &Service) -> HealthResult {
        // Find a suitable checker
        for checker in &self.checkers {
            if checker.supports(service) {
                return checker.check(service).await;
            }
        }
        
        // Fall back to port check
        self.default_checker.check(service).await
    }
}