Rename package to org.apache.pulsar.opentelemetry

apache · Feb 8, 2024 · c5e4ae2 · c5e4ae2
1 parent baa4fa9
commit c5e4ae2
Show file tree

Hide file tree

Showing 7 changed files with 9 additions and 7 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
@@ -23,7 +23,7 @@
 import lombok.Getter;
 import org.apache.pulsar.PulsarVersion;
 import org.apache.pulsar.broker.ServiceConfiguration;
-import org.apache.pulsar.common.stats.OpenTelemetryService;
+import org.apache.pulsar.opentelemetry.OpenTelemetryService;
 
 public class PulsarBrokerOpenTelemetry implements Closeable {
 

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
@@ -22,7 +22,7 @@
 import java.io.Closeable;
 import lombok.Getter;
 import org.apache.pulsar.PulsarVersion;
-import org.apache.pulsar.common.stats.OpenTelemetryService;
+import org.apache.pulsar.opentelemetry.OpenTelemetryService;
 import org.apache.pulsar.functions.worker.WorkerConfig;
 
 public class PulsarWorkerOpenTelemetry implements Closeable {

diff --git a/...common/stats/OpenTelemetryAttributes.java → ...pentelemetry/OpenTelemetryAttributes.java b/...common/stats/OpenTelemetryAttributes.java → ...pentelemetry/OpenTelemetryAttributes.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.pulsar.common.stats;
+package org.apache.pulsar.opentelemetry;
 
 import io.opentelemetry.api.common.AttributeKey;
 

diff --git a/...ar/common/stats/OpenTelemetryService.java → ...r/opentelemetry/OpenTelemetryService.java b/...ar/common/stats/OpenTelemetryService.java → ...r/opentelemetry/OpenTelemetryService.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.pulsar.common.stats;
+package org.apache.pulsar.opentelemetry;
 
 import static com.google.common.base.Preconditions.checkArgument;
 import com.google.common.annotations.VisibleForTesting;

diff --git a/...che/pulsar/common/stats/package-info.java → ...he/pulsar/opentelemetry/package-info.java b/...che/pulsar/common/stats/package-info.java → ...he/pulsar/opentelemetry/package-info.java
@@ -16,4 +16,4 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.pulsar.common.stats;
+package org.apache.pulsar.opentelemetry;
diff --git a/...ommon/stats/OpenTelemetryServiceTest.java → ...entelemetry/OpenTelemetryServiceTest.java b/...ommon/stats/OpenTelemetryServiceTest.java → ...entelemetry/OpenTelemetryServiceTest.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.pulsar.common.stats;
+package org.apache.pulsar.opentelemetry;
 
 import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.assertThat;
 import static org.testng.Assert.assertEquals;
@@ -38,6 +38,8 @@
 import lombok.Cleanup;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.pulsar.broker.stats.prometheus.PrometheusMetricsClient;
+import org.apache.pulsar.opentelemetry.OpenTelemetryAttributes;
+import org.apache.pulsar.opentelemetry.OpenTelemetryService;
 import org.awaitility.Awaitility;
 import org.testng.annotations.AfterMethod;
 import org.testng.annotations.BeforeMethod;

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
@@ -22,7 +22,7 @@
 import java.io.Closeable;
 import lombok.Getter;
 import org.apache.pulsar.PulsarVersion;
-import org.apache.pulsar.common.stats.OpenTelemetryService;
+import org.apache.pulsar.opentelemetry.OpenTelemetryService;
 import org.apache.pulsar.proxy.server.ProxyConfiguration;
 
 public class PulsarProxyOpenTelemetry implements Closeable {