pearl 0.21.0

Pearl is a low level blob-based I/O library
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
36
37
38
39
40

use crate::{
    storage::{BlobRecordTimestamp, ReadResult},
};

mod bptree;
mod core;
pub(crate) mod header;
mod simple;
mod tools;

#[cfg(test)]
mod benchmarks;

pub(crate) use bptree::BPTreeFileIndex;
use header::IndexHeader;

pub(crate) use self::core::{
    FileIndexTrait, InMemoryIndex, Index, IndexConfig, HEADER_VERSION,
    INDEX_HEADER_MAGIC_BYTE,
};
pub(crate) use super::prelude::*;
pub(crate) use crate::filter::range::RangeFilter;

mod prelude {
    pub(crate) use super::*;
    pub(crate) use tools::*;
}

#[async_trait::async_trait]
pub(crate) trait IndexTrait<K>: Send + Sync {
    async fn get_all(&self, key: &K) -> Result<Vec<RecordHeader>>;
    async fn get_all_with_deletion_marker(&self, key: &K) -> Result<Vec<RecordHeader>>;
    async fn get_latest(&self, key: &K) -> Result<ReadResult<RecordHeader>>;
    fn push(&self, key: &K, h: RecordHeader) -> Result<()>;
    async fn contains_key(&self, key: &K) -> Result<ReadResult<BlobRecordTimestamp>>;
    fn count(&self) -> usize;
    async fn dump(&mut self, blob_size: u64) -> Result<usize>;
    async fn load(&mut self, blob_size: u64) -> Result<()>;
    fn push_deletion(&mut self, key: &K, header: RecordHeader) -> Result<()>;
}