Struct linera_views::backends::memory::MemoryStore

pub struct MemoryStore { /* private fields */ }

A virtual DB client where data are persisted in memory.

Implementations

impl MemoryStore

pub fn new( max_stream_queries: usize, namespace: &str, root_key: &[u8], ) -> Result<Self, MemoryStoreError>

Creates a MemoryStore from a number of queries and a namespace.

pub fn new_for_testing( max_stream_queries: usize, namespace: &str, root_key: &[u8], ) -> Result<Self, MemoryStoreError>

Creates a MemoryStore from a number of queries and a namespace for testing.

Trait Implementations

impl AdminKeyValueStore for MemoryStore

type Config = MemoryStoreConfig

The configuration needed to interact with a new store.

fn get_name() -> String

The name of this class of stores

async fn connect( config: &Self::Config, namespace: &str, root_key: &[u8], ) -> Result<Self, MemoryStoreError>

Connects to an existing namespace using the given configuration.

fn clone_with_root_key(&self, root_key: &[u8]) -> Result<Self, MemoryStoreError>

Takes a connection and creates a new one with a different root_key.

async fn list_all( _config: &Self::Config, ) -> Result<Vec<String>, MemoryStoreError>

Obtains the list of existing namespaces.

async fn list_root_keys( _config: &Self::Config, namespace: &str, ) -> Result<Vec<Vec<u8>>, MemoryStoreError>

Lists the root keys of the namespace. It is possible that some root keys have no keys.

async fn exists( _config: &Self::Config, namespace: &str, ) -> Result<bool, MemoryStoreError>

Tests if a given namespace exists.

async fn create( _config: &Self::Config, namespace: &str, ) -> Result<(), MemoryStoreError>

Creates a namespace. Returns an error if the namespace exists.

async fn delete( _config: &Self::Config, namespace: &str, ) -> Result<(), MemoryStoreError>

Deletes the given namespace.

fn delete_all( config: &Self::Config, ) -> impl Future<Output = Result<(), Self::Error>> + Send

Deletes all the existing namespaces.

fn maybe_create_and_connect( config: &Self::Config, namespace: &str, root_key: &[u8], ) -> impl Future<Output = Result<Self, Self::Error>> + Send

Initializes a storage if missing and provides it.

fn recreate_and_connect( config: &Self::Config, namespace: &str, root_key: &[u8], ) -> impl Future<Output = Result<Self, Self::Error>> + Send

Creates a new storage. Overwrites it if this namespace already exists.

impl Clone for MemoryStore

fn clone(&self) -> MemoryStore

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Drop for MemoryStore

fn drop(&mut self)

Executes the destructor for this type.

impl ReadableKeyValueStore for MemoryStore

const MAX_KEY_SIZE: usize = 18_446_744_073_709_551_615usize

The maximal size of keys that can be stored.

type Keys = Vec<Vec<u8>>

Returns type for key search operations.

type KeyValues = Vec<(Vec<u8>, Vec<u8>)>

Returns type for key-value search operations.

fn max_stream_queries(&self) -> usize

Retrieve the number of stream queries.

async fn read_value_bytes( &self, key: &[u8], ) -> Result<Option<Vec<u8>>, MemoryStoreError>

Retrieves a Vec<u8> from the database using the provided key.

async fn contains_key(&self, key: &[u8]) -> Result<bool, MemoryStoreError>

Tests whether a key exists in the database

async fn contains_keys( &self, keys: Vec<Vec<u8>>, ) -> Result<Vec<bool>, MemoryStoreError>

Tests whether a list of keys exist in the database

async fn read_multi_values_bytes( &self, keys: Vec<Vec<u8>>, ) -> Result<Vec<Option<Vec<u8>>>, MemoryStoreError>

Retrieves multiple Vec<u8> from the database using the provided keys.

async fn find_keys_by_prefix( &self, key_prefix: &[u8], ) -> Result<Vec<Vec<u8>>, MemoryStoreError>

Finds the key matching the prefix. The prefix is not included in the returned keys.

async fn find_key_values_by_prefix( &self, key_prefix: &[u8], ) -> Result<Vec<(Vec<u8>, Vec<u8>)>, MemoryStoreError>

Finds the (key,value) pairs matching the prefix. The prefix is not included in the returned keys.

fn read_value<V: DeserializeOwned>( &self, key: &[u8], ) -> impl Future<Output = Result<Option<V>, Self::Error>> + Send

where Self: Sync,

Reads a single key and deserializes the result if present.

fn read_multi_values<V: DeserializeOwned + Send>( &self, keys: Vec<Vec<u8>>, ) -> impl Future<Output = Result<Vec<Option<V>>, Self::Error>> + Send

where Self: Sync,

Reads multiple keys and deserializes the results if present.

impl TestKeyValueStore for MemoryStore

async fn new_test_config() -> Result<MemoryStoreConfig, MemoryStoreError>

Obtains a test config

fn new_test_store() -> impl Future<Output = Result<Self, Self::Error>> + Send

Creates a store for testing purposes

impl WithError for MemoryStore

type Error = MemoryStoreError

The error type.

impl WritableKeyValueStore for MemoryStore

const MAX_VALUE_SIZE: usize = 18_446_744_073_709_551_615usize

The maximal size of values that can be stored.

async fn write_batch(&self, batch: Batch) -> Result<(), MemoryStoreError>

Writes the batch in the database.

async fn clear_journal(&self) -> Result<(), MemoryStoreError>

Clears any journal entry that may remain. The journal is located at the root_key.