(&self)
| 291 | } |
| 292 | |
| 293 | fn get_status(&self) -> GuildStatus { |
| 294 | GuildStatus { |
| 295 | vm: VmSessionStatus { |
| 296 | current_claimed_worker: self.session.as_ref().map(|v| v.worker_id()), |
| 297 | claimed_worker_at: self.last_claimed_worker_at, |
| 298 | returned_worker_at: self.last_returned_worker_at, |
| 299 | last_claimed_worker: self.last_claimed_worker_id, |
| 300 | num_pending_acks: self |
| 301 | .session |
| 302 | .as_ref() |
| 303 | .map(|v| v.num_pending_acks()) |
| 304 | .unwrap_or(0), |
| 305 | }, |
| 306 | } |
| 307 | } |
| 308 | |
| 309 | async fn handle_broker_event(&mut self, evt: DiscordEvent) { |
| 310 | crate::dispatch_metrics::record_stage("guild_handler_recv", "discord", evt.timestamp); |
no test coverage detected