Struct StorageManager 

pub struct StorageManager { /* private fields */ }

Manages collections and persistence

Implementations

impl StorageManager

pub fn new<P: AsRef<Path>>(data_dir: P) -> Result<Self>

pub fn create_collection( &self, config: CollectionConfig, ) -> Result<Arc<Collection>>

pub fn get_collection(&self, name: &str) -> Option<Arc<Collection>>

pub fn delete_collection(&self, name: &str) -> Result<bool>

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

pub fn collection_exists(&self, name: &str) -> bool

pub fn create_alias( &self, alias_name: &str, collection_name: &str, ) -> Result<bool>

Create an alias for a collection

pub fn delete_alias(&self, alias_name: &str) -> Result<bool>

Delete an alias

pub fn rename_alias(&self, old_alias: &str, new_alias: &str) -> Result<bool>

Rename an alias

pub fn list_aliases(&self) -> Vec<(String, String)>

List all aliases

pub fn list_collection_aliases(&self, collection_name: &str) -> Vec<String>

List aliases for a specific collection

pub fn data_dir(&self) -> &Path

pub fn bgsave(&self) -> Result<bool>

Trigger background save

pub fn save(&self) -> Result<()>

Force save

pub fn last_save_time(&self) -> u64

Get last save time

pub fn is_bgsave_in_progress(&self) -> bool

Check if background save is in progress

pub fn create_collection_snapshot( &self, collection_name: &str, ) -> Result<SnapshotDescription>

Create a snapshot for a collection

pub fn list_collection_snapshots( &self, collection_name: &str, ) -> Result<Vec<SnapshotDescription>>

List snapshots for a collection

pub fn delete_collection_snapshot( &self, collection_name: &str, snapshot_name: &str, ) -> Result<bool>

Delete a snapshot

pub fn get_snapshot_path( &self, collection_name: &str, snapshot_name: &str, ) -> Option<PathBuf>

Get snapshot file path for download

pub fn recover_from_snapshot( &self, collection_name: &str, snapshot_name: &str, ) -> Result<Arc<Collection>>

Recover collection from a snapshot file

pub async fn recover_from_url( &self, collection_name: &str, url: &str, checksum: Option<&str>, ) -> Result<Arc<Collection>>

Recover collection from a URL

pub fn list_all_snapshots(&self) -> Result<Vec<SnapshotDescription>>

List all snapshots

pub fn upload_and_restore_snapshot( &self, collection_name: &str, data: &[u8], filename: Option<&str>, ) -> Result<Arc<Collection>>

Upload and restore a snapshot from raw bytes