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:

cassettes/features/v2/observability_pipelines/Validate-an-observability-pipeline-with-cloud-prem-destination-buffer-returns-OK-response.frozen

@@ -0,0 +1 @@
+2026-05-21T09:58:44.439Z

cassettes/features/v2/observability_pipelines/Validate-an-observability-pipeline-with-cloud-prem-destination-buffer-returns-OK-response.yml

@@ -0,0 +1,55 @@
+# Validate an observability pipeline with cloud_prem destination buffer returns "OK" response
+
+require "datadog_api_client"
+api_instance = DatadogAPIClient::V2::ObservabilityPipelinesAPI.new
+
+body = DatadogAPIClient::V2::ObservabilityPipelineSpec.new({
+  data: DatadogAPIClient::V2::ObservabilityPipelineSpecData.new({
+    attributes: DatadogAPIClient::V2::ObservabilityPipelineDataAttributes.new({
+      config: DatadogAPIClient::V2::ObservabilityPipelineConfig.new({
+        destinations: [
+          DatadogAPIClient::V2::ObservabilityPipelineCloudPremDestination.new({
+            id: "cloud-prem-destination",
+            inputs: [
+              "my-processor-group",
+            ],
+            type: DatadogAPIClient::V2::ObservabilityPipelineCloudPremDestinationType::CLOUD_PREM,
+            endpoint_url_key: "CLOUDPREM_ENDPOINT_URL",
+            buffer: DatadogAPIClient::V2::ObservabilityPipelineDiskBufferOptions.new({
+              type: DatadogAPIClient::V2::ObservabilityPipelineBufferOptionsDiskType::DISK,
+              max_size: 1073741824,
+              when_full: DatadogAPIClient::V2::ObservabilityPipelineBufferOptionsWhenFull::BLOCK,
+            }),
+          }),
+        ],
+        processor_groups: [
+          DatadogAPIClient::V2::ObservabilityPipelineConfigProcessorGroup.new({
+            enabled: true,
+            id: "my-processor-group",
+            include: "service:my-service",
+            inputs: [
+              "datadog-agent-source",
+            ],
+            processors: [
+              DatadogAPIClient::V2::ObservabilityPipelineFilterProcessor.new({
+                enabled: true,
+                id: "filter-processor",
+                include: "status:error",
+                type: DatadogAPIClient::V2::ObservabilityPipelineFilterProcessorType::FILTER,
+              }),
+            ],
+          }),
+        ],
+        sources: [
+          DatadogAPIClient::V2::ObservabilityPipelineDatadogAgentSource.new({
+            id: "datadog-agent-source",
+            type: DatadogAPIClient::V2::ObservabilityPipelineDatadogAgentSourceType::DATADOG_AGENT,
+          }),
+        ],
+      }),
+      name: "Pipeline with CloudPrem Buffer",
+    }),
+    type: "pipelines",
+  }),
+})
+p api_instance.validate_pipeline(body)

examples/v2/observability-pipelines/ValidatePipeline_1070998129.rb

@@ -247,6 +247,14 @@ Feature: Observability Pipelines
     Then the response status is 200 OK
     And the response "errors" has length 0
 
+  @skip @team:DataDog/observability-pipelines
+  Scenario: Validate an observability pipeline with cloud_prem destination buffer returns "OK" response
+    Given new "ValidatePipeline" request
+    And body with value {"data": {"attributes": {"config": {"destinations": [{"id": "cloud-prem-destination", "inputs": ["my-processor-group"], "type": "cloud_prem", "endpoint_url_key": "CLOUDPREM_ENDPOINT_URL", "buffer": {"type": "disk", "max_size": 1073741824, "when_full": "block"}}], "processor_groups": [{"enabled": true, "id": "my-processor-group", "include": "service:my-service", "inputs": ["datadog-agent-source"], "processors": [{"enabled": true, "id": "filter-processor", "include": "status:error", "type": "filter"}]}], "sources": [{"id": "datadog-agent-source", "type": "datadog_agent"}]}, "name": "Pipeline with CloudPrem Buffer"}, "type": "pipelines"}}
+    When the request is sent
+    Then the response status is 200 OK
+    And the response "errors" has length 0
+
   @team:DataDog/observability-pipelines
   Scenario: Validate an observability pipeline with destination secret key returns "OK" response
     Given new "ValidatePipeline" request

features/v2/observability_pipelines.feature

@@ -33,6 +33,9 @@ class ObservabilityPipelineAmazonS3GenericDestination
     # S3 bucket name.
     attr_reader :bucket
 
