Struct linera_views::backends::journaling::JournalingKeyValueStore

pub struct JournalingKeyValueStore<K> { /* private fields */ }

A journaling Key Value Store built from an inner DirectKeyValueStore.

Implementations

impl<K> JournalingKeyValueStore<K>

pub fn new(store: K) -> Self

Creates a new journaling store.

Trait Implementations

impl<K> AdminKeyValueStore for JournalingKeyValueStore<K>

where K: AdminKeyValueStore + Send + Sync,

type Config = <K as AdminKeyValueStore>::Config

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, Self::Error>

Connects to an existing namespace using the given configuration.

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

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

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

Obtains the list of existing namespaces.

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

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

async fn delete_all(config: &Self::Config) -> Result<(), Self::Error>

Deletes all the existing namespaces.

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

Tests if a given namespace exists.

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

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

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

Deletes the given namespace.

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<K: Clone> Clone for JournalingKeyValueStore<K>

fn clone(&self) -> JournalingKeyValueStore<K>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<K> DeletePrefixExpander for &JournalingKeyValueStore<K>

where K: DirectKeyValueStore + Send + Sync,

type Error = <K as WithError>::Error

The error type that can happen when expanding the key prefix.

async fn expand_delete_prefix( &self, key_prefix: &[u8], ) -> Result<Vec<Vec<u8>>, Self::Error>

Returns the list of keys to be appended to the list.

impl<K> ReadableKeyValueStore for JournalingKeyValueStore<K>

where K: ReadableKeyValueStore + Send + Sync, K::Error: From<JournalConsistencyError>,

const MAX_KEY_SIZE: usize = K::MAX_KEY_SIZE

The size constant do not change

type Keys = <K as ReadableKeyValueStore>::Keys

The basic types do not change

fn max_stream_queries(&self) -> usize

The read stuff does not change

type KeyValues = <K as ReadableKeyValueStore>::KeyValues

Returns type for key-value search operations.

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

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

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

Tests whether a key exists in the database

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

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>>>, Self::Error>

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

async fn find_keys_by_prefix( &self, key_prefix: &[u8], ) -> Result<Self::Keys, Self::Error>

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<Self::KeyValues, Self::Error>

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 JournalingKeyValueStore<DynamoDbStoreInternal>

async fn new_test_config() -> Result<DynamoDbStoreInternalConfig, DynamoDbStoreInternalError>

Obtains a test config

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

Creates a store for testing purposes

impl TestKeyValueStore for JournalingKeyValueStore<ScyllaDbStoreInternal>

async fn new_test_config() -> Result<ScyllaDbStoreInternalConfig, ScyllaDbStoreInternalError>

Obtains a test config

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

Creates a store for testing purposes

impl<K> WithError for JournalingKeyValueStore<K>

where K: WithError,

type Error = <K as WithError>::Error

The error type.

impl<K> WritableKeyValueStore for JournalingKeyValueStore<K>

where K: DirectKeyValueStore + Send + Sync, K::Error: From<JournalConsistencyError>,

const MAX_VALUE_SIZE: usize = K::MAX_VALUE_SIZE

The size constant do not change

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

Writes the batch in the database.

async fn clear_journal(&self) -> Result<(), Self::Error>

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