Struct AgentStorageManager 

pub struct AgentStorageManager { /* private fields */ }

Manages storage instances for multiple agents

Each agent gets its own isolated SQLite database located at: {tap_root}/{sanitized_did}/transactions.db

Implementations

impl AgentStorageManager

pub fn new(tap_root: Option<PathBuf>) -> Self

Create a new agent storage manager

pub async fn get_agent_storage( &self, agent_did: &str, ) -> NodeResult<Arc<Storage>>

Get or create storage for an agent

This method maintains a cache of storage instances to avoid recreating databases for the same agent. If the storage doesn’t exist, it creates a new one using the agent’s DID for the database path.

pub fn get_cached_agent_storage(&self, agent_did: &str) -> Option<Arc<Storage>>

Get storage for an agent if it exists in cache (doesn’t create new one)

pub fn remove_agent_storage(&self, agent_did: &str) -> Option<Arc<Storage>>

Remove an agent’s storage from the cache

This doesn’t delete the database files, just removes the instance from memory. Useful when an agent is unregistered.

pub fn cached_storage_count(&self) -> usize

Get count of cached storage instances

pub fn cached_agent_dids(&self) -> Vec<String>

List all agent DIDs that have cached storage

pub fn clear_cache(&self)

Clear all cached storage instances

This forces recreation of storage instances on next access. Useful for testing or when storage configuration changes.

pub async fn ensure_agent_storage(&self, agent_did: &str) -> NodeResult<()>

Ensure storage exists for an agent (creates if needed but doesn’t cache)

This is useful during agent registration to ensure the storage directory and database are properly initialized.

Trait Implementations

impl Clone for AgentStorageManager

fn clone(&self) -> AgentStorageManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.