(node_id: u64, peers: Vec<u64>)
| 22 | }; |
| 23 | |
| 24 | fn config(node_id: u64, peers: Vec<u64>) -> RaftConfig { |
| 25 | RaftConfig { |
| 26 | node_id, |
| 27 | group_id: 1, |
| 28 | peers, |
| 29 | learners: vec![], |
| 30 | observers: vec![], |
| 31 | starts_as_learner: false, |
| 32 | starts_as_observer: false, |
| 33 | election_timeout_min: Duration::from_millis(150), |
| 34 | election_timeout_max: Duration::from_millis(300), |
| 35 | heartbeat_interval: Duration::from_millis(50), |
| 36 | } |
| 37 | } |
| 38 | |
| 39 | fn force_election(node: &mut RaftNode<MemStorage>) { |
| 40 | node.election_deadline_override(Instant::now() - Duration::from_millis(1)); |
no outgoing calls
no test coverage detected