Fix instrumentation scope names

apache · Feb 5, 2024 · d84655b · d84655b
1 parent fa444c7
commit d84655b
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/PulsarBrokerOpenTelemetry.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/PulsarBrokerOpenTelemetry.java
@@ -26,14 +26,15 @@
 
 public class PulsarBrokerOpenTelemetry implements Closeable {
 
+    private static final String INSTRUMENTATION_SCOPE_NAME = "org.apache.pulsar.broker";
     private final OpenTelemetryService openTelemetryService;
 
     @Getter
     private final Meter meter;
 
     public PulsarBrokerOpenTelemetry(ServiceConfiguration config) {
         openTelemetryService = OpenTelemetryService.builder().clusterName(config.getClusterName()).build();
-        meter = openTelemetryService.getMeter("pulsar.broker");
+        meter = openTelemetryService.getMeter(INSTRUMENTATION_SCOPE_NAME);
     }
 
     @Override

diff --git a/...ker/src/main/java/org/apache/pulsar/functions/worker/stats/PulsarWorkerOpenTelemetry.java b/...ker/src/main/java/org/apache/pulsar/functions/worker/stats/PulsarWorkerOpenTelemetry.java
@@ -26,6 +26,7 @@
 
 public class PulsarWorkerOpenTelemetry implements Closeable {
 
+    private static final String INSTRUMENTATION_SCOPE_NAME = "org.apache.pulsar.function_worker";
     private final OpenTelemetryService openTelemetryService;
 
     @Getter
@@ -34,7 +35,7 @@ public class PulsarWorkerOpenTelemetry implements Closeable {
     public PulsarWorkerOpenTelemetry(WorkerConfig workerConfig) {
         openTelemetryService =
                 OpenTelemetryService.builder().clusterName(workerConfig.getPulsarFunctionsCluster()).build();
-        meter = openTelemetryService.getMeter("pulsar.worker");
+        meter = openTelemetryService.getMeter(INSTRUMENTATION_SCOPE_NAME);
     }
 
     public void close() {

diff --git a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/stats/PulsarProxyOpenTelemetry.java b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/stats/PulsarProxyOpenTelemetry.java
@@ -26,6 +26,7 @@
 
 public class PulsarProxyOpenTelemetry implements Closeable {
 
+    private static final String INSTRUMENTATION_SCOPE_NAME = "org.apache.pulsar.proxy";
     private final OpenTelemetryService openTelemetryService;
 
     @Getter
@@ -34,7 +35,7 @@ public class PulsarProxyOpenTelemetry implements Closeable {
     public PulsarProxyOpenTelemetry(ProxyService proxyService) {
         openTelemetryService =
                 OpenTelemetryService.builder().clusterName(proxyService.getConfiguration().getClusterName()).build();
-        meter = openTelemetryService.getMeter("pulsar.proxy");
+        meter = openTelemetryService.getMeter(INSTRUMENTATION_SCOPE_NAME);
     }
 
     @Override