From 5d351d5916f22c93e2e1fa41a22af0c321e78336 Mon Sep 17 00:00:00 2001 From: Joris Bayer Date: Fri, 13 Sep 2024 08:59:23 +0200 Subject: [PATCH] instr(buffer): More temporary metrics around dequeue (#4030) --- relay-server/src/services/buffer/mod.rs | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) diff --git a/relay-server/src/services/buffer/mod.rs b/relay-server/src/services/buffer/mod.rs index 0a011bfe25..1955642c8b 100644 --- a/relay-server/src/services/buffer/mod.rs +++ b/relay-server/src/services/buffer/mod.rs @@ -147,11 +147,31 @@ impl EnvelopeBufferService { ); self.system_ready(buffer).await; + + relay_statsd::metric!( + counter(RelayCounters::BufferReadyToPop) += 1, + status = "system_ready" + ); + if self.sleep > Duration::ZERO { tokio::time::sleep(self.sleep).await; } + + relay_statsd::metric!( + counter(RelayCounters::BufferReadyToPop) += 1, + status = "slept" + ); + if let Some(project_cache_ready) = self.project_cache_ready.as_mut() { + relay_statsd::metric!( + counter(RelayCounters::BufferReadyToPop) += 1, + status = "waiting_for_project_cache" + ); project_cache_ready.await?; + relay_statsd::metric!( + counter(RelayCounters::BufferReadyToPop) += 1, + status = "waited_for_project_cache" + ); self.project_cache_ready = None; }