Struct InMemoryEventLog 

pub struct InMemoryEventLog { /* private fields */ }

An in-process event log, used by tests and single-node deployments.

Deduplicates on idempotency_key, so replaying an append is a no-op.

Implementations

impl InMemoryEventLog

pub fn new() -> Self

An empty log.

pub fn entries(&self) -> Vec<MemoryEventEnvelope>

Every event appended so far, in order.

pub fn len(&self) -> usize

How many events have been appended.

pub fn is_empty(&self) -> bool

Whether the log is empty.

pub fn count_label(&self, label: &str) -> usize

Count of appended events carrying a given label.

Trait Implementations

impl Debug for InMemoryEventLog

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

Formats the value using the given formatter.

impl Default for InMemoryEventLog

fn default() -> InMemoryEventLog

Returns the “default value” for a type.

impl MemoryEventLog for InMemoryEventLog

fn append<'life0, 'async_trait>( &'life0 self, envelope: MemoryEventEnvelope, ) -> Pin<Box<dyn Future<Output = Result<(), MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Append an envelope, returning once it is durable.

fn replay_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<Vec<MemoryEventEnvelope>, MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read back every event for a logical session, in append order.