(&self, function_name: &str)
| 216 | } |
| 217 | |
| 218 | pub async fn queue_depth(&self, function_name: &str) -> usize { |
| 219 | let inner = self.inner.read().await; |
| 220 | inner |
| 221 | .get(function_name) |
| 222 | .map(|queue| queue.depth()) |
| 223 | .unwrap_or(0) |
| 224 | } |
| 225 | } |
| 226 | |
| 227 | #[derive(Clone)] |