Struct InMemoryMessageStore 

pub struct InMemoryMessageStore { /* private fields */ }

In-memory implementation of MessageStore

Thread-safe storage using RwLock. Suitable for single-node deployments and testing. For persistence across restarts, use SQLite implementation.

Implementations

impl InMemoryMessageStore

pub fn new() -> Self

Create a new empty message store

pub fn shared() -> Arc<Self>

Create an Arc-wrapped instance for sharing

Trait Implementations

impl Default for InMemoryMessageStore

fn default() -> InMemoryMessageStore

Returns the “default value” for a type.

impl MessageStore for InMemoryMessageStore

fn create_thread<'life0, 'async_trait>( &'life0 self, thread: Thread, ) -> Pin<Box<dyn Future<Output = Result<ThreadId>> + Send + 'async_trait>>

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

Create a new thread

fn get_thread<'life0, 'life1, 'async_trait>( &'life0 self, thread_id: &'life1 ThreadId, ) -> Pin<Box<dyn Future<Output = Result<Option<Thread>>> + Send + 'async_trait>>

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

Get a thread by ID

fn update_thread<'life0, 'async_trait>( &'life0 self, thread: Thread, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Update thread (title, etc.)

fn delete_thread<'life0, 'life1, 'async_trait>( &'life0 self, thread_id: &'life1 ThreadId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Soft-delete a thread (sets deleted_at)

fn list_threads<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant_id: &'life1 TenantId, user_id: &'life2 UserId, limit: usize, offset: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Thread>>> + Send + 'async_trait>>

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

List threads for a user

fn create_message<'life0, 'async_trait>( &'life0 self, message: Message, ) -> Pin<Box<dyn Future<Output = Result<MessageId>> + Send + 'async_trait>>

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

Create a new message in a thread

fn get_message<'life0, 'life1, 'async_trait>( &'life0 self, message_id: &'life1 MessageId, ) -> Pin<Box<dyn Future<Output = Result<Option<Message>>> + Send + 'async_trait>>

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

Get a message by ID

fn update_message<'life0, 'async_trait>( &'life0 self, message: Message, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Update a message (content, metadata)

fn delete_message<'life0, 'life1, 'async_trait>( &'life0 self, message_id: &'life1 MessageId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Soft-delete a message

fn list_messages<'life0, 'life1, 'async_trait>( &'life0 self, thread_id: &'life1 ThreadId, include_deleted: bool, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>>> + Send + 'async_trait>>

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

Get all messages in a thread (ordered by created_at)

fn get_messages_by_execution<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>>> + Send + 'async_trait>>

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

Get messages by execution ID

fn get_or_create_thread<'life0, 'async_trait>( &'life0 self, tenant_id: TenantId, user_id: UserId, ) -> Pin<Box<dyn Future<Output = Result<Thread>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait,

Get or create a thread (implicit thread creation)

fn count_messages<'life0, 'life1, 'async_trait>( &'life0 self, thread_id: &'life1 ThreadId, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Count messages in a thread

impl StorageBackend for InMemoryMessageStore

fn name(&self) -> &str

Human-readable name of this backend (e.g., “sqlite”, “postgres”, “qdrant”)

fn requires_network(&self) -> bool

Does this backend require network access?

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

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

Health check - verify the backend is operational

fn supports_air_gapped(&self) -> bool

Can this backend operate in air-gapped mode?

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

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

Graceful shutdown