Add metric pipelines type to Observability Pipelines API

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

@@ -19,7 +19,11 @@
 import java.util.Map;
 import java.util.Objects;
 
-/** The <code>azure_storage</code> destination forwards logs to an Azure Blob Storage container. */
+/**
+ * The <code>azure_storage</code> destination forwards logs to an Azure Blob Storage container.
+ *
+ * <p><strong>Supported pipeline types:</strong> logs
+ */
 @JsonPropertyOrder({
   AzureStorageDestination.JSON_PROPERTY_BLOB_PREFIX,
   AzureStorageDestination.JSON_PROPERTY_CONTAINER_NAME,

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

@@ -19,7 +19,11 @@
 import java.util.Map;
 import java.util.Objects;
 
-/** The <code>microsoft_sentinel</code> destination forwards logs to Microsoft Sentinel. */
+/**
+ * The <code>microsoft_sentinel</code> destination forwards logs to Microsoft Sentinel.
+ *
+ * <p><strong>Supported pipeline types:</strong> logs
+ */
 @JsonPropertyOrder({
   MicrosoftSentinelDestination.JSON_PROPERTY_CLIENT_ID,
   MicrosoftSentinelDestination.JSON_PROPERTY_DCR_IMMUTABLE_ID,

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

@@ -19,7 +19,11 @@
 import java.util.Map;
 import java.util.Objects;
 
-/** The <code>add_env_vars</code> processor adds environment variable values to log events. */
+/**
+ * The <code>add_env_vars</code> processor adds environment variable values to log events.
+ *
+ * <p><strong>Supported pipeline types:</strong> logs
+ */
 @JsonPropertyOrder({
   ObservabilityPipelineAddEnvVarsProcessor.JSON_PROPERTY_DISPLAY_NAME,
   ObservabilityPipelineAddEnvVarsProcessor.JSON_PROPERTY_ENABLED,

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

@@ -19,7 +19,11 @@
 import java.util.Map;
 import java.util.Objects;
 
-/** The <code>add_fields</code> processor adds static key-value fields to logs. */
+/**
+ * The <code>add_fields</code> processor adds static key-value fields to logs.
+ *
+ * <p><strong>Supported pipeline types:</strong> logs
+ */
 @JsonPropertyOrder({
   ObservabilityPipelineAddFieldsProcessor.JSON_PROPERTY_DISPLAY_NAME,
   ObservabilityPipelineAddFieldsProcessor.JSON_PROPERTY_ENABLED,

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

@@ -17,7 +17,11 @@
 import java.util.Map;
 import java.util.Objects;
 
-/** The <code>amazon_data_firehose</code> source ingests logs from AWS Data Firehose. */
+/**
+ * The <code>amazon_data_firehose</code> source ingests logs from AWS Data Firehose.
+ *
+ * <p><strong>Supported pipeline types:</strong> logs
+ */
 @JsonPropertyOrder({
   ObservabilityPipelineAmazonDataFirehoseSource.JSON_PROPERTY_AUTH,
   ObservabilityPipelineAmazonDataFirehoseSource.JSON_PROPERTY_ID,

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

@@ -19,7 +19,11 @@
 import java.util.Map;
 import java.util.Objects;
 
-/** The <code>amazon_opensearch</code> destination writes logs to Amazon OpenSearch. */
+/**
+ * The <code>amazon_opensearch</code> destination writes logs to Amazon OpenSearch.
+ *
+ * <p><strong>Supported pipeline types:</strong> logs
+ */
 @JsonPropertyOrder({
   ObservabilityPipelineAmazonOpenSearchDestination.JSON_PROPERTY_AUTH,
   ObservabilityPipelineAmazonOpenSearchDestination.JSON_PROPERTY_BULK_INDEX,

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

@@ -22,6 +22,8 @@
 /**
  * The <code>amazon_s3</code> destination sends your logs in Datadog-rehydratable format to an
  * Amazon S3 bucket for archiving.
+ *
+ * <p><strong>Supported pipeline types:</strong> logs
  */
 @JsonPropertyOrder({
   ObservabilityPipelineAmazonS3Destination.JSON_PROPERTY_AUTH,

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

@@ -20,6 +20,8 @@
 /**
  * The <code>amazon_s3</code> source ingests logs from an Amazon S3 bucket. It supports AWS
  * authentication and TLS encryption.
+ *
+ * <p><strong>Supported pipeline types:</strong> logs
  */
 @JsonPropertyOrder({
   ObservabilityPipelineAmazonS3Source.JSON_PROPERTY_AUTH,

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

@@ -19,7 +19,11 @@
 import java.util.Map;
 import java.util.Objects;
 
-/** The <code>amazon_security_lake</code> destination sends your logs to Amazon Security Lake. */
+/**
+ * The <code>amazon_security_lake</code> destination sends your logs to Amazon Security Lake.
+ *
+ * <p><strong>Supported pipeline types:</strong> logs
+ */
 @JsonPropertyOrder({
   ObservabilityPipelineAmazonSecurityLakeDestination.JSON_PROPERTY_AUTH,
   ObservabilityPipelineAmazonSecurityLakeDestination.JSON_PROPERTY_BUCKET,

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

@@ -22,6 +22,7 @@
 /** Specifies the pipeline's configuration, including its sources, processors, and destinations. */
 @JsonPropertyOrder({
   ObservabilityPipelineConfig.JSON_PROPERTY_DESTINATIONS,
+  ObservabilityPipelineConfig.JSON_PROPERTY_PIPELINE_TYPE,
   ObservabilityPipelineConfig.JSON_PROPERTY_PROCESSORS,
   ObservabilityPipelineConfig.JSON_PROPERTY_SOURCES
 })
@@ -32,6 +33,10 @@ public class ObservabilityPipelineConfig {
   public static final String JSON_PROPERTY_DESTINATIONS = "destinations";
   private List<ObservabilityPipelineConfigDestinationItem> destinations = new ArrayList<>();
 
+  public static final String JSON_PROPERTY_PIPELINE_TYPE = "pipeline_type";
+  private ObservabilityPipelineConfigPipelineType pipelineType =
+      ObservabilityPipelineConfigPipelineType.LOGS;
+
   public static final String JSON_PROPERTY_PROCESSORS = "processors";
   private List<ObservabilityPipelineConfigProcessorGroup> processors = null;
 
@@ -81,6 +86,32 @@ public void setDestinations(List<ObservabilityPipelineConfigDestinationItem> des
     this.destinations = destinations;
   }
 
+  public ObservabilityPipelineConfig pipelineType(
+      ObservabilityPipelineConfigPipelineType pipelineType) {
+    this.pipelineType = pipelineType;
+    this.unparsed |= !pipelineType.isValid();
+    return this;
+  }
+
+  /**
+   * The type of data being ingested. Defaults to <code>logs</code> if not specified.
+   *
+   * @return pipelineType
+   */
+  @jakarta.annotation.Nullable
+  @JsonProperty(JSON_PROPERTY_PIPELINE_TYPE)
+  @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+  public ObservabilityPipelineConfigPipelineType getPipelineType() {
+    return pipelineType;
+  }
+
+  public void setPipelineType(ObservabilityPipelineConfigPipelineType pipelineType) {
+    if (!pipelineType.isValid()) {
+      this.unparsed = true;
+    }
+    this.pipelineType = pipelineType;
+  }
+
   public ObservabilityPipelineConfig processors(
       List<ObservabilityPipelineConfigProcessorGroup> processors) {
     this.processors = processors;
@@ -203,6 +234,7 @@ public boolean equals(Object o) {
     }
     ObservabilityPipelineConfig observabilityPipelineConfig = (ObservabilityPipelineConfig) o;
     return Objects.equals(this.destinations, observabilityPipelineConfig.destinations)
+        && Objects.equals(this.pipelineType, observabilityPipelineConfig.pipelineType)
         && Objects.equals(this.processors, observabilityPipelineConfig.processors)
         && Objects.equals(this.sources, observabilityPipelineConfig.sources)
         && Objects.equals(
@@ -211,14 +243,15 @@ public boolean equals(Object o) {
 
   @Override
   public int hashCode() {
-    return Objects.hash(destinations, processors, sources, additionalProperties);
+    return Objects.hash(destinations, pipelineType, processors, sources, additionalProperties);
   }
 
   @Override
   public String toString() {
     StringBuilder sb = new StringBuilder();
     sb.append("class ObservabilityPipelineConfig {\n");
     sb.append("    destinations: ").append(toIndentedString(destinations)).append("\n");
+    sb.append("    pipelineType: ").append(toIndentedString(pipelineType)).append("\n");
     sb.append("    processors: ").append(toIndentedString(processors)).append("\n");
     sb.append("    sources: ").append(toIndentedString(sources)).append("\n");
     sb.append("    additionalProperties: ")