()
| 152 | |
| 153 | #[test] |
| 154 | fn overwrite_topology() { |
| 155 | let (_dir, catalog) = temp_catalog(); |
| 156 | |
| 157 | let mut topo1 = ClusterTopology::new(); |
| 158 | topo1.add_node(NodeInfo::new( |
| 159 | 1, |
| 160 | "10.0.0.1:9400".parse().unwrap(), |
| 161 | NodeState::Active, |
| 162 | )); |
| 163 | catalog.save_topology(&topo1).unwrap(); |
| 164 | |
| 165 | let mut topo2 = ClusterTopology::new(); |
| 166 | topo2.add_node(NodeInfo::new( |
| 167 | 1, |
| 168 | "10.0.0.1:9400".parse().unwrap(), |
| 169 | NodeState::Active, |
| 170 | )); |
| 171 | topo2.add_node(NodeInfo::new( |
| 172 | 2, |
| 173 | "10.0.0.2:9400".parse().unwrap(), |
| 174 | NodeState::Active, |
| 175 | )); |
| 176 | catalog.save_topology(&topo2).unwrap(); |
| 177 | |
| 178 | let loaded = catalog.load_topology().unwrap().unwrap(); |
| 179 | assert_eq!(loaded.node_count(), 2); |
| 180 | } |
| 181 | } |
nothing calls this directly
no test coverage detected