add exportBuiltinMetricsToGoogleCloudMonitoring flag

google-cloud-firestore/src/main/java/com/google/cloud/firestore/FirestoreOpenTelemetryOptions.java

@@ -28,17 +28,24 @@
 @BetaApi
 public class FirestoreOpenTelemetryOptions {
   private final boolean tracingEnabled;
+  private final boolean exportBuiltinMetricsToGoogleCloudMonitoring;
   private final @Nullable OpenTelemetry openTelemetry;
 
   FirestoreOpenTelemetryOptions(Builder builder) {
     this.tracingEnabled = builder.tracingEnabled;
+    this.exportBuiltinMetricsToGoogleCloudMonitoring =
+        builder.exportBuiltinMetricsToGoogleCloudMonitoring;
     this.openTelemetry = builder.openTelemetry;
   }
 
   public boolean isTracingEnabled() {
     return tracingEnabled;
   }
 
+  public boolean exportBuiltinMetricsToGoogleCloudMonitoring() {
+    return exportBuiltinMetricsToGoogleCloudMonitoring;
+  }
+
   public OpenTelemetry getOpenTelemetry() {
     return openTelemetry;
   }
@@ -56,16 +63,20 @@ public static FirestoreOpenTelemetryOptions.Builder newBuilder() {
   public static class Builder {
 
     private boolean tracingEnabled;
-
+    private boolean exportBuiltinMetricsToGoogleCloudMonitoring;
     @Nullable private OpenTelemetry openTelemetry;
 
     private Builder() {
       tracingEnabled = false;
+      // TODO(metrics): default this to true when feature is ready
+      exportBuiltinMetricsToGoogleCloudMonitoring = false;
       openTelemetry = null;
     }
 
     private Builder(FirestoreOpenTelemetryOptions options) {
       this.tracingEnabled = options.tracingEnabled;
+      this.exportBuiltinMetricsToGoogleCloudMonitoring =
+          options.exportBuiltinMetricsToGoogleCloudMonitoring;
       this.openTelemetry = options.openTelemetry;
     }
 
@@ -85,6 +96,20 @@ public FirestoreOpenTelemetryOptions.Builder setTracingEnabled(boolean tracingEn
       return this;
     }
 
+    // TODO(metrics): make this public when feature is ready.
+    /**
+     * Sets whether built-in metrics should be exported to Google Cloud Monitoring
+     *
+     * @param exportBuiltinMetrics Whether built-in metrics should be exported to Google Cloud
+     *     Monitoring.
+     */
+    @Nonnull
+    private FirestoreOpenTelemetryOptions.Builder exportBuiltinMetricsToGoogleCloudMonitoring(
+        boolean exportBuiltinMetrics) {
+      this.exportBuiltinMetricsToGoogleCloudMonitoring = exportBuiltinMetrics;
+      return this;
+    }
+
     /**
      * Sets the {@link OpenTelemetry} to use with this Firestore instance. If telemetry collection
      * is enabled, but an `OpenTelemetry` is not provided, the Firestore SDK will attempt to use the

google-cloud-firestore/src/main/java/com/google/cloud/firestore/telemetry/BuiltinMetricsProvider.java

@@ -56,7 +56,7 @@ public BuiltinMetricsProvider(OpenTelemetry openTelemetry) {
     this.openTelemetry = openTelemetry;
     this.staticAttributes = createStaticAttributes();
 
-    if (openTelemetry != null && openTelemetry.getMeterProvider() != MeterProvider.noop()) {
+    if (openTelemetry.getMeterProvider() != MeterProvider.noop()) {
       configureRPCLayerMetrics();
       configureSDKLayerMetrics();
     }
@@ -66,7 +66,7 @@ public ApiTracerFactory getApiTracerFactory() {
     return this.apiTracerFactory;
   }
 
-  public void endToEndRequestLatencyRecorder(double latency, Map<String, String> attributes) {
+  public void endToEndLatencyRecorder(double latency, Map<String, String> attributes) {
     recordLatency(endToEndRequestLatency, latency, attributes);
   }
 

google-cloud-firestore/src/main/java/com/google/cloud/firestore/telemetry/EnabledMetricsUtil.java

@@ -71,23 +71,38 @@ class EnabledMetricsUtil implements MetricsUtil {
 
   EnabledMetricsUtil(FirestoreOptions firestoreOptions) {
     try {
-      OpenTelemetry defaultOpenTelemetry =
-          getDefaultOpenTelemetryInstance(firestoreOptions.getProjectId());
-      this.defaultMetricsProvider = new BuiltinMetricsProvider(defaultOpenTelemetry);
-
-      OpenTelemetry customOpenTelemetry =
-          firestoreOptions.getOpenTelemetryOptions().getOpenTelemetry();
-      if (customOpenTelemetry == null) {
-        customOpenTelemetry = GlobalOpenTelemetry.get();
-      }
-      this.customMetricsProvider = new BuiltinMetricsProvider(customOpenTelemetry);
+      configureDefaultMetricsProvider(firestoreOptions);
+      configureCustomMetricsProvider(firestoreOptions);
     } catch (IOException e) {
       logger.warning(
           "Unable to create MetricsUtil object for client side metrics, will skip exporting client side metrics"
               + e);
     }
   }
 
+  private void configureDefaultMetricsProvider(FirestoreOptions firestoreOptions)
+      throws IOException {
+    OpenTelemetry defaultOpenTelemetry;
+    boolean exportBuiltinMetricsToGoogleCloudMonitoring =
+        firestoreOptions.getOpenTelemetryOptions().exportBuiltinMetricsToGoogleCloudMonitoring();
+    if (exportBuiltinMetricsToGoogleCloudMonitoring) {
+      defaultOpenTelemetry = getDefaultOpenTelemetryInstance(firestoreOptions.getProjectId());
+    } else {
+      defaultOpenTelemetry = OpenTelemetry.noop();
+    }
+    this.defaultMetricsProvider = new BuiltinMetricsProvider(defaultOpenTelemetry);
+  }
+
+  private void configureCustomMetricsProvider(FirestoreOptions firestoreOptions)
+      throws IOException {
+    OpenTelemetry customOpenTelemetry =
+        firestoreOptions.getOpenTelemetryOptions().getOpenTelemetry();
+    if (customOpenTelemetry == null) {
+      customOpenTelemetry = GlobalOpenTelemetry.get();
+    }
+    this.customMetricsProvider = new BuiltinMetricsProvider(customOpenTelemetry);
+  }
+
   @Override
   public MetricsContext createMetricsContext(String methodName) {
     return new MetricsContext(methodName);
@@ -196,8 +211,8 @@ public void recordFirstResponseLatency() {
     private void recordEndToEndLatency(String status) {
       double elapsedTime = stopwatch.elapsed(TimeUnit.MILLISECONDS);
       Map<String, String> attributes = createAttributes(status);
-      defaultMetricsProvider.endToEndRequestLatencyRecorder(elapsedTime, attributes);
-      customMetricsProvider.endToEndRequestLatencyRecorder(elapsedTime, attributes);
+      defaultMetricsProvider.endToEndLatencyRecorder(elapsedTime, attributes);
+      customMetricsProvider.endToEndLatencyRecorder(elapsedTime, attributes);
     }
 
     private Map<String, String> createAttributes(String status) {