OP 2.9.0

.generator/schemas/v2/openapi.yaml

@@ -29300,6 +29300,7 @@ components:
       - $ref: '#/components/schemas/ObservabilityPipelineGooglePubSubSource'
       - $ref: '#/components/schemas/ObservabilityPipelineHttpClientSource'
       - $ref: '#/components/schemas/ObservabilityPipelineLogstashSource'
+      - $ref: '#/components/schemas/ObservabilityPipelineOpentelemetrySource'
       - $ref: '#/components/schemas/ObservabilityPipelineSocketSource'
     ObservabilityPipelineCrowdStrikeNextGenSiemDestination:
       description: The `crowdstrike_next_gen_siem` destination forwards logs to CrowdStrike
@@ -30749,6 +30750,33 @@ components:
       type: string
       x-enum-varnames:
       - OPENSEARCH
+    ObservabilityPipelineOpentelemetrySource:
+      description: The `opentelemetry` source receives OpenTelemetry data through
+        gRPC or HTTP.
+      properties:
+        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.

src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigSourceItem.java

@@ -823,6 +823,57 @@ public ObservabilityPipelineConfigSourceItem deserialize(
             e);
       }
 
+      // deserialize ObservabilityPipelineOpentelemetrySource
+      try {
+        boolean attemptParsing = true;
+        // ensure that we respect type coercion as set on the client ObjectMapper
+        if (ObservabilityPipelineOpentelemetrySource.class.equals(Integer.class)
+            || ObservabilityPipelineOpentelemetrySource.class.equals(Long.class)
+            || ObservabilityPipelineOpentelemetrySource.class.equals(Float.class)
+            || ObservabilityPipelineOpentelemetrySource.class.equals(Double.class)
+            || ObservabilityPipelineOpentelemetrySource.class.equals(Boolean.class)
+            || ObservabilityPipelineOpentelemetrySource.class.equals(String.class)) {
+          attemptParsing = typeCoercion;
+          if (!attemptParsing) {
+            attemptParsing |=
+                ((ObservabilityPipelineOpentelemetrySource.class.equals(Integer.class)
+                        || ObservabilityPipelineOpentelemetrySource.class.equals(Long.class))
+                    && token == JsonToken.VALUE_NUMBER_INT);
+            attemptParsing |=
+                ((ObservabilityPipelineOpentelemetrySource.class.equals(Float.class)
+                        || ObservabilityPipelineOpentelemetrySource.class.equals(Double.class))
+                    && (token == JsonToken.VALUE_NUMBER_FLOAT
+                        || token == JsonToken.VALUE_NUMBER_INT));
+            attemptParsing |=
+                (ObservabilityPipelineOpentelemetrySource.class.equals(Boolean.class)
+                    && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
+            attemptParsing |=
+                (ObservabilityPipelineOpentelemetrySource.class.equals(String.class)
+                    && token == JsonToken.VALUE_STRING);
+          }
+        }
+        if (attemptParsing) {
+          tmp =
+              tree.traverse(jp.getCodec())
+                  .readValueAs(ObservabilityPipelineOpentelemetrySource.class);
+          // TODO: there is no validation against JSON schema constraints
+          // (min, max, enum, pattern...), this does not perform a strict JSON
+          // validation, which means the 'match' count may be higher than it should be.
+          if (!((ObservabilityPipelineOpentelemetrySource) tmp).unparsed) {
+            deserialized = tmp;
+            match++;
+          }
+          log.log(
+              Level.FINER, "Input data matches schema 'ObservabilityPipelineOpentelemetrySource'");
+        }
+      } catch (Exception e) {
+        // deserialization failed, continue
+        log.log(
+            Level.FINER,
+            "Input data does not match schema 'ObservabilityPipelineOpentelemetrySource'",
+            e);
+      }
+
       // deserialize ObservabilityPipelineSocketSource
       try {
         boolean attemptParsing = true;
@@ -974,6 +1025,11 @@ public ObservabilityPipelineConfigSourceItem(ObservabilityPipelineLogstashSource
     setActualInstance(o);
   }
 
+  public ObservabilityPipelineConfigSourceItem(ObservabilityPipelineOpentelemetrySource o) {
+    super("oneOf", Boolean.FALSE);
+    setActualInstance(o);
+  }
+
   public ObservabilityPipelineConfigSourceItem(ObservabilityPipelineSocketSource o) {
     super("oneOf", Boolean.FALSE);
     setActualInstance(o);
@@ -1024,6 +1080,9 @@ public ObservabilityPipelineConfigSourceItem(ObservabilityPipelineSocketSource o
     schemas.put(
         "ObservabilityPipelineLogstashSource",
         new GenericType<ObservabilityPipelineLogstashSource>() {});
+    schemas.put(
+        "ObservabilityPipelineOpentelemetrySource",
+        new GenericType<ObservabilityPipelineOpentelemetrySource>() {});
     schemas.put(
         "ObservabilityPipelineSocketSource",
         new GenericType<ObservabilityPipelineSocketSource>() {});
@@ -1046,7 +1105,7 @@ public Map<String, GenericType> getSchemas() {
    * ObservabilityPipelineRsyslogSource, ObservabilityPipelineSyslogNgSource,
    * ObservabilityPipelineAmazonDataFirehoseSource, ObservabilityPipelineGooglePubSubSource,
    * ObservabilityPipelineHttpClientSource, ObservabilityPipelineLogstashSource,
-   * ObservabilityPipelineSocketSource
+   * ObservabilityPipelineOpentelemetrySource, ObservabilityPipelineSocketSource
    *
    * <p>It could be an instance of the 'oneOf' schemas. The oneOf child schemas may themselves be a
    * composed schema (allOf, anyOf, oneOf).
@@ -1128,6 +1187,11 @@ public void setActualInstance(Object instance) {
       super.setActualInstance(instance);
       return;
     }
+    if (JSON.isInstanceOf(
+        ObservabilityPipelineOpentelemetrySource.class, instance, new HashSet<Class<?>>())) {
+      super.setActualInstance(instance);
+      return;
+    }
     if (JSON.isInstanceOf(
         ObservabilityPipelineSocketSource.class, instance, new HashSet<Class<?>>())) {
       super.setActualInstance(instance);
@@ -1147,7 +1211,8 @@ public void setActualInstance(Object instance) {
             + " ObservabilityPipelineRsyslogSource, ObservabilityPipelineSyslogNgSource,"
             + " ObservabilityPipelineAmazonDataFirehoseSource,"
             + " ObservabilityPipelineGooglePubSubSource, ObservabilityPipelineHttpClientSource,"
-            + " ObservabilityPipelineLogstashSource, ObservabilityPipelineSocketSource");
+            + " ObservabilityPipelineLogstashSource, ObservabilityPipelineOpentelemetrySource,"
+            + " ObservabilityPipelineSocketSource");
   }
 
   /**
@@ -1159,7 +1224,7 @@ public void setActualInstance(Object instance) {
    * ObservabilityPipelineRsyslogSource, ObservabilityPipelineSyslogNgSource,
    * ObservabilityPipelineAmazonDataFirehoseSource, ObservabilityPipelineGooglePubSubSource,
    * ObservabilityPipelineHttpClientSource, ObservabilityPipelineLogstashSource,
-   * ObservabilityPipelineSocketSource
+   * ObservabilityPipelineOpentelemetrySource, ObservabilityPipelineSocketSource
    *
    * @return The actual instance (ObservabilityPipelineKafkaSource,
    *     ObservabilityPipelineDatadogAgentSource, ObservabilityPipelineSplunkTcpSource,
@@ -1169,7 +1234,7 @@ public void setActualInstance(Object instance) {
    *     ObservabilityPipelineRsyslogSource, ObservabilityPipelineSyslogNgSource,
    *     ObservabilityPipelineAmazonDataFirehoseSource, ObservabilityPipelineGooglePubSubSource,
    *     ObservabilityPipelineHttpClientSource, ObservabilityPipelineLogstashSource,
-   *     ObservabilityPipelineSocketSource)
+   *     ObservabilityPipelineOpentelemetrySource, ObservabilityPipelineSocketSource)
    */
   @Override
   public Object getActualInstance() {
@@ -1358,6 +1423,18 @@ public ObservabilityPipelineLogstashSource getObservabilityPipelineLogstashSourc
     return (ObservabilityPipelineLogstashSource) super.getActualInstance();
   }
 
+  /**
+   * Get the actual instance of `ObservabilityPipelineOpentelemetrySource`. If the actual instance
+   * is not `ObservabilityPipelineOpentelemetrySource`, the ClassCastException will be thrown.
+   *
+   * @return The actual instance of `ObservabilityPipelineOpentelemetrySource`
+   * @throws ClassCastException if the instance is not `ObservabilityPipelineOpentelemetrySource`
+   */
+  public ObservabilityPipelineOpentelemetrySource getObservabilityPipelineOpentelemetrySource()
+      throws ClassCastException {
+    return (ObservabilityPipelineOpentelemetrySource) super.getActualInstance();
+  }
+
   /**
    * Get the actual instance of `ObservabilityPipelineSocketSource`. If the actual instance is not
    * `ObservabilityPipelineSocketSource`, the ClassCastException will be thrown.