Struct StandardMultiStore 

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

Implementations

impl StandardMultiStore

pub fn get_many( &self, keys: &[EncodedKey], version: CommitVersion, ) -> Result<HashMap<EncodedKey, MultiVersionRow>>

impl StandardMultiStore

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

pub fn range( &self, range: EncodedKeyRange, scope: MultiVersionScope, batch_size: usize, ) -> MultiVersionRangeIter

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

impl StandardMultiStore

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

pub fn configure_read_buffer_capacity(&self, capacity: usize)

pub fn configure_read_buffer(&self, resident_pages: usize, page_size_rows: u64)

pub fn invalidate_read_key(&self, key: &EncodedKey)

pub fn clear_read(&self)

pub fn set_row_settings_provider(&self, provider: Arc<dyn ShapePersistence>)

pub fn set_eviction_watermark(&self, watermark: Arc<dyn EvictionWatermark>)

pub fn clear_eviction_watermark(&self)

pub fn commit(&self) -> Option<&MultiCommitBufferTier>

pub fn persistent(&self) -> Option<&MultiPersistentTier>

pub fn flush_pending_blocking(&self)

pub fn flush_all_blocking(&self)

impl StandardMultiStore

pub fn testing_memory() -> Self

pub fn testing_memory_with_eventbus(event_bus: EventBus) -> Self

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

pub fn testing_memory_with_persistent_sqlite_with_eventbus( event_bus: EventBus, ) -> (Self, SqliteTempPathGuard)

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

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<()>

impl MultiVersionContains for StandardMultiStore

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

fn contains_with_options( &self, key: &EncodedKey, version: CommitVersion, _options: ReadOptions, ) -> Result<bool, Error>

impl MultiVersionGet for StandardMultiStore

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

fn get_with_options( &self, key: &EncodedKey, version: CommitVersion, _options: ReadOptions, ) -> Result<Option<MultiVersionRow>, Error>

impl MultiVersionGetPrevious for StandardMultiStore

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

impl MultiVersionStore for StandardMultiStore

impl Shutdown for StandardMultiStore

fn shutdown(&self)