risingwave_storage::memory

Trait RangeKv

source 
pub trait RangeKv:
    Clone
    + Send
    + Sync
    + 'static {
    // Required methods
    fn range(
        &self,
        range: BytesFullKeyRange,
        limit: Option<usize>,
    ) -> StorageResult<Vec<(BytesFullKey, Option<Bytes>)>>;
    fn rev_range(
        &self,
        range: BytesFullKeyRange,
        limit: Option<usize>,
    ) -> StorageResult<Vec<(BytesFullKey, Option<Bytes>)>>;
    fn ingest_batch(
        &self,
        kv_pairs: impl Iterator<Item = (BytesFullKey, Option<Bytes>)>,
    ) -> StorageResult<()>;
    fn flush(&self) -> StorageResult<()>;
}

Required Methods§

source

fn range( &self, range: BytesFullKeyRange, limit: Option<usize>, ) -> StorageResult<Vec<(BytesFullKey, Option<Bytes>)>>

source

fn rev_range( &self, range: BytesFullKeyRange, limit: Option<usize>, ) -> StorageResult<Vec<(BytesFullKey, Option<Bytes>)>>

source

fn ingest_batch( &self, kv_pairs: impl Iterator<Item = (BytesFullKey, Option<Bytes>)>, ) -> StorageResult<()>

source

fn flush(&self) -> StorageResult<()>

Object Safety§

This trait is not object safe.

Implementors§