+    # Configuration for buffer settings on destination components.
+    attr_accessor :buffer
+
     # Compression algorithm applied to encoded logs.
     attr_reader :compression
 
@@ -66,6 +69,7 @@ def self.attribute_map
         :'auth' => :'auth',
         :'batch_settings' => :'batch_settings',
         :'bucket' => :'bucket',
+        :'buffer' => :'buffer',
         :'compression' => :'compression',
         :'encoding' => :'encoding',
         :'id' => :'id',
@@ -84,6 +88,7 @@ def self.openapi_types
         :'auth' => :'ObservabilityPipelineAwsAuth',
         :'batch_settings' => :'ObservabilityPipelineAmazonS3GenericBatchSettings',
         :'bucket' => :'String',
+        :'buffer' => :'ObservabilityPipelineBufferOptions',
         :'compression' => :'ObservabilityPipelineAmazonS3GenericCompression',
         :'encoding' => :'ObservabilityPipelineAmazonS3GenericEncoding',
         :'id' => :'String',
@@ -125,6 +130,10 @@ def initialize(attributes = {})
         self.bucket = attributes[:'bucket']
       end
 
+      if attributes.key?(:'buffer')
+        self.buffer = attributes[:'buffer']
+      end
+
       if attributes.key?(:'compression')
         self.compression = attributes[:'compression']
       end
@@ -284,6 +293,7 @@ def ==(o)
           auth == o.auth &&
           batch_settings == o.batch_settings &&
           bucket == o.bucket &&
+          buffer == o.buffer &&
           compression == o.compression &&
           encoding == o.encoding &&
           id == o.id &&
@@ -299,7 +309,7 @@ def ==(o)
     # @return [Integer] Hash code
     # @!visibility private
     def hash
-      [auth, batch_settings, bucket, compression, encoding, id, inputs, key_prefix, region, storage_class, type, additional_properties].hash
+      [auth, batch_settings, bucket, buffer, compression, encoding, id, inputs, key_prefix, region, storage_class, type, additional_properties].hash
     end
   end
 end

lib/datadog_api_client/v2/models/observability_pipeline_amazon_s3_generic_destination.rb

@@ -23,6 +23,9 @@ module DatadogAPIClient::V2
   class ObservabilityPipelineCloudPremDestination
     include BaseGenericModel
 
+    # Configuration for buffer settings on destination components.
+    attr_accessor :buffer
+
     # Name of the environment variable or secret that holds the CloudPrem endpoint URL.
     attr_accessor :endpoint_url_key
 
