sst 0.24.0

SST provides a sorted string table abstraction.
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

extern crate sst;

use sst::Builder;
use sst::log::{LogBuilder, LogIterator, LogOptions, WriteBatch};

#[test]
fn read_while_writing_log() {
    let _ = std::fs::remove_file("read_while_writing.log");
    let mut log_builder = LogBuilder::new(LogOptions::default(), "read_while_writing.log").unwrap();
    // First write batch: key1
    let mut wb = WriteBatch::default();
    wb.put(b"key1", 1, b"value1").unwrap();
    log_builder.append(&wb).unwrap();
    log_builder.flush().unwrap();
    log_builder.fsync().unwrap();
    // The key should be visible.
    let mut log = LogIterator::new(LogOptions::default(), "read_while_writing.log").unwrap();
    let kvp = log.next().unwrap().unwrap();
    assert_eq!(b"key1", kvp.key);
    assert_eq!(Some(b"value1".as_ref()), kvp.value);
    assert_eq!(1, kvp.timestamp);
    // Second write batch: key2
    let mut wb = WriteBatch::default();
    wb.put(b"key2", 2, b"value2").unwrap();
    log_builder.append(&wb).unwrap();
    log_builder.flush().unwrap();
    log_builder.fsync().unwrap();
    // A new iterator should see both keys.
    let mut log = LogIterator::new(LogOptions::default(), "read_while_writing.log").unwrap();
    let kvp = log.next().unwrap().unwrap();
    assert_eq!(b"key1", kvp.key);
    assert_eq!(Some(b"value1".as_ref()), kvp.value);
    assert_eq!(1, kvp.timestamp);
    let kvp = log.next().unwrap().unwrap();
    assert_eq!(b"key2", kvp.key);
    assert_eq!(Some(b"value2".as_ref()), kvp.value);
    assert_eq!(2, kvp.timestamp);
}

#[test]
fn read_while_writing_conclog() {
    let _ = std::fs::remove_file("read_while_writing_concurrent.log");
    let mut log_builder =
        LogBuilder::new(LogOptions::default(), "read_while_writing_concurrent.log").unwrap();
    // First write batch: key1
    let mut wb = WriteBatch::default();
    wb.put(b"key1", 1, b"value1").unwrap();
    log_builder.append(&wb).unwrap();
    log_builder.flush().unwrap();
    log_builder.fsync().unwrap();
    // The key should be visible.
    let mut log =
        LogIterator::new(LogOptions::default(), "read_while_writing_concurrent.log").unwrap();
    let kvp = log.next().unwrap().unwrap();
    assert_eq!(b"key1", kvp.key);
    assert_eq!(Some(b"value1".as_ref()), kvp.value);
    assert_eq!(1, kvp.timestamp);
    // Second write batch: key2
    let mut wb = WriteBatch::default();
    wb.put(b"key2", 2, b"value2").unwrap();
    log_builder.append(&wb).unwrap();
    log_builder.flush().unwrap();
    log_builder.fsync().unwrap();
    // A new iterator should see both keys.
    let mut log =
        LogIterator::new(LogOptions::default(), "read_while_writing_concurrent.log").unwrap();
    let kvp = log.next().unwrap().unwrap();
    assert_eq!(b"key1", kvp.key);
    assert_eq!(Some(b"value1".as_ref()), kvp.value);
    assert_eq!(1, kvp.timestamp);
    let kvp = log.next().unwrap().unwrap();
    assert_eq!(b"key2", kvp.key);
    assert_eq!(Some(b"value2".as_ref()), kvp.value);
    assert_eq!(2, kvp.timestamp);
}