Struct InMemoryStore 

pub struct InMemoryStore { /* private fields */ }

In-process, heap-backed implementation of StateStore.

Suitable for testing and single-process use. Backed by a Mutex<HashMap> wrapped in Arc so it is cheaply cloneable across tasks.

Example

use xenith_core::{InMemoryStore, StateStore, StateKey, StateValue, StateVersion, ChainId};
use bytes::Bytes;

let store = InMemoryStore::default();
let key = StateKey::new("proto", "pool", "0x1");
let val = StateValue {
    data: Bytes::new(),
    version: StateVersion { timestamp_ms: 1, sequence: 0, source_chain: 1 },
    updated_at: 0,
    source_chain: ChainId::from(1),
};
store.set(&key, val.clone()).await.unwrap();
assert_eq!(store.get(&key).await.unwrap(), Some(val));

Trait Implementations

impl Clone for InMemoryStore

fn clone(&self) -> InMemoryStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemoryStore

fn default() -> InMemoryStore

Returns the “default value” for a type.

impl StateStore for InMemoryStore

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

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

Retrieve the value for key, or None if it has not been set.

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

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

Insert or overwrite the value for key.

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

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

Remove the value for key. No-op if the key does not exist.

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

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

Return all keys whose string representation starts with prefix.

fn get_metadata<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 StateKey, ) -> Pin<Box<dyn Future<Output = Result<Option<KeyMetadata>>> + Send + 'async_trait>>

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

Retrieve the KeyMetadata for key, or None if not set.

fn set_metadata<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 StateKey, meta: KeyMetadata, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Store KeyMetadata for key.