Struct MVCCStorage 

pub struct MVCCStorage { /* private fields */ }

MVCC storage for versioned data

Implementations

impl MVCCStorage

pub fn new() -> MVCCStorage

Create new MVCC storage

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

Read a key with MVCC snapshot isolation

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

Write a key (creates a new version)

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

Delete a key (creates a delete marker)

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

Commit all versions for a transaction

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

Rollback all versions for a transaction

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

Garbage collect old versions

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

Scan keys with prefix (for range queries)

Trait Implementations

impl Default for MVCCStorage

fn default() -> MVCCStorage

Returns the “default value” for a type.