Struct SqlitePrimitiveStorage 

pub struct SqlitePrimitiveStorage { /* private fields */ }

SQLite-based primitive storage implementation with MVCC versioning.

Uses SQLite for persistent storage with a single connection protected by Mutex. Tables use (key, version) composite primary key for multi-version support.

Implementations

impl SqlitePrimitiveStorage

pub fn new(config: SqliteConfig) -> Self

Create a new SQLite primitive storage with the given configuration.

pub fn in_memory() -> Self

Create an in-memory SQLite storage for testing.

pub fn incremental_vacuum(&self)

Run incremental vacuum to return freed pages to the OS.

pub fn shrink_memory(&self)

Release unused memory back to the allocator.

pub fn shutdown(&self)

Explicitly checkpoint WAL and shrink the page cache before shutdown.

Trait Implementations

impl Clone for SqlitePrimitiveStorage

fn clone(&self) -> SqlitePrimitiveStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl TierStorage for SqlitePrimitiveStorage

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

Get the value for a key at or before the given version.

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

Check if a key exists at or before the given version.

fn set( &self, version: CommitVersion, batches: HashMap<EntryKind, Vec<(CowVec<u8>, Option<CowVec<u8>>)>>, ) -> Result<()>

Write entries to multiple tables atomically at the given version.

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

Fetch the next batch of entries in key order at or before version.

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

Fetch the next batch of entries in reverse key order at or before version.

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

Ensure a table exists (creates if needed).

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

Delete all entries in a table.

fn drop( &self, batches: HashMap<EntryKind, Vec<(CowVec<u8>, CommitVersion)>>, ) -> Result<()>

Physically drop specific versions of entries from storage.

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

Get all versions of a specific key (for internal cleanup operations).

impl TierBackend for SqlitePrimitiveStorage