Regenerate client from commit d715381 of spec repo

Author: ci.datadog-api-spec

.generator/schemas/v2/openapi.yaml

@@ -53206,6 +53206,8 @@ components:
           description: S3 bucket name.
           example: "my-bucket"
           type: string
+        buffer:
+          $ref: "#/components/schemas/ObservabilityPipelineBufferOptions"
         compression:
           $ref: "#/components/schemas/ObservabilityPipelineAmazonS3GenericCompression"
         encoding:
@@ -53455,6 +53457,8 @@ components:
 
         **Supported pipeline types:** logs
       properties:
+        buffer:
+          $ref: "#/components/schemas/ObservabilityPipelineBufferOptions"
         endpoint_url_key:
           description: Name of the environment variable or secret that holds the CloudPrem endpoint URL.
           example: CLOUDPREM_ENDPOINT_URL
@@ -55105,6 +55109,8 @@ components:
       properties:
         auth_strategy:
           $ref: "#/components/schemas/ObservabilityPipelineHttpClientDestinationAuthStrategy"
+        buffer:
+          $ref: "#/components/schemas/ObservabilityPipelineBufferOptions"
         compression:
           $ref: "#/components/schemas/ObservabilityPipelineHttpClientDestinationCompression"
         custom_key:
@@ -55389,6 +55395,8 @@ components:
           description: Name of the environment variable or secret that holds the Kafka bootstrap servers list.
           example: KAFKA_BOOTSTRAP_SERVERS
           type: string
+        buffer:
+          $ref: "#/components/schemas/ObservabilityPipelineBufferOptions"
         compression:
           $ref: "#/components/schemas/ObservabilityPipelineKafkaDestinationCompression"
         encoding:

examples/v2/observability-pipelines/ValidatePipeline_1070998129.java

@@ -0,0 +1,103 @@
+// Validate an observability pipeline with cloud_prem destination buffer returns "OK" response
+
+import com.datadog.api.client.ApiClient;
+import com.datadog.api.client.ApiException;
+import com.datadog.api.client.v2.api.ObservabilityPipelinesApi;
+import com.datadog.api.client.v2.model.ObservabilityPipelineBufferOptions;
+import com.datadog.api.client.v2.model.ObservabilityPipelineBufferOptionsDiskType;
+import com.datadog.api.client.v2.model.ObservabilityPipelineBufferOptionsWhenFull;
+import com.datadog.api.client.v2.model.ObservabilityPipelineCloudPremDestination;
+import com.datadog.api.client.v2.model.ObservabilityPipelineCloudPremDestinationType;
+import com.datadog.api.client.v2.model.ObservabilityPipelineConfig;
+import com.datadog.api.client.v2.model.ObservabilityPipelineConfigDestinationItem;
+import com.datadog.api.client.v2.model.ObservabilityPipelineConfigProcessorGroup;
+import com.datadog.api.client.v2.model.ObservabilityPipelineConfigProcessorItem;
+import com.datadog.api.client.v2.model.ObservabilityPipelineConfigSourceItem;
+import com.datadog.api.client.v2.model.ObservabilityPipelineDataAttributes;
+import com.datadog.api.client.v2.model.ObservabilityPipelineDatadogAgentSource;
+import com.datadog.api.client.v2.model.ObservabilityPipelineDatadogAgentSourceType;
+import com.datadog.api.client.v2.model.ObservabilityPipelineDiskBufferOptions;
+import com.datadog.api.client.v2.model.ObservabilityPipelineFilterProcessor;
+import com.datadog.api.client.v2.model.ObservabilityPipelineFilterProcessorType;
+import com.datadog.api.client.v2.model.ObservabilityPipelineSpec;
+import com.datadog.api.client.v2.model.ObservabilityPipelineSpecData;
+import com.datadog.api.client.v2.model.ValidationResponse;
+import java.util.Collections;
+
+public class Example {
+  public static void main(String[] args) {
+    ApiClient defaultClient = ApiClient.getDefaultApiClient();
+    ObservabilityPipelinesApi apiInstance = new ObservabilityPipelinesApi(defaultClient);
+
+    ObservabilityPipelineSpec body =
+        new ObservabilityPipelineSpec()
+            .data(
+                new ObservabilityPipelineSpecData()
+                    .attributes(
+                        new ObservabilityPipelineDataAttributes()
+                            .config(
+                                new ObservabilityPipelineConfig()
+                                    .destinations(
+                                        Collections.singletonList(
+                                            new ObservabilityPipelineConfigDestinationItem(
+                                                new ObservabilityPipelineCloudPremDestination()
+                                                    .id("cloud-prem-destination")
+                                                    .inputs(
+                                                        Collections.singletonList(
+                                                            "my-processor-group"))
+                                                    .type(
+                                                        ObservabilityPipelineCloudPremDestinationType
+                                                            .CLOUD_PREM)
+                                                    .endpointUrlKey("CLOUDPREM_ENDPOINT_URL")
+                                                    .buffer(
+                                                        new ObservabilityPipelineBufferOptions(
+                                                            new ObservabilityPipelineDiskBufferOptions()
+                                                                .type(
+                                                                    ObservabilityPipelineBufferOptionsDiskType
+                                                                        .DISK)
+                                                                .maxSize(1073741824L)
+                                                                .whenFull(
+                                                                    ObservabilityPipelineBufferOptionsWhenFull
+                                                                        .BLOCK))))))
+                                    .processorGroups(
+                                        Collections.singletonList(
+                                            new ObservabilityPipelineConfigProcessorGroup()
+                                                .enabled(true)
+                                                .id("my-processor-group")
+                                                .include("service:my-service")
+                                                .inputs(
+                                                    Collections.singletonList(
+                                                        "datadog-agent-source"))
+                                                .processors(
+                                                    Collections.singletonList(
+                                                        new ObservabilityPipelineConfigProcessorItem(
+                                                            new ObservabilityPipelineFilterProcessor()
+                                                                .enabled(true)
+                                                                .id("filter-processor")
+                                                                .include("status:error")
+                                                                .type(
+                                                                    ObservabilityPipelineFilterProcessorType
+                                                                        .FILTER))))))
+                                    .sources(
+                                        Collections.singletonList(
+                                            new ObservabilityPipelineConfigSourceItem(
+                                                new ObservabilityPipelineDatadogAgentSource()
+                                                    .id("datadog-agent-source")
+                                                    .type(
+                                                        ObservabilityPipelineDatadogAgentSourceType
+                                                            .DATADOG_AGENT)))))
+                            .name("Pipeline with CloudPrem Buffer"))
+                    .type("pipelines"));
+
+    try {
+      ValidationResponse result = apiInstance.validatePipeline(body);
+      System.out.println(result);
+    } catch (ApiException e) {
+      System.err.println("Exception when calling ObservabilityPipelinesApi#validatePipeline");
+      System.err.println("Status code: " + e.getCode());
+      System.err.println("Reason: " + e.getResponseBody());
+      System.err.println("Response headers: " + e.getResponseHeaders());
+      e.printStackTrace();
+    }
+  }
+}

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

