Struct NamespacedStorage 

pub struct NamespacedStorage { /* private fields */ }

Wraps shared storage with reversible flat keys scoped to one agent namespace.

Implementations

impl NamespacedStorage

pub fn new(inner: Arc<dyn AgentStorage>, namespace: impl Into<String>) -> Self

Trait Implementations

impl AgentStorage for NamespacedStorage

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

Return whether this backend implements a storage feature.

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

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: '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>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: '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<()>> + Send + 'async_trait>>

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

Remove a session’s persisted data.

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

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

List all stored session IDs.

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<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: '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<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: '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>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: '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>>> + Send + 'async_trait>>

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

List sessions matching a filter.

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

where Self: 'async_trait, 'life0: '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<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: '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>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: '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>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: '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<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: '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<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: '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<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: '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>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: '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>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: '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<()>> + Send + 'async_trait>>

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

Delete relationship data for a specific actor.