Add opentelemetry source to Observability Pipelines API

.generator/schemas/v2/openapi.yaml

@@ -35701,6 +35701,7 @@ components:
       - $ref: '#/components/schemas/ObservabilityPipelineHttpClientSource'
       - $ref: '#/components/schemas/ObservabilityPipelineLogstashSource'
       - $ref: '#/components/schemas/ObservabilityPipelineSocketSource'
+      - $ref: '#/components/schemas/ObservabilityPipelineOpentelemetrySource'
     ObservabilityPipelineCrowdStrikeNextGenSiemDestination:
       description: The `crowdstrike_next_gen_siem` destination forwards logs to CrowdStrike
         Next Gen SIEM.
@@ -37180,6 +37181,45 @@ components:
       type: string
       x-enum-varnames:
       - OPENSEARCH
+    ObservabilityPipelineOpentelemetrySource:
+      description: The `opentelemetry` source receives telemetry data using the OpenTelemetry
+        Protocol (OTLP) over gRPC and HTTP.
+      properties:
+        grpc_address_key:
+          description: Environment variable name containing the gRPC server address
+            for receiving OTLP data. Must be a valid environment variable name (alphanumeric
+            characters and underscores only).
+          example: OTEL_GRPC_ADDRESS
+          type: string
+        http_address_key:
+          description: Environment variable name containing the HTTP server address
+            for receiving OTLP data. Must be a valid environment variable name (alphanumeric
+            characters and underscores only).
+          example: OTEL_HTTP_ADDRESS
+          type: string
+        id:
+          description: The unique identifier for this component. Used to reference
+            this component in other parts of the pipeline (e.g., as input to downstream
+            components).
+          example: opentelemetry-source
+          type: string
+        tls:
+          $ref: '#/components/schemas/ObservabilityPipelineTls'
+        type:
+          $ref: '#/components/schemas/ObservabilityPipelineOpentelemetrySourceType'
+      required:
+      - id
+      - type
+      type: object
+    ObservabilityPipelineOpentelemetrySourceType:
+      default: opentelemetry
+      description: The source type. The value should always be `opentelemetry`.
+      enum:
+      - opentelemetry
+      example: opentelemetry
+      type: string
+      x-enum-varnames:
+      - OPENTELEMETRY
     ObservabilityPipelineParseGrokProcessor:
       description: The `parse_grok` processor extracts structured fields from unstructured
         log messages using Grok patterns.

docs/datadog_api_client.v2.model.rst

@@ -16104,6 +16104,20 @@ datadog\_api\_client.v2.model.observability\_pipeline\_open\_search\_destination
    :members:
    :show-inheritance:
 
+datadog\_api\_client.v2.model.observability\_pipeline\_opentelemetry\_source module
+-----------------------------------------------------------------------------------
+
+.. automodule:: datadog_api_client.v2.model.observability_pipeline_opentelemetry_source
+   :members:
+   :show-inheritance:
+
+datadog\_api\_client.v2.model.observability\_pipeline\_opentelemetry\_source\_type module
+-----------------------------------------------------------------------------------------
+
+.. automodule:: datadog_api_client.v2.model.observability_pipeline_opentelemetry_source_type
+   :members:
+   :show-inheritance:
+
 datadog\_api\_client.v2.model.observability\_pipeline\_parse\_grok\_processor module
 ------------------------------------------------------------------------------------
 

src/datadog_api_client/v2/model/observability_pipeline_config.py

@@ -110,6 +110,9 @@
     )
     from datadog_api_client.v2.model.observability_pipeline_logstash_source import ObservabilityPipelineLogstashSource
     from datadog_api_client.v2.model.observability_pipeline_socket_source import ObservabilityPipelineSocketSource
+    from datadog_api_client.v2.model.observability_pipeline_opentelemetry_source import (
+        ObservabilityPipelineOpentelemetrySource,
+    )
 
 
 class ObservabilityPipelineConfig(ModelNormal):
@@ -182,6 +185,7 @@ def __init__(
                 ObservabilityPipelineHttpClientSource,
                 ObservabilityPipelineLogstashSource,
                 ObservabilityPipelineSocketSource,
+                ObservabilityPipelineOpentelemetrySource,
             ]
         ],
         processors: Union[List[ObservabilityPipelineConfigProcessorGroup], UnsetType] = unset,

src/datadog_api_client/v2/model/observability_pipeline_config_source_item.py

@@ -66,6 +66,12 @@ def __init__(self, **kwargs):
 
         :param framing: Framing method configuration for the socket source.
         :type framing: ObservabilityPipelineSocketSourceFraming
