Adding datastream to Open Search destination and adding Auth Strategy for Observability Pipeline API (#3400)

Co-authored-by: ci.datadog-api-spec <packages@datadoghq.com>

Author: api-clients-generation-pipeline[bot]

.generator/schemas/v2/openapi.yaml

@@ -38691,12 +38691,14 @@ components:
       - none
       - basic
       - bearer
+      - custom
       example: basic
       type: string
       x-enum-varnames:
       - NONE
       - BASIC
       - BEARER
+      - CUSTOM
     ObservabilityPipelineHttpClientSourceType:
       default: http_client
       description: The source type. The value should always be `http_client`.
@@ -39259,6 +39261,8 @@ components:
           description: The index to write logs to.
           example: logs-index
           type: string
+        data_stream:
+          $ref: '#/components/schemas/ObservabilityPipelineOpenSearchDestinationDataStream'
         id:
           description: The unique identifier for this component.
           example: opensearch-destination
@@ -39280,6 +39284,23 @@ components:
       type: object
       x-pipeline-types:
       - logs
+    ObservabilityPipelineOpenSearchDestinationDataStream:
+      description: Configuration options for writing to OpenSearch Data Streams instead
+        of a fixed index.
+      properties:
+        dataset:
+          description: The data stream dataset for your logs. This groups logs by
+            their source or application.
+          type: string
+        dtype:
+          description: The data stream type for your logs. This determines how logs
+            are categorized within the data stream.
+          type: string
+        namespace:
+          description: The data stream namespace for your logs. This separates logs
+            into different environments or domains.
+          type: string
+      type: object
     ObservabilityPipelineOpenSearchDestinationType:
       default: opensearch
       description: The destination type. The value should always be `opensearch`.

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

@@ -26,14 +26,16 @@
 public class ObservabilityPipelineHttpClientSourceAuthStrategy extends ModelEnum<String> {
 
   private static final Set<String> allowedValues =
-      new HashSet<String>(Arrays.asList("none", "basic", "bearer"));
+      new HashSet<String>(Arrays.asList("none", "basic", "bearer", "custom"));
 
   public static final ObservabilityPipelineHttpClientSourceAuthStrategy NONE =
       new ObservabilityPipelineHttpClientSourceAuthStrategy("none");
   public static final ObservabilityPipelineHttpClientSourceAuthStrategy BASIC =
       new ObservabilityPipelineHttpClientSourceAuthStrategy("basic");
   public static final ObservabilityPipelineHttpClientSourceAuthStrategy BEARER =
       new ObservabilityPipelineHttpClientSourceAuthStrategy("bearer");
+  public static final ObservabilityPipelineHttpClientSourceAuthStrategy CUSTOM =
+      new ObservabilityPipelineHttpClientSourceAuthStrategy("custom");
 
   ObservabilityPipelineHttpClientSourceAuthStrategy(String value) {
     super(value, allowedValues);

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

@@ -26,6 +26,7 @@
  */
 @JsonPropertyOrder({
   ObservabilityPipelineOpenSearchDestination.JSON_PROPERTY_BULK_INDEX,
+  ObservabilityPipelineOpenSearchDestination.JSON_PROPERTY_DATA_STREAM,
   ObservabilityPipelineOpenSearchDestination.JSON_PROPERTY_ID,
   ObservabilityPipelineOpenSearchDestination.JSON_PROPERTY_INPUTS,
   ObservabilityPipelineOpenSearchDestination.JSON_PROPERTY_TYPE
@@ -37,6 +38,9 @@ public class ObservabilityPipelineOpenSearchDestination {
   public static final String JSON_PROPERTY_BULK_INDEX = "bulk_index";
   private String bulkIndex;
 
+  public static final String JSON_PROPERTY_DATA_STREAM = "data_stream";
+  private ObservabilityPipelineOpenSearchDestinationDataStream dataStream;
+
   public static final String JSON_PROPERTY_ID = "id";
   private String id;
 
@@ -82,6 +86,29 @@ public void setBulkIndex(String bulkIndex) {
     this.bulkIndex = bulkIndex;
   }
 
+  public ObservabilityPipelineOpenSearchDestination dataStream(
+      ObservabilityPipelineOpenSearchDestinationDataStream dataStream) {
+    this.dataStream = dataStream;
+    this.unparsed |= dataStream.unparsed;
+    return this;
+  }
+
+  /**
+   * Configuration options for writing to OpenSearch Data Streams instead of a fixed index.
+   *
+   * @return dataStream
+   */
+  @jakarta.annotation.Nullable
+  @JsonProperty(JSON_PROPERTY_DATA_STREAM)
+  @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+  public ObservabilityPipelineOpenSearchDestinationDataStream getDataStream() {
+    return dataStream;
+  }
+
+  public void setDataStream(ObservabilityPipelineOpenSearchDestinationDataStream dataStream) {
+    this.dataStream = dataStream;
+  }
+
   public ObservabilityPipelineOpenSearchDestination id(String id) {
     this.id = id;
     return this;
@@ -211,6 +238,7 @@ public boolean equals(Object o) {
     ObservabilityPipelineOpenSearchDestination observabilityPipelineOpenSearchDestination =
         (ObservabilityPipelineOpenSearchDestination) o;
     return Objects.equals(this.bulkIndex, observabilityPipelineOpenSearchDestination.bulkIndex)
+        && Objects.equals(this.dataStream, observabilityPipelineOpenSearchDestination.dataStream)
         && Objects.equals(this.id, observabilityPipelineOpenSearchDestination.id)
         && Objects.equals(this.inputs, observabilityPipelineOpenSearchDestination.inputs)
         && Objects.equals(this.type, observabilityPipelineOpenSearchDestination.type)
@@ -221,14 +249,15 @@ public boolean equals(Object o) {
 
   @Override
   public int hashCode() {
-    return Objects.hash(bulkIndex, id, inputs, type, additionalProperties);
+    return Objects.hash(bulkIndex, dataStream, id, inputs, type, additionalProperties);
   }
 
   @Override
   public String toString() {
     StringBuilder sb = new StringBuilder();
     sb.append("class ObservabilityPipelineOpenSearchDestination {\n");
     sb.append("    bulkIndex: ").append(toIndentedString(bulkIndex)).append("\n");
+    sb.append("    dataStream: ").append(toIndentedString(dataStream)).append("\n");
     sb.append("    id: ").append(toIndentedString(id)).append("\n");
     sb.append("    inputs: ").append(toIndentedString(inputs)).append("\n");
     sb.append("    type: ").append(toIndentedString(type)).append("\n");

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

@@ -0,0 +1,202 @@
+/*
+ * 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.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+
+/** Configuration options for writing to OpenSearch Data Streams instead of a fixed index. */
+@JsonPropertyOrder({
+  ObservabilityPipelineOpenSearchDestinationDataStream.JSON_PROPERTY_DATASET,
+  ObservabilityPipelineOpenSearchDestinationDataStream.JSON_PROPERTY_DTYPE,
+  ObservabilityPipelineOpenSearchDestinationDataStream.JSON_PROPERTY_NAMESPACE
+})
+@jakarta.annotation.Generated(
+    value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator")
+public class ObservabilityPipelineOpenSearchDestinationDataStream {
+  @JsonIgnore public boolean unparsed = false;
+  public static final String JSON_PROPERTY_DATASET = "dataset";
+  private String dataset;
+
+  public static final String JSON_PROPERTY_DTYPE = "dtype";
+  private String dtype;
+
+  public static final String JSON_PROPERTY_NAMESPACE = "namespace";
+  private String namespace;
+
+  public ObservabilityPipelineOpenSearchDestinationDataStream dataset(String dataset) {
+    this.dataset = dataset;
+    return this;
+  }
+
+  /**
+   * The data stream dataset for your logs. This groups logs by their source or application.
+   *
+   * @return dataset
+   */
+  @jakarta.annotation.Nullable
+  @JsonProperty(JSON_PROPERTY_DATASET)
+  @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+  public String getDataset() {
+    return dataset;
+  }
+
+  public void setDataset(String dataset) {
+    this.dataset = dataset;
+  }
+
+  public ObservabilityPipelineOpenSearchDestinationDataStream dtype(String dtype) {
+    this.dtype = dtype;
+    return this;
+  }
+
+  /**
+   * The data stream type for your logs. This determines how logs are categorized within the data
+   * stream.
+   *
+   * @return dtype
+   */
+  @jakarta.annotation.Nullable
+  @JsonProperty(JSON_PROPERTY_DTYPE)
+  @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+  public String getDtype() {
+    return dtype;
+  }
+
+  public void setDtype(String dtype) {
+    this.dtype = dtype;
+  }
+
+  public ObservabilityPipelineOpenSearchDestinationDataStream namespace(String namespace) {
+    this.namespace = namespace;
+    return this;
+  }
+
+  /**
+   * The data stream namespace for your logs. This separates logs into different environments or
+   * domains.
+   *
+   * @return namespace
+   */
+  @jakarta.annotation.Nullable
+  @JsonProperty(JSON_PROPERTY_NAMESPACE)
+  @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+  public String getNamespace() {
+    return namespace;
+  }
+
+  public void setNamespace(String namespace) {
+    this.namespace = namespace;
+  }
+
+  /**
+   * A container for additional, undeclared properties. This is a holder for any undeclared
+   * properties as specified with the 'additionalProperties' keyword in the OAS document.
+   */
+  private Map<String, Object> additionalProperties;
+
+  /**
+   * Set the additional (undeclared) property with the specified name and value. If the property
+   * does not already exist, create it otherwise replace it.
+   *
+   * @param key The arbitrary key to set
+   * @param value The associated value
+   * @return ObservabilityPipelineOpenSearchDestinationDataStream
+   */
+  @JsonAnySetter
+  public ObservabilityPipelineOpenSearchDestinationDataStream putAdditionalProperty(
+      String key, Object value) {
+    if (this.additionalProperties == null) {
+      this.additionalProperties = new HashMap<String, Object>();
+    }
+    this.additionalProperties.put(key, value);
+    return this;
+  }
+
+  /**
+   * Return the additional (undeclared) property.
+   *
+   * @return The additional properties
+   */
+  @JsonAnyGetter
+  public Map<String, Object> getAdditionalProperties() {
+    return additionalProperties;
+  }
+
+  /**
+   * Return the additional (undeclared) property with the specified name.
+   *
+   * @param key The arbitrary key to get
+   * @return The specific additional property for the given key
+   */
+  public Object getAdditionalProperty(String key) {
+    if (this.additionalProperties == null) {
+      return null;
+    }
+    return this.additionalProperties.get(key);
+  }
+
+  /**
+   * Return true if this ObservabilityPipelineOpenSearchDestinationDataStream object is equal to o.
+   */
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    ObservabilityPipelineOpenSearchDestinationDataStream
+        observabilityPipelineOpenSearchDestinationDataStream =
+            (ObservabilityPipelineOpenSearchDestinationDataStream) o;
+    return Objects.equals(
+            this.dataset, observabilityPipelineOpenSearchDestinationDataStream.dataset)
+        && Objects.equals(this.dtype, observabilityPipelineOpenSearchDestinationDataStream.dtype)
+        && Objects.equals(
+            this.namespace, observabilityPipelineOpenSearchDestinationDataStream.namespace)
+        && Objects.equals(
+            this.additionalProperties,
+            observabilityPipelineOpenSearchDestinationDataStream.additionalProperties);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(dataset, dtype, namespace, additionalProperties);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class ObservabilityPipelineOpenSearchDestinationDataStream {\n");
+    sb.append("    dataset: ").append(toIndentedString(dataset)).append("\n");
+    sb.append("    dtype: ").append(toIndentedString(dtype)).append("\n");
+    sb.append("    namespace: ").append(toIndentedString(namespace)).append("\n");
+    sb.append("    additionalProperties: ")
+        .append(toIndentedString(additionalProperties))
+        .append("\n");
+    sb.append('}');
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces (except the first line).
+   */
+  private String toIndentedString(Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+}