Struct MemoryEventStore 

pub struct MemoryEventStore { /* private fields */ }

In-memory EventStore with a per-session ring buffer.

Each session keeps up to max_events_per_session events; the oldest is evicted when the buffer is full. This is the default store; external implementations are only needed for cross-instance replay.

Implementations

impl MemoryEventStore

pub fn new() -> Self

Create a new store using DEFAULT_MAX_EVENTS_PER_SESSION.

pub fn with_capacity(max_events_per_session: usize) -> Self

Create a store with the given per-session buffer capacity.

pub async fn total_events(&self) -> usize

Total number of events currently buffered across all sessions.

pub async fn session_count(&self) -> usize

Number of sessions with at least one buffered event.

Trait Implementations

impl Clone for MemoryEventStore

fn clone(&self) -> MemoryEventStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemoryEventStore

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

Formats the value using the given formatter.

impl Default for MemoryEventStore

fn default() -> Self

Returns the “default value” for a type.

impl EventStore for MemoryEventStore

fn append<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, event: EventRecord, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Append an event to a session’s log.

fn replay_after<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, after_id: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<EventRecord>>> + Send + 'async_trait>>

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

Return events with IDs strictly greater than after_id, in order.

fn purge_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Remove all events for a session. Idempotent.