@@ -28,6 +28,7 @@
   ObservabilityPipelineAmazonS3GenericDestination.JSON_PROPERTY_AUTH,
   ObservabilityPipelineAmazonS3GenericDestination.JSON_PROPERTY_BATCH_SETTINGS,
   ObservabilityPipelineAmazonS3GenericDestination.JSON_PROPERTY_BUCKET,
+  ObservabilityPipelineAmazonS3GenericDestination.JSON_PROPERTY_BUFFER,
   ObservabilityPipelineAmazonS3GenericDestination.JSON_PROPERTY_COMPRESSION,
   ObservabilityPipelineAmazonS3GenericDestination.JSON_PROPERTY_ENCODING,
   ObservabilityPipelineAmazonS3GenericDestination.JSON_PROPERTY_ID,
@@ -50,6 +51,9 @@ public class ObservabilityPipelineAmazonS3GenericDestination {
   public static final String JSON_PROPERTY_BUCKET = "bucket";
   private String bucket;
 
+  public static final String JSON_PROPERTY_BUFFER = "buffer";
+  private ObservabilityPipelineBufferOptions buffer;
+
   public static final String JSON_PROPERTY_COMPRESSION = "compression";
   private ObservabilityPipelineAmazonS3GenericCompression compression;
 
@@ -171,6 +175,29 @@ public void setBucket(String bucket) {
     this.bucket = bucket;
   }
 
+  public ObservabilityPipelineAmazonS3GenericDestination buffer(
+      ObservabilityPipelineBufferOptions buffer) {
+    this.buffer = buffer;
+    this.unparsed |= buffer.unparsed;
+    return this;
+  }
+
+  /**
+   * Configuration for buffer settings on destination components.
+   *
+   * @return buffer
+   */
+  @jakarta.annotation.Nullable
+  @JsonProperty(JSON_PROPERTY_BUFFER)
+  @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+  public ObservabilityPipelineBufferOptions getBuffer() {
+    return buffer;
+  }
+
+  public void setBuffer(ObservabilityPipelineBufferOptions buffer) {
+    this.buffer = buffer;
+  }
+
   public ObservabilityPipelineAmazonS3GenericDestination compression(
       ObservabilityPipelineAmazonS3GenericCompression compression) {
     this.compression = compression;
@@ -414,6 +441,7 @@ public boolean equals(Object o) {
         && Objects.equals(
             this.batchSettings, observabilityPipelineAmazonS3GenericDestination.batchSettings)
         && Objects.equals(this.bucket, observabilityPipelineAmazonS3GenericDestination.bucket)
+        && Objects.equals(this.buffer, observabilityPipelineAmazonS3GenericDestination.buffer)
         && Objects.equals(
             this.compression, observabilityPipelineAmazonS3GenericDestination.compression)
         && Objects.equals(this.encoding, observabilityPipelineAmazonS3GenericDestination.encoding)
@@ -435,6 +463,7 @@ public int hashCode() {
         auth,
         batchSettings,
         bucket,
+        buffer,
         compression,
         encoding,
         id,
@@ -453,6 +482,7 @@ public String toString() {
     sb.append("    auth: ").append(toIndentedString(auth)).append("\n");
     sb.append("    batchSettings: ").append(toIndentedString(batchSettings)).append("\n");
     sb.append("    bucket: ").append(toIndentedString(bucket)).append("\n");
+    sb.append("    buffer: ").append(toIndentedString(buffer)).append("\n");
     sb.append("    compression: ").append(toIndentedString(compression)).append("\n");
     sb.append("    encoding: ").append(toIndentedString(encoding)).append("\n");
     sb.append("    id: ").append(toIndentedString(id)).append("\n");

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

@@ -25,6 +25,7 @@
  * <p><strong>Supported pipeline types:</strong> logs
  */
 @JsonPropertyOrder({
+  ObservabilityPipelineCloudPremDestination.JSON_PROPERTY_BUFFER,
   ObservabilityPipelineCloudPremDestination.JSON_PROPERTY_ENDPOINT_URL_KEY,
   ObservabilityPipelineCloudPremDestination.JSON_PROPERTY_ID,
   ObservabilityPipelineCloudPremDestination.JSON_PROPERTY_INPUTS,
@@ -34,6 +35,9 @@
     value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator")
 public class ObservabilityPipelineCloudPremDestination {
   @JsonIgnore public boolean unparsed = false;
+  public static final String JSON_PROPERTY_BUFFER = "buffer";
+  private ObservabilityPipelineBufferOptions buffer;
+
   public static final String JSON_PROPERTY_ENDPOINT_URL_KEY = "endpoint_url_key";
   private String endpointUrlKey;
 
@@ -61,6 +65,29 @@ public ObservabilityPipelineCloudPremDestination(
     this.unparsed |= !type.isValid();
   }
 
+  public ObservabilityPipelineCloudPremDestination buffer(
+      ObservabilityPipelineBufferOptions buffer) {
+    this.buffer = buffer;
+    this.unparsed |= buffer.unparsed;
+    return this;
+  }
+
+  /**
+   * Configuration for buffer settings on destination components.
+   *
+   * @return buffer
+   */
+  @jakarta.annotation.Nullable
+  @JsonProperty(JSON_PROPERTY_BUFFER)
+  @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+  public ObservabilityPipelineBufferOptions getBuffer() {
+    return buffer;
+  }
+
+  public void setBuffer(ObservabilityPipelineBufferOptions buffer) {
+    this.buffer = buffer;
+  }
+
   public ObservabilityPipelineCloudPremDestination endpointUrlKey(String endpointUrlKey) {
     this.endpointUrlKey = endpointUrlKey;
     return this;
@@ -209,7 +236,8 @@ public boolean equals(Object o) {
     }
     ObservabilityPipelineCloudPremDestination observabilityPipelineCloudPremDestination =
         (ObservabilityPipelineCloudPremDestination) o;
-    return Objects.equals(
+    return Objects.equals(this.buffer, observabilityPipelineCloudPremDestination.buffer)
+        && Objects.equals(
             this.endpointUrlKey, observabilityPipelineCloudPremDestination.endpointUrlKey)
         && Objects.equals(this.id, observabilityPipelineCloudPremDestination.id)
         && Objects.equals(this.inputs, observabilityPipelineCloudPremDestination.inputs)
@@ -221,13 +249,14 @@ public boolean equals(Object o) {
 
   @Override
   public int hashCode() {
-    return Objects.hash(endpointUrlKey, id, inputs, type, additionalProperties);
+    return Objects.hash(buffer, endpointUrlKey, id, inputs, type, additionalProperties);
   }
 
   @Override
   public String toString() {
     StringBuilder sb = new StringBuilder();
     sb.append("class ObservabilityPipelineCloudPremDestination {\n");
+    sb.append("    buffer: ").append(toIndentedString(buffer)).append("\n");
     sb.append("    endpointUrlKey: ").append(toIndentedString(endpointUrlKey)).append("\n");
     sb.append("    id: ").append(toIndentedString(id)).append("\n");
     sb.append("    inputs: ").append(toIndentedString(inputs)).append("\n");

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

@@ -26,6 +26,7 @@
  */
 @JsonPropertyOrder({
   ObservabilityPipelineHttpClientDestination.JSON_PROPERTY_AUTH_STRATEGY,
+  ObservabilityPipelineHttpClientDestination.JSON_PROPERTY_BUFFER,
   ObservabilityPipelineHttpClientDestination.JSON_PROPERTY_COMPRESSION,
   ObservabilityPipelineHttpClientDestination.JSON_PROPERTY_CUSTOM_KEY,
   ObservabilityPipelineHttpClientDestination.JSON_PROPERTY_ENCODING,
@@ -45,6 +46,9 @@ public class ObservabilityPipelineHttpClientDestination {
   public static final String JSON_PROPERTY_AUTH_STRATEGY = "auth_strategy";
   private ObservabilityPipelineHttpClientDestinationAuthStrategy authStrategy;
 
+  public static final String JSON_PROPERTY_BUFFER = "buffer";
+  private ObservabilityPipelineBufferOptions buffer;
+
   public static final String JSON_PROPERTY_COMPRESSION = "compression";
   private ObservabilityPipelineHttpClientDestinationCompression compression;
 
@@ -123,6 +127,29 @@ public void setAuthStrategy(ObservabilityPipelineHttpClientDestinationAuthStrate
     this.authStrategy = authStrategy;
   }
 
+  public ObservabilityPipelineHttpClientDestination buffer(
+      ObservabilityPipelineBufferOptions buffer) {
+    this.buffer = buffer;
+    this.unparsed |= buffer.unparsed;
+    return this;
+  }
+
+  /**
+   * Configuration for buffer settings on destination components.
+   *
+   * @return buffer
+   */
+  @jakarta.annotation.Nullable
+  @JsonProperty(JSON_PROPERTY_BUFFER)
+  @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+  public ObservabilityPipelineBufferOptions getBuffer() {
+    return buffer;
+  }
+
+  public void setBuffer(ObservabilityPipelineBufferOptions buffer) {
+    this.buffer = buffer;
+  }
+
   public ObservabilityPipelineHttpClientDestination compression(
       ObservabilityPipelineHttpClientDestinationCompression compression) {
     this.compression = compression;
@@ -432,6 +459,7 @@ public boolean equals(Object o) {
         (ObservabilityPipelineHttpClientDestination) o;
     return Objects.equals(
             this.authStrategy, observabilityPipelineHttpClientDestination.authStrategy)
+        && Objects.equals(this.buffer, observabilityPipelineHttpClientDestination.buffer)
         && Objects.equals(this.compression, observabilityPipelineHttpClientDestination.compression)
         && Objects.equals(this.customKey, observabilityPipelineHttpClientDestination.customKey)
         && Objects.equals(this.encoding, observabilityPipelineHttpClientDestination.encoding)
@@ -452,6 +480,7 @@ public boolean equals(Object o) {
   public int hashCode() {
     return Objects.hash(
         authStrategy,
+        buffer,
         compression,
         customKey,
         encoding,
@@ -471,6 +500,7 @@ public String toString() {
     StringBuilder sb = new StringBuilder();
     sb.append("class ObservabilityPipelineHttpClientDestination {\n");
     sb.append("    authStrategy: ").append(toIndentedString(authStrategy)).append("\n");
+    sb.append("    buffer: ").append(toIndentedString(buffer)).append("\n");
     sb.append("    compression: ").append(toIndentedString(compression)).append("\n");
     sb.append("    customKey: ").append(toIndentedString(customKey)).append("\n");
     sb.append("    encoding: ").append(toIndentedString(encoding)).append("\n");