chronon-telemetry 0.1.1

TelemetrySink trait and console/no-op adapters for Chronon
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use super::TelemetrySink;

/// Writes telemetry to stderr (development and bench).
#[derive(Debug, Default, Clone, Copy)]
pub struct ConsoleSink;

impl TelemetrySink for ConsoleSink {
    fn record_counter(&self, name: &str, labels: &[(&str, &str)], delta: u64) {
        eprintln!("[chronon] counter {name} +{delta} {labels:?}");
    }

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

    fn log_event(&self, schema: &str, fields: &[(&str, &str)]) {
        eprintln!("[chronon] event {schema} {fields:?}");
    }
}