Struct RecordingSink 

pub struct RecordingSink { /* private fields */ }

Append-only in-memory sink for assertions in unit and integration tests.

Implementations

impl RecordingSink

pub fn new() -> RecordingSink

Create an empty in-memory recording sink.

pub fn counters(&self) -> Vec<RecordedCounter>

Return all recorded counter increments.

pub fn events(&self) -> Vec<RecordedEvent>

Return all recorded structured events.

pub fn gauges(&self) -> Vec<RecordedGauge>

Return all recorded gauge samples.

pub fn recorded_counters_matching( &self, name: &str, labels: &[(&str, &str)], ) -> Vec<RecordedCounter>

Counters matching name and label subset (test helper).

pub fn recorded_events_for(&self, schema: &str) -> Vec<RecordedEvent>

Events matching schema name (test helper).

Trait Implementations

impl Clone for RecordingSink

fn clone(&self) -> RecordingSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecordingSink

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

Formats the value using the given formatter.

impl Default for RecordingSink

fn default() -> RecordingSink

Returns the “default value” for a type.

impl TelemetrySink for RecordingSink

fn record_counter(&self, name: &str, labels: &[(&str, &str)], delta: u64)

Increment a counter metric by delta with optional label dimensions.

fn record_gauge(&self, name: &str, labels: &[(&str, &str)], value: f64)

Record a gauge sample with optional label dimensions.

fn log_event(&self, schema: &str, fields: &[(&str, &str)])

Emit a structured log event from flat field tuples.

fn log_event_value(&self, schema: &str, payload: &Value)

Structured event with JSON payload (default flattens top-level object keys).