Struct InMemoryStore 

pub struct InMemoryStore { /* private fields */ }

内存存储

线程安全的内存存储实现，所有数据存储在内存中。 适用于：

• 单元测试
• 开发环境
• 短期会话（无需持久化）

示例

use mofa_foundation::persistence::InMemoryStore;

let store = InMemoryStore::new();

// 保存消息
store.save_message(&message).await?;

// 查询消息
let messages = store.get_session_messages(session_id).await?;

Implementations

impl InMemoryStore

pub fn new() -> InMemoryStore

创建新的内存存储

pub fn shared() -> Arc<InMemoryStore>

创建共享的内存存储

pub async fn clear(&self)

清空所有数据

pub async fn message_count(&self) -> usize

获取消息总数

pub async fn api_call_count(&self) -> usize

获取 API 调用总数

pub async fn session_count(&self) -> usize

获取会话总数

Trait Implementations

impl AgentStore for InMemoryStore

fn get_agent<'life0, 'async_trait>( &'life0 self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<Agent>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

根据 ID 获取 agent

fn get_agent_by_code<'life0, 'life1, 'async_trait>( &'life0 self, _code: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Agent>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

根据 code 获取 agent（全局查找）

fn get_agent_by_code_and_tenant<'life0, 'life1, 'async_trait>( &'life0 self, _tenant_id: Uuid, _code: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Agent>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

根据 code 和租户 ID 获取 agent

fn list_agents<'life0, 'async_trait>( &'life0 self, _tenant_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<Agent>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

列出租户的所有 agents

fn get_active_agents<'life0, 'async_trait>( &'life0 self, _tenant_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<Agent>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

获取租户所有启用的 agents

fn get_agent_with_provider<'life0, 'async_trait>( &'life0 self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<AgentConfig>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

根据 ID 获取 agent 及其 provider 配置

fn get_agent_by_code_with_provider<'life0, 'life1, 'async_trait>( &'life0 self, _code: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<AgentConfig>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

根据 code 获取 agent 及其 provider 配置（全局查找）

fn get_agent_by_code_and_tenant_with_provider<'life0, 'life1, 'async_trait>( &'life0 self, _tenant_id: Uuid, _code: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<AgentConfig>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

根据 code 和租户 ID 获取 agent 及其 provider 配置

impl ApiCallStore for InMemoryStore

fn save_api_call<'life0, 'life1, 'async_trait>( &'life0 self, call: &'life1 LLMApiCall, ) -> Pin<Box<dyn Future<Output = Result<(), PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

保存 API 调用记录

fn get_api_call<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<LLMApiCall>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

获取 API 调用记录

fn query_api_calls<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 QueryFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<LLMApiCall>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

查询 API 调用记录

fn get_statistics<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 QueryFilter, ) -> Pin<Box<dyn Future<Output = Result<UsageStatistics, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

统计 API 调用

fn delete_api_call<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<bool, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

删除 API 调用记录

fn cleanup_old_records<'life0, 'async_trait>( &'life0 self, before: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<i64, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

清理旧记录

fn save_api_calls<'life0, 'life1, 'async_trait>( &'life0 self, calls: &'life1 [LLMApiCall], ) -> Pin<Box<dyn Future<Output = Result<(), PersistenceError>> + Send + 'async_trait>>

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

批量保存 API 调用记录

impl Default for InMemoryStore

fn default() -> InMemoryStore

Returns the “default value” for a type.

impl MessageStore for InMemoryStore

fn save_message<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 LLMMessage, ) -> Pin<Box<dyn Future<Output = Result<(), PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

保存消息

fn get_message<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<LLMMessage>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

获取消息

fn get_session_messages<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<LLMMessage>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

获取会话消息列表

fn get_session_messages_paginated<'life0, 'async_trait>( &'life0 self, session_id: Uuid, offset: i64, limit: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<LLMMessage>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

获取会话消息列表 (分页)

fn delete_message<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<bool, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

删除消息

fn delete_session_messages<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<i64, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

删除会话所有消息

fn count_session_messages<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<i64, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

统计会话消息数

fn save_messages<'life0, 'life1, 'async_trait>( &'life0 self, messages: &'life1 [LLMMessage], ) -> Pin<Box<dyn Future<Output = Result<(), PersistenceError>> + Send + 'async_trait>>

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

批量保存消息

impl PersistenceStore for InMemoryStore

fn backend_name(&self) -> &str

获取存储后端名称

fn is_connected(&self) -> bool

检查连接状态

async fn close(&self) -> Result<(), PersistenceError>

关闭连接

impl ProviderStore for InMemoryStore

fn get_provider<'life0, 'async_trait>( &'life0 self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<Provider>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

根据 ID 获取 provider

fn get_provider_by_name<'life0, 'life1, 'async_trait>( &'life0 self, _tenant_id: Uuid, _name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Provider>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

根据名称和租户 ID 获取 provider

fn list_providers<'life0, 'async_trait>( &'life0 self, _tenant_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<Provider>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

列出租户的所有 providers

fn get_enabled_providers<'life0, 'async_trait>( &'life0 self, _tenant_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<Provider>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

获取租户所有启用的 providers

impl SessionStore for InMemoryStore

fn create_session<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 ChatSession, ) -> Pin<Box<dyn Future<Output = Result<(), PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

创建会话

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

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

获取会话

fn get_user_sessions<'life0, 'async_trait>( &'life0 self, user_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<ChatSession>, PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

获取用户会话列表

fn update_session<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 ChatSession, ) -> Pin<Box<dyn Future<Output = Result<(), PersistenceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

更新会话

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

where 'life0: 'async_trait, InMemoryStore: 'async_trait,

删除会话