Struct MemorySessionStore 

pub struct MemorySessionStore { /* private fields */ }

In-memory session store for testing, development, and prototyping.

Sessions are stored in HashMap<Uuid, Session> and messages in HashMap<Uuid, Vec<MessageRecord>>, both protected by RwLock. A reverse index message_id → session_id enables O(1) message lookups in update_usage. Data is lost when the process exits. Implements SessionStore.

Implementations

impl MemorySessionStore

pub fn new() -> Self

Creates an empty in-memory session store.

Trait Implementations

impl Default for MemorySessionStore

fn default() -> MemorySessionStore

Returns the “default value” for a type.

impl SessionStore for MemorySessionStore

fn create_session<'life0, 'async_trait>( &'life0 self, session: Session, ) -> Pin<Box<dyn Future<Output = StoreResult<Session>> + Send + 'async_trait>>

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

Persists a new session and returns it with server-assigned fields.

fn list_sessions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StoreResult<Vec<Session>>> + Send + 'async_trait>>

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

Returns all sessions ordered by most recently updated (descending).

fn get_session<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = StoreResult<Option<Session>>> + Send + 'async_trait>>

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

Returns a session by identifier, or None if not found.

fn delete_session<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = StoreResult<()>> + Send + 'async_trait>>

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

Deletes a session and all related data (cascading delete).

fn update_session<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, id: &'life1 Uuid, title: &'life2 str, model: Option<&'life3 ModelName>, ) -> Pin<Box<dyn Future<Output = StoreResult<Session>> + Send + 'async_trait>>

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

Updates a session’s title and/or model.

fn append_message<'life0, 'async_trait>( &'life0 self, message: MessageRecord, ) -> Pin<Box<dyn Future<Output = StoreResult<MessageRecord>> + Send + 'async_trait>>

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

Appends a message to a session’s history.

fn list_messages<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = StoreResult<Vec<MessageRecord>>> + Send + 'async_trait>>

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

Returns all messages for a session ordered by creation time.

fn update_usage<'life0, 'life1, 'async_trait>( &'life0 self, message_id: &'life1 Uuid, usage: TokenUsage, ) -> Pin<Box<dyn Future<Output = StoreResult<()>> + Send + 'async_trait>>

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

Updates token usage on an existing message record.

fn list_sessions_paginated<'life0, 'async_trait>( &'life0 self, pagination: Pagination, filter: SessionFilter, ) -> Pin<Box<dyn Future<Output = StoreResult<Vec<Session>>> + Send + 'async_trait>>

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

Returns sessions matching the filter, paginated.

fn list_messages_paginated<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 Uuid, pagination: Pagination, ) -> Pin<Box<dyn Future<Output = StoreResult<Vec<MessageRecord>>> + Send + 'async_trait>>

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

Returns messages for a session, paginated.

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

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

Checks connectivity to the backend.

fn get_latest_compaction<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = StoreResult<Option<MessageRecord>>> + Send + 'async_trait>>

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

Returns the most recent compaction user message for a session.

fn mark_compacted<'life0, 'life1, 'async_trait>( &'life0 self, _message_id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = StoreResult<()>> + Send + 'async_trait>>

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

Marks a message as compacted, setting its is_summary flag.