Struct LockFreeMemTable 

pub struct LockFreeMemTable { /* private fields */ }

Lock-free memtable with hazard pointer protection

Implementations

impl LockFreeMemTable

pub fn new() -> Self

Create a new lock-free memtable

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

Read a value at snapshot timestamp

This is a lock-free read protected by hazard pointers. Returns a cloned value for safety across hazard pointer boundaries.

pub fn read_with<F, R>( &self, key: &[u8], snapshot_ts: u64, txn_id: Option<u64>, f: F, ) -> Option<R>

where F: FnOnce(&[u8]) -> R,

Read a value at snapshot timestamp with zero-copy callback

This is an optimized read path that avoids cloning for inline values. The callback receives a reference to the value, avoiding allocation.

Arguments

• key - The key to read
• snapshot_ts - Snapshot timestamp for visibility
• txn_id - Current transaction ID (to see own uncommitted writes)
• f - Callback that receives the value reference

Returns

The result of the callback, or None if key not found

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

Write a value (creates uncommitted version)

pub fn commit(&self, txn_id: u64, commit_ts: u64, keys: &[Vec<u8>])

Commit a transaction’s writes

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

Check for write conflict

pub fn size_bytes(&self) -> usize

Get approximate size in bytes

pub fn len(&self) -> usize

Get number of keys

pub fn is_empty(&self) -> bool

Check if empty

Trait Implementations

impl Default for LockFreeMemTable

fn default() -> Self

Returns the “default value” for a type.

impl Send for LockFreeMemTable

impl Sync for LockFreeMemTable