Per-database pressure state for the given core (used by metrics exporters). Returns `PressureState::Normal` when no pressure has been recorded for the database on that core.
(&self, core_id: usize, database_id: u64)
| 431 | /// Returns `PressureState::Normal` when no pressure has been recorded for |
| 432 | /// the database on that core. |
| 433 | pub fn db_pressure_on_core(&self, core_id: usize, database_id: u64) -> PressureState { |
| 434 | self.cores |
| 435 | .get(core_id) |
| 436 | .and_then(|ch| ch.db_pressure.get(&database_id).copied()) |
| 437 | .unwrap_or(PressureState::Normal) |
| 438 | } |
| 439 | |
| 440 | /// Poll responses from all Data Plane cores. |
| 441 | pub fn poll_responses(&mut self) -> Vec<envelope::Response> { |