(&self)
| 370 | self.workers.insert(worker_id, details); |
| 371 | } |
| 372 | pub fn count(&self) -> u64 { |
| 373 | self.workers.len() as u64 |
| 374 | } |
| 375 | |
| 376 | /// Returns true if all workers that have disconnected have crashed. |
| 377 | /// A worker is considered to be failed if it has lost connection to the server very soon |