reddb 2.0.0

Minimalistic async in-memory embedded document database with closure-based queries and optional persistence
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

use crate::document::Document;
use crate::error::Result;
use crate::wal::WalOp;
use crate::RedDbHM;
use core::fmt::Debug;
use serde::{Deserialize, Serialize};
use uuid::Uuid;

mod file;
mod mem;

pub use file::FileStorage;
pub use mem::MemStorage;

#[async_trait::async_trait]
pub(crate) trait Storage {
    async fn new(db_name: &str, compaction_ratio: f64) -> Result<Self>
    where
        Self: Sized;

    async fn load<T>(&self) -> Result<RedDbHM>
    where
        for<'de> T: Serialize + Deserialize<'de> + Debug + PartialEq + Send + Sync;

    async fn persist<T>(&self, records: &[Document<T>], op: WalOp) -> Result<()>
    where
        for<'de> T: Serialize + Deserialize<'de> + Debug + Send + Sync + Clone;

    /// Rewrite the storage with exactly one Insert record per live document.
    async fn compact(&self, data: &RedDbHM) -> Result<()>;

    /// Size of the backing store in bytes (0 for in-memory backends).
    async fn file_size(&self) -> Result<u64>;

    /// Write a batch of raw (op, id, payload) records directly, bypassing
    /// type-aware serialization. Used by `Transaction::commit`.
    async fn persist_raw(&self, records: &[(WalOp, Uuid, Vec<u8>)]) -> Result<()>;
}