Struct InMemoryCloudHome 

pub struct InMemoryCloudHome { /* private fields */ }

In-memory CloudHome backed by a HashMap. Thread-safe; cheap to share between simulated devices via Arc.

Implementations

impl InMemoryCloudHome

pub fn new() -> Self

pub fn keys(&self) -> Vec<String>

Snapshot of every key currently in the cloud. Useful for assertions that don’t want to hold the lock across an await.

pub fn get(&self, key: &str) -> Option<Vec<u8>>

Snapshot of the bytes at key, or None if absent. Cloned so the caller can hold the result across await points without retaining the internal lock.

pub fn len(&self) -> usize

Number of objects stored. Cheap snapshot.

pub fn is_empty(&self) -> bool

Returns true if the store is empty.

pub fn deletes_seen(&self) -> Vec<String>

Snapshot of every delete that’s been requested, in arrival order.

Trait Implementations

impl CloudHome for InMemoryCloudHome

fn write<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, data: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<(), CloudHomeError>> + Send + 'async_trait>>

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

Write bytes to a key, creating or overwriting.

fn read<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, CloudHomeError>> + Send + 'async_trait>>

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

Read the full contents of a key.

fn read_range<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, start: u64, end: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, CloudHomeError>> + Send + 'async_trait>>

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

Read a byte range from a key. start is inclusive, end is exclusive.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, CloudHomeError>> + Send + 'async_trait>>

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

List all keys under a prefix.

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

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

Delete a key. Not an error if the key does not exist.

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

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

Check whether a key exists.

fn grant_access<'life0, 'life1, 'async_trait>( &'life0 self, _member_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<CloudHomeJoinInfo, CloudHomeError>> + Send + 'async_trait>>

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

Grant access to a member and return connection info for the cloud home. For S3 this ignores member_id and returns bucket/region/endpoint (access is managed externally via IAM/pre-shared credentials). For consumer clouds this shares the folder with the member’s account.

fn revoke_access<'life0, 'life1, 'async_trait>( &'life0 self, _member_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CloudHomeError>> + Send + 'async_trait>>

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

Revoke a previously granted access. No-op for backends where access is controlled externally (e.g. S3 with pre-shared credentials).

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

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

Verify the backend is reachable with the configured credentials. Setup flows call this before persisting credentials, so a typo or missing bucket fails fast at setup time instead of via a delayed reconnect banner. Default implementation issues a no-op list against a sentinel prefix — backends override with cheaper provider-specific auth checks (e.g. S3 HeadBucket) where available.

impl Default for InMemoryCloudHome

fn default() -> Self

Returns the “default value” for a type.