Struct MultilevelDataCache 

pub struct MultilevelDataCache<DiskCache, ExpressCache> { /* private fields */ }

A data cache which uses both the local disk and S3 Express One Zone bucket as a storage.

Implementations

impl<DiskCache: DataCache, ExpressCache: DataCache> MultilevelDataCache<DiskCache, ExpressCache>

pub fn new( disk_cache: Arc<DiskCache>, express_cache: ExpressCache, runtime: Runtime, ) -> Self

Both the disk_cache and express_cache must be configured with the same block_size.

Trait Implementations

impl<DiskCache, ExpressCache> DataCache for MultilevelDataCache<DiskCache, ExpressCache>

where DiskCache: DataCache + Sync + Send + 'static, ExpressCache: DataCache + Sync,

fn get_block<'life0, 'life1, 'async_trait>( &'life0 self, cache_key: &'life1 ObjectId, block_idx: BlockIndex, block_offset: u64, object_size: usize, ) -> Pin<Box<dyn Future<Output = DataCacheResult<Option<ChecksummedBytes>>> + Send + 'async_trait>>

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

Gets a block from one of the underlying caches. Populates the disk cache with data fetched from the S3 Express cache.

fn put_block<'life0, 'async_trait>( &'life0 self, cache_key: ObjectId, block_idx: BlockIndex, block_offset: u64, bytes: ChecksummedBytes, object_size: usize, ) -> Pin<Box<dyn Future<Output = DataCacheResult<()>> + Send + 'async_trait>>

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

Puts a block to both caches.

fn block_size(&self) -> u64

Returns the block size for the data cache.