laminar-core 0.26.0

Core streaming engine for LaminarDB - operators, checkpoint barriers, and streaming primitives
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

//! Weak leader election: lowest-ID live instance wins. Split-brain is
//! tolerated because `epoch=N/_COMMIT` is CAS-guarded.

use crate::cluster::discovery::NodeId;

/// Smallest non-sentinel ID in `live`, or `None` if empty/all-sentinel.
#[must_use]
pub fn leader_of(live: &[NodeId]) -> Option<NodeId> {
    live.iter().copied().filter(|n| !n.is_unassigned()).min()
}

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

    #[test]
    fn empty_has_no_leader() {
        assert_eq!(leader_of(&[]), None);
    }

    #[test]
    fn only_unassigned_has_no_leader() {
        assert_eq!(leader_of(&[NodeId::UNASSIGNED]), None);
    }

    #[test]
    fn single_instance_is_leader() {
        assert_eq!(leader_of(&[NodeId(42)]), Some(NodeId(42)));
    }

    #[test]
    fn smallest_wins() {
        let live = [NodeId(100), NodeId(1), NodeId(50)];
        assert_eq!(leader_of(&live), Some(NodeId(1)));
    }

    #[test]
    fn unassigned_ignored_with_real_ids() {
        let live = [NodeId::UNASSIGNED, NodeId(5), NodeId(3)];
        assert_eq!(leader_of(&live), Some(NodeId(3)));
    }

    #[test]
    fn deterministic_across_calls() {
        let live = [NodeId(7), NodeId(3), NodeId(9)];
        assert_eq!(leader_of(&live), leader_of(&live));
    }
}