Struct CachedObjectStore 

pub struct CachedObjectStore<S> { /* private fields */ }

Async immutable-object accelerator over any conforming backend.

Implementations

impl<S> CachedObjectStore<S>

pub fn new( inner: S, options: ObjectCacheOptions, ) -> Result<Self, ObjectCacheConfigError>

Wraps one backend with an independently bounded disposable cache.

Errors

Rejects a zero bound.

pub const fn inner(&self) -> &S

Returns the wrapped correctness backend.

pub fn stats(&self) -> Result<ObjectCacheStats, ObjectStoreError>

Returns exact current and cumulative accelerator observations.

Errors

Fails closed if accelerator state was poisoned.

pub fn clear(&self) -> Result<(), ObjectStoreError>

Discards every resident byte. In-flight reads remain valid and may repopulate after this call.

Errors

Fails closed if accelerator state was poisoned.

Trait Implementations

impl<S: AsyncObjectStore> AsyncObjectStore for CachedObjectStore<S>

fn decoded_cache_get( &self, key: DecodedCacheKey, ) -> Result<Option<DecodedCacheValue>, ObjectStoreError>

Returns one exact decoded immutable representation when resident.

fn decoded_cache_admit( &self, key: DecodedCacheKey, value: DecodedCacheValue, ) -> Result<DecodedCacheAdmission, ObjectStoreError>

Offers one authenticated decoded representation to a disposable cache.

async fn put( &self, object_id: ObjectId, bytes: Bytes, budget: WorkBudget, cancellation: &CancellationToken, ) -> ObjectResult<()>

Asynchronously admits one verified immutable object.

async fn put_many( &self, writes: &[ObjectWrite], budget: WorkBudget, cancellation: &CancellationToken, ) -> ObjectResult<()>

Asynchronously admits an ordered bounded group of verified immutable objects.

async fn read( &self, object_id: ObjectId, maximum_bytes: u64, budget: WorkBudget, cancellation: &CancellationToken, ) -> ObjectResult<ObjectRead>

Asynchronously reads one complete bounded object.

async fn read_many( &self, requests: &[ObjectReadRequest], budget: WorkBudget, cancellation: &CancellationToken, ) -> ObjectResult<Vec<ObjectRead>>

Asynchronously reads an ordered batch of complete bounded objects.

async fn contains( &self, object_id: ObjectId, budget: WorkBudget, cancellation: &CancellationToken, ) -> ObjectResult<bool>

Asynchronously probes one exact object identity.

fn flush_before_publish( &self, _budget: WorkBudget, _cancellation: &CancellationToken, ) -> impl Future<Output = ObjectResult<()>> + StorageFuture

Makes every previously admitted immutable object crash-durable before an authority record may reference it. Ordinary stores already provide that guarantee from put/put_many; a bounded staging adapter overrides this boundary to group physical writes without changing publication.

impl<S: Clone> Clone for CachedObjectStore<S>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.