Remove a learner peer (e.g., join was rolled back before promotion).
(&mut self, peer: u64)
| 117 | |
| 118 | /// Remove a learner peer (e.g., join was rolled back before promotion). |
| 119 | pub fn remove_learner(&mut self, peer: u64) { |
| 120 | if !self.config.learners.contains(&peer) { |
| 121 | return; |
| 122 | } |
| 123 | if let Some(ref mut leader) = self.leader_state { |
| 124 | leader.remove_peer(peer); |
| 125 | } |
| 126 | self.config.learners.retain(|&id| id != peer); |
| 127 | |
| 128 | info!( |
| 129 | node = self.config.node_id, |
| 130 | group = self.config.group_id, |
| 131 | peer, |
| 132 | "removed learner peer" |
| 133 | ); |
| 134 | } |
| 135 | |
| 136 | /// Promote an existing learner to a full voter. |
| 137 | /// |