diff --git a/.generator/schemas/v2/openapi.yaml b/.generator/schemas/v2/openapi.yaml index 95f5775c6b9..604a90a3364 100644 --- a/.generator/schemas/v2/openapi.yaml +++ b/.generator/schemas/v2/openapi.yaml @@ -6766,6 +6766,8 @@ components: description: Optional prefix for blobs written to the container. example: logs/ type: string + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' container_name: description: The name of the Azure Blob Storage container to store logs in. @@ -36391,6 +36393,8 @@ components: **Supported pipeline types:** logs' properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' client_id: description: Azure AD client ID used for authentication. example: a1b2c3d4-5678-90ab-cdef-1234567890ab @@ -38337,6 +38341,8 @@ components: properties: auth: $ref: '#/components/schemas/ObservabilityPipelineAmazonOpenSearchDestinationAuth' + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' bulk_index: description: The index to write logs to. example: logs-index @@ -38418,6 +38424,8 @@ components: description: S3 bucket name. example: error-logs type: string + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' id: description: Unique identifier for the destination component. example: amazon-s3-destination @@ -38539,6 +38547,8 @@ components: description: Name of the Amazon S3 bucket in Security Lake (3-63 characters). example: security-lake-bucket type: string + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' custom_source_name: description: Custom source name for the logs in Security Lake. example: my-custom-source @@ -38598,6 +38608,39 @@ components: role session. type: string type: object + ObservabilityPipelineBufferOptions: + description: Configuration for buffer settings on destination components. + oneOf: + - $ref: '#/components/schemas/ObservabilityPipelineDiskBufferOptions' + - $ref: '#/components/schemas/ObservabilityPipelineMemoryBufferOptions' + - $ref: '#/components/schemas/ObservabilityPipelineMemoryBufferSizeOptions' + ObservabilityPipelineBufferOptionsDiskType: + default: disk + description: The type of the buffer that will be configured, a disk buffer. + enum: + - disk + type: string + x-enum-varnames: + - DISK + ObservabilityPipelineBufferOptionsMemoryType: + default: memory + description: The type of the buffer that will be configured, a memory buffer. + enum: + - memory + type: string + x-enum-varnames: + - MEMORY + ObservabilityPipelineBufferOptionsWhenFull: + default: block + description: Behavior when the buffer is full (block and stop accepting new + events, or drop new events) + enum: + - block + - drop_newest + type: string + x-enum-varnames: + - BLOCK + - DROP_NEWEST ObservabilityPipelineCloudPremDestination: description: 'The `cloud_prem` destination sends logs to Datadog CloudPrem. @@ -38868,6 +38911,8 @@ components: **Supported pipeline types:** logs' properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' compression: $ref: '#/components/schemas/ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression' encoding: @@ -39093,6 +39138,8 @@ components: **Supported pipeline types:** logs' properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' id: description: The unique identifier for this component. example: datadog-logs-destination @@ -39347,6 +39394,19 @@ components: type: string x-enum-varnames: - DEDUPE + ObservabilityPipelineDiskBufferOptions: + description: Options for configuring a disk buffer. + properties: + max_size: + description: Maximum size of the disk buffer. + example: 4096 + format: int64 + type: integer + type: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptionsDiskType' + when_full: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptionsWhenFull' + type: object ObservabilityPipelineElasticsearchDestination: description: 'The `elasticsearch` destination writes logs to an Elasticsearch cluster. @@ -39356,6 +39416,8 @@ components: properties: api_version: $ref: '#/components/schemas/ObservabilityPipelineElasticsearchDestinationApiVersion' + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' bulk_index: description: The index to write logs to in Elasticsearch. example: logs-index @@ -39901,6 +39963,8 @@ components: properties: auth: $ref: '#/components/schemas/ObservabilityPipelineGcpAuth' + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' customer_id: description: The Google Chronicle customer ID. example: abcdefg123456789 @@ -39969,6 +40033,8 @@ components: description: Name of the GCS bucket. example: error-logs type: string + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' id: description: Unique identifier for the destination component. example: gcs-destination @@ -40053,6 +40119,8 @@ components: properties: auth: $ref: '#/components/schemas/ObservabilityPipelineGcpAuth' + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' encoding: $ref: '#/components/schemas/ObservabilityPipelineGooglePubSubDestinationEncoding' id: @@ -40579,6 +40647,28 @@ components: type: string x-enum-varnames: - LOGSTASH + ObservabilityPipelineMemoryBufferOptions: + description: Options for configuring a memory buffer by byte size. + properties: + max_size: + description: Maximum size of the memory buffer. + example: 4096 + format: int64 + type: integer + type: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptionsMemoryType' + type: object + ObservabilityPipelineMemoryBufferSizeOptions: + description: Options for configuring a memory buffer by queue length. + properties: + max_events: + description: Maximum events for the memory buffer. + example: 500 + format: int64 + type: integer + type: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptionsMemoryType' + type: object ObservabilityPipelineMetadataEntry: description: A custom metadata entry. properties: @@ -40701,6 +40791,8 @@ components: **Supported pipeline types:** logs' properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' id: description: The unique identifier for this component. example: new-relic-destination @@ -40847,6 +40939,8 @@ components: **Supported pipeline types:** logs' properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' bulk_index: description: The index to write logs to. example: logs-index @@ -41560,6 +41654,8 @@ components: **Supported pipeline types:** logs' properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' id: description: The unique identifier for this component. example: rsyslog-destination @@ -42065,6 +42161,8 @@ components: **Supported pipeline types:** logs' properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' id: description: The unique identifier for this component. example: sentinelone-destination @@ -42119,6 +42217,8 @@ components: **Supported pipeline types:** logs' properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' encoding: $ref: '#/components/schemas/ObservabilityPipelineSocketDestinationEncoding' framing: @@ -42495,6 +42595,8 @@ components: If `false`, Splunk assigns the time the event was received.' example: true type: boolean + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' encoding: $ref: '#/components/schemas/ObservabilityPipelineSplunkHecDestinationEncoding' id: @@ -42619,6 +42721,8 @@ components: **Supported pipeline types:** logs' properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' encoding: $ref: '#/components/schemas/ObservabilityPipelineSumoLogicDestinationEncoding' header_custom_fields: @@ -42732,6 +42836,8 @@ components: **Supported pipeline types:** logs' properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' id: description: The unique identifier for this component. example: syslog-ng-destination diff --git a/src/main/java/com/datadog/api/client/v2/model/AzureStorageDestination.java b/src/main/java/com/datadog/api/client/v2/model/AzureStorageDestination.java index 1687442550d..d46d455c142 100644 --- a/src/main/java/com/datadog/api/client/v2/model/AzureStorageDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/AzureStorageDestination.java @@ -26,6 +26,7 @@ */ @JsonPropertyOrder({ AzureStorageDestination.JSON_PROPERTY_BLOB_PREFIX, + AzureStorageDestination.JSON_PROPERTY_BUFFER, AzureStorageDestination.JSON_PROPERTY_CONTAINER_NAME, AzureStorageDestination.JSON_PROPERTY_ID, AzureStorageDestination.JSON_PROPERTY_INPUTS, @@ -38,6 +39,9 @@ public class AzureStorageDestination { public static final String JSON_PROPERTY_BLOB_PREFIX = "blob_prefix"; private String blobPrefix; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_CONTAINER_NAME = "container_name"; private String containerName; @@ -86,6 +90,28 @@ public void setBlobPrefix(String blobPrefix) { this.blobPrefix = blobPrefix; } + public AzureStorageDestination 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 AzureStorageDestination containerName(String containerName) { this.containerName = containerName; return this; @@ -232,6 +258,7 @@ public boolean equals(Object o) { } AzureStorageDestination azureStorageDestination = (AzureStorageDestination) o; return Objects.equals(this.blobPrefix, azureStorageDestination.blobPrefix) + && Objects.equals(this.buffer, azureStorageDestination.buffer) && Objects.equals(this.containerName, azureStorageDestination.containerName) && Objects.equals(this.id, azureStorageDestination.id) && Objects.equals(this.inputs, azureStorageDestination.inputs) @@ -241,7 +268,7 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(blobPrefix, containerName, id, inputs, type, additionalProperties); + return Objects.hash(blobPrefix, buffer, containerName, id, inputs, type, additionalProperties); } @Override @@ -249,6 +276,7 @@ public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class AzureStorageDestination {\n"); sb.append(" blobPrefix: ").append(toIndentedString(blobPrefix)).append("\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" containerName: ").append(toIndentedString(containerName)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/MicrosoftSentinelDestination.java b/src/main/java/com/datadog/api/client/v2/model/MicrosoftSentinelDestination.java index 51571518f7b..500121c0cf6 100644 --- a/src/main/java/com/datadog/api/client/v2/model/MicrosoftSentinelDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/MicrosoftSentinelDestination.java @@ -25,6 +25,7 @@ *

