Sync connection count for an instance to KvStore
(&self, instance_id: &str, count: u64)
| 1344 | |
| 1345 | /// Sync connection count for an instance to KvStore |
| 1346 | pub(crate) fn sync_connections(&self, instance_id: &str, count: u64) { |
| 1347 | if let Err(err) = self.kv_store.sync_connections(instance_id, count) { |
| 1348 | debug!("Failed to sync connections: {err:?}"); |
| 1349 | } |
| 1350 | } |
| 1351 | |
| 1352 | /// Get latest handshake for an instance from KvStore (max across all nodes) |
| 1353 | pub(crate) fn get_instance_latest_handshake(&self, instance_id: &str) -> Option<u64> { |
no outgoing calls
no test coverage detected