enable OTLP export

service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerConfiguration.java

@@ -45,6 +45,7 @@ import org.whispersystems.textsecuregcm.configuration.MessageByteLimitCardinalit
 import org.whispersystems.textsecuregcm.configuration.MessageCacheConfiguration;
 import org.whispersystems.textsecuregcm.configuration.NoiseTunnelConfiguration;
 import org.whispersystems.textsecuregcm.configuration.OneTimeDonationConfiguration;
+import org.whispersystems.textsecuregcm.configuration.OpenTelemetryConfiguration;
 import org.whispersystems.textsecuregcm.configuration.PagedSingleUseKEMPreKeyStoreConfiguration;
 import org.whispersystems.textsecuregcm.configuration.PaymentsServiceConfiguration;
 import org.whispersystems.textsecuregcm.configuration.RegistrationServiceClientFactory;
@@ -138,6 +139,11 @@ public class WhisperServerConfiguration extends Configuration {
   @JsonProperty
   private DatadogConfiguration dogstatsd = new DogstatsdConfiguration();
 
+  @NotNull
+  @Valid
+  @JsonProperty
+  private OpenTelemetryConfiguration openTelemetry;
+
   @NotNull
   @Valid
   @JsonProperty
@@ -442,6 +448,10 @@ public class WhisperServerConfiguration extends Configuration {
     return dogstatsd;
   }
 
+  public OpenTelemetryConfiguration getOpenTelemetryConfiguration() {
+    return openTelemetry;
+  }
+
   public UnidentifiedDeliveryConfiguration getDeliveryCertificate() {
     return unidentifiedDelivery;
   }

service/src/main/java/org/whispersystems/textsecuregcm/configuration/DatadogConfiguration.java

@@ -13,6 +13,8 @@ import java.time.Duration;
 @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "type", defaultImpl = DogstatsdConfiguration.class)
 public interface DatadogConfiguration extends StatsdConfig, Discoverable {
 
+  boolean enabled();
+
   String getEnvironment();
 
   Duration getShutdownWaitDuration();

service/src/main/java/org/whispersystems/textsecuregcm/configuration/DogstatsdConfiguration.java

@@ -15,6 +15,9 @@ import java.time.Duration;
 @JsonTypeName("default")
 public class DogstatsdConfiguration implements DatadogConfiguration {
 
+  @JsonProperty
+  private boolean enabled = true;
+
   @JsonProperty
   @NotNull
   private Duration step = Duration.ofSeconds(10);
@@ -27,6 +30,11 @@ public class DogstatsdConfiguration implements DatadogConfiguration {
   @NotBlank
   private String host;
 
+  @Override
+  public boolean enabled() {
+    return enabled;
+  }
+
   @Override
   public Duration step() {
     return step;

service/src/main/java/org/whispersystems/textsecuregcm/configuration/OpenTelemetryConfiguration.java

@@ -0,0 +1,33 @@
+/*
+ * Copyright 2025 Signal Messenger, LLC
+ * SPDX-License-Identifier: AGPL-3.0-only
+ */
+
+package org.whispersystems.textsecuregcm.configuration;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.micrometer.registry.otlp.OtlpConfig;
+import java.time.Duration;
+import java.util.Map;
+
+public record OpenTelemetryConfiguration(
+  @JsonProperty boolean enabled,
+  @JsonProperty Duration shutdownWaitDuration,
+  @JsonAnyGetter @JsonAnySetter Map<String, String> otlpConfig
+) implements OtlpConfig {
+
+  @Override
+  public String get(String key) {
+    return otlpConfig.get(key.split("\\.", 2)[1]);
+  }
+
+  public Duration shutdownWaitDuration() {
+    if (shutdownWaitDuration == null) {
+      return step().plus(step().dividedBy(2));
+    }
+    return shutdownWaitDuration;
+  }
+
+}

service/src/main/java/org/whispersystems/textsecuregcm/metrics/MetricsUtil.java

@@ -19,7 +19,11 @@ import io.micrometer.core.instrument.binder.system.FileDescriptorMetrics;
 import io.micrometer.core.instrument.binder.system.ProcessorMetrics;
 import io.micrometer.core.instrument.config.MeterFilter;
 import io.micrometer.core.instrument.distribution.DistributionStatisticConfig;
+import io.micrometer.registry.otlp.OtlpMeterRegistry;
 import io.micrometer.statsd.StatsdMeterRegistry;
+
+import java.time.Duration;
+
 import org.whispersystems.textsecuregcm.WhisperServerConfiguration;
 import org.whispersystems.textsecuregcm.WhisperServerVersion;
 import org.whispersystems.textsecuregcm.configuration.dynamic.DynamicConfiguration;
@@ -59,7 +63,9 @@ public class MetricsUtil {
 
     SharedMetricRegistries.add(Constants.METRICS_NAME, environment.metrics());
 
-    {
+    Duration shutdownWaitDuration = Duration.ZERO;
+
+    if (config.getDatadogConfiguration() != null && config.getDatadogConfiguration().enabled()) {
       final StatsdMeterRegistry dogstatsdMeterRegistry = new StatsdMeterRegistry(
           config.getDatadogConfiguration(), io.micrometer.core.instrument.Clock.SYSTEM);
 
@@ -71,6 +77,20 @@ public class MetricsUtil {
 
       configureMeterFilters(dogstatsdMeterRegistry.config(), dynamicConfigurationManager);
       Metrics.addRegistry(dogstatsdMeterRegistry);
+
+      shutdownWaitDuration = config.getDatadogConfiguration().getShutdownWaitDuration();
+    }
+
+    if (config.getOpenTelemetryConfiguration() != null && config.getOpenTelemetryConfiguration().enabled()) {
+      final OtlpMeterRegistry otlpMeterRegistry = new OtlpMeterRegistry(
+        config.getOpenTelemetryConfiguration(), io.micrometer.core.instrument.Clock.SYSTEM);
+
+      configureMeterFilters(otlpMeterRegistry.config(), dynamicConfigurationManager);
+      Metrics.addRegistry(otlpMeterRegistry);
+
+      if (config.getOpenTelemetryConfiguration().shutdownWaitDuration().compareTo(shutdownWaitDuration) > 0) {
+        shutdownWaitDuration = config.getOpenTelemetryConfiguration().shutdownWaitDuration();
+      }
     }
 
     environment.lifecycle().addServerLifecycleListener(
@@ -78,8 +98,7 @@ public class MetricsUtil {
 
     environment.lifecycle().addEventListener(new ApplicationShutdownMonitor(Metrics.globalRegistry));
     environment.lifecycle().addEventListener(
-        new MicrometerRegistryManager(Metrics.globalRegistry,
-            config.getDatadogConfiguration().getShutdownWaitDuration()));
+        new MicrometerRegistryManager(Metrics.globalRegistry, shutdownWaitDuration));
   }
 
   @VisibleForTesting