@@ -41,6 +44,7 @@ class ObservabilityPipelineCloudPremDestination
     # @!visibility private
     def self.attribute_map
       {
+        :'buffer' => :'buffer',
         :'endpoint_url_key' => :'endpoint_url_key',
         :'id' => :'id',
         :'inputs' => :'inputs',
@@ -52,6 +56,7 @@ def self.attribute_map
     # @!visibility private
     def self.openapi_types
       {
+        :'buffer' => :'ObservabilityPipelineBufferOptions',
         :'endpoint_url_key' => :'String',
         :'id' => :'String',
         :'inputs' => :'Array<String>',
@@ -77,6 +82,10 @@ def initialize(attributes = {})
         end
       }
 
+      if attributes.key?(:'buffer')
+        self.buffer = attributes[:'buffer']
+      end
+
       if attributes.key?(:'endpoint_url_key')
         self.endpoint_url_key = attributes[:'endpoint_url_key']
       end
@@ -162,6 +171,7 @@ def to_hash
     def ==(o)
       return true if self.equal?(o)
       self.class == o.class &&
+          buffer == o.buffer &&
           endpoint_url_key == o.endpoint_url_key &&
           id == o.id &&
           inputs == o.inputs &&
@@ -173,7 +183,7 @@ def ==(o)
     # @return [Integer] Hash code
     # @!visibility private
     def hash
-      [endpoint_url_key, id, inputs, type, additional_properties].hash
+      [buffer, endpoint_url_key, id, inputs, type, additional_properties].hash
     end
   end
 end

lib/datadog_api_client/v2/models/observability_pipeline_cloud_prem_destination.rb

@@ -26,6 +26,9 @@ class ObservabilityPipelineHttpClientDestination
     # HTTP authentication strategy.
     attr_accessor :auth_strategy
 
+    # Configuration for buffer settings on destination components.
+    attr_accessor :buffer
+
     # Compression configuration for HTTP requests.
     attr_accessor :compression
 
@@ -66,6 +69,7 @@ class ObservabilityPipelineHttpClientDestination
     def self.attribute_map
       {
         :'auth_strategy' => :'auth_strategy',
+        :'buffer' => :'buffer',
         :'compression' => :'compression',
         :'custom_key' => :'custom_key',
         :'encoding' => :'encoding',
@@ -85,6 +89,7 @@ def self.attribute_map
     def self.openapi_types
       {
         :'auth_strategy' => :'ObservabilityPipelineHttpClientDestinationAuthStrategy',
+        :'buffer' => :'ObservabilityPipelineBufferOptions',
         :'compression' => :'ObservabilityPipelineHttpClientDestinationCompression',
         :'custom_key' => :'String',
         :'encoding' => :'ObservabilityPipelineHttpClientDestinationEncoding',
@@ -121,6 +126,10 @@ def initialize(attributes = {})
         self.auth_strategy = attributes[:'auth_strategy']
       end
 
+      if attributes.key?(:'buffer')
+        self.buffer = attributes[:'buffer']
+      end
+
       if attributes.key?(:'compression')
         self.compression = attributes[:'compression']
       end
@@ -246,6 +255,7 @@ def ==(o)
       return true if self.equal?(o)
       self.class == o.class &&
           auth_strategy == o.auth_strategy &&
+          buffer == o.buffer &&
           compression == o.compression &&
           custom_key == o.custom_key &&
           encoding == o.encoding &&
@@ -264,7 +274,7 @@ def ==(o)
     # @return [Integer] Hash code
     # @!visibility private
     def hash
-      [auth_strategy, compression, custom_key, encoding, id, inputs, password_key, tls, token_key, type, uri_key, username_key, additional_properties].hash
+      [auth_strategy, buffer, compression, custom_key, encoding, id, inputs, password_key, tls, token_key, type, uri_key, username_key, additional_properties].hash
     end
   end
 end

lib/datadog_api_client/v2/models/observability_pipeline_http_client_destination.rb

@@ -26,6 +26,9 @@ class ObservabilityPipelineKafkaDestination
     # Name of the environment variable or secret that holds the Kafka bootstrap servers list.
     attr_accessor :bootstrap_servers_key
 
+    # Configuration for buffer settings on destination components.
+    attr_accessor :buffer
+
     # Compression codec for Kafka messages.
     attr_accessor :compression
 
@@ -78,6 +81,7 @@ class ObservabilityPipelineKafkaDestination
     def self.attribute_map
       {
         :'bootstrap_servers_key' => :'bootstrap_servers_key',
+        :'buffer' => :'buffer',
         :'compression' => :'compression',
         :'encoding' => :'encoding',
         :'headers_key' => :'headers_key',
@@ -101,6 +105,7 @@ def self.attribute_map
     def self.openapi_types
       {
         :'bootstrap_servers_key' => :'String',
+        :'buffer' => :'ObservabilityPipelineBufferOptions',
         :'compression' => :'ObservabilityPipelineKafkaDestinationCompression',
         :'encoding' => :'ObservabilityPipelineKafkaDestinationEncoding',
         :'headers_key' => :'String',
@@ -141,6 +146,10 @@ def initialize(attributes = {})
         self.bootstrap_servers_key = attributes[:'bootstrap_servers_key']
       end
 
+      if attributes.key?(:'buffer')
+        self.buffer = attributes[:'buffer']
+      end
+
       if attributes.key?(:'compression')
         self.compression = attributes[:'compression']
       end
@@ -343,6 +352,7 @@ def ==(o)
       return true if self.equal?(o)
       self.class == o.class &&
           bootstrap_servers_key == o.bootstrap_servers_key &&
+          buffer == o.buffer &&
           compression == o.compression &&
           encoding == o.encoding &&
           headers_key == o.headers_key &&
@@ -365,7 +375,7 @@ def ==(o)
     # @return [Integer] Hash code
     # @!visibility private
     def hash
-      [bootstrap_servers_key, compression, encoding, headers_key, id, inputs, key_field, librdkafka_options, message_timeout_ms, rate_limit_duration_secs, rate_limit_num, sasl, socket_timeout_ms, tls, topic, type, additional_properties].hash
+      [bootstrap_servers_key, buffer, compression, encoding, headers_key, id, inputs, key_field, librdkafka_options, message_timeout_ms, rate_limit_duration_secs, rate_limit_num, sasl, socket_timeout_ms, tls, topic, type, additional_properties].hash
     end
   end
 end