Struct MVCCStorage 

pub struct MVCCStorage { /* private fields */ }

MVCC storage for versioned data

Implementations

impl MVCCStorage

pub fn new() -> Self

Create new MVCC storage

pub fn read( &self, key: &[u8], snapshot_ts: Timestamp, txn_id: TransactionId, ) -> Result<Option<Vec<u8>>>

Read a key with MVCC snapshot isolation

pub fn write( &self, key: Vec<u8>, value: Vec<u8>, txn_id: TransactionId, timestamp: Timestamp, ) -> Result<()>

Write a key (creates a new version)

pub fn delete( &self, key: &[u8], txn_id: TransactionId, timestamp: Timestamp, ) -> Result<()>

Delete a key (creates a delete marker)

pub fn commit(&self, txn_id: TransactionId) -> Result<()>

Commit all versions for a transaction

pub fn rollback(&self, txn_id: TransactionId) -> Result<()>

Rollback all versions for a transaction

pub fn gc(&self, min_active_ts: Timestamp) -> Result<()>

Garbage collect old versions

pub fn scan_prefix( &self, prefix: &[u8], snapshot_ts: Timestamp, txn_id: TransactionId, ) -> Result<Vec<(Vec<u8>, Vec<u8>)>>

Scan keys with prefix (for range queries)

Trait Implementations

impl Default for MVCCStorage

fn default() -> Self

Returns the “default value” for a type.