Struct RecordingSink 

pub struct RecordingSink { /* private fields */ }

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

Clones share the same captured data. Use the typed accessors to inspect all emits or the matching helpers to select one metric name, label subset, or event table.

Examples

use spectra_core::{RecordingSink, SpectraSink};

let sink = RecordingSink::new();
sink.record_counter("cache_hits", &[("region", "us")], 2);

let hits = sink.recorded_counters_matching("cache_hits", &[("region", "us")]);
assert_eq!(hits.len(), 1);
assert_eq!(hits[0].delta, 2);

sink.clear();
assert!(sink.counters().is_empty());

Implementations

impl RecordingSink

pub fn new() -> RecordingSink

Creates an empty recording sink.

pub fn clear(&self)

Clears all recorded emits.

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

Returns all recorded counter increments.

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

Returns all recorded gauge samples.

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

Returns all recorded events.

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

Returns counters matching a name and label subset.

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

Returns events recorded for a specific table.

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 SpectraSink for RecordingSink

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

Increment (or decrement) a counter.

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

Set a gauge value.

fn log_event(&self, table: &str, fields: &Value)

Append a structured event row.