Struct SimulatedObjectStore 

pub struct SimulatedObjectStore<O = ProviderObjectStore<MemoryObjects>> { /* private fields */ }

Immutable-object backend handle controlled by one Simulation.

Trait Implementations

impl<O: AsyncObjectStore> AsyncObjectStore for SimulatedObjectStore<O>

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 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.

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<O: Clone> Clone for SimulatedObjectStore<O>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.