Struct JournalingKeyValueStore

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

A journaling key-value store.

Implementations

impl<S> JournalingKeyValueStore<S>

pub fn new(store: S) -> Self

Creates a new journaling store.

Trait Implementations

impl<S: Clone> Clone for JournalingKeyValueStore<S>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S> DeletePrefixExpander for &JournalingKeyValueStore<S>

where S: DirectKeyValueStore,

type Error = <S 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<S> ReadableKeyValueStore for JournalingKeyValueStore<S>

where S: ReadableKeyValueStore, S::Error: From<JournalConsistencyError>,

const MAX_KEY_SIZE: usize = S::MAX_KEY_SIZE

The size constant do not change

fn max_stream_queries(&self) -> usize

The read stuff does not change

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<Vec<Vec<u8>>, 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<Vec<(Vec<u8>, Vec<u8>)>, 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 + Sync

Reads a single key and deserializes the result if present.

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

Reads multiple keys and deserializes the results if present.

impl<S> WithError for JournalingKeyValueStore<S>

where S: WithError,

type Error = <S as WithError>::Error

The error type.

impl<S> WritableKeyValueStore for JournalingKeyValueStore<S>

where S: DirectKeyValueStore, S::Error: From<JournalConsistencyError>,

const MAX_VALUE_SIZE: usize = S::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.