sova-observability 0.1.2

Request metrics (Prometheus), OpenTelemetry, and Elasticsearch logs for Sova
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

//! Prometheus recorder install for Sova.

use metrics_exporter_prometheus::{PrometheusBuilder, PrometheusHandle};
use std::sync::{Mutex, OnceLock};

static HANDLE: OnceLock<Mutex<Option<PrometheusHandle>>> = OnceLock::new();

/// Install (or reuse) the global Prometheus recorder and return a scrape handle.
pub fn install_recorder() -> PrometheusHandle {
    let slot = HANDLE.get_or_init(|| Mutex::new(None));
    let mut g = slot.lock().unwrap();
    if let Some(h) = g.as_ref() {
        return h.clone();
    }
    let handle = PrometheusBuilder::new()
        .install_recorder()
        .expect("prometheus recorder");
    *g = Some(handle.clone());
    handle
}

pub use metrics_exporter_prometheus::PrometheusHandle as Handle;