Struct MemoryObjects 

pub struct MemoryObjects { /* private fields */ }

Bounded deterministic process-local reference provider.

Acknowledged state is ephemeral and has no isolation, durability, distribution, or production availability claim.

Implementations

impl MemoryObjects

pub async fn bucket_named( &self, name: &str, ) -> Result<Option<BucketRef>, ObjectsError>

Resolves a bucket by its canonical name without mutating provider state.

pub fn with_default_bucket() -> (Self, BucketRef)

Creates the default bounded reference provider with one deterministic bucket.

pub fn new(maximum_bytes: u64) -> Result<Self, ObjectsError>

Creates an empty reference provider with an explicit aggregate byte ceiling.

Errors

Rejects zero or process-unrepresentable limits before allocating provider state.

pub fn with_bucket( name: impl Into<String>, maximum_bytes: u64, ) -> Result<(Self, BucketRef), ObjectsError>

Creates a bounded provider with one deterministic bucket already admitted.

This synchronous constructor lets another in-process SDK family compose the exact public reference provider without running an executor merely to establish its private bucket.

Errors

Rejects an invalid bucket name or memory ceiling.

pub fn with_bucket_limits( name: impl Into<String>, maximum_object_bytes: u64, maximum_bytes: u64, ) -> Result<(Self, BucketRef), ObjectsError>

Creates one deterministic bucket with independent per-object and aggregate bounds.

Errors

Rejects an invalid bucket name, zero limits, a per-object limit larger than the aggregate limit, or limits that cannot be represented by this process.

Trait Implementations

impl Clone for MemoryObjects

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MemoryObjects

fn default() -> Self

Returns the “default value” for a type.

impl ObjectsProvider for MemoryObjects

fn create_bucket<'life0, 'async_trait>( &'life0 self, name: String, idempotency_key: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<Bucket, ObjectsError>> + Send + 'async_trait>>

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

Create one permanently versioned bucket.

fn head_bucket<'life0, 'life1, 'async_trait>( &'life0 self, bucket: &'life1 BucketRef, ) -> Pin<Box<dyn Future<Output = Result<Bucket, ObjectsError>> + Send + 'async_trait>>

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

Resolve one exact bucket identity.

fn delete_bucket<'life0, 'life1, 'async_trait>( &'life0 self, bucket: &'life1 BucketRef, idempotency_key: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<bool, ObjectsError>> + Send + 'async_trait>>

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

Delete one empty exact bucket identity.

fn put<'life0, 'async_trait>( &'life0 self, request: PutRequest, ) -> Pin<Box<dyn Future<Output = Result<ObjectVersion, ObjectsError>> + Send + 'async_trait>>

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

Create one immutable version.

fn get<'life0, 'async_trait>( &'life0 self, request: GetRequest, ) -> Pin<Box<dyn Future<Output = Result<BufferedObject, ObjectsError>> + Send + 'async_trait>>

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

Read one immutable version or its visible current selection.

fn get_batch<'life0, 'async_trait>( &'life0 self, requests: Vec<GetRequest>, ) -> Pin<Box<dyn Future<Output = Vec<Result<BufferedObject, ObjectsError>>> + Send + 'async_trait>>

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

Reads an ordered bounded group of immutable versions.

fn delete<'life0, 'async_trait>( &'life0 self, bucket: BucketRef, object_key: String, version_id: Option<String>, condition: Option<Condition>, idempotency_key: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<DeleteResult, ObjectsError>> + Send + 'async_trait>>

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

Create a delete marker or delete one exact version.

fn list<'life0, 'async_trait>( &'life0 self, target: ReadTarget, prefix: String, delimiter: Option<String>, versions: bool, page_size: u32, continuation: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<ProviderListPage, ObjectsError>> + Send + 'async_trait>>

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

Capture or continue one stable listing.

fn snapshot<'life0, 'async_trait>( &'life0 self, bucket: BucketRef, idempotency_key: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<Snapshot, ObjectsError>> + Send + 'async_trait>>

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

Atomically capture an immutable whole-bucket snapshot.

fn destroy_snapshot<'life0, 'async_trait>( &'life0 self, snapshot: SnapshotRef, idempotency_key: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<bool, ObjectsError>> + Send + 'async_trait>>

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

Destroy one exact snapshot identity.

fn fork<'life0, 'async_trait>( &'life0 self, source: ReadTarget, destination_name: String, idempotency_key: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<Bucket, ObjectsError>> + Send + 'async_trait>>

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

Atomically fork a whole bucket or snapshot into an independent bucket.

fn create_multipart<'life0, 'async_trait>( &'life0 self, bucket: BucketRef, object_key: String, metadata: ObjectMetadata, condition: Option<Condition>, idempotency_key: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<MultipartUpload, ObjectsError>> + Send + 'async_trait>>

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

Create one multipart upload without publishing a version.

fn upload_part<'life0, 'async_trait>( &'life0 self, bucket: BucketRef, object_key: String, upload_id: String, part_number: u32, body: Bytes, idempotency_key: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<UploadedPart, ObjectsError>> + Send + 'async_trait>>

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

Upload or replace one exact staged part.

fn list_parts<'life0, 'async_trait>( &'life0 self, bucket: BucketRef, object_key: String, upload_id: String, ) -> Pin<Box<dyn Future<Output = Result<Vec<UploadedPart>, ObjectsError>> + Send + 'async_trait>>

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

List staged parts in ascending part-number order.

fn complete_multipart<'life0, 'async_trait>( &'life0 self, bucket: BucketRef, object_key: String, upload_id: String, parts: Vec<UploadedPart>, idempotency_key: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<ObjectVersion, ObjectsError>> + Send + 'async_trait>>

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

Atomically publish a version from exact staged part receipts.

fn abort_multipart<'life0, 'async_trait>( &'life0 self, bucket: BucketRef, object_key: String, upload_id: String, idempotency_key: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<bool, ObjectsError>> + Send + 'async_trait>>

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

Abort one exact staged upload.

fn put_batch<'life0, 'async_trait>( &'life0 self, requests: Vec<PutRequest>, ) -> Pin<Box<dyn Future<Output = Vec<Result<ObjectVersion, ObjectsError>>> + Send + 'async_trait>>

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

Creates an ordered bounded group of immutable versions.