chore: update udp exporter package name to include distro

Author: yiyuan-he

.github/workflows/release-udp-exporter.yml

@@ -9,7 +9,7 @@ on:
         type: string
 env:
   AWS_DEFAULT_REGION: us-east-1
-  ARTIFACT_NAME: aws_otel_otlp_udp_exporter-${{ github.event.inputs.version }}-py3-none-any.whl
+  ARTIFACT_NAME: aws_distro_otel_otlp_udp_exporter-${{ github.event.inputs.version }}-py3-none-any.whl
 
 permissions:
   id-token: write
@@ -32,7 +32,7 @@ jobs:
           pip install hatch pytest flask
 
       - name: Build package
-        working-directory: exporters/aws-otel-otlp-udp-exporter
+        working-directory: exporters/aws-distro-otel-otlp-udp-exporter
         run: hatch build
 
       - name: Download and run X-Ray Daemon
@@ -45,11 +45,11 @@ jobs:
 
       - name: Install UDP Exporter
         run: |
-          pip install ./exporters/aws-otel-otlp-udp-exporter/dist/*.whl
+          pip install ./exporters/aws-distro-otel-otlp-udp-exporter/dist/*.whl
 
       - name: Ensure Unit Tests are passing
         run: |
-          pytest exporters/aws-otel-otlp-udp-exporter/tests/
+          pytest exporters/aws-distro-otel-otlp-udp-exporter/tests/
 
       - name: Run Sample App in Background
         working-directory: sample-applications/integ-test-app
@@ -106,12 +106,12 @@ jobs:
           TWINE_USERNAME: '__token__'
           TWINE_PASSWORD: ${{ env.TEST_PYPI_TOKEN_API_TOKEN }}
         run: |
-          twine upload --repository testpypi --skip-existing --verbose exporters/aws-otel-otlp-udp-exporter/dist/${{ env.ARTIFACT_NAME }}
+          twine upload --repository testpypi --skip-existing --verbose exporters/aws-distro-otel-otlp-udp-exporter/dist/${{ env.ARTIFACT_NAME }}
 
       # Publish to prod PyPI
       - name: Publish to PyPI
         env:
           TWINE_USERNAME: '__token__'
           TWINE_PASSWORD: ${{ env.PROD_PYPI_TOKEN_API_TOKEN }}
         run: |
-          twine upload --skip-existing --verbose exporters/aws-otel-otlp-udp-exporter/dist/${{ env.ARTIFACT_NAME }}
+          twine upload --skip-existing --verbose exporters/aws-distro-otel-otlp-udp-exporter/dist/${{ env.ARTIFACT_NAME }}

exporters/aws-otel-otlp-udp-exporter/README.rst renamed to exporters/aws-distro-otel-otlp-udp-exporter/README.rst

@@ -6,7 +6,7 @@ Installation
 
 ::
 
-    pip install aws-otel-otlp-udp-exporter
+    pip install aws-distro-otel-otlp-udp-exporter
 
 
 This package provides a UDP exporter for OpenTelemetry.

exporters/aws-otel-otlp-udp-exporter/pyproject.toml renamed to exporters/aws-distro-otel-otlp-udp-exporter/pyproject.toml

@@ -3,7 +3,7 @@ requires = ["hatchling"]
 build-backend = "hatchling.build"
 
 [project]
-name = "aws-otel-otlp-udp-exporter"
+name = "aws-distro-otel-otlp-udp-exporter"
 version = "0.1.0"
 description = "OTLP UDP Exporter for OpenTelemetry"
 readme = "README.rst"
@@ -30,7 +30,7 @@ dependencies = [
 ]
 
 [project.urls]
-Homepage = "https://github.com/aws-observability/aws-otel-python-instrumentation/tree/main/exporters/aws-otel-otlp-udp-exporter"
+Homepage = "https://github.com/aws-observability/aws-otel-python-instrumentation/tree/main/exporters/aws-distro-otel-otlp-udp-exporter"
 
 [tool.hatch.build.targets.wheel]
 packages = ["src/amazon"]

exporters/aws-otel-otlp-udp-exporter/src/amazon/opentelemetry/exporters/otlp/udp/__init__.py renamed to exporters/aws-distro-otel-otlp-udp-exporter/src/amazon/distro/opentelemetry/exporters/otlp/udp/__init__.py

@@ -6,7 +6,7 @@
 from unittest import TestCase
 from unittest.mock import MagicMock, patch
 
-from amazon.opentelemetry.exporters.otlp.udp import (
+from amazon.distro.opentelemetry.exporters.otlp.udp import (
     DEFAULT_ENDPOINT,
     FORMAT_OTEL_SAMPLED_TRACES_BINARY_PREFIX,
     FORMAT_OTEL_UNSAMPLED_TRACES_BINARY_PREFIX,
@@ -19,7 +19,7 @@
 
 class TestUdpExporter(TestCase):
 
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.socket.socket")
+    @patch("amazon.distro.opentelemetry.exporters.otlp.udp.exporter.socket.socket")
     def test_udp_exporter_init_default(self, mock_socket):
         exporter = UdpExporter()
         self.assertEqual(exporter._endpoint, DEFAULT_ENDPOINT)
@@ -28,7 +28,7 @@ def test_udp_exporter_init_default(self, mock_socket):
         mock_socket.assert_called_once_with(socket.AF_INET, socket.SOCK_DGRAM)
         mock_socket().setblocking.assert_called_once_with(False)
 
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.socket.socket")
+    @patch("amazon.distro.opentelemetry.exporters.otlp.udp.exporter.socket.socket")
     def test_udp_exporter_init_with_endpoint(self, mock_socket):
         exporter = UdpExporter(endpoint="localhost:5000")
         self.assertNotEqual(exporter._endpoint, DEFAULT_ENDPOINT)
@@ -37,13 +37,13 @@ def test_udp_exporter_init_with_endpoint(self, mock_socket):
         mock_socket.assert_called_once_with(socket.AF_INET, socket.SOCK_DGRAM)
         mock_socket().setblocking.assert_called_once_with(False)
 
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.socket.socket")
+    @patch("amazon.distro.opentelemetry.exporters.otlp.udp.exporter.socket.socket")
     def test_udp_exporter_init_invalid_endpoint(self, mock_socket):
         with self.assertRaises(ValueError):
             UdpExporter(endpoint="invalidEndpoint:port")
 
     # pylint: disable=no-self-use
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.socket.socket")
+    @patch("amazon.distro.opentelemetry.exporters.otlp.udp.exporter.socket.socket")
     def test_send_data(self, mock_socket):
         mock_socket_instance = mock_socket.return_value
         exporter = UdpExporter()
@@ -53,7 +53,7 @@ def test_send_data(self, mock_socket):
         expected_message = PROTOCOL_HEADER + "signal_prefix" + encoded_bytes.decode("utf-8")
         mock_socket_instance.sendto.assert_called_once_with(expected_message.encode("utf-8"), ("127.0.0.1", 2000))
 
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.socket.socket")
+    @patch("amazon.distro.opentelemetry.exporters.otlp.udp.exporter.socket.socket")
     def test_shutdown(self, mock_socket):
         mock_socket_instance = mock_socket.return_value
         exporter = UdpExporter()
@@ -63,8 +63,8 @@ def test_shutdown(self, mock_socket):
 
 class TestOTLPUdpSpanExporter(unittest.TestCase):
 
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.encode_spans")
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.UdpExporter")
+    @patch("amazon.distro.opentelemetry.exporters.otlp.udp.exporter.encode_spans")
+    @patch("amazon.distro.opentelemetry.exporters.otlp.udp.exporter.UdpExporter")
     def test_export_unsampled_span(self, mock_udp_exporter, mock_encode_spans):
         mock_udp_exporter_instance = mock_udp_exporter.return_value
         mock_encoded_data = MagicMock()
@@ -76,8 +76,8 @@ def test_export_unsampled_span(self, mock_udp_exporter, mock_encode_spans):
         )
         self.assertEqual(result, SpanExportResult.SUCCESS)
 
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.encode_spans")
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.UdpExporter")
+    @patch("amazon.distro.opentelemetry.exporters.otlp.udp.exporter.encode_spans")
+    @patch("amazon.distro.opentelemetry.exporters.otlp.udp.exporter.UdpExporter")
     def test_export_sampled_span(self, mock_udp_exporter, mock_encode_spans):
         mock_udp_exporter_instance = mock_udp_exporter.return_value
         mock_encoded_data = MagicMock()
@@ -89,8 +89,8 @@ def test_export_sampled_span(self, mock_udp_exporter, mock_encode_spans):
         )
         self.assertEqual(result, SpanExportResult.SUCCESS)
 
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.encode_spans")
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.UdpExporter")
+    @patch("amazon.distro.opentelemetry.exporters.otlp.udp.exporter.encode_spans")
+    @patch("amazon.distro.opentelemetry.exporters.otlp.udp.exporter.UdpExporter")
     def test_export_with_exception(self, mock_udp_exporter, mock_encode_spans):
         mock_udp_exporter_instance = mock_udp_exporter.return_value
         mock_encoded_data = MagicMock()
@@ -101,7 +101,7 @@ def test_export_with_exception(self, mock_udp_exporter, mock_encode_spans):
         self.assertEqual(result, SpanExportResult.FAILURE)
 
     # pylint: disable=no-self-use
-    @patch("amazon.opentelemetry.exporters.otlp.udp.exporter.UdpExporter")
+    @patch("amazon.distro.opentelemetry.exporters.otlp.udp.exporter.UdpExporter")
     def test_shutdown(self, mock_udp_exporter):
         mock_udp_exporter_instance = mock_udp_exporter.return_value
         exporter = OTLPUdpSpanExporter()

exporters/aws-otel-otlp-udp-exporter/src/amazon/opentelemetry/exporters/otlp/udp/exporter.py renamed to exporters/aws-distro-otel-otlp-udp-exporter/src/amazon/distro/opentelemetry/exporters/otlp/udp/exporter.py

@@ -1,6 +1,6 @@
 from flask import Flask
 
-from amazon.opentelemetry.exporters.otlp.udp import OTLPUdpSpanExporter
+from amazon.distro.opentelemetry.exporters.otlp.udp import OTLPUdpSpanExporter
 from opentelemetry import trace
 from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import BatchSpanProcessor