[DO NOT MERGE] tracing template

gcsio/src/main/java/com/google/cloud/hadoop/gcsio/GoogleCloudStorageImpl.java

@@ -46,6 +46,7 @@
 import com.google.api.gax.core.FixedCredentialsProvider;
 import com.google.api.services.storage.Storage;
 import com.google.api.services.storage.Storage.Objects.Copy;
+import com.google.api.services.storage.Storage.Objects.Get;
 import com.google.api.services.storage.StorageRequest;
 import com.google.api.services.storage.model.Bucket;
 import com.google.api.services.storage.model.Bucket.Lifecycle;
@@ -2324,8 +2325,11 @@ private StorageObject getObject(StorageResourceId resourceId) throws IOException
             // Request only fields used in GoogleCloudStorageItemInfo:
             // https://cloud.google.com/storage/docs/json_api/v1/objects#resource-representations
             .setFields(OBJECT_FIELDS);
+
+    GoogleCloudStorageObjectsRequest getRequest =
+        new GoogleCloudStorageObjectsRequest<Get>(getObject, "getObject");
     try (ITraceOperation op = TraceOperation.addToExistingTrace("gcs.objects.get")) {
-      return getObject.execute();
+      return getRequest.execute();
     } catch (IOException e) {
       if (errorExtractor.itemNotFound(e)) {
         logger.atFiner().withCause(e).log("getObject(%s): not found", resourceId);

gcsio/src/main/java/com/google/cloud/hadoop/gcsio/GoogleCloudStorageObjectsRequest.java

@@ -0,0 +1,29 @@
+package com.google.cloud.hadoop.gcsio;
+
+import com.google.api.services.storage.StorageRequest;
+import com.google.api.services.storage.model.StorageObject;
+import java.io.IOException;
+
+public class GoogleCloudStorageObjectsRequest<T extends StorageRequest<?>>
+    implements StorageObjectRequest<T> {
+  private final T request;
+  private final String operationName;
+
+  public GoogleCloudStorageObjectsRequest(T request, String operationName) {
+    this.request = request;
+    this.operationName = operationName;
+  }
+
+  @Override
+  public StorageObject execute() throws IOException {
+    // Long startTime = System.currentTimeMillis();
+    return (StorageObject) request.execute();
+    // increment GCS_API_TOTAL metric by System.currentTimeMillis() - startTime;
+    // if time is greater > threshold then log
+  }
+
+  @Override
+  public String getOperationName() {
+    return operationName;
+  }
+}

gcsio/src/main/java/com/google/cloud/hadoop/gcsio/StorageObjectRequest.java

@@ -0,0 +1,10 @@
+package com.google.cloud.hadoop.gcsio;
+
+import com.google.api.services.storage.model.StorageObject;
+import java.io.IOException;
+
+public interface StorageObjectRequest<T> {
+  StorageObject execute() throws IOException;
+
+  String getOperationName(); // Method to retrieve the operation name
+}