Struct MockStorage 

pub struct MockStorage { /* private fields */ }

Storage wrapper that delegates to MemoryStorage but can return configurable errors for specific keys.

Error injection is useful for testing SDK retry logic, cache behaviour, and error propagation without a running server.

Note: The error map uses Key directly (no collection prefix) because the StorageEngine trait does not have a collection concept — collections are resolved in the gRPC service layer above storage.

Implementations

impl MockStorage

pub fn new() -> Self

Create a new MockStorage wrapping a fresh MemoryStorage.

pub async fn insert( &self, key: impl Into<Key>, value: CipherBlob, ) -> CoreResult<()>

Pre-populate a key with a value.

Prefer MockServerBuilder::with_value for pre-start setup; this method works at any time once you have a handle to the storage.

Errors

Propagates errors from the underlying MemoryStorage::put.

pub fn inject_error(&self, key: impl Into<Key>, err: AmateRSError)

Configure an error to be returned for the given key.

All subsequent get, put, and delete calls for key will return this error instead of delegating to the inner storage.

pub fn clear_error(&self, key: impl Into<Key>)

Remove an injected error for key, restoring normal behaviour.

pub async fn get_all(&self) -> CoreResult<Vec<(Key, CipherBlob)>>

Snapshot all key→value pairs currently in the backing store.

Trait Implementations

impl Clone for MockStorage

fn clone(&self) -> MockStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MockStorage

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

Formats the value using the given formatter.

impl Default for MockStorage

fn default() -> Self

Returns the “default value” for a type.

impl StorageEngine for MockStorage

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 Key, value: &'life2 CipherBlob, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

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

Write data with fsync guarantee

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 Key, ) -> Pin<Box<dyn Future<Output = CoreResult<Option<CipherBlob>>> + Send + 'async_trait>>

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

Read data, returns None if key doesn’t exist

fn atomic_update<'life0, 'life1, 'async_trait, F>( &'life0 self, key: &'life1 Key, f: F, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

where F: Fn(&CipherBlob) -> CoreResult<CipherBlob> + Send + Sync + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Atomic update operation (Read-Modify-Write)

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 Key, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

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

Delete a key

fn range<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, start: &'life1 Key, end: &'life2 Key, ) -> Pin<Box<dyn Future<Output = CoreResult<Vec<(Key, CipherBlob)>>> + Send + 'async_trait>>

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

Range scan from start (inclusive) to end (exclusive)

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

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

Get all keys in the storage (for debugging/admin)

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

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

Flush all pending writes to disk

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

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

Close the storage engine gracefully

fn contains<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 Key, ) -> Pin<Box<dyn Future<Output = Result<bool, AmateRSError>> + Send + 'async_trait>>

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

Check if a key exists