armdb 0.12.0

sharded bitcask key-value storage optimized for NVMe
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
41
42
43
44
45
46
47
48
49
50
51

//! Placeholder for T5 crash-atomic multi-collection commit + TTL interaction.
//!
//! Lands for real once T5 (`spec/t5-crash-atomic-tx`) merges: a row written
//! inside a committed multi-collection transaction must still expire on schedule.

#![cfg(all(feature = "armour", feature = "typed-tree", feature = "rapira-codec"))]

use armdb::armour::Db;
use armdb::{CollectionMeta, Config, NoHook, RapiraCodec, TtlPolicy};
use armour_core::GetType;
use rapira::Rapira;
use tempfile::tempdir;

#[derive(Clone, Debug, PartialEq, Rapira, GetType)]
struct Row {
    expires_at_ms: u64,
}

impl CollectionMeta for Row {
    type SelfId = [u8; 8];
    const NAME: &'static str = "ttl_t5_commit_rows";
    const TTL: Option<TtlPolicy<Self>> = Some(TtlPolicy {
        revision: 1,
        deadline: |row, _| Some(row.expires_at_ms),
    });
}

fn key(id: u64) -> [u8; 8] {
    id.to_be_bytes()
}

#[test]
#[ignore = "waits for T5 merge"]
fn row_in_committed_multi_collection_tx_expires() {
    let dir = tempdir().unwrap();
    let db = Db::open_test(dir.path()).unwrap();
    let tree = db
        .open_typed_tree::<Row, RapiraCodec, NoHook>(Config::test(), NoHook, &[])
        .unwrap();
    tree.build_ttl_index().unwrap();

    let k = key(1);
    // TODO(T5): replace with a real multi-collection commit API once T5 lands.
    tree.put(&k, Row { expires_at_ms: 1 }).unwrap();

    tree.sweep_expired(2, usize::MAX).unwrap();
    assert!(
        !tree.contains(&k),
        "row written inside committed tx must be physically removed after deadline"
    );
}