Lib.rs

Infinitree

Infinitree 是一个版本化的嵌入式数据库，使用统一且加密的二进制大对象（blob）来存储数据。

它最适合独立写进程的使用场景，因为不支持单个树上的多个写进程。

实际上，将 Infinitree 称为数据库可能过于宽泛，因为所有持久性操作都是显式的。底层，它使用 serde 以实现灵活性和与大多数库的互操作性。

特性

• 默认线程安全
• 透明地处理热/温/冷存储层；目前支持与 S3 兼容的后端
• 支持通过 Iterator 特性查询版本化数据结构，无需加载全部内容
• 加密所有磁盘上的数据，并在使用时才解密
• 注重性能，并允许灵活地选择性能与内存使用之间的权衡
• 可扩展以支持自定义数据类型和存储策略
• 易于与云工作者和 KMS 集成以实现访问控制

示例用法

use infinitree::{
    Infinitree,
    Index,
    Key,
    anyhow,
    backends::Directory,
    fields::{Serialized, VersionedMap, LocalField},
};
use serde::{Serialize, Deserialize};

#[derive(Serialize, Deserialize)]
pub struct PlantHealth {
    id: usize,
    air_humidity: usize,
    soil_humidity: usize,
    temperature: f32
}

#[derive(Index, Default, Clone)]
pub struct Measurements {
    // rename the field when serializing
    #[infinitree(name = "last_time")]
    _old_last_time: Serialized<String>,

    #[infinitree(name = "last_time2")]
    last_time: Serialized<usize>,

    // only store the keys in the index, not the values
    #[infinitree(strategy = "infinitree::fields::SparseField")]
    measurements: VersionedMap<usize, PlantHealth>,

    // skip the next field when loading & serializing
    #[infinitree(skip)]
    current_time: usize,
}

fn main() -> anyhow::Result<()> {
    let mut tree = Infinitree::<Measurements>::empty(
        Directory::new("/storage")?,
        Key::from_credentials("username", "password")?
    );

    tree.index().measurements.insert(1, PlantHealth {
        id: 0,
        air_humidity: 50,
        soil_humidity: 60,
        temperature: 23.3,
    });

    *tree.index().last_time.write() = 1;
    tree.commit("first measurement! yay!");
    Ok(())
}

版本控制

Infinitree 支持版本化数据集，类似于 Git 对文件的版本控制。

虽然某些索引字段作为快照工作（例如，Serialized<T>），并在每次提交时序列化全部内容，但可以使用例如 VersionedMap<K, V> 作为增量 HashMap。