Struct InMemoryStreamSessionRepository

pub struct InMemoryStreamSessionRepository { /* private fields */ }

In-memory implementation of StreamSessionRepository

This implementation provides full ACID transaction support and is suitable for testing and development.

Implementations

impl InMemoryStreamSessionRepository

pub fn new() -> Self

Trait Implementations

impl Default for InMemoryStreamSessionRepository

fn default() -> Self

Returns the “default value” for a type.

impl StreamSessionRepository for InMemoryStreamSessionRepository

fn begin_transaction<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = DomainResult<Box<dyn SessionTransaction>>> + Send + 'async_trait>>

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

Start a new transaction

fn find_session<'life0, 'async_trait>( &'life0 self, session_id: SessionId, ) -> Pin<Box<dyn Future<Output = DomainResult<Option<StreamSession>>> + Send + 'async_trait>>

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

Find session by ID with read consistency guarantees

fn save_session<'life0, 'async_trait>( &'life0 self, session: StreamSession, expected_version: Option<u64>, ) -> Pin<Box<dyn Future<Output = DomainResult<u64>> + Send + 'async_trait>>

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

Save session with optimistic concurrency control

fn remove_session<'life0, 'async_trait>( &'life0 self, session_id: SessionId, ) -> Pin<Box<dyn Future<Output = DomainResult<()>> + Send + 'async_trait>>

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

Remove session and all associated data

fn find_sessions_by_criteria<'life0, 'async_trait>( &'life0 self, criteria: SessionQueryCriteria, pagination: Pagination, ) -> Pin<Box<dyn Future<Output = DomainResult<SessionQueryResult>> + Send + 'async_trait>>

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

Find sessions by criteria with pagination

fn get_session_health<'life0, 'async_trait>( &'life0 self, session_id: SessionId, ) -> Pin<Box<dyn Future<Output = DomainResult<SessionHealthSnapshot>> + Send + 'async_trait>>

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

Get session health metrics

fn session_exists<'life0, 'async_trait>( &'life0 self, session_id: SessionId, ) -> Pin<Box<dyn Future<Output = DomainResult<bool>> + Send + 'async_trait>>

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

Check if session exists (lightweight operation)