Struct CachedPeerStorage 

pub struct CachedPeerStorage { /* private fields */ }

Storage decorator that caches blob reads while always delegating roots.

Implementations

impl CachedPeerStorage

pub fn open( storage: Arc<dyn PeerStorage>, config: &SegmentCacheConfig, ) -> Result<Self>

Opens a cache around peer storage.

Errors

Returns an error for invalid configuration, inaccessible storage, or an already-owned cache directory.

pub fn metrics(&self) -> Arc<SegmentCacheMetrics>

Returns cache counters for a metrics adapter.

Trait Implementations

impl PeerStorage for CachedPeerStorage

fn get_blob<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 BlobId, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, StoreError>> + Send + 'async_trait>>

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

Loads one immutable blob.

fn get_peer_root<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, StoreError>> + Send + 'async_trait>>

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

Loads one named root record.

impl SegmentReader for CachedPeerStorage

fn read_segment<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 BlobId, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, StoreError>> + Send + 'async_trait>>

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

Reads an immutable segment from authoritative storage.