Struct MemoryRepository 

pub struct MemoryRepository<V: RepositoryItem> {
    store: Mutex<HashMap<String, V>>,
}

A simple in-memory repository implementation. The data is only stored in memory and will not persist beyond the lifetime of the repository instance.

Primary use case is for unit and integration tests.

Fields

store: Mutex<HashMap<String, V>>

Trait Implementations

impl<V: RepositoryItem + Clone> Default for MemoryRepository<V>

fn default() -> Self

Returns the “default value” for a type.

impl<V: RepositoryItem + Clone> Repository<V> for MemoryRepository<V>

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

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

Retrieves an item from the repository by its key.

fn list<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<V>, RepositoryError>> + Send + 'async_trait>>

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

Lists all items in the repository.

fn set<'life0, 'async_trait>( &'life0 self, key: V::Key, value: V, ) -> Pin<Box<dyn Future<Output = Result<(), RepositoryError>> + Send + 'async_trait>>

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

Sets an item in the repository with the specified key.

fn set_bulk<'life0, 'async_trait>( &'life0 self, values: Vec<(V::Key, V)>, ) -> Pin<Box<dyn Future<Output = Result<(), RepositoryError>> + Send + 'async_trait>>

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

Sets multiple items in the repository.

fn remove<'life0, 'async_trait>( &'life0 self, key: V::Key, ) -> Pin<Box<dyn Future<Output = Result<(), RepositoryError>> + Send + 'async_trait>>

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

Removes an item from the repository by its key.

fn remove_bulk<'life0, 'async_trait>( &'life0 self, keys: Vec<V::Key>, ) -> Pin<Box<dyn Future<Output = Result<(), RepositoryError>> + Send + 'async_trait>>

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

Removes multiple items from the repository by their keys.

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

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

Removes all items from the repository.

fn replace_all<'life0, 'async_trait>( &'life0 self, values: Vec<(<V as RepositoryItem>::Key, V)>, ) -> Pin<Box<dyn Future<Output = Result<(), RepositoryError>> + Send + 'async_trait>>

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

Replaces all items in the repository with the provided values. This is a convenience method that first removes all existing items and then sets the new items in bulk.