Struct DynamoDbStoreInternal

pub struct DynamoDbStoreInternal { /* private fields */ }

A DynamoDB client.

Trait Implementations

impl AdminKeyValueStore for DynamoDbStoreInternal

type Config = DynamoDbStoreInternalConfig

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, ) -> Result<Self, DynamoDbStoreInternalError>

Connects to an existing namespace using the given configuration.

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

Opens the key partition starting at root_key and returns a clone of the connection to work in this partition.

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

Obtains the list of existing namespaces.

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

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<(), DynamoDbStoreInternalError>

Deletes all the existing namespaces.

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

Tests if a given namespace exists.

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

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

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

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 Clone for DynamoDbStoreInternal

fn clone(&self) -> DynamoDbStoreInternal

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DynamoDbStoreInternal

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl DirectWritableKeyValueStore for DynamoDbStoreInternal

const MAX_BATCH_SIZE: usize = 100usize

The maximal number of items in a batch.

const MAX_BATCH_TOTAL_SIZE: usize = 4_000_000usize

The maximal number of bytes of a batch.

const MAX_VALUE_SIZE: usize = 408_569usize

The maximal size of values that can be stored.

type Batch = SimpleUnorderedBatch

The batch type.

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

Writes the batch to the database.

impl ReadableKeyValueStore for DynamoDbStoreInternal

const MAX_KEY_SIZE: usize = 1_024usize

The maximal size of keys that can be stored.

type Keys = DynamoDbKeys

Returns type for key search operations.

type KeyValues = DynamoDbKeyValues

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>>, DynamoDbStoreInternalError>

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

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

Tests whether a key exists in the database

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

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>>>, DynamoDbStoreInternalError>

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

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

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<DynamoDbKeyValues, DynamoDbStoreInternalError>

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 WithError for DynamoDbStoreInternal

type Error = DynamoDbStoreInternalError

The error type.