instr(buffer): More temporary metrics around dequeue (#4030)

getsentry · Sep 13, 2024 · 5d351d5 · 5d351d5
1 parent c08c634
commit 5d351d5
Showing 1 changed file with 20 additions and 0 deletions.
diff --git 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;
         }