Struct CommitStore 

pub struct CommitStore { /* private fields */ }

Implementations

impl CommitStore

pub fn new() -> Self

pub fn with_close_threshold(threshold: ByteSize) -> Self

pub fn estimated_current_count(&self, table: EntryKind) -> Result<u64>

pub fn list_all_entry_kinds(&self) -> Result<Vec<EntryKind>>

pub fn list_entry_kinds_by_oldest_pending(&self) -> Result<Vec<EntryKind>>

pub fn oldest_pending_for(&self, kind: EntryKind) -> Option<CommitVersion>

pub fn current_resident_bytes(&self) -> ByteSize

pub fn historical_resident_bytes(&self) -> ByteSize

pub fn oldest_pending_version(&self) -> Option<CommitVersion>

pub fn collect_evictable_below( &self, table: EntryKind, cutoff: CommitVersion, budget: ByteSize, ) -> (Vec<(EncodedKey, CommitVersion, Option<CowVec<u8>>)>, Vec<EvictedVersion>, ByteSize, bool)

impl CommitStore

pub fn get( &self, table: EntryKind, key: &[u8], version: CommitVersion, ) -> Result<VersionedGetResult>

pub fn contains( &self, table: EntryKind, key: &[u8], version: CommitVersion, ) -> Result<bool>

pub fn set(&self, version: CommitVersion, batches: TierBatch) -> Result<()>

pub fn range_next( &self, table: EntryKind, cursor: &mut RangeCursor, start: Bound<&[u8]>, end: Bound<&[u8]>, scope: MultiVersionScope, batch_size: usize, ) -> Result<RangeBatch>

pub fn range_next_into( &self, table: EntryKind, cursor: &mut RangeCursor, start: Bound<&[u8]>, end: Bound<&[u8]>, scope: MultiVersionScope, batch_size: usize, entries: &mut Vec<RawEntry>, ) -> Result<bool>

pub fn range_rev_next( &self, table: EntryKind, cursor: &mut RangeCursor, start: Bound<&[u8]>, end: Bound<&[u8]>, scope: MultiVersionScope, batch_size: usize, ) -> Result<RangeBatch>

pub fn ensure_table(&self, table: EntryKind) -> Result<()>

pub fn clear_table(&self, table: EntryKind) -> Result<()>

impl CommitStore

pub fn compact( &self, batches: HashMap<EntryKind, Vec<(EncodedKey, CommitVersion)>>, ) -> Result<Vec<EvictedVersion>>

pub fn get_all_versions( &self, table: EntryKind, key: &[u8], ) -> Result<Vec<(CommitVersion, Option<CowVec<u8>>)>>

pub fn sweep_historical_below( &self, table: EntryKind, cutoff: CommitVersion, batch_size: usize, ) -> Result<HistoricalSweep>

impl CommitStore

pub fn metrics(&self) -> MultiCommitMetrics

Trait Implementations

impl Clone for CommitStore

fn clone(&self) -> CommitStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for CommitStore

fn default() -> Self

Returns the “default value” for a type.

impl MetricsCollector for CommitStore

fn collect(&self, out: &mut Vec<MetricsSample>)