Sync instance deletion to other nodes
(&self, instance_id: &str)
| 505 | |
| 506 | /// Sync instance deletion to other nodes |
| 507 | pub fn sync_delete_instance(&self, instance_id: &str) -> Result<()> { |
| 508 | self.persistent.write().delete(keys::inst(instance_id))?; |
| 509 | self.ephemeral |
| 510 | .write() |
| 511 | .delete(keys::conn(instance_id, self.my_node_id))?; |
| 512 | // Delete this node's handshake record |
| 513 | self.ephemeral |
| 514 | .write() |
| 515 | .delete(keys::handshake(instance_id, self.my_node_id))?; |
| 516 | Ok(()) |
| 517 | } |
| 518 | |
| 519 | /// Load all instances from sync store (for initial sync on startup) |
| 520 | pub fn load_all_instances(&self) -> BTreeMap<String, InstanceData> { |
no test coverage detected