Struct MemoryStore 

pub struct MemoryStore { /* private fields */ }

In-memory implementation of both Collection and State.

Data is stored in a BTreeMap behind an Arc<RwLock<...>> so it can be shared across clones. All keys in collection mode are prefixed with "<prefix>." to avoid collisions with state-mode entries.

Trait Implementations

impl Clone for MemoryStore

fn clone(&self) -> MemoryStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Collection for MemoryStore

fn last(&self) -> Result<Option<(String, Vec<u8>)>, Error>

Returns the last key-value pair in insertion/sort order, or None if the collection is empty.

fn name(&self) -> &str

Returns the name identifier of this collection.

fn get(&self, key: &str) -> Result<Vec<u8>, Error>

Returns the value stored under key.

fn put(&mut self, key: &str, data: &[u8]) -> Result<(), Error>

Associates data with key, inserting or replacing any previous value.

fn del(&mut self, key: &str) -> Result<(), Error>

Removes the entry for key.

fn purge(&mut self) -> Result<(), Error>

Removes all entries from the collection.

fn iter<'a>( &'a self, reverse: bool, ) -> Result<Box<dyn Iterator<Item = Result<(String, Vec<u8>), Error>> + 'a>, Error>

Returns an iterator over all key-value pairs.

fn get_by_range( &self, from: Option<String>, quantity: isize, ) -> Result<Vec<Vec<u8>>, Error>

Returns at most quantity.abs() values, optionally starting after from.

impl DbManager<MemoryStore, MemoryStore> for MemoryManager

fn create_state(&self, name: &str, prefix: &str) -> Result<MemoryStore, Error>

Creates a single-value state store, typically used to store actor snapshots.

fn stop(&mut self) -> Result<(), Error>

Optional cleanup hook called when the database manager should shut down.

fn create_collection( &self, name: &str, prefix: &str, ) -> Result<MemoryStore, Error>

Creates a new ordered key-value collection, typically used to store events.

impl Default for MemoryStore

fn default() -> MemoryStore

Returns the “default value” for a type.

impl State for MemoryStore

fn name(&self) -> &str

Returns the name identifier of this state storage unit.

fn get(&self) -> Result<Vec<u8>, Error>

Returns the currently stored bytes.

fn put(&mut self, data: &[u8]) -> Result<(), Error>

Stores data as the current value, replacing any previous one.

fn del(&mut self) -> Result<(), Error>

Deletes the current value.

fn purge(&mut self) -> Result<(), Error>

Removes all data from this state store. Succeeds silently if the store is already empty.