risingwave_storage::memory

Type Alias BTreeMapRangeKv

source
pub type BTreeMapRangeKv = Arc<RwLock<BTreeMap<BytesFullKey, Option<Bytes>>>>;

Aliased Type§

struct BTreeMapRangeKv { /* private fields */ }

Trait Implementations§

source§

impl RangeKv for BTreeMapRangeKv

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