coordinode-lsm-tree 5.7.0

Embedded LSM-tree storage engine: BuRR filters, zstd dictionary compression, MVCC, range tombstones, merge operators, K/V separation, AES-256-GCM at rest.
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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108

use super::*;
use crate::SequenceNumberCounter;

#[test]
fn restart_interval_policies_can_be_overridden_independently() {
    let folder = match tempfile::tempdir() {
        Ok(folder) => folder,
        Err(err) => panic!("tempdir failed: {err}"),
    };
    let cfg = Config::new(
        folder.path(),
        SequenceNumberCounter::default(),
        SequenceNumberCounter::default(),
    )
    .data_block_restart_interval_policy(RestartIntervalPolicy::all(7))
    .index_block_restart_interval_policy(RestartIntervalPolicy::all(3));

    assert_eq!(cfg.data_block_restart_interval_policy.first(), Some(&7));
    assert_eq!(cfg.index_block_restart_interval_policy.first(), Some(&3));
}

#[test]
fn fs_aware_builders_thread_to_initial_runtime_config() -> crate::Result<()> {
    // The CoW-disable + reflink toggles default ON and flip via the builder
    // (AC: "controlled via builder"). Verifies the builder threads to the
    // initial RuntimeConfig the Tree opens with; a wiring regression would
    // silently ignore the user's setting. Lives in the ungated builder
    // tests (the behaviour is unrelated to zstd).
    let folder = tempfile::tempdir()?;
    let mk = || {
        Config::new(
            folder.path(),
            SequenceNumberCounter::default(),
            SequenceNumberCounter::default(),
        )
    };

    let dflt = mk();
    assert!(dflt.initial_runtime_config.disable_cow_on_sst_files);
    assert!(dflt.initial_runtime_config.use_reflink_for_checkpoint);

    let off = mk()
        .disable_cow_on_sst_files(false)
        .use_reflink_for_checkpoint(false);
    assert!(!off.initial_runtime_config.disable_cow_on_sst_files);
    assert!(!off.initial_runtime_config.use_reflink_for_checkpoint);
    Ok(())
}

#[test]
#[should_panic(expected = "index block restart interval must be greater than zero")]
fn index_restart_interval_policy_rejects_zero_values() {
    let folder = match tempfile::tempdir() {
        Ok(folder) => folder,
        Err(err) => panic!("tempdir failed: {err}"),
    };
    let _cfg = Config::new(
        folder.path(),
        SequenceNumberCounter::default(),
        SequenceNumberCounter::default(),
    )
    .index_block_restart_interval_policy(RestartIntervalPolicy::all(0));
}

#[test]
#[should_panic(expected = "data block restart interval must be greater than zero")]
fn data_restart_interval_policy_rejects_zero_values() {
    let folder = match tempfile::tempdir() {
        Ok(folder) => folder,
        Err(err) => panic!("tempdir failed: {err}"),
    };
    let _cfg = Config::new(
        folder.path(),
        SequenceNumberCounter::default(),
        SequenceNumberCounter::default(),
    )
    .data_block_restart_interval_policy(RestartIntervalPolicy::all(0));
}

#[test]
#[should_panic(expected = "restart interval policy may not be empty")]
fn index_restart_interval_policy_rejects_empty() {
    let folder = match tempfile::tempdir() {
        Ok(folder) => folder,
        Err(err) => panic!("tempdir failed: {err}"),
    };
    let _cfg = Config::new(
        folder.path(),
        SequenceNumberCounter::default(),
        SequenceNumberCounter::default(),
    )
    .index_block_restart_interval_policy(RestartIntervalPolicy::new([]));
}

#[test]
#[should_panic(expected = "restart interval policy may not be empty")]
fn data_restart_interval_policy_rejects_empty() {
    let folder = match tempfile::tempdir() {
        Ok(folder) => folder,
        Err(err) => panic!("tempdir failed: {err}"),
    };
    let _cfg = Config::new(
        folder.path(),
        SequenceNumberCounter::default(),
        SequenceNumberCounter::default(),
    )
    .data_block_restart_interval_policy(RestartIntervalPolicy::new([]));
}