Struct PersistenceManager 

pub struct PersistenceManager { /* private fields */ }

Main persistence manager

Implementations

impl PersistenceManager

pub fn new(backend: Arc<dyn PersistenceBackend>) -> Self

Create a new persistence manager with the given backend

pub fn with_file_backend(path: impl AsRef<Path>) -> Self

Create with file backend

pub fn with_memory_backend() -> Self

Create with memory backend

pub fn set_checkpoint_config(&mut self, config: CheckpointConfig)

Set checkpoint configuration

pub async fn initialize(&self) -> Result<()>

Initialize the persistence system

pub async fn save_agent(&self, state: &AgentState) -> Result<()>

Save agent state

pub async fn load_agent(&self, agent_id: &AgentId) -> Result<Option<AgentState>>

Load agent state

pub async fn delete_agent(&self, agent_id: &AgentId) -> Result<()>

Delete agent and all associated data

pub async fn list_agents(&self) -> Result<Vec<AgentId>>

List all agents

pub async fn save_conversation(&self, conversation: &Conversation) -> Result<()>

Save conversation

pub async fn load_conversation( &self, conversation_id: &ConversationId, ) -> Result<Option<Conversation>>

Load conversation

pub async fn delete_conversation( &self, conversation_id: &ConversationId, ) -> Result<()>

Delete conversation

pub async fn list_conversations( &self, agent_id: &AgentId, ) -> Result<Vec<ConversationId>>

List conversations for an agent

pub async fn search_conversations( &self, agent_id: &AgentId, query: &str, limit: usize, ) -> Result<Vec<ConversationId>>

Search conversations

pub async fn add_message( &self, conversation_id: &ConversationId, message: Message, ) -> Result<()>

Add a message to a conversation

pub async fn create_checkpoint( &self, agent_id: &AgentId, name: &str, checkpoint_type: CheckpointType, ) -> Result<CheckpointId>

Create a checkpoint

pub async fn restore_checkpoint( &self, checkpoint_id: &CheckpointId, ) -> Result<AgentId>

Restore from a checkpoint

pub async fn list_checkpoints( &self, agent_id: &AgentId, ) -> Result<Vec<CheckpointId>>

List checkpoints for an agent

pub async fn delete_checkpoint( &self, checkpoint_id: &CheckpointId, ) -> Result<()>

Delete a checkpoint

pub async fn start_auto_checkpoint(&self, agent_ids: Vec<AgentId>)

Start automatic checkpoint scheduler

pub async fn stop_auto_checkpoint(&self)

Stop automatic checkpointing

pub async fn get_stats(&self) -> Result<StorageStats>

Get storage statistics