Struct StorageServiceStoreInternal 

pub struct StorageServiceStoreInternal { /* private fields */ }

A store within a namespace and root key, backed by a remote storage service.

Trait Implementations

impl Clone for StorageServiceStoreInternal

fn clone(&self) -> StorageServiceStoreInternal

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ReadableKeyValueStore for StorageServiceStoreInternal

const MAX_KEY_SIZE: usize = MAX_KEY_SIZE

The maximal size of keys that can be stored.

fn max_stream_queries(&self) -> usize

Retrieve the number of stream queries.

fn root_key(&self) -> Result<Vec<u8>, StorageServiceStoreError>

Gets the root key of the store.

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

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

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

Tests whether a key exists in the database

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

Tests whether a list of keys exist in the database

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

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

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>)>, StorageServiceStoreError>

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

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

where V: DeserializeOwned,

Reads a single key and deserializes the result if present.

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

where V: DeserializeOwned + Send + Sync,

Reads multiple keys and deserializes the results if present.

impl WithError for StorageServiceStoreInternal

type Error = StorageServiceStoreError

The error type.

impl WritableKeyValueStore for StorageServiceStoreInternal

const MAX_VALUE_SIZE: usize = usize::MAX

The maximal size of values that can be stored.

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

Writes the batch in the database.

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

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