From beaa9c5711a79d2b67cbdd6d6e2cf51bac883d02 Mon Sep 17 00:00:00 2001 From: "ci.datadog-api-spec" Date: Tue, 8 Sep 2026 20:45:03 +0000 Subject: [PATCH] Regenerate client from commit b74d458 of spec repo --- .generator/schemas/v2/openapi.yaml | 5 +++ .../v2/model/ObservabilityPipelineConfig.java | 36 +++++++++++++++++++ .../v2/api/observability_pipelines.feature | 1 + 3 files changed, 42 insertions(+) diff --git a/.generator/schemas/v2/openapi.yaml b/.generator/schemas/v2/openapi.yaml index 1a0972d5a21..ec3ac2f57b7 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/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfig.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfig.java index 7bfe99fd428..314bbfcdc28 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfig.java +++ b/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_END_TO_END_ACKNOWLEDGEMENTS, ObservabilityPipelineConfig.JSON_PROPERTY_PIPELINE_TYPE, ObservabilityPipelineConfig.JSON_PROPERTY_PROCESSOR_GROUPS, ObservabilityPipelineConfig.JSON_PROPERTY_PROCESSORS, @@ -35,6 +36,10 @@ public class ObservabilityPipelineConfig { public static final String JSON_PROPERTY_DESTINATIONS = "destinations"; private List destinations = new ArrayList<>(); + public static final String JSON_PROPERTY_END_TO_END_ACKNOWLEDGEMENTS = + "end_to_end_acknowledgements"; + private Boolean endToEndAcknowledgements; + public static final String JSON_PROPERTY_PIPELINE_TYPE = "pipeline_type"; private ObservabilityPipelineConfigPipelineType pipelineType = ObservabilityPipelineConfigPipelineType.LOGS; @@ -105,6 +110,31 @@ public void setDestinations(List des } } + public ObservabilityPipelineConfig endToEndAcknowledgements(Boolean endToEndAcknowledgements) { + this.endToEndAcknowledgements = endToEndAcknowledgements; + return this; + } + + /** + * 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. + * + * @return endToEndAcknowledgements + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_END_TO_END_ACKNOWLEDGEMENTS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEndToEndAcknowledgements() { + return endToEndAcknowledgements; + } + + public void setEndToEndAcknowledgements(Boolean endToEndAcknowledgements) { + this.endToEndAcknowledgements = endToEndAcknowledgements; + } + public ObservabilityPipelineConfig pipelineType( ObservabilityPipelineConfigPipelineType pipelineType) { this.pipelineType = pipelineType; @@ -340,6 +370,8 @@ public boolean equals(Object o) { } ObservabilityPipelineConfig observabilityPipelineConfig = (ObservabilityPipelineConfig) o; return Objects.equals(this.destinations, observabilityPipelineConfig.destinations) + && Objects.equals( + this.endToEndAcknowledgements, observabilityPipelineConfig.endToEndAcknowledgements) && Objects.equals(this.pipelineType, observabilityPipelineConfig.pipelineType) && Objects.equals(this.processorGroups, observabilityPipelineConfig.processorGroups) && Objects.equals(this.processors, observabilityPipelineConfig.processors) @@ -354,6 +386,7 @@ public boolean equals(Object o) { public int hashCode() { return Objects.hash( destinations, + endToEndAcknowledgements, pipelineType, processorGroups, processors, @@ -367,6 +400,9 @@ public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineConfig {\n"); sb.append(" destinations: ").append(toIndentedString(destinations)).append("\n"); + sb.append(" endToEndAcknowledgements: ") + .append(toIndentedString(endToEndAcknowledgements)) + .append("\n"); sb.append(" pipelineType: ").append(toIndentedString(pipelineType)).append("\n"); sb.append(" processorGroups: ").append(toIndentedString(processorGroups)).append("\n"); sb.append(" processors: ").append(toIndentedString(processors)).append("\n"); diff --git a/src/test/resources/com/datadog/api/client/v2/api/observability_pipelines.feature b/src/test/resources/com/datadog/api/client/v2/api/observability_pipelines.feature index 78729ae2e8b..4eaf5ec1666 100644 --- a/src/test/resources/com/datadog/api/client/v2/api/observability_pipelines.feature +++ b/src/test/resources/com/datadog/api/client/v2/api/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