Struct InMemoryMemoryStore 

pub struct InMemoryMemoryStore { /* private fields */ }

纯内存版的实现：

• 使用 HashMap<conversation_id, Vec<Message>> 保存消息；
• 不做容量控制与持久化，仅用于开发与测试；
• 线程安全，但不保证高并发场景下的性能。

Implementations

impl InMemoryMemoryStore

pub fn new() -> Self

Trait Implementations

impl Default for InMemoryMemoryStore

fn default() -> InMemoryMemoryStore

Returns the “default value” for a type.

impl MemoryStore for InMemoryMemoryStore

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

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

一个极简的包含匹配查询实现：

• 仅在指定 conversation_id 的会话内搜索；
• 使用不区分大小写的子串匹配；
• 若 query 为空字符串，则返回整个会话的消息列表。

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

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

追加一条消息到某个会话中。

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

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

获取某个会话的完整消息列表。

fn save_conversation<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, conversation_id: &'life1 str, messages: &'life2 [Message], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

覆盖保存整个会话的消息列表。