Struct InMemoryObservationSink 

pub struct InMemoryObservationSink { /* private fields */ }

Bounded in-memory sink used by diagnostics and embedded runtimes.

Implementations

impl InMemoryObservationSink

pub fn new(capacity: usize) -> Self

Creates a sink that retains the newest capacity events.

pub fn add_drain(&self, drain: Arc<dyn ObservationSink>)

Adds an operational drain that receives future redacted events.

pub fn drain_count(&self) -> usize

Returns the number of attached operational drains.

pub fn snapshot(&self) -> Vec<ObservationEvent>

Returns a stable snapshot from oldest to newest.

pub fn len(&self) -> usize

Returns the number of retained events.

pub fn is_empty(&self) -> bool

Reports whether no events are retained.

Trait Implementations

impl Clone for InMemoryObservationSink

fn clone(&self) -> InMemoryObservationSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryObservationSink

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

Formats the value using the given formatter.

impl Default for InMemoryObservationSink

fn default() -> Self

Returns the “default value” for a type.

impl ObservationSink for InMemoryObservationSink

fn emit(&self, event: ObservationEvent)

Emits one event without blocking on external tooling.