Struct VersionStore 

pub struct VersionStore { /* private fields */ }

Lock-free version store using DashMap

Provides O(1) key lookup + O(log V) version lookup per key.

Implementations

impl VersionStore

pub fn new() -> Self

Create new version store

pub fn insert_uncommitted( &self, key: &[u8], value: Option<Vec<u8>>, txn_id: u64, epoch: u32, ) -> Result<()>

Insert a new uncommitted version

pub fn commit(&self, key: &[u8], txn_id: u64, commit_ts: u64) -> bool

Commit a version

pub fn abort(&self, key: &[u8], txn_id: u64)

Abort uncommitted version

pub fn get( &self, key: &[u8], snapshot_ts: u64, current_txn_id: Option<u64>, ) -> Option<Vec<u8>>

Read value at snapshot timestamp

pub fn contains(&self, key: &[u8], snapshot_ts: u64) -> bool

Check if key exists at snapshot

pub fn gc(&self, min_epoch: u32, min_snapshot_ts: u64) -> usize

Run garbage collection

Removes old versions that are no longer visible to any reader.

pub fn len(&self) -> usize

Get number of keys

pub fn is_empty(&self) -> bool

Check if empty

pub fn stats(&self) -> &VersionStoreStats

Get statistics

Trait Implementations

impl Default for VersionStore

fn default() -> Self

Returns the “default value” for a type.