wal-db 0.8.0

Write-ahead log primitive for Rust storage engines. Durable, recoverable, lock-free append path. The WAL substrate under lsm-db, txn-db, raft-io, 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
48
49
50
51
52
53
54
55
56
57
58

//! Replay from a checkpoint, and truncate back to one.
//!
//! Run it with:
//!
//! ```text
//! cargo run --example checkpoint
//! ```
//!
//! An engine applies WAL records to its state and remembers the last LSN it
//! applied (its checkpoint). Two operations follow from that: replaying only the
//! records after the checkpoint on restart (`iter_from`), and — when records
//! after a point must be discarded, as a Raft log does on a conflict, or to roll
//! back speculative writes — truncating the log back to it (`truncate_after`).

use wal_db::Wal;

fn main() -> Result<(), wal_db::WalError> {
    let dir = tempfile::tempdir().map_err(wal_db::WalError::from)?;
    let path = dir.path().join("checkpoint.wal");

    let wal = Wal::open(&path)?;
    let _ = wal.append(b"set x = 1")?;
    let checkpoint = wal.append(b"set y = 2")?; // the engine has durably applied through here
    let _ = wal.append(b"set z = 3")?;
    let _ = wal.append(b"set w = 4")?;
    wal.sync()?;

    // Replay only what came after the checkpoint — the work still to apply.
    println!("records after the checkpoint (lsn {checkpoint}):");
    for entry in wal.iter_from(checkpoint)? {
        let entry = entry?;
        // The checkpoint record itself is included; skip it to get strictly later.
        if entry.lsn() > checkpoint {
            println!(
                "  lsn {}: {}",
                entry.lsn(),
                String::from_utf8_lossy(entry.data())
            );
        }
    }

    // Now discard everything after the checkpoint and prove it is durable.
    wal.truncate_after(checkpoint)?;
    drop(wal);

    let reopened = Wal::open(&path)?;
    println!("after truncating back to the checkpoint, the log holds:");
    for entry in reopened.iter()? {
        let entry = entry?;
        println!(
            "  lsn {}: {}",
            entry.lsn(),
            String::from_utf8_lossy(entry.data())
        );
    }

    Ok(())
}