Struct StandardMultiStore 

pub struct StandardMultiStore(/* private fields */);

Implementations

impl StandardMultiStore

pub fn range_next( &self, cursor: &mut MultiVersionRangeCursor, range: EncodedKeyRange, version: CommitVersion, batch_size: u64, ) -> Result<MultiVersionBatch>

Fetch the next batch of entries, continuing from cursor position.

This properly handles high version density by scanning until batch_size unique logical keys are collected OR all tiers are exhausted.

pub fn range( &self, range: EncodedKeyRange, version: CommitVersion, batch_size: usize, ) -> MultiVersionRangeIter

Create an iterator for forward range queries.

This properly handles high version density by scanning until batch_size unique logical keys are collected. The iterator yields individual entries and maintains cursor state internally.

pub fn range_rev( &self, range: EncodedKeyRange, version: CommitVersion, batch_size: usize, ) -> MultiVersionRangeRevIter

Create an iterator for reverse range queries.

This properly handles high version density by scanning until batch_size unique logical keys are collected. The iterator yields individual entries in reverse key order and maintains cursor state internally.

impl StandardMultiStore

pub fn new(config: MultiStoreConfig) -> Result<Self>

pub fn hot(&self) -> Option<&HotStorage>

Get access to the hot storage tier.

Returns None if the hot tier is not configured.

impl StandardMultiStore

pub fn testing_memory() -> Self

pub fn testing_memory_with_eventbus(event_bus: EventBus) -> Self

Trait Implementations

impl Clone for StandardMultiStore

fn clone(&self) -> StandardMultiStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Deref for StandardMultiStore

type Target = StandardMultiStoreInner

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl MultiVersionCommit for StandardMultiStore

fn commit(&self, deltas: CowVec<Delta>, version: CommitVersion) -> Result<()>

Commit a batch of deltas at the given version.

impl MultiVersionContains for StandardMultiStore

fn contains(&self, key: &EncodedKey, version: CommitVersion) -> Result<bool>

Check if a key exists at a specific version.

impl MultiVersionGet for StandardMultiStore

fn get( &self, key: &EncodedKey, version: CommitVersion, ) -> Result<Option<MultiVersionValues>>

Get the value for a key at a specific version.

impl MultiVersionGetPrevious for StandardMultiStore

fn get_previous_version( &self, key: &EncodedKey, before_version: CommitVersion, ) -> Result<Option<MultiVersionValues>>

Get the previous version of a key before the given version.

impl MultiVersionStore for StandardMultiStore