hydracache 0.59.0

User-facing HydraCache runtime crate.
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

use std::collections::BTreeMap;

use hydracache::{
    resolve_live_split_brain, ClusterEpoch, ClusterNodeId, HigherVersionWins, NodeTopology,
    PartitionId, ReplicatedValueRecord, TopologyAuthority,
};

#[test]
fn split_brain_live_partition_then_heal_resolves_to_higher_epoch() {
    let mut left = BTreeMap::new();
    left.insert(
        "user:42".to_owned(),
        ReplicatedValueRecord::value(PartitionId::new(1), 3, ClusterEpoch::new(7), b"left"),
    );
    let mut right = BTreeMap::new();
    right.insert(
        "user:42".to_owned(),
        ReplicatedValueRecord::value(PartitionId::new(1), 4, ClusterEpoch::new(6), b"right"),
    );

    let resolution = resolve_live_split_brain(
        ClusterEpoch::new(7),
        left,
        ClusterEpoch::new(6),
        right,
        &HigherVersionWins,
    );

    assert_eq!(resolution.winner_epoch, ClusterEpoch::new(7));
    assert_eq!(resolution.loser_epoch, ClusterEpoch::new(6));
    assert_eq!(resolution.outcome.records["user:42"].version, 4);
}

#[test]
fn split_brain_live_loser_side_discards_split_time_topology() {
    let mut winner_topology = TopologyAuthority::new();
    winner_topology.commit_topology(
        "member-a",
        NodeTopology::new("eu", "az-a"),
        ClusterEpoch::new(8),
    );
    let mut loser_topology = TopologyAuthority::new();
    loser_topology.commit_topology(
        "member-a",
        NodeTopology::new("eu", "split-zone"),
        ClusterEpoch::new(7),
    );
    loser_topology.observe_gossip("member-b", NodeTopology::new("eu", "split-gossip"));

    let resolution = resolve_live_split_brain(
        winner_topology.epoch(),
        BTreeMap::new(),
        loser_topology.epoch(),
        BTreeMap::new(),
        &HigherVersionWins,
    );
    let committed_after_heal = if resolution.winner_epoch == winner_topology.epoch() {
        winner_topology.committed_map()
    } else {
        loser_topology.committed_map()
    };

    assert_eq!(resolution.winner_epoch, ClusterEpoch::new(8));
    assert_eq!(
        committed_after_heal[&ClusterNodeId::from("member-a")]
            .zone
            .as_str(),
        "az-a"
    );
    assert!(!committed_after_heal.contains_key(&ClusterNodeId::from("member-b")));
    assert_eq!(
        loser_topology
            .gossip_map()
            .get(&ClusterNodeId::from("member-b"))
            .expect("loser split-time gossip")
            .zone
            .as_str(),
        "split-gossip"
    );
}

#[test]
fn split_brain_live_tombstone_on_winner_beats_value_on_loser() {
    let mut winner = BTreeMap::new();
    winner.insert(
        "user:42".to_owned(),
        ReplicatedValueRecord::tombstone(PartitionId::new(1), 9, ClusterEpoch::new(8), None),
    );
    let mut loser = BTreeMap::new();
    loser.insert(
        "user:42".to_owned(),
        ReplicatedValueRecord::value(PartitionId::new(1), 9, ClusterEpoch::new(8), b"stale"),
    );

    let resolution = resolve_live_split_brain(
        ClusterEpoch::new(8),
        winner,
        ClusterEpoch::new(7),
        loser,
        &HigherVersionWins,
    );

    assert!(resolution.outcome.records["user:42"].is_tombstone());
}

#[test]
#[ignore = "chaos gate: run with -- --ignored when exercising partition heal under churn"]
fn split_brain_live_split_then_heal_under_churn_converges() {
    let resolution = resolve_live_split_brain(
        ClusterEpoch::new(2),
        BTreeMap::new(),
        ClusterEpoch::new(1),
        BTreeMap::new(),
        &HigherVersionWins,
    );
    assert_eq!(resolution.outcome.report.unresolved_conflicts, 0);
}