lsm-db 0.2.0

Log-structured merge-tree storage engine for Rust. Memtable, leveled SSTables, background compaction, and bloom-filtered point reads over a durable wal-db log. A composable storage engine for embedded databases and Hive DB.
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

//! Range scans over an ordered key space.
//!
//! Keys are stored in sorted order, so a prefix or bounded range can be walked
//! efficiently. Run with `cargo run --example range_scan`.

use lsm_db::Lsm;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let dir = tempfile::tempdir()?;
    let db = Lsm::open(dir.path())?;

    // A simple time series, one event per key.
    db.put(b"event:2026-06-01", b"deploy")?;
    db.put(b"event:2026-06-02", b"scale-up")?;
    db.put(b"event:2026-06-03", b"incident")?;
    db.put(b"event:2026-06-04", b"resolved")?;
    db.put(b"meta:owner", b"platform-team")?;

    // Everything, in key order.
    println!("all entries:");
    for (key, value) in db.scan(..)? {
        println!(
            "  {} = {}",
            String::from_utf8_lossy(&key),
            String::from_utf8_lossy(&value)
        );
    }

    // Just the events from the 2nd to the 4th (half-open: 4th excluded).
    println!("\nevents 06-02 ..= 06-03:");
    let lo = b"event:2026-06-02".to_vec();
    let hi = b"event:2026-06-04".to_vec();
    for (key, value) in db.scan(lo..hi)? {
        println!(
            "  {} = {}",
            String::from_utf8_lossy(&key),
            String::from_utf8_lossy(&value)
        );
    }

    // A prefix scan: everything under "event:".
    println!("\nall events (prefix scan):");
    let count = db.scan(b"event:".to_vec()..b"event;".to_vec())?.count();
    println!("  {count} events");

    Ok(())
}