Struct InMemoryObservationSink 

pub struct InMemoryObservationSink { /* private fields */ }

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

Drain configuration is copy-on-write. Emission borrows one immutable drain generation and releases its configuration lock before invoking callbacks.

Implementations

impl InMemoryObservationSink

pub fn new(capacity: usize) -> Self

Creates a sink that retains the newest capacity events.

pub fn with_max_bytes(capacity: usize, max_bytes: usize) -> Self

Creates a sink with a tighter aggregate retained-byte ceiling.

Count is clamped to the public safety ceiling. The byte limit is clamped to 1..=default_max_bytes(capacity) and is observable through Self::pressure.

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

Adds an operational drain that receives future redacted events.

pub fn try_add_drain(&self, drain: Arc<dyn ObservationSink>) -> bool

Attempts to add an operational drain under the attachment ceiling.

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 shared_snapshot(&self) -> ObservationSnapshot

Returns an immutable snapshot without cloning retained observations.

pub fn pressure(&self) -> InMemoryObservationPressure

Returns current count and retained-memory pressure.

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.

fn emit_shared(&self, event: &SharedObservationEvent)

Emits an already validated shared event.