Enum TransactionStore 

#[repr(u8)]
pub enum TransactionStore {
    Standard(StandardTransactionStore),
}

Variants

Standard(StandardTransactionStore)

Implementations

impl TransactionStore

pub fn standard(config: TransactionStoreConfig) -> TransactionStore

impl TransactionStore

pub async fn testing_memory() -> TransactionStore

pub fn stats_tracker(&self) -> &StorageTracker

Get access to the storage tracker.

Trait Implementations

impl CdcCount for TransactionStore

fn count<'life0, 'async_trait>( &'life0 self, version: CommitVersion, ) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, TransactionStore: 'async_trait,

impl CdcGet for TransactionStore

fn get<'life0, 'async_trait>( &'life0 self, version: CommitVersion, ) -> Pin<Box<dyn Future<Output = Result<Option<Cdc>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, TransactionStore: 'async_trait,

impl CdcRange for TransactionStore

fn range_batch<'life0, 'async_trait>( &'life0 self, start: Bound<CommitVersion>, end: Bound<CommitVersion>, batch_size: u64, ) -> Pin<Box<dyn Future<Output = Result<CdcBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, TransactionStore: 'async_trait,

Fetch a batch of CDC entries in version order (ascending).

fn range<'life0, 'async_trait>( &'life0 self, start: Bound<CommitVersion>, end: Bound<CommitVersion>, ) -> Pin<Box<dyn Future<Output = Result<CdcBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Convenience method with default batch size.

fn scan<'life0, 'async_trait>( &'life0 self, batch_size: u64, ) -> Pin<Box<dyn Future<Output = Result<CdcBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Scan all CDC entries.

impl Clone for TransactionStore

fn clone(&self) -> TransactionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl MultiVersionCommit for TransactionStore

fn commit<'life0, 'async_trait>( &'life0 self, deltas: CowVec<Delta>, version: CommitVersion, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, TransactionStore: 'async_trait,

Commit a batch of deltas at the given version.

impl MultiVersionContains for TransactionStore

fn contains<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 EncodedKey, version: CommitVersion, ) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, TransactionStore: 'async_trait,

Check if a key exists at a specific version.

impl MultiVersionGet for TransactionStore

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 EncodedKey, version: CommitVersion, ) -> Pin<Box<dyn Future<Output = Result<Option<MultiVersionValues>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, TransactionStore: 'async_trait,

Get the value for a key at a specific version.

impl MultiVersionRange for TransactionStore

fn range_batch<'life0, 'async_trait>( &'life0 self, range: EncodedKeyRange, version: CommitVersion, batch_size: u64, ) -> Pin<Box<dyn Future<Output = Result<MultiVersionBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, TransactionStore: 'async_trait,

Fetch a batch of values in key order (ascending).

fn range<'life0, 'async_trait>( &'life0 self, range: EncodedKeyRange, version: CommitVersion, ) -> Pin<Box<dyn Future<Output = Result<MultiVersionBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Convenience method with default batch size.

fn prefix<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 EncodedKey, version: CommitVersion, ) -> Pin<Box<dyn Future<Output = Result<MultiVersionBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Range query with prefix.

impl MultiVersionRangeRev for TransactionStore

fn range_rev_batch<'life0, 'async_trait>( &'life0 self, range: EncodedKeyRange, version: CommitVersion, batch_size: u64, ) -> Pin<Box<dyn Future<Output = Result<MultiVersionBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, TransactionStore: 'async_trait,

Fetch a batch of values in reverse key order (descending).

fn range_rev<'life0, 'async_trait>( &'life0 self, range: EncodedKeyRange, version: CommitVersion, ) -> Pin<Box<dyn Future<Output = Result<MultiVersionBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Convenience method with default batch size.

fn prefix_rev<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 EncodedKey, version: CommitVersion, ) -> Pin<Box<dyn Future<Output = Result<MultiVersionBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Reverse range query with prefix.

impl SingleVersionCommit for TransactionStore

fn commit<'life0, 'async_trait>( &'life0 mut self, deltas: CowVec<Delta>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, TransactionStore: 'async_trait,

Commit a batch of deltas.

impl SingleVersionContains for TransactionStore

fn contains<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 EncodedKey, ) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, TransactionStore: 'async_trait,

Check if a key exists.

impl SingleVersionGet for TransactionStore

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 EncodedKey, ) -> Pin<Box<dyn Future<Output = Result<Option<SingleVersionValues>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, TransactionStore: 'async_trait,

Get the value for a key.

impl SingleVersionRange for TransactionStore

fn range_batch<'life0, 'async_trait>( &'life0 self, range: EncodedKeyRange, batch_size: u64, ) -> Pin<Box<dyn Future<Output = Result<SingleVersionBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, TransactionStore: 'async_trait,

Fetch a batch of values in key order (ascending).

fn range<'life0, 'async_trait>( &'life0 self, range: EncodedKeyRange, ) -> Pin<Box<dyn Future<Output = Result<SingleVersionBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Convenience method with default batch size.

fn prefix<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 EncodedKey, ) -> Pin<Box<dyn Future<Output = Result<SingleVersionBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Range query with prefix.

impl SingleVersionRangeRev for TransactionStore

fn range_rev_batch<'life0, 'async_trait>( &'life0 self, range: EncodedKeyRange, batch_size: u64, ) -> Pin<Box<dyn Future<Output = Result<SingleVersionBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, TransactionStore: 'async_trait,

Fetch a batch of values in reverse key order (descending).

fn range_rev<'life0, 'async_trait>( &'life0 self, range: EncodedKeyRange, ) -> Pin<Box<dyn Future<Output = Result<SingleVersionBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Convenience method with default batch size.

fn prefix_rev<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 EncodedKey, ) -> Pin<Box<dyn Future<Output = Result<SingleVersionBatch, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Reverse range query with prefix.

impl SingleVersionRemove for TransactionStore

fn remove<'life0, 'life1, 'async_trait>( &'life0 mut self, key: &'life1 EncodedKey, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Send + 'async_trait,

Remove a key.

impl SingleVersionSet for TransactionStore

fn set<'life0, 'life1, 'async_trait>( &'life0 mut self, key: &'life1 EncodedKey, values: EncodedValues, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Send + 'async_trait,

Set a value for a key.

impl CdcStore for TransactionStore

impl MultiVersionStore for TransactionStore

impl SingleVersionStore for TransactionStore