+
+        :param grpc_address_key: Environment variable name containing the gRPC server address for receiving OTLP data. Must be a valid environment variable name (alphanumeric characters and underscores only).
+        :type grpc_address_key: str, optional
+
+        :param http_address_key: Environment variable name containing the HTTP server address for receiving OTLP data. Must be a valid environment variable name (alphanumeric characters and underscores only).
+        :type http_address_key: str, optional
         """
         super().__init__(kwargs)
 
@@ -118,6 +124,9 @@ def _composed_schemas(_):
             ObservabilityPipelineLogstashSource,
         )
         from datadog_api_client.v2.model.observability_pipeline_socket_source import ObservabilityPipelineSocketSource
+        from datadog_api_client.v2.model.observability_pipeline_opentelemetry_source import (
+            ObservabilityPipelineOpentelemetrySource,
+        )
 
         return {
             "oneOf": [
@@ -137,5 +146,6 @@ def _composed_schemas(_):
                 ObservabilityPipelineHttpClientSource,
                 ObservabilityPipelineLogstashSource,
                 ObservabilityPipelineSocketSource,
+                ObservabilityPipelineOpentelemetrySource,
             ],
         }

src/datadog_api_client/v2/model/observability_pipeline_opentelemetry_source.py

@@ -0,0 +1,83 @@
+# Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+# This product includes software developed at Datadog (https://www.datadoghq.com/).
+# Copyright 2019-Present Datadog, Inc.
+from __future__ import annotations
+
+from typing import Union, TYPE_CHECKING
+
+from datadog_api_client.model_utils import (
+    ModelNormal,
+    cached_property,
+    unset,
+    UnsetType,
+)
+
+
+if TYPE_CHECKING:
+    from datadog_api_client.v2.model.observability_pipeline_tls import ObservabilityPipelineTls
+    from datadog_api_client.v2.model.observability_pipeline_opentelemetry_source_type import (
+        ObservabilityPipelineOpentelemetrySourceType,
+    )
+
+
+class ObservabilityPipelineOpentelemetrySource(ModelNormal):
+    @cached_property
+    def openapi_types(_):
+        from datadog_api_client.v2.model.observability_pipeline_tls import ObservabilityPipelineTls
+        from datadog_api_client.v2.model.observability_pipeline_opentelemetry_source_type import (
+            ObservabilityPipelineOpentelemetrySourceType,
+        )
+
+        return {
+            "grpc_address_key": (str,),
+            "http_address_key": (str,),
+            "id": (str,),
+            "tls": (ObservabilityPipelineTls,),
+            "type": (ObservabilityPipelineOpentelemetrySourceType,),
+        }
+
+    attribute_map = {
+        "grpc_address_key": "grpc_address_key",
+        "http_address_key": "http_address_key",
+        "id": "id",
+        "tls": "tls",
+        "type": "type",
+    }
+
+    def __init__(
+        self_,
+        id: str,
+        type: ObservabilityPipelineOpentelemetrySourceType,
+        grpc_address_key: Union[str, UnsetType] = unset,
+        http_address_key: Union[str, UnsetType] = unset,
+        tls: Union[ObservabilityPipelineTls, UnsetType] = unset,
+        **kwargs,
+    ):
+        """
+        The ``opentelemetry`` source receives telemetry data using the OpenTelemetry Protocol (OTLP) over gRPC and HTTP.
+
+        :param grpc_address_key: Environment variable name containing the gRPC server address for receiving OTLP data. Must be a valid environment variable name (alphanumeric characters and underscores only).
+        :type grpc_address_key: str, optional
+
+        :param http_address_key: Environment variable name containing the HTTP server address for receiving OTLP data. Must be a valid environment variable name (alphanumeric characters and underscores only).
+        :type http_address_key: str, optional
+
+        :param id: The unique identifier for this component. Used to reference this component in other parts of the pipeline (e.g., as input to downstream components).
+        :type id: str
+
+        :param tls: Configuration for enabling TLS encryption between the pipeline component and external services.
+        :type tls: ObservabilityPipelineTls, optional
+
+        :param type: The source type. The value should always be ``opentelemetry``.
+        :type type: ObservabilityPipelineOpentelemetrySourceType
+        """
+        if grpc_address_key is not unset:
+            kwargs["grpc_address_key"] = grpc_address_key
+        if http_address_key is not unset:
+            kwargs["http_address_key"] = http_address_key
+        if tls is not unset:
+            kwargs["tls"] = tls
+        super().__init__(kwargs)
+
+        self_.id = id
+        self_.type = type

src/datadog_api_client/v2/model/observability_pipeline_opentelemetry_source_type.py

@@ -0,0 +1,37 @@
+# Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+# This product includes software developed at Datadog (https://www.datadoghq.com/).
+# Copyright 2019-Present Datadog, Inc.
+from __future__ import annotations
+
+
+from datadog_api_client.model_utils import (
+    ModelSimple,
+    cached_property,
+)
+
+from typing import ClassVar
+
+
+class ObservabilityPipelineOpentelemetrySourceType(ModelSimple):
+    """
+    The source type. The value should always be `opentelemetry`.
+
+    :param value: If omitted defaults to "opentelemetry". Must be one of ["opentelemetry"].
+    :type value: str
+    """
+
+    allowed_values = {
+        "opentelemetry",
+    }
+    OPENTELEMETRY: ClassVar["ObservabilityPipelineOpentelemetrySourceType"]
+
+    @cached_property
+    def openapi_types(_):
+        return {
+            "value": (str,),
+        }
+
+
+ObservabilityPipelineOpentelemetrySourceType.OPENTELEMETRY = ObservabilityPipelineOpentelemetrySourceType(
+    "opentelemetry"
+)

src/datadog_api_client/v2/models/__init__.py

@@ -3156,6 +3156,12 @@
 from datadog_api_client.v2.model.observability_pipeline_open_search_destination_type import (
     ObservabilityPipelineOpenSearchDestinationType,
 )
+from datadog_api_client.v2.model.observability_pipeline_opentelemetry_source import (
+    ObservabilityPipelineOpentelemetrySource,
+)
+from datadog_api_client.v2.model.observability_pipeline_opentelemetry_source_type import (
+    ObservabilityPipelineOpentelemetrySourceType,
+)
 from datadog_api_client.v2.model.observability_pipeline_parse_grok_processor import (
     ObservabilityPipelineParseGrokProcessor,
 )
@@ -7422,6 +7428,8 @@
     "ObservabilityPipelineOcsfMappingLibrary",
     "ObservabilityPipelineOpenSearchDestination",
     "ObservabilityPipelineOpenSearchDestinationType",
+    "ObservabilityPipelineOpentelemetrySource",
+    "ObservabilityPipelineOpentelemetrySourceType",
     "ObservabilityPipelineParseGrokProcessor",
     "ObservabilityPipelineParseGrokProcessorRule",
     "ObservabilityPipelineParseGrokProcessorRuleMatchRule",