boson-telemetry 0.1.1

Boson OpsLog telemetry port
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

use super::OpsLog;

/// stderr structured lines (default dev adapter).
///
/// # Examples
///
/// ```
/// use boson_telemetry::{ConsoleOpsLog, OpsLog};
///
/// let log = ConsoleOpsLog;
/// log.record_counter("boson_tasks_enqueued", &[("task_name", "ping")], 1.0);
/// ```
#[derive(Debug, Default, Clone, Copy)]
pub struct ConsoleOpsLog;

impl OpsLog for ConsoleOpsLog {
    fn record_counter(&self, name: &str, labels: &[(&str, &str)], value: f64) {
        eprintln!("[boson-telemetry] counter {name}={value} {labels:?}");
    }

    fn record_gauge(&self, name: &str, labels: &[(&str, &str)], value: f64) {
        eprintln!("[boson-telemetry] gauge {name}={value} {labels:?}");
    }

    fn log_event(&self, name: &str, payload: &serde_json::Value) {
        eprintln!("[boson-telemetry] event {name} {payload}");
    }
}