Struct MetricsCollector 

pub struct MetricsCollector { /* private fields */ }

Subscribes to the domain-event stream and maintains a running snapshot.

Implementations

impl MetricsCollector

pub fn new() -> Self

pub fn snapshot(&self) -> TelemetrySnapshot

pub fn observe(&mut self, env: &EventEnvelope)

Fold one event into the snapshot. Reads only numeric/enum fields.

Trait Implementations

impl Debug for MetricsCollector

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

Formats the value using the given formatter.

impl Default for MetricsCollector

fn default() -> MetricsCollector

Returns the “default value” for a type.