Struct mithril_persistence::store::adapter::MemoryAdapter

pub struct MemoryAdapter<K, V> { /* private fields */ }

A StoreAdapter that store data in memory.

Implementations

impl<K, V> MemoryAdapter<K, V>

where K: Hash + Eq + Send + Sync + Clone, V: Send + Sync + Clone,

pub fn new(data: Option<Vec<(K, V)>>) -> Result<Self, AdapterError>

MemoryAdapter factory

Trait Implementations

impl<K, V> StoreAdapter for MemoryAdapter<K, V>

where K: Hash + Eq + Send + Sync + Clone, V: Send + Sync + Clone,

type Key = K

The key type

type Record = V

The record type

fn store_record<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, key: &'life1 Self::Key, record: &'life2 Self::Record, ) -> Pin<Box<dyn Future<Output = Result<(), AdapterError>> + Send + 'async_trait>>

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

Store the given record.

fn get_record<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 Self::Key, ) -> Pin<Box<dyn Future<Output = Result<Option<Self::Record>, AdapterError>> + Send + 'async_trait>>

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

Get the record stored using the given key.

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

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

Check if a record exist for the given key.

fn get_last_n_records<'life0, 'async_trait>( &'life0 self, how_many: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<(Self::Key, Self::Record)>, AdapterError>> + Send + 'async_trait>>

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

Get the last n records in the store

fn remove<'life0, 'life1, 'async_trait>( &'life0 mut self, key: &'life1 Self::Key, ) -> Pin<Box<dyn Future<Output = Result<Option<Self::Record>, AdapterError>> + Send + 'async_trait>>

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

remove values from store

fn get_iter<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Iterator<Item = Self::Record> + '_>, AdapterError>> + Send + 'async_trait>>

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

Get an iterator over the stored values, from the latest to the oldest.