Skip to main content

chronon_telemetry/
console.rs

1use super::TelemetrySink;
2
3/// Writes telemetry to stderr (development and bench).
4#[derive(Debug, Default, Clone, Copy)]
5pub struct ConsoleSink;
6
7impl TelemetrySink for ConsoleSink {
8    fn record_counter(&self, name: &str, labels: &[(&str, &str)], delta: u64) {
9        eprintln!("[chronon] counter {name} +{delta} {labels:?}");
10    }
11
12    fn record_gauge(&self, name: &str, labels: &[(&str, &str)], value: f64) {
13        eprintln!("[chronon] gauge {name} = {value} {labels:?}");
14    }
15
16    fn log_event(&self, schema: &str, fields: &[(&str, &str)]) {
17        eprintln!("[chronon] event {schema} {fields:?}");
18    }
19}