Struct JournalingKeyValueDatabase 

pub struct JournalingKeyValueDatabase<D> { /* private fields */ }

A journaling key-value database.

Trait Implementations

impl<D: Clone> Clone for JournalingKeyValueDatabase<D>

fn clone(&self) -> JournalingKeyValueDatabase<D>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<D> KeyValueDatabase for JournalingKeyValueDatabase<D>

where D: KeyValueDatabase, D::Error: 'static,

type Config = <D as KeyValueDatabase>::Config

The configuration needed to interact with a new backend.

type Store = JournalingKeyValueStore<<D as KeyValueDatabase>::Store>

The result of opening a partition.

fn get_name() -> String

The name of this database.

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

Connects to an existing namespace using the given configuration.

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

Opens a shared partition starting at root_key. It is understood that the partition MAY be read and written simultaneously from other clients.

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

Opens an exclusive partition starting at root_key. It is assumed that the partition WILL NOT be read and written simultaneously by other clients.

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

Obtains the list of existing namespaces.

async fn list_root_keys(&self) -> 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, ) -> impl Future<Output = Result<Self, Self::Error>> + Send + Sync

Initializes a storage if missing and provides it.

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

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

impl TestKeyValueDatabase for JournalingKeyValueDatabase<ScyllaDbDatabaseInternal>

Available on with_testing only.

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

Obtains a test config

async fn connect_test_namespace() -> Result<Self, Self::Error>

Creates a database for testing purposes

async fn new_test_store() -> Result<Self::Store, Self::Error>

Creates a store for testing purposes

impl<D> WithError for JournalingKeyValueDatabase<D>

where D: WithError, D::Error: 'static,

type Error = JournalingError<<D as WithError>::Error>

The error type.