diff --git a/.generator/schemas/v2/openapi.yaml b/.generator/schemas/v2/openapi.yaml index d437f7bb503b..f11915f6c80f 100644 --- a/.generator/schemas/v2/openapi.yaml +++ b/.generator/schemas/v2/openapi.yaml @@ -73676,6 +73676,11 @@ components: items: $ref: "#/components/schemas/ObservabilityPipelineConfigDestinationItem" type: array + end_to_end_acknowledgements: + description: |- + Enables end-to-end event delivery confirmation. Without a disk buffer, sources acknowledge events after delivery to all final destinations; when a disk buffer provides the acknowledgment boundary, they acknowledge after durable persistence. + Defaults to `false` when omitted. Requires Observability Pipelines Worker 2.14 or later. All configured sources must support this behavior. + type: boolean pipeline_type: $ref: "#/components/schemas/ObservabilityPipelineConfigPipelineType" processor_groups: diff --git a/features/v2/observability_pipelines.feature b/features/v2/observability_pipelines.feature index 78729ae2e8b9..4eaf5ec16663 100644 --- a/features/v2/observability_pipelines.feature +++ b/features/v2/observability_pipelines.feature @@ -34,6 +34,7 @@ Feature: Observability Pipelines And the response "data.attributes.config.sources" has length 1 And the response "data.attributes.config.processor_groups" has length 1 And the response "data.attributes.config.destinations" has length 1 + And the response "data.attributes.config" does not have field "end_to_end_acknowledgements" @team:DataDog/observability-pipelines Scenario: Create a pipeline with dedupe processor with cache returns "OK" response diff --git a/lib/datadog_api_client/v2/models/observability_pipeline_config.rb b/lib/datadog_api_client/v2/models/observability_pipeline_config.rb index 3b3ec1641f66..c6c473170ea7 100644 --- a/lib/datadog_api_client/v2/models/observability_pipeline_config.rb +++ b/lib/datadog_api_client/v2/models/observability_pipeline_config.rb @@ -24,6 +24,10 @@ class ObservabilityPipelineConfig # A list of destination components where processed logs are sent. attr_reader :destinations + # Enables end-to-end event delivery confirmation. Without a disk buffer, sources acknowledge events after delivery to all final destinations; when a disk buffer provides the acknowledgment boundary, they acknowledge after durable persistence. + # Defaults to `false` when omitted. Requires Observability Pipelines Worker 2.14 or later. All configured sources must support this behavior. + attr_accessor :end_to_end_acknowledgements + # The type of data being ingested. Defaults to `logs` if not specified. attr_accessor :pipeline_type @@ -52,6 +56,7 @@ class ObservabilityPipelineConfig def self.attribute_map { :'destinations' => :'destinations', + :'end_to_end_acknowledgements' => :'end_to_end_acknowledgements', :'pipeline_type' => :'pipeline_type', :'processor_groups' => :'processor_groups', :'processors' => :'processors', @@ -65,6 +70,7 @@ def self.attribute_map def self.openapi_types { :'destinations' => :'Array', + :'end_to_end_acknowledgements' => :'Boolean', :'pipeline_type' => :'ObservabilityPipelineConfigPipelineType', :'processor_groups' => :'Array', :'processors' => :'Array', @@ -97,6 +103,10 @@ def initialize(attributes = {}) end end + if attributes.key?(:'end_to_end_acknowledgements') + self.end_to_end_acknowledgements = attributes[:'end_to_end_acknowledgements'] + end + if attributes.key?(:'pipeline_type') self.pipeline_type = attributes[:'pipeline_type'] end @@ -180,6 +190,7 @@ def ==(o) return true if self.equal?(o) self.class == o.class && destinations == o.destinations && + end_to_end_acknowledgements == o.end_to_end_acknowledgements && pipeline_type == o.pipeline_type && processor_groups == o.processor_groups && processors == o.processors && @@ -192,7 +203,7 @@ def ==(o) # @return [Integer] Hash code # @!visibility private def hash - [destinations, pipeline_type, processor_groups, processors, sources, use_legacy_search_syntax, additional_properties].hash + [destinations, end_to_end_acknowledgements, pipeline_type, processor_groups, processors, sources, use_legacy_search_syntax, additional_properties].hash end end end