tiemr

geph-official · Jan 9, 2025 · 90916c8 · 90916c8
1 parent 24cf8f9
commit 90916c8
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/binaries/geph5-broker/src/rpc_impl.rs b/binaries/geph5-broker/src/rpc_impl.rs
@@ -44,10 +44,15 @@ impl RpcService for WrappedBrokerService {
         method: &str,
         params: Vec<serde_json::Value>,
     ) -> Option<Result<serde_json::Value, ServerError>> {
+        let start = Instant::now();
+        let resp = self.0.respond(method, params).await?;
         if let Some(client) = STATSD_CLIENT.as_ref() {
             client.count(&format!("broker.{method}"), 1).unwrap();
+            client
+                .time(&format!("broker_resptime.{method}"), start.elapsed())
+                .unwrap();
         }
-        self.0.respond(method, params).await
+        Some(resp)
     }
 }