Struct InMemoryMessageRetriever 

pub struct InMemoryMessageRetriever { /* private fields */ }

In-memory message retriever

Stores messages in a HashMap keyed by session ID. Implements the MessageRetriever trait for retrieval operations.

Note: Write operations (add, store) are provided as inherent methods for testing purposes. In production, messages are stored via EventEmitter.

Implementations

impl InMemoryMessageRetriever

pub fn new() -> Self

Create a new in-memory message retriever

pub async fn sessions(&self) -> Vec<SessionId>

Get all sessions

pub async fn clear(&self)

Clear all messages

pub async fn clear_session(&self, session_id: SessionId)

Clear messages for a specific session

pub async fn seed(&self, session_id: SessionId, messages: Vec<Message>)

Pre-populate with messages (useful for testing)

pub async fn add( &self, session_id: SessionId, input: InputMessage, ) -> Result<Message>

Add a new message and return it with generated ID (for testing)

Note: In production, messages are stored via EventService. This method is provided for test setup and in-memory usage.

pub async fn store(&self, session_id: SessionId, message: Message) -> Result<()>

Store an existing message (for testing)

Note: In production, messages are stored via EventEmitter. This method is provided for test setup and in-memory usage.

Trait Implementations

impl Clone for InMemoryMessageRetriever

fn clone(&self) -> InMemoryMessageRetriever

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryMessageRetriever

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

Formats the value using the given formatter.

impl Default for InMemoryMessageRetriever

fn default() -> InMemoryMessageRetriever

Returns the “default value” for a type.

impl MessageRetriever for InMemoryMessageRetriever

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

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

Get a specific message by ID

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

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

Load all messages for a session

fn load_filtered<'life0, 'async_trait>( &'life0 self, query: MessageQuery, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>>> + Send + 'async_trait>>

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

Load messages with filters and injections applied.

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

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

Count messages in a session

fn load_page<'life0, 'async_trait>( &'life0 self, session_id: SessionId, offset: usize, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>>> + Send + 'async_trait>>

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

Load messages with pagination