Enum HotStorage 

#[repr(u8)]
pub enum HotStorage {
    Memory(MemoryPrimitiveStorage),
    Sqlite(SqlitePrimitiveStorage),
}

Hot storage tier.

Provides a single interface for hot tier storage operations, dispatching to either Memory or SQLite implementations.

Variants

Memory(MemoryPrimitiveStorage)

In-memory storage (non-persistent)

Sqlite(SqlitePrimitiveStorage)

SQLite-based persistent storage

Implementations

impl HotStorage

pub fn memory() -> Self

Create a new in-memory backend

pub fn sqlite_in_memory() -> Self

Create a new SQLite backend with in-memory database

pub fn sqlite(config: SqliteConfig) -> Self

Create a new SQLite backend with the given configuration

impl HotStorage

pub fn maintenance(&self)

Run periodic maintenance (vacuum + shrink) to reclaim memory.

Trait Implementations

impl Clone for HotStorage

fn clone(&self) -> HotStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl TierStorage for HotStorage

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 HotStorage