commit a5263131cd8c64cc040e021ac32095a314b6e44c
author Kaushik Lingarkar <kaushik.lingarkar@linaro.org> Fri Jul 07 16:29:33 2023 +0000
committer Gerrit Code Review <noreply-gerritcodereview@google.com> Fri Jul 07 16:29:33 2023 +0000
tree 9c4c703c6a55b14491a5558354947c463ecdeaf9
parent 3ec47c72ae6bce119eb9e0f1c448454d7fcc7b19
parent e4fa3953965cf817f5e5331b5954c3f907536a29

Merge "Add trace timer around Elasticsearch's performRequest" into stable-3.5

src/main/java/com/google/gerrit/elasticsearch/AbstractElasticIndex.java

diff --git a/src/main/java/com/google/gerrit/elasticsearch/AbstractElasticIndex.java b/src/main/java/com/google/gerrit/elasticsearch/AbstractElasticIndex.java
index fce86b9..1aac6e7 100644
--- a/src/main/java/com/google/gerrit/elasticsearch/AbstractElasticIndex.java
+++ b/src/main/java/com/google/gerrit/elasticsearch/AbstractElasticIndex.java
@@ -52,6 +52,8 @@
 import com.google.gerrit.server.config.SitePaths;
 import com.google.gerrit.server.index.IndexUtils;
 import com.google.gerrit.server.index.options.AutoFlush;
+import com.google.gerrit.server.logging.Metadata;
+import com.google.gerrit.server.logging.TraceContext;
 import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;
 import com.google.gson.JsonArray;
@@ -354,7 +356,15 @@
     for (Map.Entry<String, String> entry : params.entrySet()) {
       request.addParameter(entry.getKey(), entry.getValue());
     }
-    try {
+    try (TraceContext.TraceTimer traceTimer =
+        TraceContext.newTimer(
+            "Elasticsearch perform request",
+            Metadata.builder()
+                .indexName(indexName)
+                .operationName(
+                    String.format(
+                        "method:%s uri:%s payload:%s params:%s", method, uri, payload, params))
+                .build())) {
       return client.get().performRequest(request);
     } catch (IOException e) {
       throw new StorageException(e);