Number of consumer tasks (one per core).
(&self)
| 231 | |
| 232 | /// Number of consumer tasks (one per core). |
| 233 | pub fn num_consumers(&self) -> usize { |
| 234 | self.consumers.len() |
| 235 | } |
| 236 | |
| 237 | /// Total events processed across all consumers. |
| 238 | pub fn total_events_processed(&self) -> u64 { |