lora-wal 0.7.0

Write-ahead log and replay engine for LoraDB.
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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155

//! Regression baseline for `WalError`, `WalCommitError`, and
//! `WalBufferedCommitError` `Display` output.
//!
//! These messages flow into `LoraError::message()`. Pinning each
//! variant catches wording drift in CI before it reaches a binding.
//! `WalPoisonError` has a private constructor and is exercised
//! indirectly through `WalBufferedCommitError::Poisoned`, whose
//! wording mirrors it.

use std::path::PathBuf;

use lora_wal::{Lsn, WalBufferedCommitError, WalCommitError, WalError};

#[test]
fn io() {
    let inner = std::io::Error::new(std::io::ErrorKind::PermissionDenied, "denied");
    let err = WalError::Io(inner);
    assert_eq!(err.to_string(), "WAL I/O error: denied");
}

#[test]
fn encode() {
    let err = WalError::Encode("buffer too small".into());
    assert_eq!(
        err.to_string(),
        "WAL record could not be encoded: buffer too small"
    );
}

#[test]
fn decode() {
    let err = WalError::Decode("trailing bytes".into());
    assert_eq!(
        err.to_string(),
        "WAL record could not be decoded: trailing bytes"
    );
}

#[test]
fn crc_mismatch() {
    let err = WalError::CrcMismatch {
        lsn: Lsn::new(42),
        expected: 0xdead_beef,
        actual: 0xfeed_face,
    };
    assert_eq!(
        err.to_string(),
        "WAL record CRC mismatch at lsn 42: expected 0xdeadbeef, got 0xfeedface"
    );
}

#[test]
fn truncated() {
    let err = WalError::Truncated {
        expected: 16,
        actual: 8,
    };
    assert_eq!(
        err.to_string(),
        "WAL record truncated: expected 16 bytes, got 8"
    );
}

#[test]
fn unknown_kind() {
    let err = WalError::UnknownKind(7);
    assert_eq!(err.to_string(), "unknown WAL record kind: 7");
}

#[test]
fn bad_segment_header() {
    let err = WalError::BadSegmentHeader("magic mismatch");
    assert_eq!(
        err.to_string(),
        "WAL segment header is malformed: magic mismatch"
    );
}

#[test]
fn malformed() {
    let err = WalError::Malformed("dangling commit".into());
    assert_eq!(
        err.to_string(),
        "WAL structure is malformed: dangling commit"
    );
}

#[test]
fn already_open() {
    let err = WalError::AlreadyOpen {
        dir: PathBuf::from("/tmp/wal"),
    };
    assert_eq!(
        err.to_string(),
        "WAL directory is already open by another live handle: /tmp/wal"
    );
}

#[test]
fn poisoned() {
    assert_eq!(
        WalError::Poisoned.to_string(),
        "WAL is poisoned: a previous append failed and the log is no longer durable"
    );
}

#[test]
fn commit_error_commit() {
    let inner = WalError::Io(std::io::Error::other("disk full"));
    let err = WalCommitError::Commit(inner);
    assert_eq!(
        err.to_string(),
        "WAL commit failed: WAL I/O error: disk full"
    );
}

#[test]
fn commit_error_flush() {
    let inner = WalError::Poisoned;
    let err = WalCommitError::Flush(inner);
    assert_eq!(
        err.to_string(),
        "WAL flush failed: WAL is poisoned: a previous append failed and the log is no longer durable"
    );
}

#[test]
fn buffered_commit_arm() {
    let inner = WalError::Io(std::io::Error::other("io"));
    let err = WalBufferedCommitError::Arm(inner);
    assert_eq!(err.to_string(), "WAL arm failed: WAL I/O error: io");
}

#[test]
fn buffered_commit_poisoned() {
    let err = WalBufferedCommitError::Poisoned("prior commit failed".into());
    assert_eq!(err.to_string(), "WAL poisoned: prior commit failed");
}

#[test]
fn buffered_commit_replay_poisoned() {
    let err = WalBufferedCommitError::ReplayPoisoned("torn tail".into());
    assert_eq!(
        err.to_string(),
        "WAL poisoned during commit replay: torn tail"
    );
}

#[test]
fn buffered_commit_commit() {
    let inner = WalCommitError::Commit(WalError::Io(std::io::Error::other("boom")));
    let err = WalBufferedCommitError::Commit(inner);
    // `#[error(transparent)]` defers to the inner Display.
    assert_eq!(err.to_string(), "WAL commit failed: WAL I/O error: boom");
}