Supported pipeline types: logs */ @JsonPropertyOrder({ + MicrosoftSentinelDestination.JSON_PROPERTY_BUFFER, MicrosoftSentinelDestination.JSON_PROPERTY_CLIENT_ID, MicrosoftSentinelDestination.JSON_PROPERTY_DCR_IMMUTABLE_ID, MicrosoftSentinelDestination.JSON_PROPERTY_ID, @@ -37,6 +38,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class MicrosoftSentinelDestination { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_CLIENT_ID = "client_id"; private String clientId; @@ -81,6 +85,28 @@ public MicrosoftSentinelDestination( this.unparsed |= !type.isValid(); } + public MicrosoftSentinelDestination 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 MicrosoftSentinelDestination clientId(String clientId) { this.clientId = clientId; return this; @@ -286,7 +312,8 @@ public boolean equals(Object o) { return false; } MicrosoftSentinelDestination microsoftSentinelDestination = (MicrosoftSentinelDestination) o; - return Objects.equals(this.clientId, microsoftSentinelDestination.clientId) + return Objects.equals(this.buffer, microsoftSentinelDestination.buffer) + && Objects.equals(this.clientId, microsoftSentinelDestination.clientId) && Objects.equals(this.dcrImmutableId, microsoftSentinelDestination.dcrImmutableId) && Objects.equals(this.id, microsoftSentinelDestination.id) && Objects.equals(this.inputs, microsoftSentinelDestination.inputs) @@ -300,13 +327,14 @@ public boolean equals(Object o) { @Override public int hashCode() { return Objects.hash( - clientId, dcrImmutableId, id, inputs, table, tenantId, type, additionalProperties); + buffer, clientId, dcrImmutableId, id, inputs, table, tenantId, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class MicrosoftSentinelDestination {\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" clientId: ").append(toIndentedString(clientId)).append("\n"); sb.append(" dcrImmutableId: ").append(toIndentedString(dcrImmutableId)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAmazonOpenSearchDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAmazonOpenSearchDestination.java index 57c9c89f0ca..ee1ab9d0f08 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAmazonOpenSearchDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAmazonOpenSearchDestination.java @@ -26,6 +26,7 @@ */ @JsonPropertyOrder({ ObservabilityPipelineAmazonOpenSearchDestination.JSON_PROPERTY_AUTH, + ObservabilityPipelineAmazonOpenSearchDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineAmazonOpenSearchDestination.JSON_PROPERTY_BULK_INDEX, ObservabilityPipelineAmazonOpenSearchDestination.JSON_PROPERTY_ID, ObservabilityPipelineAmazonOpenSearchDestination.JSON_PROPERTY_INPUTS, @@ -38,6 +39,9 @@ public class ObservabilityPipelineAmazonOpenSearchDestination { public static final String JSON_PROPERTY_AUTH = "auth"; private ObservabilityPipelineAmazonOpenSearchDestinationAuth auth; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_BULK_INDEX = "bulk_index"; private String bulkIndex; @@ -92,6 +96,29 @@ public void setAuth(ObservabilityPipelineAmazonOpenSearchDestinationAuth auth) { this.auth = auth; } + public ObservabilityPipelineAmazonOpenSearchDestination 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 ObservabilityPipelineAmazonOpenSearchDestination bulkIndex(String bulkIndex) { this.bulkIndex = bulkIndex; return this; @@ -243,6 +270,7 @@ public boolean equals(Object o) { observabilityPipelineAmazonOpenSearchDestination = (ObservabilityPipelineAmazonOpenSearchDestination) o; return Objects.equals(this.auth, observabilityPipelineAmazonOpenSearchDestination.auth) + && Objects.equals(this.buffer, observabilityPipelineAmazonOpenSearchDestination.buffer) && Objects.equals( this.bulkIndex, observabilityPipelineAmazonOpenSearchDestination.bulkIndex) && Objects.equals(this.id, observabilityPipelineAmazonOpenSearchDestination.id) @@ -255,7 +283,7 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(auth, bulkIndex, id, inputs, type, additionalProperties); + return Objects.hash(auth, buffer, bulkIndex, id, inputs, type, additionalProperties); } @Override @@ -263,6 +291,7 @@ public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineAmazonOpenSearchDestination {\n"); sb.append(" auth: ").append(toIndentedString(auth)).append("\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" bulkIndex: ").append(toIndentedString(bulkIndex)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAmazonS3Destination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAmazonS3Destination.java index 6538942f2ef..c78d0024dd6 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAmazonS3Destination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAmazonS3Destination.java @@ -28,6 +28,7 @@ @JsonPropertyOrder({ ObservabilityPipelineAmazonS3Destination.JSON_PROPERTY_AUTH, ObservabilityPipelineAmazonS3Destination.JSON_PROPERTY_BUCKET, + ObservabilityPipelineAmazonS3Destination.JSON_PROPERTY_BUFFER, ObservabilityPipelineAmazonS3Destination.JSON_PROPERTY_ID, ObservabilityPipelineAmazonS3Destination.JSON_PROPERTY_INPUTS, ObservabilityPipelineAmazonS3Destination.JSON_PROPERTY_KEY_PREFIX, @@ -46,6 +47,9 @@ public class ObservabilityPipelineAmazonS3Destination { 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_ID = "id"; private String id; @@ -133,6 +137,29 @@ public void setBucket(String bucket) { this.bucket = bucket; } + public ObservabilityPipelineAmazonS3Destination 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 ObservabilityPipelineAmazonS3Destination id(String id) { this.id = id; return this; @@ -350,6 +377,7 @@ public boolean equals(Object o) { (ObservabilityPipelineAmazonS3Destination) o; return Objects.equals(this.auth, observabilityPipelineAmazonS3Destination.auth) && Objects.equals(this.bucket, observabilityPipelineAmazonS3Destination.bucket) + && Objects.equals(this.buffer, observabilityPipelineAmazonS3Destination.buffer) && Objects.equals(this.id, observabilityPipelineAmazonS3Destination.id) && Objects.equals(this.inputs, observabilityPipelineAmazonS3Destination.inputs) && Objects.equals(this.keyPrefix, observabilityPipelineAmazonS3Destination.keyPrefix) @@ -365,7 +393,17 @@ public boolean equals(Object o) { @Override public int hashCode() { return Objects.hash( - auth, bucket, id, inputs, keyPrefix, region, storageClass, tls, type, additionalProperties); + auth, + bucket, + buffer, + id, + inputs, + keyPrefix, + region, + storageClass, + tls, + type, + additionalProperties); } @Override @@ -374,6 +412,7 @@ public String toString() { sb.append("class ObservabilityPipelineAmazonS3Destination {\n"); sb.append(" auth: ").append(toIndentedString(auth)).append("\n"); sb.append(" bucket: ").append(toIndentedString(bucket)).append("\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n"); sb.append(" keyPrefix: ").append(toIndentedString(keyPrefix)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAmazonSecurityLakeDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAmazonSecurityLakeDestination.java index 221bc4b2806..98fc932d182 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAmazonSecurityLakeDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAmazonSecurityLakeDestination.java @@ -27,6 +27,7 @@ @JsonPropertyOrder({ ObservabilityPipelineAmazonSecurityLakeDestination.JSON_PROPERTY_AUTH, ObservabilityPipelineAmazonSecurityLakeDestination.JSON_PROPERTY_BUCKET, + ObservabilityPipelineAmazonSecurityLakeDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineAmazonSecurityLakeDestination.JSON_PROPERTY_CUSTOM_SOURCE_NAME, ObservabilityPipelineAmazonSecurityLakeDestination.JSON_PROPERTY_ID, ObservabilityPipelineAmazonSecurityLakeDestination.JSON_PROPERTY_INPUTS, @@ -44,6 +45,9 @@ public class ObservabilityPipelineAmazonSecurityLakeDestination { 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_CUSTOM_SOURCE_NAME = "custom_source_name"; private String customSourceName; @@ -128,6 +132,29 @@ public void setBucket(String bucket) { this.bucket = bucket; } + public ObservabilityPipelineAmazonSecurityLakeDestination 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 ObservabilityPipelineAmazonSecurityLakeDestination customSourceName( String customSourceName) { this.customSourceName = customSourceName; @@ -324,6 +351,7 @@ public boolean equals(Object o) { (ObservabilityPipelineAmazonSecurityLakeDestination) o; return Objects.equals(this.auth, observabilityPipelineAmazonSecurityLakeDestination.auth) && Objects.equals(this.bucket, observabilityPipelineAmazonSecurityLakeDestination.bucket) + && Objects.equals(this.buffer, observabilityPipelineAmazonSecurityLakeDestination.buffer) && Objects.equals( this.customSourceName, observabilityPipelineAmazonSecurityLakeDestination.customSourceName) @@ -340,7 +368,16 @@ public boolean equals(Object o) { @Override public int hashCode() { return Objects.hash( - auth, bucket, customSourceName, id, inputs, region, tls, type, additionalProperties); + auth, + bucket, + buffer, + customSourceName, + id, + inputs, + region, + tls, + type, + additionalProperties); } @Override @@ -349,6 +386,7 @@ public String toString() { sb.append("class ObservabilityPipelineAmazonSecurityLakeDestination {\n"); sb.append(" auth: ").append(toIndentedString(auth)).append("\n"); sb.append(" bucket: ").append(toIndentedString(bucket)).append("\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" customSourceName: ").append(toIndentedString(customSourceName)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineBufferOptions.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineBufferOptions.java new file mode 100644 index 00000000000..bc7dbbaed68 --- /dev/null +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineBufferOptions.java @@ -0,0 +1,390 @@ +/* + * 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.datadog.api.client.AbstractOpenApiSchema; +import com.datadog.api.client.JSON; +import com.datadog.api.client.UnparsedObject; +import com.fasterxml.jackson.annotation.JsonIgnore; +import com.fasterxml.jackson.core.JsonGenerator; +import com.fasterxml.jackson.core.JsonParser; +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.core.JsonToken; +import com.fasterxml.jackson.core.type.TypeReference; +import com.fasterxml.jackson.databind.DeserializationContext; +import com.fasterxml.jackson.databind.JsonMappingException; +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.MapperFeature; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.fasterxml.jackson.databind.SerializerProvider; +import com.fasterxml.jackson.databind.annotation.JsonDeserialize; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.deser.std.StdDeserializer; +import com.fasterxml.jackson.databind.ser.std.StdSerializer; +import jakarta.ws.rs.core.GenericType; +import java.io.IOException; +import java.util.Collections; +import java.util.HashMap; +import java.util.HashSet; +import java.util.Map; +import java.util.logging.Level; +import java.util.logging.Logger; + +@jakarta.annotation.Generated( + value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") +@JsonDeserialize( + using = ObservabilityPipelineBufferOptions.ObservabilityPipelineBufferOptionsDeserializer.class) +@JsonSerialize( + using = ObservabilityPipelineBufferOptions.ObservabilityPipelineBufferOptionsSerializer.class) +public class ObservabilityPipelineBufferOptions extends AbstractOpenApiSchema { + private static final Logger log = + Logger.getLogger(ObservabilityPipelineBufferOptions.class.getName()); + + @JsonIgnore public boolean unparsed = false; + + public static class ObservabilityPipelineBufferOptionsSerializer + extends StdSerializer { + public ObservabilityPipelineBufferOptionsSerializer( + Class t) { + super(t); + } + + public ObservabilityPipelineBufferOptionsSerializer() { + this(null); + } + + @Override + public void serialize( + ObservabilityPipelineBufferOptions value, JsonGenerator jgen, SerializerProvider provider) + throws IOException, JsonProcessingException { + jgen.writeObject(value.getActualInstance()); + } + } + + public static class ObservabilityPipelineBufferOptionsDeserializer + extends StdDeserializer { + public ObservabilityPipelineBufferOptionsDeserializer() { + this(ObservabilityPipelineBufferOptions.class); + } + + public ObservabilityPipelineBufferOptionsDeserializer(Class vc) { + super(vc); + } + + @Override + public ObservabilityPipelineBufferOptions deserialize( + JsonParser jp, DeserializationContext ctxt) throws IOException, JsonProcessingException { + JsonNode tree = jp.readValueAsTree(); + Object deserialized = null; + Object tmp = null; + boolean typeCoercion = ctxt.isEnabled(MapperFeature.ALLOW_COERCION_OF_SCALARS); + int match = 0; + JsonToken token = tree.traverse(jp.getCodec()).nextToken(); + // deserialize ObservabilityPipelineDiskBufferOptions + try { + boolean attemptParsing = true; + // ensure that we respect type coercion as set on the client ObjectMapper + if (ObservabilityPipelineDiskBufferOptions.class.equals(Integer.class) + || ObservabilityPipelineDiskBufferOptions.class.equals(Long.class) + || ObservabilityPipelineDiskBufferOptions.class.equals(Float.class) + || ObservabilityPipelineDiskBufferOptions.class.equals(Double.class) + || ObservabilityPipelineDiskBufferOptions.class.equals(Boolean.class) + || ObservabilityPipelineDiskBufferOptions.class.equals(String.class)) { + attemptParsing = typeCoercion; + if (!attemptParsing) { + attemptParsing |= + ((ObservabilityPipelineDiskBufferOptions.class.equals(Integer.class) + || ObservabilityPipelineDiskBufferOptions.class.equals(Long.class)) + && token == JsonToken.VALUE_NUMBER_INT); + attemptParsing |= + ((ObservabilityPipelineDiskBufferOptions.class.equals(Float.class) + || ObservabilityPipelineDiskBufferOptions.class.equals(Double.class)) + && (token == JsonToken.VALUE_NUMBER_FLOAT + || token == JsonToken.VALUE_NUMBER_INT)); + attemptParsing |= + (ObservabilityPipelineDiskBufferOptions.class.equals(Boolean.class) + && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE)); + attemptParsing |= + (ObservabilityPipelineDiskBufferOptions.class.equals(String.class) + && token == JsonToken.VALUE_STRING); + } + } + if (attemptParsing) { + tmp = + tree.traverse(jp.getCodec()) + .readValueAs(ObservabilityPipelineDiskBufferOptions.class); + // TODO: there is no validation against JSON schema constraints + // (min, max, enum, pattern...), this does not perform a strict JSON + // validation, which means the 'match' count may be higher than it should be. + if (!((ObservabilityPipelineDiskBufferOptions) tmp).unparsed) { + deserialized = tmp; + match++; + } + log.log( + Level.FINER, "Input data matches schema 'ObservabilityPipelineDiskBufferOptions'"); + } + } catch (Exception e) { + // deserialization failed, continue + log.log( + Level.FINER, + "Input data does not match schema 'ObservabilityPipelineDiskBufferOptions'", + e); + } + + // deserialize ObservabilityPipelineMemoryBufferOptions + try { + boolean attemptParsing = true; + // ensure that we respect type coercion as set on the client ObjectMapper + if (ObservabilityPipelineMemoryBufferOptions.class.equals(Integer.class) + || ObservabilityPipelineMemoryBufferOptions.class.equals(Long.class) + || ObservabilityPipelineMemoryBufferOptions.class.equals(Float.class) + || ObservabilityPipelineMemoryBufferOptions.class.equals(Double.class) + || ObservabilityPipelineMemoryBufferOptions.class.equals(Boolean.class) + || ObservabilityPipelineMemoryBufferOptions.class.equals(String.class)) { + attemptParsing = typeCoercion; + if (!attemptParsing) { + attemptParsing |= + ((ObservabilityPipelineMemoryBufferOptions.class.equals(Integer.class) + || ObservabilityPipelineMemoryBufferOptions.class.equals(Long.class)) + && token == JsonToken.VALUE_NUMBER_INT); + attemptParsing |= + ((ObservabilityPipelineMemoryBufferOptions.class.equals(Float.class) + || ObservabilityPipelineMemoryBufferOptions.class.equals(Double.class)) + && (token == JsonToken.VALUE_NUMBER_FLOAT + || token == JsonToken.VALUE_NUMBER_INT)); + attemptParsing |= + (ObservabilityPipelineMemoryBufferOptions.class.equals(Boolean.class) + && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE)); + attemptParsing |= + (ObservabilityPipelineMemoryBufferOptions.class.equals(String.class) + && token == JsonToken.VALUE_STRING); + } + } + if (attemptParsing) { + tmp = + tree.traverse(jp.getCodec()) + .readValueAs(ObservabilityPipelineMemoryBufferOptions.class); + // TODO: there is no validation against JSON schema constraints + // (min, max, enum, pattern...), this does not perform a strict JSON + // validation, which means the 'match' count may be higher than it should be. + if (!((ObservabilityPipelineMemoryBufferOptions) tmp).unparsed) { + deserialized = tmp; + match++; + } + log.log( + Level.FINER, "Input data matches schema 'ObservabilityPipelineMemoryBufferOptions'"); + } + } catch (Exception e) { + // deserialization failed, continue + log.log( + Level.FINER, + "Input data does not match schema 'ObservabilityPipelineMemoryBufferOptions'", + e); + } + + // deserialize ObservabilityPipelineMemoryBufferSizeOptions + try { + boolean attemptParsing = true; + // ensure that we respect type coercion as set on the client ObjectMapper + if (ObservabilityPipelineMemoryBufferSizeOptions.class.equals(Integer.class) + || ObservabilityPipelineMemoryBufferSizeOptions.class.equals(Long.class) + || ObservabilityPipelineMemoryBufferSizeOptions.class.equals(Float.class) + || ObservabilityPipelineMemoryBufferSizeOptions.class.equals(Double.class) + || ObservabilityPipelineMemoryBufferSizeOptions.class.equals(Boolean.class) + || ObservabilityPipelineMemoryBufferSizeOptions.class.equals(String.class)) { + attemptParsing = typeCoercion; + if (!attemptParsing) { + attemptParsing |= + ((ObservabilityPipelineMemoryBufferSizeOptions.class.equals(Integer.class) + || ObservabilityPipelineMemoryBufferSizeOptions.class.equals(Long.class)) + && token == JsonToken.VALUE_NUMBER_INT); + attemptParsing |= + ((ObservabilityPipelineMemoryBufferSizeOptions.class.equals(Float.class) + || ObservabilityPipelineMemoryBufferSizeOptions.class.equals(Double.class)) + && (token == JsonToken.VALUE_NUMBER_FLOAT + || token == JsonToken.VALUE_NUMBER_INT)); + attemptParsing |= + (ObservabilityPipelineMemoryBufferSizeOptions.class.equals(Boolean.class) + && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE)); + attemptParsing |= + (ObservabilityPipelineMemoryBufferSizeOptions.class.equals(String.class) + && token == JsonToken.VALUE_STRING); + } + } + if (attemptParsing) { + tmp = + tree.traverse(jp.getCodec()) + .readValueAs(ObservabilityPipelineMemoryBufferSizeOptions.class); + // TODO: there is no validation against JSON schema constraints + // (min, max, enum, pattern...), this does not perform a strict JSON + // validation, which means the 'match' count may be higher than it should be. + if (!((ObservabilityPipelineMemoryBufferSizeOptions) tmp).unparsed) { + deserialized = tmp; + match++; + } + log.log( + Level.FINER, + "Input data matches schema 'ObservabilityPipelineMemoryBufferSizeOptions'"); + } + } catch (Exception e) { + // deserialization failed, continue + log.log( + Level.FINER, + "Input data does not match schema 'ObservabilityPipelineMemoryBufferSizeOptions'", + e); + } + + ObservabilityPipelineBufferOptions ret = new ObservabilityPipelineBufferOptions(); + if (match == 1) { + ret.setActualInstance(deserialized); + } else { + Map res = + new ObjectMapper() + .readValue( + tree.traverse(jp.getCodec()).readValueAsTree().toString(), + new TypeReference>() {}); + ret.setActualInstance(new UnparsedObject(res)); + } + return ret; + } + + /** Handle deserialization of the 'null' value. */ + @Override + public ObservabilityPipelineBufferOptions getNullValue(DeserializationContext ctxt) + throws JsonMappingException { + throw new JsonMappingException( + ctxt.getParser(), "ObservabilityPipelineBufferOptions cannot be null"); + } + } + + // store a list of schema names defined in oneOf + public static final Map schemas = new HashMap(); + + public ObservabilityPipelineBufferOptions() { + super("oneOf", Boolean.FALSE); + } + + public ObservabilityPipelineBufferOptions(ObservabilityPipelineDiskBufferOptions o) { + super("oneOf", Boolean.FALSE); + setActualInstance(o); + } + + public ObservabilityPipelineBufferOptions(ObservabilityPipelineMemoryBufferOptions o) { + super("oneOf", Boolean.FALSE); + setActualInstance(o); + } + + public ObservabilityPipelineBufferOptions(ObservabilityPipelineMemoryBufferSizeOptions o) { + super("oneOf", Boolean.FALSE); + setActualInstance(o); + } + + static { + schemas.put( + "ObservabilityPipelineDiskBufferOptions", + new GenericType() {}); + schemas.put( + "ObservabilityPipelineMemoryBufferOptions", + new GenericType() {}); + schemas.put( + "ObservabilityPipelineMemoryBufferSizeOptions", + new GenericType() {}); + JSON.registerDescendants( + ObservabilityPipelineBufferOptions.class, Collections.unmodifiableMap(schemas)); + } + + @Override + public Map getSchemas() { + return ObservabilityPipelineBufferOptions.schemas; + } + + /** + * Set the instance that matches the oneOf child schema, check the instance parameter is valid + * against the oneOf child schemas: ObservabilityPipelineDiskBufferOptions, + * ObservabilityPipelineMemoryBufferOptions, ObservabilityPipelineMemoryBufferSizeOptions + * + *

It could be an instance of the 'oneOf' schemas. The oneOf child schemas may themselves be a + * composed schema (allOf, anyOf, oneOf). + */ + @Override + public void setActualInstance(Object instance) { + if (JSON.isInstanceOf( + ObservabilityPipelineDiskBufferOptions.class, instance, new HashSet>())) { + super.setActualInstance(instance); + return; + } + if (JSON.isInstanceOf( + ObservabilityPipelineMemoryBufferOptions.class, instance, new HashSet>())) { + super.setActualInstance(instance); + return; + } + if (JSON.isInstanceOf( + ObservabilityPipelineMemoryBufferSizeOptions.class, instance, new HashSet>())) { + super.setActualInstance(instance); + return; + } + + if (JSON.isInstanceOf(UnparsedObject.class, instance, new HashSet>())) { + super.setActualInstance(instance); + return; + } + throw new RuntimeException( + "Invalid instance type. Must be ObservabilityPipelineDiskBufferOptions," + + " ObservabilityPipelineMemoryBufferOptions," + + " ObservabilityPipelineMemoryBufferSizeOptions"); + } + + /** + * Get the actual instance, which can be the following: ObservabilityPipelineDiskBufferOptions, + * ObservabilityPipelineMemoryBufferOptions, ObservabilityPipelineMemoryBufferSizeOptions + * + * @return The actual instance (ObservabilityPipelineDiskBufferOptions, + * ObservabilityPipelineMemoryBufferOptions, ObservabilityPipelineMemoryBufferSizeOptions) + */ + @Override + public Object getActualInstance() { + return super.getActualInstance(); + } + + /** + * Get the actual instance of `ObservabilityPipelineDiskBufferOptions`. If the actual instance is + * not `ObservabilityPipelineDiskBufferOptions`, the ClassCastException will be thrown. + * + * @return The actual instance of `ObservabilityPipelineDiskBufferOptions` + * @throws ClassCastException if the instance is not `ObservabilityPipelineDiskBufferOptions` + */ + public ObservabilityPipelineDiskBufferOptions getObservabilityPipelineDiskBufferOptions() + throws ClassCastException { + return (ObservabilityPipelineDiskBufferOptions) super.getActualInstance(); + } + + /** + * Get the actual instance of `ObservabilityPipelineMemoryBufferOptions`. If the actual instance + * is not `ObservabilityPipelineMemoryBufferOptions`, the ClassCastException will be thrown. + * + * @return The actual instance of `ObservabilityPipelineMemoryBufferOptions` + * @throws ClassCastException if the instance is not `ObservabilityPipelineMemoryBufferOptions` + */ + public ObservabilityPipelineMemoryBufferOptions getObservabilityPipelineMemoryBufferOptions() + throws ClassCastException { + return (ObservabilityPipelineMemoryBufferOptions) super.getActualInstance(); + } + + /** + * Get the actual instance of `ObservabilityPipelineMemoryBufferSizeOptions`. If the actual + * instance is not `ObservabilityPipelineMemoryBufferSizeOptions`, the ClassCastException will be + * thrown. + * + * @return The actual instance of `ObservabilityPipelineMemoryBufferSizeOptions` + * @throws ClassCastException if the instance is not + * `ObservabilityPipelineMemoryBufferSizeOptions` + */ + public ObservabilityPipelineMemoryBufferSizeOptions + getObservabilityPipelineMemoryBufferSizeOptions() throws ClassCastException { + return (ObservabilityPipelineMemoryBufferSizeOptions) super.getActualInstance(); + } +} diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineBufferOptionsDiskType.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineBufferOptionsDiskType.java new file mode 100644 index 00000000000..927da620cef --- /dev/null +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineBufferOptionsDiskType.java @@ -0,0 +1,62 @@ +/* + * 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.datadog.api.client.ModelEnum; +import com.fasterxml.jackson.annotation.JsonCreator; +import com.fasterxml.jackson.core.JsonGenerator; +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.SerializerProvider; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.StdSerializer; +import java.io.IOException; +import java.util.Arrays; +import java.util.HashSet; +import java.util.Set; + +/** The type of the buffer that will be configured, a disk buffer. */ +@JsonSerialize( + using = + ObservabilityPipelineBufferOptionsDiskType + .ObservabilityPipelineBufferOptionsDiskTypeSerializer.class) +public class ObservabilityPipelineBufferOptionsDiskType extends ModelEnum { + + private static final Set allowedValues = new HashSet(Arrays.asList("disk")); + + public static final ObservabilityPipelineBufferOptionsDiskType DISK = + new ObservabilityPipelineBufferOptionsDiskType("disk"); + + ObservabilityPipelineBufferOptionsDiskType(String value) { + super(value, allowedValues); + } + + public static class ObservabilityPipelineBufferOptionsDiskTypeSerializer + extends StdSerializer { + public ObservabilityPipelineBufferOptionsDiskTypeSerializer( + Class t) { + super(t); + } + + public ObservabilityPipelineBufferOptionsDiskTypeSerializer() { + this(null); + } + + @Override + public void serialize( + ObservabilityPipelineBufferOptionsDiskType value, + JsonGenerator jgen, + SerializerProvider provider) + throws IOException, JsonProcessingException { + jgen.writeObject(value.value); + } + } + + @JsonCreator + public static ObservabilityPipelineBufferOptionsDiskType fromValue(String value) { + return new ObservabilityPipelineBufferOptionsDiskType(value); + } +} diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineBufferOptionsMemoryType.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineBufferOptionsMemoryType.java new file mode 100644 index 00000000000..e1a1bbd8fb6 --- /dev/null +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineBufferOptionsMemoryType.java @@ -0,0 +1,62 @@ +/* + * 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.datadog.api.client.ModelEnum; +import com.fasterxml.jackson.annotation.JsonCreator; +import com.fasterxml.jackson.core.JsonGenerator; +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.SerializerProvider; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.StdSerializer; +import java.io.IOException; +import java.util.Arrays; +import java.util.HashSet; +import java.util.Set; + +/** The type of the buffer that will be configured, a memory buffer. */ +@JsonSerialize( + using = + ObservabilityPipelineBufferOptionsMemoryType + .ObservabilityPipelineBufferOptionsMemoryTypeSerializer.class) +public class ObservabilityPipelineBufferOptionsMemoryType extends ModelEnum { + + private static final Set allowedValues = new HashSet(Arrays.asList("memory")); + + public static final ObservabilityPipelineBufferOptionsMemoryType MEMORY = + new ObservabilityPipelineBufferOptionsMemoryType("memory"); + + ObservabilityPipelineBufferOptionsMemoryType(String value) { + super(value, allowedValues); + } + + public static class ObservabilityPipelineBufferOptionsMemoryTypeSerializer + extends StdSerializer { + public ObservabilityPipelineBufferOptionsMemoryTypeSerializer( + Class t) { + super(t); + } + + public ObservabilityPipelineBufferOptionsMemoryTypeSerializer() { + this(null); + } + + @Override + public void serialize( + ObservabilityPipelineBufferOptionsMemoryType value, + JsonGenerator jgen, + SerializerProvider provider) + throws IOException, JsonProcessingException { + jgen.writeObject(value.value); + } + } + + @JsonCreator + public static ObservabilityPipelineBufferOptionsMemoryType fromValue(String value) { + return new ObservabilityPipelineBufferOptionsMemoryType(value); + } +} diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineBufferOptionsWhenFull.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineBufferOptionsWhenFull.java new file mode 100644 index 00000000000..08d5f05ed6a --- /dev/null +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineBufferOptionsWhenFull.java @@ -0,0 +1,65 @@ +/* + * 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.datadog.api.client.ModelEnum; +import com.fasterxml.jackson.annotation.JsonCreator; +import com.fasterxml.jackson.core.JsonGenerator; +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.SerializerProvider; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.StdSerializer; +import java.io.IOException; +import java.util.Arrays; +import java.util.HashSet; +import java.util.Set; + +/** Behavior when the buffer is full (block and stop accepting new events, or drop new events) */ +@JsonSerialize( + using = + ObservabilityPipelineBufferOptionsWhenFull + .ObservabilityPipelineBufferOptionsWhenFullSerializer.class) +public class ObservabilityPipelineBufferOptionsWhenFull extends ModelEnum { + + private static final Set allowedValues = + new HashSet(Arrays.asList("block", "drop_newest")); + + public static final ObservabilityPipelineBufferOptionsWhenFull BLOCK = + new ObservabilityPipelineBufferOptionsWhenFull("block"); + public static final ObservabilityPipelineBufferOptionsWhenFull DROP_NEWEST = + new ObservabilityPipelineBufferOptionsWhenFull("drop_newest"); + + ObservabilityPipelineBufferOptionsWhenFull(String value) { + super(value, allowedValues); + } + + public static class ObservabilityPipelineBufferOptionsWhenFullSerializer + extends StdSerializer { + public ObservabilityPipelineBufferOptionsWhenFullSerializer( + Class t) { + super(t); + } + + public ObservabilityPipelineBufferOptionsWhenFullSerializer() { + this(null); + } + + @Override + public void serialize( + ObservabilityPipelineBufferOptionsWhenFull value, + JsonGenerator jgen, + SerializerProvider provider) + throws IOException, JsonProcessingException { + jgen.writeObject(value.value); + } + } + + @JsonCreator + public static ObservabilityPipelineBufferOptionsWhenFull fromValue(String value) { + return new ObservabilityPipelineBufferOptionsWhenFull(value); + } +} diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestination.java index 20fb23651d9..bd6741381fc 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestination.java @@ -26,6 +26,7 @@ *

Supported pipeline types: logs */ @JsonPropertyOrder({ + ObservabilityPipelineCrowdStrikeNextGenSiemDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineCrowdStrikeNextGenSiemDestination.JSON_PROPERTY_COMPRESSION, ObservabilityPipelineCrowdStrikeNextGenSiemDestination.JSON_PROPERTY_ENCODING, ObservabilityPipelineCrowdStrikeNextGenSiemDestination.JSON_PROPERTY_ID, @@ -37,6 +38,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineCrowdStrikeNextGenSiemDestination { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_COMPRESSION = "compression"; private ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression compression; @@ -74,6 +78,29 @@ public ObservabilityPipelineCrowdStrikeNextGenSiemDestination( this.unparsed |= !type.isValid(); } + public ObservabilityPipelineCrowdStrikeNextGenSiemDestination 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 ObservabilityPipelineCrowdStrikeNextGenSiemDestination compression( ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression compression) { this.compression = compression; @@ -278,6 +305,8 @@ public boolean equals(Object o) { observabilityPipelineCrowdStrikeNextGenSiemDestination = (ObservabilityPipelineCrowdStrikeNextGenSiemDestination) o; return Objects.equals( + this.buffer, observabilityPipelineCrowdStrikeNextGenSiemDestination.buffer) + && Objects.equals( this.compression, observabilityPipelineCrowdStrikeNextGenSiemDestination.compression) && Objects.equals( this.encoding, observabilityPipelineCrowdStrikeNextGenSiemDestination.encoding) @@ -293,13 +322,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(compression, encoding, id, inputs, tls, type, additionalProperties); + return Objects.hash(buffer, compression, encoding, id, inputs, tls, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineCrowdStrikeNextGenSiemDestination {\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"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogLogsDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogLogsDestination.java index 344e10d3f63..e6492a1affd 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogLogsDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogLogsDestination.java @@ -25,6 +25,7 @@ *

Supported pipeline types: logs */ @JsonPropertyOrder({ + ObservabilityPipelineDatadogLogsDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineDatadogLogsDestination.JSON_PROPERTY_ID, ObservabilityPipelineDatadogLogsDestination.JSON_PROPERTY_INPUTS, ObservabilityPipelineDatadogLogsDestination.JSON_PROPERTY_ROUTES, @@ -34,6 +35,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineDatadogLogsDestination { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -61,6 +65,29 @@ public ObservabilityPipelineDatadogLogsDestination( this.unparsed |= !type.isValid(); } + public ObservabilityPipelineDatadogLogsDestination 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 ObservabilityPipelineDatadogLogsDestination id(String id) { this.id = id; return this; @@ -224,7 +251,8 @@ public boolean equals(Object o) { } ObservabilityPipelineDatadogLogsDestination observabilityPipelineDatadogLogsDestination = (ObservabilityPipelineDatadogLogsDestination) o; - return Objects.equals(this.id, observabilityPipelineDatadogLogsDestination.id) + return Objects.equals(this.buffer, observabilityPipelineDatadogLogsDestination.buffer) + && Objects.equals(this.id, observabilityPipelineDatadogLogsDestination.id) && Objects.equals(this.inputs, observabilityPipelineDatadogLogsDestination.inputs) && Objects.equals(this.routes, observabilityPipelineDatadogLogsDestination.routes) && Objects.equals(this.type, observabilityPipelineDatadogLogsDestination.type) @@ -235,13 +263,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(id, inputs, routes, type, additionalProperties); + return Objects.hash(buffer, id, inputs, routes, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineDatadogLogsDestination {\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n"); sb.append(" routes: ").append(toIndentedString(routes)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDiskBufferOptions.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDiskBufferOptions.java new file mode 100644 index 00000000000..dfc587a3eec --- /dev/null +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDiskBufferOptions.java @@ -0,0 +1,205 @@ +/* + * 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; + +/** Options for configuring a disk buffer. */ +@JsonPropertyOrder({ + ObservabilityPipelineDiskBufferOptions.JSON_PROPERTY_MAX_SIZE, + ObservabilityPipelineDiskBufferOptions.JSON_PROPERTY_TYPE, + ObservabilityPipelineDiskBufferOptions.JSON_PROPERTY_WHEN_FULL +}) +@jakarta.annotation.Generated( + value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") +public class ObservabilityPipelineDiskBufferOptions { + @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_MAX_SIZE = "max_size"; + private Long maxSize; + + public static final String JSON_PROPERTY_TYPE = "type"; + private ObservabilityPipelineBufferOptionsDiskType type = + ObservabilityPipelineBufferOptionsDiskType.DISK; + + public static final String JSON_PROPERTY_WHEN_FULL = "when_full"; + private ObservabilityPipelineBufferOptionsWhenFull whenFull = + ObservabilityPipelineBufferOptionsWhenFull.BLOCK; + + public ObservabilityPipelineDiskBufferOptions maxSize(Long maxSize) { + this.maxSize = maxSize; + return this; + } + + /** + * Maximum size of the disk buffer. + * + * @return maxSize + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_MAX_SIZE) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Long getMaxSize() { + return maxSize; + } + + public void setMaxSize(Long maxSize) { + this.maxSize = maxSize; + } + + public ObservabilityPipelineDiskBufferOptions type( + ObservabilityPipelineBufferOptionsDiskType type) { + this.type = type; + this.unparsed |= !type.isValid(); + return this; + } + + /** + * The type of the buffer that will be configured, a disk buffer. + * + * @return type + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_TYPE) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public ObservabilityPipelineBufferOptionsDiskType getType() { + return type; + } + + public void setType(ObservabilityPipelineBufferOptionsDiskType type) { + if (!type.isValid()) { + this.unparsed = true; + } + this.type = type; + } + + public ObservabilityPipelineDiskBufferOptions whenFull( + ObservabilityPipelineBufferOptionsWhenFull whenFull) { + this.whenFull = whenFull; + this.unparsed |= !whenFull.isValid(); + return this; + } + + /** + * Behavior when the buffer is full (block and stop accepting new events, or drop new events) + * + * @return whenFull + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_WHEN_FULL) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public ObservabilityPipelineBufferOptionsWhenFull getWhenFull() { + return whenFull; + } + + public void setWhenFull(ObservabilityPipelineBufferOptionsWhenFull whenFull) { + if (!whenFull.isValid()) { + this.unparsed = true; + } + this.whenFull = whenFull; + } + + /** + * 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 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 ObservabilityPipelineDiskBufferOptions + */ + @JsonAnySetter + public ObservabilityPipelineDiskBufferOptions putAdditionalProperty(String key, Object value) { + if (this.additionalProperties == null) { + this.additionalProperties = new HashMap(); + } + this.additionalProperties.put(key, value); + return this; + } + + /** + * Return the additional (undeclared) property. + * + * @return The additional properties + */ + @JsonAnyGetter + public Map 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 ObservabilityPipelineDiskBufferOptions object is equal to o. */ + @Override + public boolean equals(Object o) { + if (this == o) { + return true; + } + if (o == null || getClass() != o.getClass()) { + return false; + } + ObservabilityPipelineDiskBufferOptions observabilityPipelineDiskBufferOptions = + (ObservabilityPipelineDiskBufferOptions) o; + return Objects.equals(this.maxSize, observabilityPipelineDiskBufferOptions.maxSize) + && Objects.equals(this.type, observabilityPipelineDiskBufferOptions.type) + && Objects.equals(this.whenFull, observabilityPipelineDiskBufferOptions.whenFull) + && Objects.equals( + this.additionalProperties, observabilityPipelineDiskBufferOptions.additionalProperties); + } + + @Override + public int hashCode() { + return Objects.hash(maxSize, type, whenFull, additionalProperties); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder(); + sb.append("class ObservabilityPipelineDiskBufferOptions {\n"); + sb.append(" maxSize: ").append(toIndentedString(maxSize)).append("\n"); + sb.append(" type: ").append(toIndentedString(type)).append("\n"); + sb.append(" whenFull: ").append(toIndentedString(whenFull)).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 "); + } +} diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineElasticsearchDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineElasticsearchDestination.java index af6f8d805d0..3f441c4ef65 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineElasticsearchDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineElasticsearchDestination.java @@ -26,6 +26,7 @@ */ @JsonPropertyOrder({ ObservabilityPipelineElasticsearchDestination.JSON_PROPERTY_API_VERSION, + ObservabilityPipelineElasticsearchDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineElasticsearchDestination.JSON_PROPERTY_BULK_INDEX, ObservabilityPipelineElasticsearchDestination.JSON_PROPERTY_DATA_STREAM, ObservabilityPipelineElasticsearchDestination.JSON_PROPERTY_ID, @@ -39,6 +40,9 @@ public class ObservabilityPipelineElasticsearchDestination { public static final String JSON_PROPERTY_API_VERSION = "api_version"; private ObservabilityPipelineElasticsearchDestinationApiVersion apiVersion; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_BULK_INDEX = "bulk_index"; private String bulkIndex; @@ -95,6 +99,29 @@ public void setApiVersion(ObservabilityPipelineElasticsearchDestinationApiVersio this.apiVersion = apiVersion; } + public ObservabilityPipelineElasticsearchDestination 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 ObservabilityPipelineElasticsearchDestination bulkIndex(String bulkIndex) { this.bulkIndex = bulkIndex; return this; @@ -268,6 +295,7 @@ public boolean equals(Object o) { ObservabilityPipelineElasticsearchDestination observabilityPipelineElasticsearchDestination = (ObservabilityPipelineElasticsearchDestination) o; return Objects.equals(this.apiVersion, observabilityPipelineElasticsearchDestination.apiVersion) + && Objects.equals(this.buffer, observabilityPipelineElasticsearchDestination.buffer) && Objects.equals(this.bulkIndex, observabilityPipelineElasticsearchDestination.bulkIndex) && Objects.equals(this.dataStream, observabilityPipelineElasticsearchDestination.dataStream) && Objects.equals(this.id, observabilityPipelineElasticsearchDestination.id) @@ -280,7 +308,8 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(apiVersion, bulkIndex, dataStream, id, inputs, type, additionalProperties); + return Objects.hash( + apiVersion, buffer, bulkIndex, dataStream, id, inputs, type, additionalProperties); } @Override @@ -288,6 +317,7 @@ public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineElasticsearchDestination {\n"); sb.append(" apiVersion: ").append(toIndentedString(apiVersion)).append("\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\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"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGoogleChronicleDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGoogleChronicleDestination.java index 42e408347d2..905fc27f209 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGoogleChronicleDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGoogleChronicleDestination.java @@ -26,6 +26,7 @@ */ @JsonPropertyOrder({ ObservabilityPipelineGoogleChronicleDestination.JSON_PROPERTY_AUTH, + ObservabilityPipelineGoogleChronicleDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineGoogleChronicleDestination.JSON_PROPERTY_CUSTOMER_ID, ObservabilityPipelineGoogleChronicleDestination.JSON_PROPERTY_ENCODING, ObservabilityPipelineGoogleChronicleDestination.JSON_PROPERTY_ID, @@ -40,6 +41,9 @@ public class ObservabilityPipelineGoogleChronicleDestination { public static final String JSON_PROPERTY_AUTH = "auth"; private ObservabilityPipelineGcpAuth auth; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_CUSTOMER_ID = "customer_id"; private String customerId; @@ -97,6 +101,29 @@ public void setAuth(ObservabilityPipelineGcpAuth auth) { this.auth = auth; } + public ObservabilityPipelineGoogleChronicleDestination 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 ObservabilityPipelineGoogleChronicleDestination customerId(String customerId) { this.customerId = customerId; return this; @@ -294,6 +321,7 @@ public boolean equals(Object o) { observabilityPipelineGoogleChronicleDestination = (ObservabilityPipelineGoogleChronicleDestination) o; return Objects.equals(this.auth, observabilityPipelineGoogleChronicleDestination.auth) + && Objects.equals(this.buffer, observabilityPipelineGoogleChronicleDestination.buffer) && Objects.equals( this.customerId, observabilityPipelineGoogleChronicleDestination.customerId) && Objects.equals(this.encoding, observabilityPipelineGoogleChronicleDestination.encoding) @@ -309,7 +337,7 @@ public boolean equals(Object o) { @Override public int hashCode() { return Objects.hash( - auth, customerId, encoding, id, inputs, logType, type, additionalProperties); + auth, buffer, customerId, encoding, id, inputs, logType, type, additionalProperties); } @Override @@ -317,6 +345,7 @@ public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineGoogleChronicleDestination {\n"); sb.append(" auth: ").append(toIndentedString(auth)).append("\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" customerId: ").append(toIndentedString(customerId)).append("\n"); sb.append(" encoding: ").append(toIndentedString(encoding)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGoogleCloudStorageDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGoogleCloudStorageDestination.java index b66adc5727a..317cb20bdf7 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGoogleCloudStorageDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGoogleCloudStorageDestination.java @@ -29,6 +29,7 @@ ObservabilityPipelineGoogleCloudStorageDestination.JSON_PROPERTY_ACL, ObservabilityPipelineGoogleCloudStorageDestination.JSON_PROPERTY_AUTH, ObservabilityPipelineGoogleCloudStorageDestination.JSON_PROPERTY_BUCKET, + ObservabilityPipelineGoogleCloudStorageDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineGoogleCloudStorageDestination.JSON_PROPERTY_ID, ObservabilityPipelineGoogleCloudStorageDestination.JSON_PROPERTY_INPUTS, ObservabilityPipelineGoogleCloudStorageDestination.JSON_PROPERTY_KEY_PREFIX, @@ -49,6 +50,9 @@ public class ObservabilityPipelineGoogleCloudStorageDestination { 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_ID = "id"; private String id; @@ -157,6 +161,29 @@ public void setBucket(String bucket) { this.bucket = bucket; } + public ObservabilityPipelineGoogleCloudStorageDestination 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 ObservabilityPipelineGoogleCloudStorageDestination id(String id) { this.id = id; return this; @@ -373,6 +400,7 @@ public boolean equals(Object o) { return Objects.equals(this.acl, observabilityPipelineGoogleCloudStorageDestination.acl) && Objects.equals(this.auth, observabilityPipelineGoogleCloudStorageDestination.auth) && Objects.equals(this.bucket, observabilityPipelineGoogleCloudStorageDestination.bucket) + && Objects.equals(this.buffer, observabilityPipelineGoogleCloudStorageDestination.buffer) && Objects.equals(this.id, observabilityPipelineGoogleCloudStorageDestination.id) && Objects.equals(this.inputs, observabilityPipelineGoogleCloudStorageDestination.inputs) && Objects.equals( @@ -393,6 +421,7 @@ public int hashCode() { acl, auth, bucket, + buffer, id, inputs, keyPrefix, @@ -409,6 +438,7 @@ public String toString() { sb.append(" acl: ").append(toIndentedString(acl)).append("\n"); sb.append(" auth: ").append(toIndentedString(auth)).append("\n"); sb.append(" bucket: ").append(toIndentedString(bucket)).append("\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n"); sb.append(" keyPrefix: ").append(toIndentedString(keyPrefix)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGooglePubSubDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGooglePubSubDestination.java index 877c5b6c6d4..4edb02fbc8f 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGooglePubSubDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGooglePubSubDestination.java @@ -26,6 +26,7 @@ */ @JsonPropertyOrder({ ObservabilityPipelineGooglePubSubDestination.JSON_PROPERTY_AUTH, + ObservabilityPipelineGooglePubSubDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineGooglePubSubDestination.JSON_PROPERTY_ENCODING, ObservabilityPipelineGooglePubSubDestination.JSON_PROPERTY_ID, ObservabilityPipelineGooglePubSubDestination.JSON_PROPERTY_INPUTS, @@ -41,6 +42,9 @@ public class ObservabilityPipelineGooglePubSubDestination { public static final String JSON_PROPERTY_AUTH = "auth"; private ObservabilityPipelineGcpAuth auth; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_ENCODING = "encoding"; private ObservabilityPipelineGooglePubSubDestinationEncoding encoding; @@ -107,6 +111,29 @@ public void setAuth(ObservabilityPipelineGcpAuth auth) { this.auth = auth; } + public ObservabilityPipelineGooglePubSubDestination 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 ObservabilityPipelineGooglePubSubDestination encoding( ObservabilityPipelineGooglePubSubDestinationEncoding encoding) { this.encoding = encoding; @@ -323,6 +350,7 @@ public boolean equals(Object o) { ObservabilityPipelineGooglePubSubDestination observabilityPipelineGooglePubSubDestination = (ObservabilityPipelineGooglePubSubDestination) o; return Objects.equals(this.auth, observabilityPipelineGooglePubSubDestination.auth) + && Objects.equals(this.buffer, observabilityPipelineGooglePubSubDestination.buffer) && Objects.equals(this.encoding, observabilityPipelineGooglePubSubDestination.encoding) && Objects.equals(this.id, observabilityPipelineGooglePubSubDestination.id) && Objects.equals(this.inputs, observabilityPipelineGooglePubSubDestination.inputs) @@ -338,7 +366,7 @@ public boolean equals(Object o) { @Override public int hashCode() { return Objects.hash( - auth, encoding, id, inputs, project, tls, topic, type, additionalProperties); + auth, buffer, encoding, id, inputs, project, tls, topic, type, additionalProperties); } @Override @@ -346,6 +374,7 @@ public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineGooglePubSubDestination {\n"); sb.append(" auth: ").append(toIndentedString(auth)).append("\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" encoding: ").append(toIndentedString(encoding)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineMemoryBufferOptions.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineMemoryBufferOptions.java new file mode 100644 index 00000000000..f78d253a091 --- /dev/null +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineMemoryBufferOptions.java @@ -0,0 +1,173 @@ +/* + * 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; + +/** Options for configuring a memory buffer by byte size. */ +@JsonPropertyOrder({ + ObservabilityPipelineMemoryBufferOptions.JSON_PROPERTY_MAX_SIZE, + ObservabilityPipelineMemoryBufferOptions.JSON_PROPERTY_TYPE +}) +@jakarta.annotation.Generated( + value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") +public class ObservabilityPipelineMemoryBufferOptions { + @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_MAX_SIZE = "max_size"; + private Long maxSize; + + public static final String JSON_PROPERTY_TYPE = "type"; + private ObservabilityPipelineBufferOptionsMemoryType type = + ObservabilityPipelineBufferOptionsMemoryType.MEMORY; + + public ObservabilityPipelineMemoryBufferOptions maxSize(Long maxSize) { + this.maxSize = maxSize; + return this; + } + + /** + * Maximum size of the memory buffer. + * + * @return maxSize + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_MAX_SIZE) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Long getMaxSize() { + return maxSize; + } + + public void setMaxSize(Long maxSize) { + this.maxSize = maxSize; + } + + public ObservabilityPipelineMemoryBufferOptions type( + ObservabilityPipelineBufferOptionsMemoryType type) { + this.type = type; + this.unparsed |= !type.isValid(); + return this; + } + + /** + * The type of the buffer that will be configured, a memory buffer. + * + * @return type + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_TYPE) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public ObservabilityPipelineBufferOptionsMemoryType getType() { + return type; + } + + public void setType(ObservabilityPipelineBufferOptionsMemoryType type) { + if (!type.isValid()) { + this.unparsed = true; + } + this.type = type; + } + + /** + * 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 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 ObservabilityPipelineMemoryBufferOptions + */ + @JsonAnySetter + public ObservabilityPipelineMemoryBufferOptions putAdditionalProperty(String key, Object value) { + if (this.additionalProperties == null) { + this.additionalProperties = new HashMap(); + } + this.additionalProperties.put(key, value); + return this; + } + + /** + * Return the additional (undeclared) property. + * + * @return The additional properties + */ + @JsonAnyGetter + public Map 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 ObservabilityPipelineMemoryBufferOptions object is equal to o. */ + @Override + public boolean equals(Object o) { + if (this == o) { + return true; + } + if (o == null || getClass() != o.getClass()) { + return false; + } + ObservabilityPipelineMemoryBufferOptions observabilityPipelineMemoryBufferOptions = + (ObservabilityPipelineMemoryBufferOptions) o; + return Objects.equals(this.maxSize, observabilityPipelineMemoryBufferOptions.maxSize) + && Objects.equals(this.type, observabilityPipelineMemoryBufferOptions.type) + && Objects.equals( + this.additionalProperties, + observabilityPipelineMemoryBufferOptions.additionalProperties); + } + + @Override + public int hashCode() { + return Objects.hash(maxSize, type, additionalProperties); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder(); + sb.append("class ObservabilityPipelineMemoryBufferOptions {\n"); + sb.append(" maxSize: ").append(toIndentedString(maxSize)).append("\n"); + sb.append(" type: ").append(toIndentedString(type)).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 "); + } +} diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineMemoryBufferSizeOptions.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineMemoryBufferSizeOptions.java new file mode 100644 index 00000000000..22dc94686e2 --- /dev/null +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineMemoryBufferSizeOptions.java @@ -0,0 +1,174 @@ +/* + * 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; + +/** Options for configuring a memory buffer by queue length. */ +@JsonPropertyOrder({ + ObservabilityPipelineMemoryBufferSizeOptions.JSON_PROPERTY_MAX_EVENTS, + ObservabilityPipelineMemoryBufferSizeOptions.JSON_PROPERTY_TYPE +}) +@jakarta.annotation.Generated( + value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") +public class ObservabilityPipelineMemoryBufferSizeOptions { + @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_MAX_EVENTS = "max_events"; + private Long maxEvents; + + public static final String JSON_PROPERTY_TYPE = "type"; + private ObservabilityPipelineBufferOptionsMemoryType type = + ObservabilityPipelineBufferOptionsMemoryType.MEMORY; + + public ObservabilityPipelineMemoryBufferSizeOptions maxEvents(Long maxEvents) { + this.maxEvents = maxEvents; + return this; + } + + /** + * Maximum events for the memory buffer. + * + * @return maxEvents + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_MAX_EVENTS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Long getMaxEvents() { + return maxEvents; + } + + public void setMaxEvents(Long maxEvents) { + this.maxEvents = maxEvents; + } + + public ObservabilityPipelineMemoryBufferSizeOptions type( + ObservabilityPipelineBufferOptionsMemoryType type) { + this.type = type; + this.unparsed |= !type.isValid(); + return this; + } + + /** + * The type of the buffer that will be configured, a memory buffer. + * + * @return type + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_TYPE) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public ObservabilityPipelineBufferOptionsMemoryType getType() { + return type; + } + + public void setType(ObservabilityPipelineBufferOptionsMemoryType type) { + if (!type.isValid()) { + this.unparsed = true; + } + this.type = type; + } + + /** + * 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 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 ObservabilityPipelineMemoryBufferSizeOptions + */ + @JsonAnySetter + public ObservabilityPipelineMemoryBufferSizeOptions putAdditionalProperty( + String key, Object value) { + if (this.additionalProperties == null) { + this.additionalProperties = new HashMap(); + } + this.additionalProperties.put(key, value); + return this; + } + + /** + * Return the additional (undeclared) property. + * + * @return The additional properties + */ + @JsonAnyGetter + public Map 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 ObservabilityPipelineMemoryBufferSizeOptions object is equal to o. */ + @Override + public boolean equals(Object o) { + if (this == o) { + return true; + } + if (o == null || getClass() != o.getClass()) { + return false; + } + ObservabilityPipelineMemoryBufferSizeOptions observabilityPipelineMemoryBufferSizeOptions = + (ObservabilityPipelineMemoryBufferSizeOptions) o; + return Objects.equals(this.maxEvents, observabilityPipelineMemoryBufferSizeOptions.maxEvents) + && Objects.equals(this.type, observabilityPipelineMemoryBufferSizeOptions.type) + && Objects.equals( + this.additionalProperties, + observabilityPipelineMemoryBufferSizeOptions.additionalProperties); + } + + @Override + public int hashCode() { + return Objects.hash(maxEvents, type, additionalProperties); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder(); + sb.append("class ObservabilityPipelineMemoryBufferSizeOptions {\n"); + sb.append(" maxEvents: ").append(toIndentedString(maxEvents)).append("\n"); + sb.append(" type: ").append(toIndentedString(type)).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 "); + } +} diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineNewRelicDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineNewRelicDestination.java index 4b5a6059657..f85076f201b 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineNewRelicDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineNewRelicDestination.java @@ -25,6 +25,7 @@ *

Supported pipeline types: logs */ @JsonPropertyOrder({ + ObservabilityPipelineNewRelicDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineNewRelicDestination.JSON_PROPERTY_ID, ObservabilityPipelineNewRelicDestination.JSON_PROPERTY_INPUTS, ObservabilityPipelineNewRelicDestination.JSON_PROPERTY_REGION, @@ -34,6 +35,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineNewRelicDestination { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -65,6 +69,29 @@ public ObservabilityPipelineNewRelicDestination( this.unparsed |= !type.isValid(); } + public ObservabilityPipelineNewRelicDestination 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 ObservabilityPipelineNewRelicDestination id(String id) { this.id = id; return this; @@ -217,7 +244,8 @@ public boolean equals(Object o) { } ObservabilityPipelineNewRelicDestination observabilityPipelineNewRelicDestination = (ObservabilityPipelineNewRelicDestination) o; - return Objects.equals(this.id, observabilityPipelineNewRelicDestination.id) + return Objects.equals(this.buffer, observabilityPipelineNewRelicDestination.buffer) + && Objects.equals(this.id, observabilityPipelineNewRelicDestination.id) && Objects.equals(this.inputs, observabilityPipelineNewRelicDestination.inputs) && Objects.equals(this.region, observabilityPipelineNewRelicDestination.region) && Objects.equals(this.type, observabilityPipelineNewRelicDestination.type) @@ -228,13 +256,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(id, inputs, region, type, additionalProperties); + return Objects.hash(buffer, id, inputs, region, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineNewRelicDestination {\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n"); sb.append(" region: ").append(toIndentedString(region)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineOpenSearchDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineOpenSearchDestination.java index 0f4884cc5dc..f1e9f4f0233 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineOpenSearchDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineOpenSearchDestination.java @@ -25,6 +25,7 @@ *

Supported pipeline types: logs */ @JsonPropertyOrder({ + ObservabilityPipelineOpenSearchDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineOpenSearchDestination.JSON_PROPERTY_BULK_INDEX, ObservabilityPipelineOpenSearchDestination.JSON_PROPERTY_DATA_STREAM, ObservabilityPipelineOpenSearchDestination.JSON_PROPERTY_ID, @@ -35,6 +36,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineOpenSearchDestination { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_BULK_INDEX = "bulk_index"; private String bulkIndex; @@ -65,6 +69,29 @@ public ObservabilityPipelineOpenSearchDestination( this.unparsed |= !type.isValid(); } + public ObservabilityPipelineOpenSearchDestination 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 ObservabilityPipelineOpenSearchDestination bulkIndex(String bulkIndex) { this.bulkIndex = bulkIndex; return this; @@ -237,7 +264,8 @@ public boolean equals(Object o) { } ObservabilityPipelineOpenSearchDestination observabilityPipelineOpenSearchDestination = (ObservabilityPipelineOpenSearchDestination) o; - return Objects.equals(this.bulkIndex, observabilityPipelineOpenSearchDestination.bulkIndex) + return Objects.equals(this.buffer, observabilityPipelineOpenSearchDestination.buffer) + && Objects.equals(this.bulkIndex, observabilityPipelineOpenSearchDestination.bulkIndex) && Objects.equals(this.dataStream, observabilityPipelineOpenSearchDestination.dataStream) && Objects.equals(this.id, observabilityPipelineOpenSearchDestination.id) && Objects.equals(this.inputs, observabilityPipelineOpenSearchDestination.inputs) @@ -249,13 +277,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(bulkIndex, dataStream, id, inputs, type, additionalProperties); + return Objects.hash(buffer, bulkIndex, dataStream, id, inputs, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineOpenSearchDestination {\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\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"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineRsyslogDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineRsyslogDestination.java index bb99d29f889..b0ac0d72203 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineRsyslogDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineRsyslogDestination.java @@ -26,6 +26,7 @@ *

Supported pipeline types: logs */ @JsonPropertyOrder({ + ObservabilityPipelineRsyslogDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineRsyslogDestination.JSON_PROPERTY_ID, ObservabilityPipelineRsyslogDestination.JSON_PROPERTY_INPUTS, ObservabilityPipelineRsyslogDestination.JSON_PROPERTY_KEEPALIVE, @@ -36,6 +37,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineRsyslogDestination { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -66,6 +70,28 @@ public ObservabilityPipelineRsyslogDestination( this.unparsed |= !type.isValid(); } + public ObservabilityPipelineRsyslogDestination 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 ObservabilityPipelineRsyslogDestination id(String id) { this.id = id; return this; @@ -236,7 +262,8 @@ public boolean equals(Object o) { } ObservabilityPipelineRsyslogDestination observabilityPipelineRsyslogDestination = (ObservabilityPipelineRsyslogDestination) o; - return Objects.equals(this.id, observabilityPipelineRsyslogDestination.id) + return Objects.equals(this.buffer, observabilityPipelineRsyslogDestination.buffer) + && Objects.equals(this.id, observabilityPipelineRsyslogDestination.id) && Objects.equals(this.inputs, observabilityPipelineRsyslogDestination.inputs) && Objects.equals(this.keepalive, observabilityPipelineRsyslogDestination.keepalive) && Objects.equals(this.tls, observabilityPipelineRsyslogDestination.tls) @@ -248,13 +275,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(id, inputs, keepalive, tls, type, additionalProperties); + return Objects.hash(buffer, id, inputs, keepalive, tls, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineRsyslogDestination {\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n"); sb.append(" keepalive: ").append(toIndentedString(keepalive)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSentinelOneDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSentinelOneDestination.java index afa0ca3f007..e4d54b1f230 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSentinelOneDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSentinelOneDestination.java @@ -25,6 +25,7 @@ *

Supported pipeline types: logs */ @JsonPropertyOrder({ + ObservabilityPipelineSentinelOneDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineSentinelOneDestination.JSON_PROPERTY_ID, ObservabilityPipelineSentinelOneDestination.JSON_PROPERTY_INPUTS, ObservabilityPipelineSentinelOneDestination.JSON_PROPERTY_REGION, @@ -34,6 +35,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineSentinelOneDestination { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -65,6 +69,29 @@ public ObservabilityPipelineSentinelOneDestination( this.unparsed |= !type.isValid(); } + public ObservabilityPipelineSentinelOneDestination 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 ObservabilityPipelineSentinelOneDestination id(String id) { this.id = id; return this; @@ -218,7 +245,8 @@ public boolean equals(Object o) { } ObservabilityPipelineSentinelOneDestination observabilityPipelineSentinelOneDestination = (ObservabilityPipelineSentinelOneDestination) o; - return Objects.equals(this.id, observabilityPipelineSentinelOneDestination.id) + return Objects.equals(this.buffer, observabilityPipelineSentinelOneDestination.buffer) + && Objects.equals(this.id, observabilityPipelineSentinelOneDestination.id) && Objects.equals(this.inputs, observabilityPipelineSentinelOneDestination.inputs) && Objects.equals(this.region, observabilityPipelineSentinelOneDestination.region) && Objects.equals(this.type, observabilityPipelineSentinelOneDestination.type) @@ -229,13 +257,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(id, inputs, region, type, additionalProperties); + return Objects.hash(buffer, id, inputs, region, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineSentinelOneDestination {\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n"); sb.append(" region: ").append(toIndentedString(region)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSocketDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSocketDestination.java index c2193bcfa08..448c0650efa 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSocketDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSocketDestination.java @@ -25,6 +25,7 @@ *

Supported pipeline types: logs */ @JsonPropertyOrder({ + ObservabilityPipelineSocketDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineSocketDestination.JSON_PROPERTY_ENCODING, ObservabilityPipelineSocketDestination.JSON_PROPERTY_FRAMING, ObservabilityPipelineSocketDestination.JSON_PROPERTY_ID, @@ -37,6 +38,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineSocketDestination { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_ENCODING = "encoding"; private ObservabilityPipelineSocketDestinationEncoding encoding; @@ -85,6 +89,28 @@ public ObservabilityPipelineSocketDestination( this.unparsed |= !type.isValid(); } + public ObservabilityPipelineSocketDestination 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 ObservabilityPipelineSocketDestination encoding( ObservabilityPipelineSocketDestinationEncoding encoding) { this.encoding = encoding; @@ -306,7 +332,8 @@ public boolean equals(Object o) { } ObservabilityPipelineSocketDestination observabilityPipelineSocketDestination = (ObservabilityPipelineSocketDestination) o; - return Objects.equals(this.encoding, observabilityPipelineSocketDestination.encoding) + return Objects.equals(this.buffer, observabilityPipelineSocketDestination.buffer) + && Objects.equals(this.encoding, observabilityPipelineSocketDestination.encoding) && Objects.equals(this.framing, observabilityPipelineSocketDestination.framing) && Objects.equals(this.id, observabilityPipelineSocketDestination.id) && Objects.equals(this.inputs, observabilityPipelineSocketDestination.inputs) @@ -319,13 +346,15 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(encoding, framing, id, inputs, mode, tls, type, additionalProperties); + return Objects.hash( + buffer, encoding, framing, id, inputs, mode, tls, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineSocketDestination {\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" encoding: ").append(toIndentedString(encoding)).append("\n"); sb.append(" framing: ").append(toIndentedString(framing)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSplunkHecDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSplunkHecDestination.java index ce0acda5641..a5291e3aef9 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSplunkHecDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSplunkHecDestination.java @@ -27,6 +27,7 @@ */ @JsonPropertyOrder({ ObservabilityPipelineSplunkHecDestination.JSON_PROPERTY_AUTO_EXTRACT_TIMESTAMP, + ObservabilityPipelineSplunkHecDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineSplunkHecDestination.JSON_PROPERTY_ENCODING, ObservabilityPipelineSplunkHecDestination.JSON_PROPERTY_ID, ObservabilityPipelineSplunkHecDestination.JSON_PROPERTY_INDEX, @@ -41,6 +42,9 @@ public class ObservabilityPipelineSplunkHecDestination { public static final String JSON_PROPERTY_AUTO_EXTRACT_TIMESTAMP = "auto_extract_timestamp"; private Boolean autoExtractTimestamp; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_ENCODING = "encoding"; private ObservabilityPipelineSplunkHecDestinationEncoding encoding; @@ -97,6 +101,29 @@ public void setAutoExtractTimestamp(Boolean autoExtractTimestamp) { this.autoExtractTimestamp = autoExtractTimestamp; } + public ObservabilityPipelineSplunkHecDestination 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 ObservabilityPipelineSplunkHecDestination encoding( ObservabilityPipelineSplunkHecDestinationEncoding encoding) { this.encoding = encoding; @@ -296,6 +323,7 @@ public boolean equals(Object o) { return Objects.equals( this.autoExtractTimestamp, observabilityPipelineSplunkHecDestination.autoExtractTimestamp) + && Objects.equals(this.buffer, observabilityPipelineSplunkHecDestination.buffer) && Objects.equals(this.encoding, observabilityPipelineSplunkHecDestination.encoding) && Objects.equals(this.id, observabilityPipelineSplunkHecDestination.id) && Objects.equals(this.index, observabilityPipelineSplunkHecDestination.index) @@ -310,7 +338,15 @@ public boolean equals(Object o) { @Override public int hashCode() { return Objects.hash( - autoExtractTimestamp, encoding, id, index, inputs, sourcetype, type, additionalProperties); + autoExtractTimestamp, + buffer, + encoding, + id, + index, + inputs, + sourcetype, + type, + additionalProperties); } @Override @@ -320,6 +356,7 @@ public String toString() { sb.append(" autoExtractTimestamp: ") .append(toIndentedString(autoExtractTimestamp)) .append("\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" encoding: ").append(toIndentedString(encoding)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" index: ").append(toIndentedString(index)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSumoLogicDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSumoLogicDestination.java index 241f315a1a7..ac19f6555da 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSumoLogicDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSumoLogicDestination.java @@ -25,6 +25,7 @@ *

Supported pipeline types: logs */ @JsonPropertyOrder({ + ObservabilityPipelineSumoLogicDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineSumoLogicDestination.JSON_PROPERTY_ENCODING, ObservabilityPipelineSumoLogicDestination.JSON_PROPERTY_HEADER_CUSTOM_FIELDS, ObservabilityPipelineSumoLogicDestination.JSON_PROPERTY_HEADER_HOST_NAME, @@ -38,6 +39,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineSumoLogicDestination { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_ENCODING = "encoding"; private ObservabilityPipelineSumoLogicDestinationEncoding encoding; @@ -78,6 +82,29 @@ public ObservabilityPipelineSumoLogicDestination( this.unparsed |= !type.isValid(); } + public ObservabilityPipelineSumoLogicDestination 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 ObservabilityPipelineSumoLogicDestination encoding( ObservabilityPipelineSumoLogicDestinationEncoding encoding) { this.encoding = encoding; @@ -333,7 +360,8 @@ public boolean equals(Object o) { } ObservabilityPipelineSumoLogicDestination observabilityPipelineSumoLogicDestination = (ObservabilityPipelineSumoLogicDestination) o; - return Objects.equals(this.encoding, observabilityPipelineSumoLogicDestination.encoding) + return Objects.equals(this.buffer, observabilityPipelineSumoLogicDestination.buffer) + && Objects.equals(this.encoding, observabilityPipelineSumoLogicDestination.encoding) && Objects.equals( this.headerCustomFields, observabilityPipelineSumoLogicDestination.headerCustomFields) && Objects.equals( @@ -354,6 +382,7 @@ public boolean equals(Object o) { @Override public int hashCode() { return Objects.hash( + buffer, encoding, headerCustomFields, headerHostName, @@ -369,6 +398,7 @@ public int hashCode() { public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineSumoLogicDestination {\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" encoding: ").append(toIndentedString(encoding)).append("\n"); sb.append(" headerCustomFields: ").append(toIndentedString(headerCustomFields)).append("\n"); sb.append(" headerHostName: ").append(toIndentedString(headerHostName)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSyslogNgDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSyslogNgDestination.java index f048dd4b192..8408e05ff91 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSyslogNgDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSyslogNgDestination.java @@ -26,6 +26,7 @@ *

Supported pipeline types: logs */ @JsonPropertyOrder({ + ObservabilityPipelineSyslogNgDestination.JSON_PROPERTY_BUFFER, ObservabilityPipelineSyslogNgDestination.JSON_PROPERTY_ID, ObservabilityPipelineSyslogNgDestination.JSON_PROPERTY_INPUTS, ObservabilityPipelineSyslogNgDestination.JSON_PROPERTY_KEEPALIVE, @@ -36,6 +37,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineSyslogNgDestination { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_BUFFER = "buffer"; + private ObservabilityPipelineBufferOptions buffer; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -66,6 +70,29 @@ public ObservabilityPipelineSyslogNgDestination( this.unparsed |= !type.isValid(); } + public ObservabilityPipelineSyslogNgDestination 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 ObservabilityPipelineSyslogNgDestination id(String id) { this.id = id; return this; @@ -236,7 +263,8 @@ public boolean equals(Object o) { } ObservabilityPipelineSyslogNgDestination observabilityPipelineSyslogNgDestination = (ObservabilityPipelineSyslogNgDestination) o; - return Objects.equals(this.id, observabilityPipelineSyslogNgDestination.id) + return Objects.equals(this.buffer, observabilityPipelineSyslogNgDestination.buffer) + && Objects.equals(this.id, observabilityPipelineSyslogNgDestination.id) && Objects.equals(this.inputs, observabilityPipelineSyslogNgDestination.inputs) && Objects.equals(this.keepalive, observabilityPipelineSyslogNgDestination.keepalive) && Objects.equals(this.tls, observabilityPipelineSyslogNgDestination.tls) @@ -248,13 +276,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(id, inputs, keepalive, tls, type, additionalProperties); + return Objects.hash(buffer, id, inputs, keepalive, tls, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineSyslogNgDestination {\n"); + sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n"); sb.append(" keepalive: ").append(toIndentedString(keepalive)).append("\n");