Struct SqlitePersistentStorage 

pub struct SqlitePersistentStorage { /* private fields */ }

Implementations

impl SqlitePersistentStorage

pub fn new(config: SqliteConfig) -> Self

pub fn page_cache_metrics(&self) -> SqlitePageCacheMetrics

pub fn set_checkpoint_threshold(&self, frames: u32)

pub fn in_memory() -> (Self, SqliteTempPathGuard)

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

pub fn delete_below_version( &self, table: EntryKind, cutoff_version: CommitVersion, prefix: Option<&[u8]>, cursor: Option<&[u8]>, limit: usize, ) -> Result<(Vec<EncodedKey>, Option<EncodedKey>)>

pub fn delete_keys(&self, table: EntryKind, keys: &[EncodedKey]) -> Result<u64>

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

pub fn reap_tombstones( &self, kind: EntryKind, cutoff_version: CommitVersion, limit: usize, ) -> Result<(u64, bool)>

pub fn expired_keys( &self, table: EntryKind, cutoff: DateTime, cursor: Option<(DateTime, &[u8])>, limit: usize, ) -> Result<Vec<(EncodedKey, DateTime)>>

pub fn resurrections(&self) -> u64

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

pub fn persist_sweep( &self, batches: Vec<(CommitVersion, TierBatch)>, ) -> Result<Vec<EncodedKey>>

pub fn load_range_consistent( &self, table: EntryKind, start: Bound<&[u8]>, end: Bound<&[u8]>, read: CommitVersion, limit: Option<usize>, ) -> Result<Vec<RawEntry>>

Trait Implementations

impl Clone for SqlitePersistentStorage

fn clone(&self) -> SqlitePersistentStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Shutdown for SqlitePersistentStorage

fn shutdown(&self)

impl TierBackend for SqlitePersistentStorage

impl TierStorage for SqlitePersistentStorage

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

fn get_many( &self, table: EntryKind, keys: &[&[u8]], version: CommitVersion, ) -> Result<Vec<VersionedGetResult>>

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

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

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

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

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

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