atomr-cluster 0.6.0

Membership, gossip, reachability, vector clocks, and split-brain resolvers for atomr clusters.
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

//! Cluster heartbeat state.

use std::collections::HashMap;

use atomr_core::actor::Address;

use atomr_remote::PhiAccrualFailureDetector;

#[derive(Default)]
pub struct HeartbeatState {
    pub detectors: HashMap<Address, PhiAccrualFailureDetector>,
}

impl HeartbeatState {
    pub fn new() -> Self {
        Self::default()
    }

    pub fn heartbeat(&mut self, from: Address) {
        self.detectors
            .entry(from)
            .or_insert_with(|| {
                PhiAccrualFailureDetector::new(
                    8.0,
                    1000,
                    std::time::Duration::from_millis(100),
                    std::time::Duration::from_secs(3),
                    std::time::Duration::from_secs(1),
                )
            })
            .heartbeat_on_proxy();
    }
}

// Helper — PhiAccrualFailureDetector has `heartbeat` via trait; use it.
// We need to call FailureDetector::heartbeat — provide a tiny helper.
trait _HeartbeatOnProxy {
    fn heartbeat_on_proxy(&self);
}

impl _HeartbeatOnProxy for PhiAccrualFailureDetector {
    fn heartbeat_on_proxy(&self) {
        use atomr_remote::FailureDetector;
        FailureDetector::heartbeat(self);
    }
}