Struct PersistencePlugin 

pub struct PersistencePlugin { /* private fields */ }

持久化插件

实现 AgentPlugin trait，提供完整的持久化能力：

• 从数据库加载会话历史
• 自动记录用户消息、助手消息、API 调用

示例

use mofa_foundation::persistence::{PersistencePlugin, PostgresStore};
use mofa_sdk::llm::LLMAgentBuilder;
use uuid::Uuid;

let store = PostgresStore::connect("postgres://localhost/mofa").await?;
let user_id = Uuid::now_v7();
let tenant_id = Uuid::now_v7();
let agent_id = Uuid::now_v7();
let session_id = Uuid::now_v7();

let plugin = PersistencePlugin::from_store(
    "persistence-plugin",
    store,
    user_id,
    tenant_id,
    agent_id,
    session_id,
);

let agent = LLMAgentBuilder::new()
    .with_plugin(plugin)
    .build_async()
    .await;

Implementations

impl PersistencePlugin

pub fn new( plugin_id: &str, message_store: Arc<dyn MessageStore + Sync + Send>, api_call_store: Arc<dyn ApiCallStore + Sync + Send>, user_id: Uuid, tenant_id: Uuid, agent_id: Uuid, session_id: Uuid, ) -> PersistencePlugin

创建持久化插件

参数

• plugin_id: 插件唯一标识
• message_store: 消息存储后端
• api_call_store: API 调用存储后端
• user_id: 用户 ID
• tenant_id: 租户 ID
• agent_id: Agent ID
• session_id: 会话 ID

pub fn from_store<S>( plugin_id: &str, store: S, user_id: Uuid, tenant_id: Uuid, agent_id: Uuid, session_id: Uuid, ) -> PersistencePlugin

where S: MessageStore + ApiCallStore + SessionStore + Send + Sync + 'static,

创建持久化插件（便捷方法，使用单个存储后端）

参数

• plugin_id: 插件唯一标识
• store: 持久化存储后端（需要同时实现 MessageStore、ApiCallStore、SessionStore）
• user_id: 用户 ID
• tenant_id: 租户 ID
• agent_id: Agent ID
• session_id: 会话 ID

pub async fn with_session_id(&self, session_id: Uuid)

更新会话 ID

pub async fn session_id(&self) -> Uuid

获取当前会话 ID

pub async fn load_history(&self) -> Result<Vec<LLMMessage>, PersistenceError>

获取历史消息（用于 build_async）

pub fn message_store(&self) -> Arc<dyn MessageStore + Sync + Send>

获取消息存储引用

pub fn api_call_store(&self) -> Arc<dyn ApiCallStore + Sync + Send>

获取 API 调用存储引用

pub fn session_store(&self) -> Option<Arc<dyn SessionStore + Sync + Send>>

获取会话存储引用

pub fn user_id(&self) -> Uuid

获取用户 ID

pub fn tenant_id(&self) -> Uuid

获取租户 ID

pub fn agent_id(&self) -> Uuid

获取 Agent ID

pub async fn save_user_message(&self, content: &str) -> Result<Uuid, LLMError>

保存用户消息

pub async fn save_assistant_message( &self, content: &str, ) -> Result<Uuid, LLMError>

保存助手消息

Trait Implementations

impl AgentPlugin for PersistencePlugin

fn metadata(&self) -> &PluginMetadata

获取插件元数据

fn state(&self) -> PluginState

获取插件状态

fn load<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 PluginContext, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, PersistencePlugin: 'async_trait,

插件加载（分配资源）

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

where 'life0: 'async_trait, PersistencePlugin: 'async_trait,

插件初始化（配置初始化）

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

where 'life0: 'async_trait, PersistencePlugin: 'async_trait,

插件启动

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

where 'life0: 'async_trait, PersistencePlugin: 'async_trait,

插件停止

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

where 'life0: 'async_trait, PersistencePlugin: 'async_trait,

插件卸载（释放资源）

fn execute<'life0, 'async_trait>( &'life0 mut self, _input: String, ) -> Pin<Box<dyn Future<Output = Result<String, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, PersistencePlugin: 'async_trait,

执行插件功能

fn stats(&self) -> HashMap<String, Value>

获取插件统计信息

fn as_any(&self) -> &(dyn Any + 'static)

转换为 Any（用于向下转型）

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

转换为可变 Any

fn into_any(self: Box<PersistencePlugin>) -> Box<dyn Any>

消费并转换为 Any（用于提取具体的插件类型）

fn plugin_id(&self) -> &str

获取插件 ID（便捷方法）

fn plugin_type(&self) -> PluginType

获取插件类型

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

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

插件暂停

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

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

插件恢复

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

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

健康检查

impl Clone for PersistencePlugin

fn clone(&self) -> PersistencePlugin

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl LLMAgentEventHandler for PersistencePlugin

fn before_chat<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, LLMError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, PersistencePlugin: 'async_trait,

在发送用户消息前调用 - 记录用户消息

fn before_chat_with_model<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, message: &'life1 str, model: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, LLMError>> + Send + 'async_trait>>

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

在发送用户消息前调用（带模型名称）- 记录用户消息和模型

fn after_chat<'life0, 'life1, 'async_trait>( &'life0 self, response: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, LLMError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, PersistencePlugin: 'async_trait,

在收到 LLM 响应后调用 - 记录助手消息和 API 调用

fn after_chat_with_metadata<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, response: &'life1 str, metadata: &'life2 LLMResponseMetadata, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, LLMError>> + Send + 'async_trait>>

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

在收到 LLM 响应后调用 - 记录助手消息和 API 调用（带元数据）

fn on_error<'life0, 'life1, 'async_trait>( &'life0 self, error: &'life1 LLMError, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, LLMError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, PersistencePlugin: 'async_trait,

在发生错误时调用 - 记录 API 错误

fn clone_box(&self) -> Box<dyn LLMAgentEventHandler>

Clone this handler trait object

fn as_any(&self) -> &(dyn Any + 'static)

获取 Any 类型用于 downcasting

fn on_tool_call<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, name: &'life1 str, arguments: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, LLMError>> + Send + 'async_trait>>

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

处理工具调用