coordinode-lsm-tree 5.6.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

use super::prefixed_range;
use crate::UserKey;
use core::ops::Bound::{Excluded, Included};
use core::ops::RangeBounds;
use test_log::test;

#[test]
fn prefixed_range_1() {
    let prefix = "abc";
    let min = 5u8.to_be_bytes();
    let max = 9u8.to_be_bytes();

    let range = prefixed_range(prefix, min..=max);

    assert_eq!(
        range.start_bound(),
        Included(&UserKey::new(&[b'a', b'b', b'c', 5]))
    );
    assert_eq!(
        range.end_bound(),
        Included(&UserKey::new(&[b'a', b'b', b'c', 9]))
    );
}

#[test]
fn prefixed_range_2() {
    let prefix = "abc";
    let min = 5u8.to_be_bytes();
    let max = 9u8.to_be_bytes();

    let range = prefixed_range(prefix, min..max);

    assert_eq!(
        range.start_bound(),
        Included(&UserKey::new(&[b'a', b'b', b'c', 5]))
    );
    assert_eq!(
        range.end_bound(),
        Excluded(&UserKey::new(&[b'a', b'b', b'c', 9]))
    );
}

#[test]
fn prefixed_range_3() {
    let prefix = "abc";
    let min = 5u8.to_be_bytes();

    let range = prefixed_range(prefix, min..);

    assert_eq!(
        range.start_bound(),
        Included(&UserKey::new(&[b'a', b'b', b'c', 5]))
    );
    assert_eq!(range.end_bound(), Excluded(&UserKey::new(b"abd")));
}

#[test]
fn prefixed_range_4() {
    let prefix = "abc";
    let max = 9u8.to_be_bytes();

    let range = prefixed_range(prefix, ..max);

    assert_eq!(range.start_bound(), Included(&UserKey::new(b"abc")));
    assert_eq!(
        range.end_bound(),
        Excluded(&UserKey::new(&[b'a', b'b', b'c', 9]))
    );
}

#[test]
fn prefixed_range_5() {
    let prefix = "abc";
    let max = u8::MAX.to_be_bytes();

    let range = prefixed_range(prefix, ..=max);

    assert_eq!(range.start_bound(), Included(&UserKey::new(b"abc")));
    assert_eq!(
        range.end_bound(),
        Included(&UserKey::new(&[b'a', b'b', b'c', u8::MAX]))
    );
}

#[test]
fn prefixed_range_6() {
    let prefix = "abc";
    let max = u8::MAX.to_be_bytes();

    let range = prefixed_range(prefix, ..max);

    assert_eq!(range.start_bound(), Included(&UserKey::new(b"abc")));
    assert_eq!(
        range.end_bound(),
        Excluded(&UserKey::new(&[b'a', b'b', b'c', u8::MAX]))
    );
}

#[test]
fn prefixed_range_7() {
    let prefix = "abc";

    let range = prefixed_range::<_, &[u8], _>(prefix, ..);

    assert_eq!(range.start_bound(), Included(&UserKey::new(b"abc")));
    assert_eq!(range.end_bound(), Excluded(&UserKey::new(b"abd")));
}