Struct InMemoryBackend 

pub struct InMemoryBackend { /* private fields */ }

In-memory Backend backed by a HashMap.

Removes the need for filesystem tempdir management in unit tests. The backend is Clone so tests can hold a handle for direct inspection while the service owns a boxed copy.

Implementations

impl InMemoryBackend

pub fn new(name: &'static str) -> Self

Creates a new InMemoryBackend with the given diagnostic name.

pub fn with_change_stream(self, change_stream: Arc<dyn ChangeStream>) -> Self

Publishes this backend’s changes to change_stream.

pub fn get(&self, id: &ObjectId) -> Entry

Returns the stored entry for id, for direct inspection in tests.

pub fn contains(&self, id: &ObjectId) -> bool

Returns true if the backend contains an entry for the given id.

pub fn is_empty(&self) -> bool

Returns true if the backend has no stored objects.

pub fn remove(&self, id: &ObjectId)

Removes an entry directly, bypassing the Backend trait.

Useful for simulating partial failures (e.g. orphan tombstones).

Trait Implementations

impl Backend for InMemoryBackend

fn name(&self) -> &'static str

The backend name, used for diagnostics.

fn as_multipart_upload_backend(&self) -> Result<&dyn MultipartUploadBackend>

Borrows this backend as a MultipartUploadBackend if supported.

fn put_object<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, metadata: &'life2 Metadata, stream: ClientStream, _access_time: Timestamp, ) -> Pin<Box<dyn Future<Output = Result<PutResponse>> + Send + 'async_trait>>

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

Stores an object at the given path with the given metadata.

fn get_object<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 ObjectId, access_time: Timestamp, range: Option<ByteRange>, ) -> Pin<Box<dyn Future<Output = Result<GetResponse>> + Send + 'async_trait>>

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

Retrieves (part of) an object at the given path, returning its metadata, a description of the part being returned, and the payload.

fn set_expiry<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 ObjectId, expire_at: Timestamp, access_time: Timestamp, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Extends the deadline of an existing object with expiration policy.

fn delete_object<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 ObjectId, _access_time: Timestamp, ) -> Pin<Box<dyn Future<Output = Result<DeleteResponse>> + Send + 'async_trait>>

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

Deletes the object at the given path.

fn join<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Waits for any outstanding background operations to complete before shutdown.

fn get_metadata<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 ObjectId, access_time: Timestamp, ) -> Pin<Box<dyn Future<Output = Result<MetadataResponse>> + Send + 'async_trait>>

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

Retrieves only the metadata for an object, without the payload.

fn create_upload_session<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, metadata: &'life2 Metadata, total_length: NonZeroU64, ) -> Pin<Box<dyn Future<Output = Result<Option<BackendToken>>> + Send + 'async_trait>>

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

Creates a resumable upload session for the object at id.

fn put_chunk<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, token: &'life2 BackendToken, offset: u64, content_length: u64, stream: ClientStream, ) -> Pin<Box<dyn Future<Output = Result<UploadProgress>> + Send + 'async_trait>>

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

Writes a chunk of content_length bytes at offset into an open session.

fn upload_offset<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, token: &'life2 BackendToken, ) -> Pin<Box<dyn Future<Output = Result<UploadProgress>> + Send + 'async_trait>>

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

Reports how far the session has progressed.

fn cancel_upload<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, token: &'life2 BackendToken, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Cancels an upload session, discarding whatever was uploaded.

impl Clone for InMemoryBackend

fn clone(&self) -> InMemoryBackend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryBackend

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl HighVolumeBackend for InMemoryBackend

fn put_non_tombstone<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, metadata: &'life2 Metadata, payload: Bytes, access_time: Timestamp, ) -> Pin<Box<dyn Future<Output = Result<Option<Tombstone>>> + Send + 'async_trait>>

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

Writes the object only if NO redirect tombstone exists at this key.

fn get_tiered_object<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 ObjectId, access_time: Timestamp, range: Option<ByteRange>, ) -> Pin<Box<dyn Future<Output = Result<TieredGet>> + Send + 'async_trait>>

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

Retrieves (part of) an object with explicit tombstone awareness.

fn get_tiered_metadata<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 ObjectId, access_time: Timestamp, ) -> Pin<Box<dyn Future<Output = Result<TieredMetadata>> + Send + 'async_trait>>

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

Retrieves only metadata with explicit tombstone awareness.

fn delete_non_tombstone<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 ObjectId, access_time: Timestamp, ) -> Pin<Box<dyn Future<Output = Result<Option<Tombstone>>> + Send + 'async_trait>>

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

Deletes the object only if it is NOT a redirect tombstone.

fn compare_and_update<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, current: Option<&'life2 ObjectId>, update: TieredUpdate, access_time: Timestamp, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Atomically updates an existing row if its kind and redirect target match.

fn compare_and_write<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, current: Option<&'life2 ObjectId>, write: TieredWrite, access_time: Timestamp, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Atomically mutates the row if the current redirect state matches.

impl MultipartUploadBackend for InMemoryBackend

fn initiate_multipart<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, metadata: &'life2 Metadata, ) -> Pin<Box<dyn Future<Output = Result<InitiateMultipartResponse>> + Send + 'async_trait>>

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

Initiates a new multipart upload at id with the given metadata.

fn upload_part<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, id: &'life1 ObjectId, upload_id: &'life2 UploadId, part_number: PartNumber, _content_length: u64, _content_md5: Option<&'life3 str>, body: ClientStream, ) -> Pin<Box<dyn Future<Output = Result<UploadPartResponse>> + Send + 'async_trait>>

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

Uploads a single part of the upload identified by (id, upload_id).

fn list_parts<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, upload_id: &'life2 UploadId, max_parts: Option<u32>, part_number_marker: Option<PartNumber>, ) -> Pin<Box<dyn Future<Output = Result<ListPartsResponse>> + Send + 'async_trait>>

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

Lists the parts uploaded so far for (id, upload_id).

fn abort_multipart<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, upload_id: &'life2 UploadId, ) -> Pin<Box<dyn Future<Output = Result<AbortMultipartResponse>> + Send + 'async_trait>>

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

Aborts the upload identified by (id, upload_id).

fn complete_multipart<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, upload_id: &'life2 UploadId, parts: Vec<CompletedPart>, _access_time: Timestamp, ) -> Pin<Box<dyn Future<Output = Result<CompleteMultipartResponse>> + Send + 'async_trait>>

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

Finalizes the upload identified by (id, upload_id) with the given ordered list of parts.