Struct FileStorage 

pub struct FileStorage { /* private fields */ }

Implementations

impl FileStorage

pub fn new(base_path: impl AsRef<Path>) -> FileStorage

Trait Implementations

impl AgentStorage for FileStorage

fn save<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, snapshot: &'life2 AgentSnapshot, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

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

Persist an agent snapshot for the given session ID.

fn load<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<AgentSnapshot>, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FileStorage: 'async_trait,

Load a snapshot. Returns None if the session does not exist.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FileStorage: 'async_trait,

Remove a session’s persisted data.

fn list_sessions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, FileStorage: 'async_trait,

List all stored session IDs.

fn supports(&self, capability: StorageCapability) -> bool

Return whether this backend implements a storage feature.

fn save_snapshot_with_metadata<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session_id: &'life1 str, snapshot: &'life2 AgentSnapshot, metadata: &'life3 SessionMetadata, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

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

Atomically persist a snapshot and its metadata when the backend supports session metadata.

fn save_metadata<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _session_id: &'life1 str, _metadata: &'life2 SessionMetadata, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

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

Save session metadata alongside the snapshot.

fn load_metadata<'life0, 'life1, 'async_trait>( &'life0 self, _session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<SessionMetadata>, AgentError>> + Send + 'async_trait>>

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

Load session metadata.

fn list_sessions_filtered<'life0, 'life1, 'async_trait>( &'life0 self, _filter: &'life1 SessionFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<SessionSummary>, AgentError>> + Send + 'async_trait>>

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

List sessions matching a filter.

fn cleanup_expired<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize, AgentError>> + Send + 'async_trait>>

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

Delete sessions that have expired based on TTL.

fn save_facts<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _agent_id: &'life1 str, _actor_id: &'life2 str, _facts: &'life3 [KeyFact], ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

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

Persist facts for an actor. Merges with existing facts.

fn load_facts<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _agent_id: &'life1 str, _actor_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<KeyFact>, AgentError>> + Send + 'async_trait>>

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

Load all facts for a specific actor.

fn query_facts<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _agent_id: &'life1 str, _filter: &'life2 FactFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<KeyFact>, AgentError>> + Send + 'async_trait>>

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

Load facts matching a filter (cross-actor queries).

fn delete_fact<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _agent_id: &'life1 str, _actor_id: &'life2 str, _fact_id: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

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

Delete a single fact by ID.

fn delete_actor_data<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _agent_id: &'life1 str, _actor_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

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

Atomically delete facts, relationships, and sessions owned by an actor.

fn save_relationship<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _agent_id: &'life1 str, _actor_id: &'life2 str, _relationship: &'life3 Value, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

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

Persist relationship data for an actor. Value is owned by the relationships crate.

fn load_relationship<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _agent_id: &'life1 str, _actor_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, AgentError>> + Send + 'async_trait>>

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

Load relationship data for a specific actor.

fn list_relationship_actors<'life0, 'life1, 'async_trait>( &'life0 self, _agent_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, AgentError>> + Send + 'async_trait>>

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

List actor IDs that have relationship data for an agent.

fn delete_relationship<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _agent_id: &'life1 str, _actor_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

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

Delete relationship data for a specific actor.