Struct MemorySink 

pub struct MemorySink { /* private fields */ }

In-memory sink for unit tests — retains events for assertion.

Implementations

impl MemorySink

pub fn new() -> Self

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

pub fn summaries(&self) -> Vec<SessionSummary>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl Default for MemorySink

fn default() -> MemorySink

Returns the “default value” for a type.

impl TelemetrySink for MemorySink

fn record(&self, event: &PipelineEvent) -> Result<()>

Append a single per-response event.

fn record_summary(&self, summary: &SessionSummary) -> Result<()>

Append the session summary at session close. Default no-op for sinks that don’t distinguish rollups.

fn flush(&self) -> Result<()>

Flush any buffered writes to durable storage.