Struct InMemoryChangeFeedSink 

pub struct InMemoryChangeFeedSink { /* private fields */ }

In-memory sink for ChangeEvent records.

The default sink is a thread-safe Vec<ChangeEvent> wrapped in a Mutex. The detector owns the sink; callers consume events from it via InMemoryChangeFeedSink::drain or InMemoryChangeFeedSink::events.

The sink is the primary emission surface — it is always available, independent of the optional metrics feature, and uses no external dependencies.

Implementations

impl InMemoryChangeFeedSink

pub fn new() -> Self

Build a fresh, empty sink.

pub fn len(&self) -> usize

Current event count.

Panics

Panics only if the underlying mutex is poisoned — should not occur under normal use.

pub fn is_empty(&self) -> bool

true if no events have been recorded.

pub fn drain(&self) -> Vec<ChangeEvent>

Drain all events, leaving the sink empty.

Panics

Panics only if the underlying mutex is poisoned.

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

Borrow the current event list (snapshot copy).

pub fn clear(&self)

Clear all events without returning them.

Trait Implementations

impl ChangeEventSink for InMemoryChangeFeedSink

fn record_change_event(&self, event: &ChangeEvent)

Record a single ChangeEvent.

impl Debug for InMemoryChangeFeedSink

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

Formats the value using the given formatter.

impl Default for InMemoryChangeFeedSink

fn default() -> InMemoryChangeFeedSink

Returns the “default value” for a type.