Struct TelemetrySender 

pub struct TelemetrySender<T: Telemetry> { /* private fields */ }

Sender-side handle that implements Telemetry and forwards all calls to the core via a multi-producer, single-consumer channel.

Implementations

impl<T: Telemetry> TelemetrySender<T>

pub fn send_shutdown(&self)

Send an explicit shutdown message to the telemetry core.

After this call, the core will exit its run loop once it processes the message and perform a final flush.

Trait Implementations

impl<T: Telemetry> Clone for TelemetrySender<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Telemetry> Telemetry for TelemetrySender<T>

const METRICS_ENABLED: bool = T::METRICS_ENABLED

Compile-time flag indicating whether this telemetry implementation wants metrics (counters, gauges, latencies) at all.

const EVENTS_STATICALLY_ENABLED: bool = T::EVENTS_STATICALLY_ENABLED

Compile-time flag indicating whether this telemetry implementation ever produces structured events.

fn incr_counter(&mut self, key: TelemetryKey, delta: u64)

Increment a counter metric identified by the given key.

fn set_gauge(&mut self, key: TelemetryKey, value: u64)

Set a gauge metric identified by the given key.

fn record_latency_ns(&mut self, key: TelemetryKey, value_ns: u64)

Record a latency sample in nanoseconds for the given key.

fn push_metrics(&mut self)

Optional: push a snapshot of aggregated metrics to the sink.

fn events_enabled(&self) -> bool

Return true if this telemetry collector wants structured events.

fn push_event(&mut self, event: TelemetryEvent)

Emit a structured telemetry event.

fn flush(&mut self)

Flush any buffered telemetry data to the underlying sink.