Struct ExpressDataCache 

pub struct ExpressDataCache<Client: ObjectClient> { /* private fields */ }

A data cache on S3 Express One Zone that can be shared across Mountpoint instances.

Implementations

impl<Client> ExpressDataCache<Client>

where Client: ObjectClient + Send + Sync + 'static,

pub fn new(client: Client, config: ExpressDataCacheConfig) -> Self

Create a new instance.

pub async fn make_put_object_request<'a>( &self, params: PutObjectSingleParams, object_key: &str, data: impl AsRef<[u8]> + Send + 'a, ) -> Result<(), DataCacheError>

pub async fn verify_cache_valid(&self) -> Result<(), DataCacheError>

Trait Implementations

impl<Client> DataCache for ExpressDataCache<Client>

where Client: ObjectClient + Send + Sync + 'static,

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,

Get block of data from the cache for the given ObjectId and BlockIndex, if available.

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,

Put block of data to the cache for the given ObjectId and BlockIndex.

fn block_size(&self) -> u64

Returns the block size for the data cache.