Struct StorageService

pub struct StorageService<S: StoreParams> { /* private fields */ }

Implementations

impl<S: StoreParams> StorageService<S>

where Ipld: Decode<S::Codecs>,

pub fn open( config: &Config, cache_size: usize, sweep_interval: Option<Duration>, ) -> Result<Self>

pub fn atime(&self) -> u64

pub async fn evict(&self, grace_atime: u64) -> Result<()>

pub async fn flush(&self) -> Result<()>

pub fn iter(&self) -> impl Iterator<Item = Result<Cid>>

Trait Implementations

impl<S: StoreParams> Storage<S> for StorageService<S>

where Ipld: Decode<S::Codecs>,

type Subscription = Subscription

fn contains(&self, cid: &Cid) -> Result<bool>

fn get(&self, cid: &Cid) -> Result<Option<Vec<u8>>>

fn insert(&self, block: &Block<S>) -> Result<()>

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

where T: 'async_trait + AsRef<[u8]> + Send + Sync, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn resolve<T: AsRef<[u8]> + Send + Sync>(&self, alias: T) -> Result<Option<Cid>>

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

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

fn subscribe(&self) -> Self::Subscription