tempest-kv 0.0.2

Key-Value storage layer for TempestDB
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use bytes::Bytes;
use tempest_io::Io;

use crate::{
    StorageError,
    base::{Comparer, InternalKey},
};

//pub(crate) mod filter;
//pub(crate) mod merging;
pub(crate) mod logical_dedup;
pub(crate) mod snapshot;

//pub(crate) use filter::*;
//pub(crate) use merging::*;
pub(crate) use logical_dedup::*;
pub(crate) use snapshot::*;

#[cfg(test)]
pub(crate) mod mock;

/// An async forward iterator over key-value entries in storage.
///
/// Entries are yielded in [`InternalKey`] order. Seeking backwards is a no-op.
/// Call [`close`] when done to release any held resources (e.g. file descriptors).
///
/// [`close`]: StorageIterator::close
pub(crate) trait StorageIterator<I: Io, C: Comparer> {
    /// Advance to and return the next entry, or `None` if exhausted.
    async fn next(&mut self) -> Result<Option<(InternalKey<C, Bytes>, Bytes)>, StorageError>;

    /// Advance the cursor to the first entry with a logical key >= `key`.
    /// If the cursor is already at or past `key`, this is a no-op.
    async fn seek(&mut self, key: InternalKey<C, Bytes>) -> Result<(), StorageError>;
}