Struct LocalStorage 

pub struct LocalStorage { /* private fields */ }

Local filesystem storage implementation Stores shards and metadata on local filesystem with CID-based addressing

Implementations

impl LocalStorage

pub async fn new(base_path: PathBuf) -> Result<Self, FecError>

Create a new local storage backend

Trait Implementations

impl StorageBackend for LocalStorage

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