Struct MemorySink 

pub struct MemorySink { /* private fields */ }

A sink that records every event in memory, for tests to assert on.

Implementations

impl MemorySink

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

A snapshot of everything emitted so far, in order.

pub fn lane_samples(&self) -> Vec<LaneHealth>

Every lane-health sample recorded so far, in order.

pub fn provider_samples(&self) -> Vec<Vec<ProviderHealth>>

Every provider-health sample recorded so far, in order.

pub fn flush_count(&self) -> usize

How many times force_flush was called.

Trait Implementations

impl Default for MemorySink

fn default() -> MemorySink

Returns the “default value” for a type.

impl TelemetrySink for MemorySink

fn emit(&self, event: TelemetryEvent)

Record one event.

fn observe_lanes(&self, health: LaneHealth)

Record one daemon-wide health sample. Default: ignore it, so a sink that only cares about runs needs no changes.

fn observe_providers(&self, down: &[ProviderHealth])

Record which providers are currently out of service, sampled on the same re-drive tick as TelemetrySink::observe_lanes. Default: ignore it, so an existing sink keeps compiling unchanged.

fn force_flush(&self)

Flush any buffered export before shutdown. Default: nothing buffered.