saku-storage 0.4.0

Shared storage infrastructure for the saku ecosystem
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

use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, Default, PartialEq, Eq, PartialOrd, Ord, Serialize, Deserialize)]
pub struct HybridTimestamp {
    pub wall_ms: i64,
    pub lamport: u64,
    pub device_id: String,
}

impl HybridTimestamp {
    /// Create a new HybridTimestamp using the current wall clock time.
    pub fn now(lamport: u64, device_id: String) -> Self {
        Self {
            wall_ms: jiff::Timestamp::now().as_millisecond(),
            lamport,
            device_id,
        }
    }

    /// Create a HybridTimestamp from an existing jiff Timestamp (useful for migrations).
    pub fn from_jiff(ts: jiff::Timestamp, lamport: u64, device_id: String) -> Self {
        Self {
            wall_ms: ts.as_millisecond(),
            lamport,
            device_id,
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn ordering_wall_ms_takes_priority() {
        let earlier = HybridTimestamp {
            wall_ms: 100,
            lamport: 5,
            device_id: "z".into(),
        };
        let later = HybridTimestamp {
            wall_ms: 200,
            lamport: 1,
            device_id: "a".into(),
        };
        assert!(earlier < later);
    }

    #[test]
    fn ordering_lamport_breaks_wall_ms_tie() {
        let low = HybridTimestamp {
            wall_ms: 100,
            lamport: 1,
            device_id: "z".into(),
        };
        let high = HybridTimestamp {
            wall_ms: 100,
            lamport: 2,
            device_id: "a".into(),
        };
        assert!(low < high);
    }

    #[test]
    fn ordering_device_id_breaks_lamport_tie() {
        let a = HybridTimestamp {
            wall_ms: 100,
            lamport: 1,
            device_id: "aaa".into(),
        };
        let b = HybridTimestamp {
            wall_ms: 100,
            lamport: 1,
            device_id: "bbb".into(),
        };
        assert!(a < b);
    }

    #[test]
    fn equality() {
        let ts1 = HybridTimestamp {
            wall_ms: 100,
            lamport: 1,
            device_id: "dev1".into(),
        };
        let ts2 = HybridTimestamp {
            wall_ms: 100,
            lamport: 1,
            device_id: "dev1".into(),
        };
        assert_eq!(ts1, ts2);
    }

    #[test]
    fn default_is_zero() {
        let ts = HybridTimestamp::default();
        assert_eq!(ts.wall_ms, 0);
        assert_eq!(ts.lamport, 0);
        assert_eq!(ts.device_id, "");
    }

    #[test]
    fn serde_roundtrip() {
        let ts = HybridTimestamp {
            wall_ms: 1234567890,
            lamport: 42,
            device_id: "device-abc".into(),
        };
        let json = serde_json::to_string(&ts).unwrap();
        let deserialized: HybridTimestamp = serde_json::from_str(&json).unwrap();
        assert_eq!(ts, deserialized);
    }

    #[test]
    fn from_jiff_produces_correct_wall_ms() {
        let jiff_ts = jiff::Timestamp::from_millisecond(1_700_000_000_000).unwrap();
        let ts = HybridTimestamp::from_jiff(jiff_ts, 5, "dev".into());
        assert_eq!(ts.wall_ms, 1_700_000_000_000);
        assert_eq!(ts.lamport, 5);
        assert_eq!(ts.device_id, "dev");
    }
}