Struct ObservationMetricsSink 

pub struct ObservationMetricsSink { /* private fields */ }

Observation drain that records stable monotonic counters.

Implementations

impl ObservationMetricsSink

pub fn new(metrics: Arc<InMemoryMetrics>) -> Self

Creates a drain backed by the provided process-local registry.

pub fn metrics(&self) -> Arc<InMemoryMetrics>

Returns the shared metrics registry.

Trait Implementations

impl Clone for ObservationMetricsSink

fn clone(&self) -> ObservationMetricsSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ObservationMetricsSink

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ObservationSink for ObservationMetricsSink

fn emit(&self, event: ObservationEvent)

Emits one event without blocking on external tooling.

fn emit_shared(&self, event: &SharedObservationEvent)

Emits an already validated shared event.