xbp 10.15.4

XBP is a zero-config build pack that can also interact with proxies, kafka, sockets, synthetic monitors.
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

use crate::cli::commands;
use crate::cli::error::CliResult;
use xbp_monitoring::{list_items, run_all_once, serve, RunKind};

pub async fn handle_monitoring(cmd: commands::MonitoringCmd) -> CliResult<()> {
    match cmd.command {
        commands::MonitoringSubCommand::Serve { file } => {
            if let Err(err) = serve(&file).await {
                return Err(format!("Failed to start monitoring service: {}", err).into());
            }
        }
        commands::MonitoringSubCommand::RunOnce {
            file,
            probes_only,
            stories_only,
        } => {
            let results = run_all_once(&file, probes_only, stories_only)
                .await
                .map_err(|e| e.to_string())?;
            if results.is_empty() {
                println!("No probes or stories configured");
            } else {
                for result in results {
                    let label = match result.kind {
                        RunKind::Probe => "probe",
                        RunKind::Story => "story",
                    };
                    if result.success {
                        println!("{} {} ✓", label, result.name);
                    } else {
                        let code = result
                            .status_code
                            .map(|c| c.to_string())
                            .unwrap_or_else(|| "-".into());
                        let err = result.error.unwrap_or_else(|| "Unknown error".into());
                        println!("{} {} ✗ (code {}, {})", label, result.name, code, err);
                    }
                }
            }
        }
        commands::MonitoringSubCommand::List { file } => {
            let (probes, stories) = list_items(&file).await.map_err(|e| e.to_string())?;
            println!(
                "Probes: {}",
                if probes.is_empty() {
                    "none".into()
                } else {
                    probes.join(", ")
                }
            );
            println!(
                "Stories: {}",
                if stories.is_empty() {
                    "none".into()
                } else {
                    stories.join(", ")
                }
            );
        }
    }
    Ok(())
}