Struct MultiStorage 

pub struct MultiStorage { /* private fields */ }

Multi-backend storage that combines multiple backends for redundancy and load balancing Implements failover capabilities and load distribution

Implementations

impl MultiStorage

pub fn new(backends: Vec<Arc<dyn StorageBackend>>) -> Self

Create a new multi-backend storage with redundant strategy

pub fn with_strategy( backends: Vec<Arc<dyn StorageBackend>>, strategy: MultiStorageStrategy, ) -> Self

Create with specific strategy

pub fn add_backend(&mut self, backend: Arc<dyn StorageBackend>)

Add a backend

pub fn remove_backend( &mut self, index: usize, ) -> Option<Arc<dyn StorageBackend>>

Remove a backend

pub fn backend_count(&self) -> usize

Get number of backends

Trait Implementations

impl StorageBackend for MultiStorage

fn put_shard<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, cid: &'life1 Cid, shard: &'life2 Shard, ) -> Pin<Box<dyn Future<Output = Result<(), FecError>> + Send + 'async_trait>>

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

Store a shard with the given CID

fn get_shard<'life0, 'life1, 'async_trait>( &'life0 self, cid: &'life1 Cid, ) -> Pin<Box<dyn Future<Output = Result<Shard, FecError>> + Send + 'async_trait>>

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

Retrieve a shard by CID

fn delete_shard<'life0, 'life1, 'async_trait>( &'life0 self, cid: &'life1 Cid, ) -> Pin<Box<dyn Future<Output = Result<(), FecError>> + Send + 'async_trait>>

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

Delete a shard by CID

fn has_shard<'life0, 'life1, 'async_trait>( &'life0 self, cid: &'life1 Cid, ) -> Pin<Box<dyn Future<Output = Result<bool, FecError>> + Send + 'async_trait>>

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

Check if a shard exists

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

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

List all shard CIDs in storage

fn put_metadata<'life0, 'life1, 'async_trait>( &'life0 self, metadata: &'life1 FileMetadata, ) -> Pin<Box<dyn Future<Output = Result<(), FecError>> + Send + 'async_trait>>

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

Store file metadata

fn get_metadata<'life0, 'life1, 'async_trait>( &'life0 self, file_id: &'life1 [u8; 32], ) -> Pin<Box<dyn Future<Output = Result<FileMetadata, FecError>> + Send + 'async_trait>>

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

Retrieve file metadata

fn delete_metadata<'life0, 'life1, 'async_trait>( &'life0 self, file_id: &'life1 [u8; 32], ) -> Pin<Box<dyn Future<Output = Result<(), FecError>> + Send + 'async_trait>>

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

Delete file metadata

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

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

List all file metadata

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

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

Get storage statistics

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

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

Run garbage collection