()
| 329 | |
| 330 | #[test] |
| 331 | fn remove_node() { |
| 332 | let mut topo = ClusterTopology::new(); |
| 333 | topo.add_node(NodeInfo::new( |
| 334 | 1, |
| 335 | "127.0.0.1:9400".parse().unwrap(), |
| 336 | NodeState::Active, |
| 337 | )); |
| 338 | let removed = topo.remove_node(1); |
| 339 | assert!(removed.is_some()); |
| 340 | assert_eq!(topo.node_count(), 0); |
| 341 | assert_eq!(topo.version(), 2); // add + remove |
| 342 | } |
| 343 | |
| 344 | #[test] |
| 345 | fn set_state() { |
nothing calls this directly
no test coverage detected