atomr-telemetry 0.3.1

Tracing, metrics, and exporter probes for atomr — actors, dead letters, cluster, sharding, persistence, remote, streams, and distributed data.
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

//! Pluggable exporters for external observability backends.
//!
//! The [`Exporter`] trait is synchronous so probes can call exporters
//! from hot paths without `.await`ing. Exporters that need to batch or
//! send over the network can buffer internally and flush on an interval
//! (see [`otel`]) or on scrape (see [`prometheus`]).

use crate::bus::TelemetryEvent;

pub mod config;

#[cfg(feature = "prometheus")]
pub mod prometheus;

#[cfg(feature = "otel")]
pub mod otel;

/// Synchronous exporter callback surface. Implementers are stored as
/// `Arc<dyn Exporter>` on the `TelemetryBus`.
pub trait Exporter: Send + Sync + 'static {
    fn on_event(&self, event: &TelemetryEvent);

    /// Called by the dashboard on shutdown. Implementations can flush
    /// buffered metrics/spans here.
    fn shutdown(&self) {}
}