darpan 0.1.0

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;
use crate::models::{HealthResult, Service};
use async_trait::async_trait;
use sysinfo::{Pid, System};
use tracing::trace;

pub struct ProcessHealthChecker;

impl ProcessHealthChecker {
    pub fn new() -> Self {
        Self
    }
}

#[async_trait]
impl HealthCheckerTrait for ProcessHealthChecker {
    async fn check(&self, service: &Service) -> HealthResult {
        if let Some(pid) = service.pid {
            let mut sys = System::new();
            sys.refresh_processes();
            
            if sys.process(Pid::from_u32(pid)).is_some() {
                trace!("Process {} is running", pid);
                HealthResult::healthy(0)
            } else {
                trace!("Process {} is not running", pid);
                HealthResult::not_running(
                    service.command_line.as_ref().map(|cmd| {
                        format!("Try running: {}", cmd)
                    })
                )
            }
        } else {
            // No PID info, can't check
            HealthResult::unhealthy(
                "No process information available".to_string(),
                None,
            )
        }
    }

    fn supports(&self, service: &Service) -> bool {
        service.pid.is_some()
    }
}