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; }