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

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§