From 45f29eb0120e3ca365c1319bd6f254758f60d5ac Mon Sep 17 00:00:00 2001 From: "ci.datadog-api-spec" Date: Thu, 21 Aug 2025 17:08:29 +0000 Subject: [PATCH] Regenerate client from commit ca16233 of spec repo --- .generated-info | 4 +- .generator/schemas/v2/openapi.yaml | 110 +++++++++++++++++- .../observability_pipelines/src/v2/index.ts | 6 + .../src/v2/models/AzureStorageDestination.ts | 9 ++ .../v2/models/MicrosoftSentinelDestination.ts | 9 ++ ...lityPipelineAmazonOpenSearchDestination.ts | 9 ++ ...bservabilityPipelineAmazonS3Destination.ts | 9 ++ .../ObservabilityPipelineBufferOptions.ts | 14 +++ ...ervabilityPipelineBufferOptionsDiskType.ts | 9 ++ ...vabilityPipelineBufferOptionsMemoryType.ts | 9 ++ ...rvabilityPipelineDatadogLogsDestination.ts | 9 ++ .../ObservabilityPipelineDiskBufferOptions.ts | 55 +++++++++ ...abilityPipelineElasticsearchDestination.ts | 9 ++ ...ilityPipelineGoogleChronicleDestination.ts | 9 ++ ...tyPipelineGoogleCloudStorageDestination.ts | 9 ++ ...bservabilityPipelineMemoryBufferOptions.ts | 55 +++++++++ ...vabilityPipelineMemoryBufferSizeOptions.ts | 55 +++++++++ ...bservabilityPipelineNewRelicDestination.ts | 9 ++ ...ervabilityPipelineOpenSearchDestination.ts | 9 ++ .../ObservabilityPipelineQuotaProcessor.ts | 18 ++- ...ityPipelineQuotaProcessorOverflowAction.ts | 2 +- ...ObservabilityPipelineRsyslogDestination.ts | 9 ++ .../ObservabilityPipelineSampleProcessor.ts | 8 ++ ...rvabilityPipelineSentinelOneDestination.ts | 9 ++ ...servabilityPipelineSplunkHecDestination.ts | 9 ++ ...servabilityPipelineSumoLogicDestination.ts | 9 ++ ...bservabilityPipelineSyslogNgDestination.ts | 9 ++ .../src/v2/models/TypingInfo.ts | 16 +++ 28 files changed, 484 insertions(+), 12 deletions(-) create mode 100644 services/observability_pipelines/src/v2/models/ObservabilityPipelineBufferOptions.ts create mode 100644 services/observability_pipelines/src/v2/models/ObservabilityPipelineBufferOptionsDiskType.ts create mode 100644 services/observability_pipelines/src/v2/models/ObservabilityPipelineBufferOptionsMemoryType.ts create mode 100644 services/observability_pipelines/src/v2/models/ObservabilityPipelineDiskBufferOptions.ts create mode 100644 services/observability_pipelines/src/v2/models/ObservabilityPipelineMemoryBufferOptions.ts create mode 100644 services/observability_pipelines/src/v2/models/ObservabilityPipelineMemoryBufferSizeOptions.ts diff --git a/.generated-info b/.generated-info index 5e56f75ccf96..03d2a7546c18 100644 --- a/.generated-info +++ b/.generated-info @@ -1,4 +1,4 @@ { - "spec_repo_commit": "4413e63", - "generated": "2025-08-19 20:28:35.046" + "spec_repo_commit": "ca16233", + "generated": "2025-08-21 17:08:29.204" } diff --git a/.generator/schemas/v2/openapi.yaml b/.generator/schemas/v2/openapi.yaml index 5dc52e4a2ee2..7be522b9349c 100644 --- a/.generator/schemas/v2/openapi.yaml +++ b/.generator/schemas/v2/openapi.yaml @@ -4983,6 +4983,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. @@ -25037,6 +25039,8 @@ components: description: The `microsoft_sentinel` destination forwards logs to Microsoft Sentinel. properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' client_id: description: Azure AD client ID used for authentication. example: a1b2c3d4-5678-90ab-cdef-1234567890ab @@ -26669,6 +26673,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 @@ -26747,6 +26753,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 @@ -26919,6 +26927,30 @@ 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: Specifies the buffer type to configure. This option supports only + a disk buffer. + enum: + - disk + type: string + x-enum-varnames: + - DISK + ObservabilityPipelineBufferOptionsMemoryType: + default: memory + description: Specifies the buffer type to configure. This option supports only + a memory buffer. + enum: + - memory + type: string + x-enum-varnames: + - MEMORY ObservabilityPipelineConfig: description: Specifies the pipeline's configuration, including its sources, processors, and destinations. @@ -27232,6 +27264,8 @@ components: ObservabilityPipelineDatadogLogsDestination: description: The `datadog_logs` destination forwards logs to Datadog Log Management. properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' id: description: The unique identifier for this component. example: datadog-logs-destination @@ -27407,12 +27441,25 @@ 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' + type: object ObservabilityPipelineElasticsearchDestination: description: The `elasticsearch` destination writes logs to an Elasticsearch cluster. 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 @@ -27897,6 +27944,8 @@ components: properties: auth: $ref: '#/components/schemas/ObservabilityPipelineGcpAuth' + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' customer_id: description: The Google Chronicle customer ID. example: abcdefg123456789 @@ -27963,6 +28012,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 @@ -28273,6 +28324,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 disk 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: @@ -28296,6 +28369,8 @@ components: ObservabilityPipelineNewRelicDestination: description: The `new_relic` destination sends logs to the New Relic platform. properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' id: description: The unique identifier for this component. example: new-relic-destination @@ -28433,6 +28508,8 @@ components: ObservabilityPipelineOpenSearchDestination: description: The `opensearch` destination writes logs to an OpenSearch cluster. properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' bulk_index: description: The index to write logs to. example: logs-index @@ -28657,9 +28734,10 @@ components: can drop or alert. properties: drop_events: - description: If set to `true`, logs that matched the quota filter and sent - after the quota has been met are dropped; only logs that did not match - the filter query continue through the pipeline. + description: 'If set to `true`, logs that match the quota filter and are + sent after the quota is exceeded are dropped. Logs that do not match the + filter continue through the pipeline. **Note**: You can set either `drop_events` + or `overflow_action`, but not both.' example: false type: boolean id: @@ -28707,6 +28785,8 @@ components: items: type: string type: array + too_many_buckets_action: + $ref: '#/components/schemas/ObservabilityPipelineQuotaProcessorOverflowAction' type: $ref: '#/components/schemas/ObservabilityPipelineQuotaProcessorType' required: @@ -28714,7 +28794,6 @@ components: - type - include - name - - drop_events - limit - inputs type: object @@ -28745,7 +28824,8 @@ components: - BYTES - EVENTS ObservabilityPipelineQuotaProcessorOverflowAction: - description: 'The action to take when the quota is exceeded. Options: + description: 'The action to take when the quota or bucket limit is exceeded. + Options: - `drop`: Drop the event. @@ -29006,6 +29086,8 @@ components: description: The `rsyslog` destination forwards logs to an external `rsyslog` server over TCP or UDP using the syslog protocol. properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' id: description: The unique identifier for this component. example: rsyslog-destination @@ -29076,6 +29158,16 @@ components: description: The `sample` processor allows probabilistic sampling of logs at a fixed rate. properties: + group_by: + description: Optional list of fields to group events by. Each group is sampled + independently. + example: + - service + - host + items: + type: string + minItems: 1 + type: array id: description: The unique identifier for this component. Used to reference this component in other parts of the pipeline (for example, as the `input` @@ -29480,6 +29572,8 @@ components: ObservabilityPipelineSentinelOneDestination: description: The `sentinel_one` destination sends logs to SentinelOne. properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' id: description: The unique identifier for this component. example: sentinelone-destination @@ -29836,6 +29930,8 @@ components: ' example: true type: boolean + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' encoding: $ref: '#/components/schemas/ObservabilityPipelineSplunkHecDestinationEncoding' id: @@ -29949,6 +30045,8 @@ components: ObservabilityPipelineSumoLogicDestination: description: The `sumo_logic` destination forwards logs to Sumo Logic. properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' encoding: $ref: '#/components/schemas/ObservabilityPipelineSumoLogicDestinationEncoding' header_custom_fields: @@ -30052,6 +30150,8 @@ components: description: The `syslog_ng` destination forwards logs to an external `syslog-ng` server over TCP or UDP using the syslog protocol. properties: + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' id: description: The unique identifier for this component. example: syslog-ng-destination diff --git a/services/observability_pipelines/src/v2/index.ts b/services/observability_pipelines/src/v2/index.ts index 748a59a5298b..f7b6ba067b5b 100644 --- a/services/observability_pipelines/src/v2/index.ts +++ b/services/observability_pipelines/src/v2/index.ts @@ -35,6 +35,9 @@ export { ObservabilityPipelineAmazonS3SourceType } from "./models/ObservabilityP export { ObservabilityPipelineAmazonSecurityLakeDestination } from "./models/ObservabilityPipelineAmazonSecurityLakeDestination"; export { ObservabilityPipelineAmazonSecurityLakeDestinationType } from "./models/ObservabilityPipelineAmazonSecurityLakeDestinationType"; export { ObservabilityPipelineAwsAuth } from "./models/ObservabilityPipelineAwsAuth"; +export { ObservabilityPipelineBufferOptions } from "./models/ObservabilityPipelineBufferOptions"; +export { ObservabilityPipelineBufferOptionsDiskType } from "./models/ObservabilityPipelineBufferOptionsDiskType"; +export { ObservabilityPipelineBufferOptionsMemoryType } from "./models/ObservabilityPipelineBufferOptionsMemoryType"; export { ObservabilityPipelineConfig } from "./models/ObservabilityPipelineConfig"; export { ObservabilityPipelineConfigDestinationItem } from "./models/ObservabilityPipelineConfigDestinationItem"; export { ObservabilityPipelineConfigProcessorItem } from "./models/ObservabilityPipelineConfigProcessorItem"; @@ -61,6 +64,7 @@ export { ObservabilityPipelineDecoding } from "./models/ObservabilityPipelineDec export { ObservabilityPipelineDedupeProcessor } from "./models/ObservabilityPipelineDedupeProcessor"; export { ObservabilityPipelineDedupeProcessorMode } from "./models/ObservabilityPipelineDedupeProcessorMode"; export { ObservabilityPipelineDedupeProcessorType } from "./models/ObservabilityPipelineDedupeProcessorType"; +export { ObservabilityPipelineDiskBufferOptions } from "./models/ObservabilityPipelineDiskBufferOptions"; export { ObservabilityPipelineElasticsearchDestination } from "./models/ObservabilityPipelineElasticsearchDestination"; export { ObservabilityPipelineElasticsearchDestinationApiVersion } from "./models/ObservabilityPipelineElasticsearchDestinationApiVersion"; export { ObservabilityPipelineElasticsearchDestinationType } from "./models/ObservabilityPipelineElasticsearchDestinationType"; @@ -111,6 +115,8 @@ export { ObservabilityPipelineKafkaSourceSasl } from "./models/ObservabilityPipe export { ObservabilityPipelineKafkaSourceType } from "./models/ObservabilityPipelineKafkaSourceType"; export { ObservabilityPipelineLogstashSource } from "./models/ObservabilityPipelineLogstashSource"; export { ObservabilityPipelineLogstashSourceType } from "./models/ObservabilityPipelineLogstashSourceType"; +export { ObservabilityPipelineMemoryBufferOptions } from "./models/ObservabilityPipelineMemoryBufferOptions"; +export { ObservabilityPipelineMemoryBufferSizeOptions } from "./models/ObservabilityPipelineMemoryBufferSizeOptions"; export { ObservabilityPipelineMetadataEntry } from "./models/ObservabilityPipelineMetadataEntry"; export { ObservabilityPipelineMetricValue } from "./models/ObservabilityPipelineMetricValue"; export { ObservabilityPipelineNewRelicDestination } from "./models/ObservabilityPipelineNewRelicDestination"; diff --git a/services/observability_pipelines/src/v2/models/AzureStorageDestination.ts b/services/observability_pipelines/src/v2/models/AzureStorageDestination.ts index f87be8af32a7..684c66a96dda 100644 --- a/services/observability_pipelines/src/v2/models/AzureStorageDestination.ts +++ b/services/observability_pipelines/src/v2/models/AzureStorageDestination.ts @@ -1,6 +1,7 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; import { AzureStorageDestinationType } from "./AzureStorageDestinationType"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; /** * The `azure_storage` destination forwards logs to an Azure Blob Storage container. @@ -10,6 +11,10 @@ export class AzureStorageDestination { * Optional prefix for blobs written to the container. */ "blobPrefix"?: string; + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * The name of the Azure Blob Storage container to store logs in. */ @@ -45,6 +50,10 @@ export class AzureStorageDestination { baseName: "blob_prefix", type: "string", }, + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, containerName: { baseName: "container_name", type: "string", diff --git a/services/observability_pipelines/src/v2/models/MicrosoftSentinelDestination.ts b/services/observability_pipelines/src/v2/models/MicrosoftSentinelDestination.ts index deaf7d1973c7..1753d01677fb 100644 --- a/services/observability_pipelines/src/v2/models/MicrosoftSentinelDestination.ts +++ b/services/observability_pipelines/src/v2/models/MicrosoftSentinelDestination.ts @@ -1,11 +1,16 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; import { MicrosoftSentinelDestinationType } from "./MicrosoftSentinelDestinationType"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; /** * The `microsoft_sentinel` destination forwards logs to Microsoft Sentinel. */ export class MicrosoftSentinelDestination { + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * Azure AD client ID used for authentication. */ @@ -49,6 +54,10 @@ export class MicrosoftSentinelDestination { * @ignore */ static readonly attributeTypeMap: AttributeTypeMap = { + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, clientId: { baseName: "client_id", type: "string", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineAmazonOpenSearchDestination.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineAmazonOpenSearchDestination.ts index aaa428c87cc6..1202f4ea4432 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineAmazonOpenSearchDestination.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineAmazonOpenSearchDestination.ts @@ -2,6 +2,7 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; import { ObservabilityPipelineAmazonOpenSearchDestinationAuth } from "./ObservabilityPipelineAmazonOpenSearchDestinationAuth"; import { ObservabilityPipelineAmazonOpenSearchDestinationType } from "./ObservabilityPipelineAmazonOpenSearchDestinationType"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; /** * The `amazon_opensearch` destination writes logs to Amazon OpenSearch. @@ -12,6 +13,10 @@ export class ObservabilityPipelineAmazonOpenSearchDestination { * The `strategy` field determines whether basic or AWS-based authentication is used. */ "auth": ObservabilityPipelineAmazonOpenSearchDestinationAuth; + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * The index to write logs to. */ @@ -48,6 +53,10 @@ export class ObservabilityPipelineAmazonOpenSearchDestination { type: "ObservabilityPipelineAmazonOpenSearchDestinationAuth", required: true, }, + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, bulkIndex: { baseName: "bulk_index", type: "string", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineAmazonS3Destination.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineAmazonS3Destination.ts index 2951acd39d3f..bff5b99713d2 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineAmazonS3Destination.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineAmazonS3Destination.ts @@ -3,6 +3,7 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; import { ObservabilityPipelineAmazonS3DestinationStorageClass } from "./ObservabilityPipelineAmazonS3DestinationStorageClass"; import { ObservabilityPipelineAmazonS3DestinationType } from "./ObservabilityPipelineAmazonS3DestinationType"; import { ObservabilityPipelineAwsAuth } from "./ObservabilityPipelineAwsAuth"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; import { ObservabilityPipelineTls } from "./ObservabilityPipelineTls"; /** @@ -18,6 +19,10 @@ export class ObservabilityPipelineAmazonS3Destination { * S3 bucket name. */ "bucket": string; + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * Unique identifier for the destination component. */ @@ -70,6 +75,10 @@ export class ObservabilityPipelineAmazonS3Destination { type: "string", required: true, }, + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, id: { baseName: "id", type: "string", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineBufferOptions.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineBufferOptions.ts new file mode 100644 index 000000000000..8079f8871d4e --- /dev/null +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineBufferOptions.ts @@ -0,0 +1,14 @@ +import { UnparsedObject } from "@datadog/datadog-api-client"; + +import { ObservabilityPipelineDiskBufferOptions } from "./ObservabilityPipelineDiskBufferOptions"; +import { ObservabilityPipelineMemoryBufferOptions } from "./ObservabilityPipelineMemoryBufferOptions"; +import { ObservabilityPipelineMemoryBufferSizeOptions } from "./ObservabilityPipelineMemoryBufferSizeOptions"; + +/** + * Configuration for buffer settings on destination components. + */ +export type ObservabilityPipelineBufferOptions = + | ObservabilityPipelineDiskBufferOptions + | ObservabilityPipelineMemoryBufferOptions + | ObservabilityPipelineMemoryBufferSizeOptions + | UnparsedObject; diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineBufferOptionsDiskType.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineBufferOptionsDiskType.ts new file mode 100644 index 000000000000..eec5101b59f3 --- /dev/null +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineBufferOptionsDiskType.ts @@ -0,0 +1,9 @@ +import { UnparsedObject } from "@datadog/datadog-api-client"; + +/** + * Specifies the buffer type to configure. This option supports only a disk buffer. + */ +export type ObservabilityPipelineBufferOptionsDiskType = + | typeof DISK + | UnparsedObject; +export const DISK = "disk"; diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineBufferOptionsMemoryType.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineBufferOptionsMemoryType.ts new file mode 100644 index 000000000000..7861ff865740 --- /dev/null +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineBufferOptionsMemoryType.ts @@ -0,0 +1,9 @@ +import { UnparsedObject } from "@datadog/datadog-api-client"; + +/** + * Specifies the buffer type to configure. This option supports only a memory buffer. + */ +export type ObservabilityPipelineBufferOptionsMemoryType = + | typeof MEMORY + | UnparsedObject; +export const MEMORY = "memory"; diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineDatadogLogsDestination.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineDatadogLogsDestination.ts index 72a745883fc7..890cc06b10f9 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineDatadogLogsDestination.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineDatadogLogsDestination.ts @@ -1,11 +1,16 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; import { ObservabilityPipelineDatadogLogsDestinationType } from "./ObservabilityPipelineDatadogLogsDestinationType"; /** * The `datadog_logs` destination forwards logs to Datadog Log Management. */ export class ObservabilityPipelineDatadogLogsDestination { + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * The unique identifier for this component. */ @@ -33,6 +38,10 @@ export class ObservabilityPipelineDatadogLogsDestination { * @ignore */ static readonly attributeTypeMap: AttributeTypeMap = { + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, id: { baseName: "id", type: "string", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineDiskBufferOptions.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineDiskBufferOptions.ts new file mode 100644 index 000000000000..e26e819077e0 --- /dev/null +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineDiskBufferOptions.ts @@ -0,0 +1,55 @@ +import { AttributeTypeMap } from "@datadog/datadog-api-client"; + +import { ObservabilityPipelineBufferOptionsDiskType } from "./ObservabilityPipelineBufferOptionsDiskType"; + +/** + * Options for configuring a disk buffer. + */ +export class ObservabilityPipelineDiskBufferOptions { + /** + * Maximum size of the disk buffer. + */ + "maxSize"?: number; + /** + * Specifies the buffer type to configure. This option supports only a disk buffer. + */ + "type"?: ObservabilityPipelineBufferOptionsDiskType; + /** + * A container for additional, undeclared properties. + * This is a holder for any undeclared properties as specified with + * the 'additionalProperties' keyword in the OAS document. + */ + "additionalProperties"?: { [key: string]: any }; + /** + * @ignore + */ + "_unparsed"?: boolean; + + /** + * @ignore + */ + static readonly attributeTypeMap: AttributeTypeMap = { + maxSize: { + baseName: "max_size", + type: "number", + format: "int64", + }, + type: { + baseName: "type", + type: "ObservabilityPipelineBufferOptionsDiskType", + }, + additionalProperties: { + baseName: "additionalProperties", + type: "{ [key: string]: any; }", + }, + }; + + /** + * @ignore + */ + static getAttributeTypeMap(): AttributeTypeMap { + return ObservabilityPipelineDiskBufferOptions.attributeTypeMap; + } + + public constructor() {} +} diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineElasticsearchDestination.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineElasticsearchDestination.ts index b02763cc68eb..3b9eec77550a 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineElasticsearchDestination.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineElasticsearchDestination.ts @@ -1,5 +1,6 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; import { ObservabilityPipelineElasticsearchDestinationApiVersion } from "./ObservabilityPipelineElasticsearchDestinationApiVersion"; import { ObservabilityPipelineElasticsearchDestinationType } from "./ObservabilityPipelineElasticsearchDestinationType"; @@ -11,6 +12,10 @@ export class ObservabilityPipelineElasticsearchDestination { * The Elasticsearch API version to use. Set to `auto` to auto-detect. */ "apiVersion"?: ObservabilityPipelineElasticsearchDestinationApiVersion; + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * The index to write logs to in Elasticsearch. */ @@ -46,6 +51,10 @@ export class ObservabilityPipelineElasticsearchDestination { baseName: "api_version", type: "ObservabilityPipelineElasticsearchDestinationApiVersion", }, + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, bulkIndex: { baseName: "bulk_index", type: "string", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineGoogleChronicleDestination.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineGoogleChronicleDestination.ts index 64cafc002335..8a7359e13b37 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineGoogleChronicleDestination.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineGoogleChronicleDestination.ts @@ -1,5 +1,6 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; import { ObservabilityPipelineGcpAuth } from "./ObservabilityPipelineGcpAuth"; import { ObservabilityPipelineGoogleChronicleDestinationEncoding } from "./ObservabilityPipelineGoogleChronicleDestinationEncoding"; import { ObservabilityPipelineGoogleChronicleDestinationType } from "./ObservabilityPipelineGoogleChronicleDestinationType"; @@ -12,6 +13,10 @@ export class ObservabilityPipelineGoogleChronicleDestination { * GCP credentials used to authenticate with Google Cloud Storage. */ "auth": ObservabilityPipelineGcpAuth; + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * The Google Chronicle customer ID. */ @@ -56,6 +61,10 @@ export class ObservabilityPipelineGoogleChronicleDestination { type: "ObservabilityPipelineGcpAuth", required: true, }, + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, customerId: { baseName: "customer_id", type: "string", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineGoogleCloudStorageDestination.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineGoogleCloudStorageDestination.ts index 77ed997a849d..771ef3f69557 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineGoogleCloudStorageDestination.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineGoogleCloudStorageDestination.ts @@ -1,5 +1,6 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; import { ObservabilityPipelineGcpAuth } from "./ObservabilityPipelineGcpAuth"; import { ObservabilityPipelineGoogleCloudStorageDestinationAcl } from "./ObservabilityPipelineGoogleCloudStorageDestinationAcl"; import { ObservabilityPipelineGoogleCloudStorageDestinationStorageClass } from "./ObservabilityPipelineGoogleCloudStorageDestinationStorageClass"; @@ -23,6 +24,10 @@ export class ObservabilityPipelineGoogleCloudStorageDestination { * Name of the GCS bucket. */ "bucket": string; + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * Unique identifier for the destination component. */ @@ -77,6 +82,10 @@ export class ObservabilityPipelineGoogleCloudStorageDestination { type: "string", required: true, }, + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, id: { baseName: "id", type: "string", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineMemoryBufferOptions.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineMemoryBufferOptions.ts new file mode 100644 index 000000000000..c84954cd92e1 --- /dev/null +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineMemoryBufferOptions.ts @@ -0,0 +1,55 @@ +import { AttributeTypeMap } from "@datadog/datadog-api-client"; + +import { ObservabilityPipelineBufferOptionsMemoryType } from "./ObservabilityPipelineBufferOptionsMemoryType"; + +/** + * Options for configuring a memory buffer by byte size. + */ +export class ObservabilityPipelineMemoryBufferOptions { + /** + * Maximum size of the disk buffer. + */ + "maxSize"?: number; + /** + * Specifies the buffer type to configure. This option supports only a memory buffer. + */ + "type"?: ObservabilityPipelineBufferOptionsMemoryType; + /** + * A container for additional, undeclared properties. + * This is a holder for any undeclared properties as specified with + * the 'additionalProperties' keyword in the OAS document. + */ + "additionalProperties"?: { [key: string]: any }; + /** + * @ignore + */ + "_unparsed"?: boolean; + + /** + * @ignore + */ + static readonly attributeTypeMap: AttributeTypeMap = { + maxSize: { + baseName: "max_size", + type: "number", + format: "int64", + }, + type: { + baseName: "type", + type: "ObservabilityPipelineBufferOptionsMemoryType", + }, + additionalProperties: { + baseName: "additionalProperties", + type: "{ [key: string]: any; }", + }, + }; + + /** + * @ignore + */ + static getAttributeTypeMap(): AttributeTypeMap { + return ObservabilityPipelineMemoryBufferOptions.attributeTypeMap; + } + + public constructor() {} +} diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineMemoryBufferSizeOptions.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineMemoryBufferSizeOptions.ts new file mode 100644 index 000000000000..2313a386b895 --- /dev/null +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineMemoryBufferSizeOptions.ts @@ -0,0 +1,55 @@ +import { AttributeTypeMap } from "@datadog/datadog-api-client"; + +import { ObservabilityPipelineBufferOptionsMemoryType } from "./ObservabilityPipelineBufferOptionsMemoryType"; + +/** + * Options for configuring a memory buffer by queue length. + */ +export class ObservabilityPipelineMemoryBufferSizeOptions { + /** + * Maximum events for the memory buffer. + */ + "maxEvents"?: number; + /** + * Specifies the buffer type to configure. This option supports only a memory buffer. + */ + "type"?: ObservabilityPipelineBufferOptionsMemoryType; + /** + * A container for additional, undeclared properties. + * This is a holder for any undeclared properties as specified with + * the 'additionalProperties' keyword in the OAS document. + */ + "additionalProperties"?: { [key: string]: any }; + /** + * @ignore + */ + "_unparsed"?: boolean; + + /** + * @ignore + */ + static readonly attributeTypeMap: AttributeTypeMap = { + maxEvents: { + baseName: "max_events", + type: "number", + format: "int64", + }, + type: { + baseName: "type", + type: "ObservabilityPipelineBufferOptionsMemoryType", + }, + additionalProperties: { + baseName: "additionalProperties", + type: "{ [key: string]: any; }", + }, + }; + + /** + * @ignore + */ + static getAttributeTypeMap(): AttributeTypeMap { + return ObservabilityPipelineMemoryBufferSizeOptions.attributeTypeMap; + } + + public constructor() {} +} diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineNewRelicDestination.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineNewRelicDestination.ts index 8fbb6db08543..56e1d02bda26 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineNewRelicDestination.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineNewRelicDestination.ts @@ -1,5 +1,6 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; import { ObservabilityPipelineNewRelicDestinationRegion } from "./ObservabilityPipelineNewRelicDestinationRegion"; import { ObservabilityPipelineNewRelicDestinationType } from "./ObservabilityPipelineNewRelicDestinationType"; @@ -7,6 +8,10 @@ import { ObservabilityPipelineNewRelicDestinationType } from "./ObservabilityPip * The `new_relic` destination sends logs to the New Relic platform. */ export class ObservabilityPipelineNewRelicDestination { + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * The unique identifier for this component. */ @@ -38,6 +43,10 @@ export class ObservabilityPipelineNewRelicDestination { * @ignore */ static readonly attributeTypeMap: AttributeTypeMap = { + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, id: { baseName: "id", type: "string", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineOpenSearchDestination.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineOpenSearchDestination.ts index 9ec99f471ce7..7a838f0725c0 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineOpenSearchDestination.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineOpenSearchDestination.ts @@ -1,11 +1,16 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; import { ObservabilityPipelineOpenSearchDestinationType } from "./ObservabilityPipelineOpenSearchDestinationType"; /** * The `opensearch` destination writes logs to an OpenSearch cluster. */ export class ObservabilityPipelineOpenSearchDestination { + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * The index to write logs to. */ @@ -37,6 +42,10 @@ export class ObservabilityPipelineOpenSearchDestination { * @ignore */ static readonly attributeTypeMap: AttributeTypeMap = { + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, bulkIndex: { baseName: "bulk_index", type: "string", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineQuotaProcessor.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineQuotaProcessor.ts index 3084dfa0ab17..d77147e5a128 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineQuotaProcessor.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineQuotaProcessor.ts @@ -10,9 +10,9 @@ import { ObservabilityPipelineQuotaProcessorType } from "./ObservabilityPipeline */ export class ObservabilityPipelineQuotaProcessor { /** - * If set to `true`, logs that matched the quota filter and sent after the quota has been met are dropped; only logs that did not match the filter query continue through the pipeline. + * If set to `true`, logs that match the quota filter and are sent after the quota is exceeded are dropped. Logs that do not match the filter continue through the pipeline. **Note**: You can set either `drop_events` or `overflow_action`, but not both. */ - "dropEvents": boolean; + "dropEvents"?: boolean; /** * The unique identifier for this component. Used to reference this component in other parts of the pipeline (for example, as the `input` to downstream components). */ @@ -38,7 +38,7 @@ export class ObservabilityPipelineQuotaProcessor { */ "name": string; /** - * The action to take when the quota is exceeded. Options: + * The action to take when the quota or bucket limit is exceeded. Options: * - `drop`: Drop the event. * - `no_action`: Let the event pass through. * - `overflow_routing`: Route to an overflow destination. @@ -52,6 +52,13 @@ export class ObservabilityPipelineQuotaProcessor { * A list of fields used to segment log traffic for quota enforcement. Quotas are tracked independently by unique combinations of these field values. */ "partitionFields"?: Array; + /** + * The action to take when the quota or bucket limit is exceeded. Options: + * - `drop`: Drop the event. + * - `no_action`: Let the event pass through. + * - `overflow_routing`: Route to an overflow destination. + */ + "tooManyBucketsAction"?: ObservabilityPipelineQuotaProcessorOverflowAction; /** * The processor type. The value should always be `quota`. */ @@ -74,7 +81,6 @@ export class ObservabilityPipelineQuotaProcessor { dropEvents: { baseName: "drop_events", type: "boolean", - required: true, }, id: { baseName: "id", @@ -117,6 +123,10 @@ export class ObservabilityPipelineQuotaProcessor { baseName: "partition_fields", type: "Array", }, + tooManyBucketsAction: { + baseName: "too_many_buckets_action", + type: "ObservabilityPipelineQuotaProcessorOverflowAction", + }, type: { baseName: "type", type: "ObservabilityPipelineQuotaProcessorType", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineQuotaProcessorOverflowAction.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineQuotaProcessorOverflowAction.ts index 0ad1e9dd5cec..f1e24bf0772c 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineQuotaProcessorOverflowAction.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineQuotaProcessorOverflowAction.ts @@ -1,7 +1,7 @@ import { UnparsedObject } from "@datadog/datadog-api-client"; /** - * The action to take when the quota is exceeded. Options: + * The action to take when the quota or bucket limit is exceeded. Options: * - `drop`: Drop the event. * - `no_action`: Let the event pass through. * - `overflow_routing`: Route to an overflow destination. diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineRsyslogDestination.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineRsyslogDestination.ts index bd4891ed1ee3..d879fa5424ef 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineRsyslogDestination.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineRsyslogDestination.ts @@ -1,5 +1,6 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; import { ObservabilityPipelineRsyslogDestinationType } from "./ObservabilityPipelineRsyslogDestinationType"; import { ObservabilityPipelineTls } from "./ObservabilityPipelineTls"; @@ -7,6 +8,10 @@ import { ObservabilityPipelineTls } from "./ObservabilityPipelineTls"; * The `rsyslog` destination forwards logs to an external `rsyslog` server over TCP or UDP using the syslog protocol. */ export class ObservabilityPipelineRsyslogDestination { + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * The unique identifier for this component. */ @@ -42,6 +47,10 @@ export class ObservabilityPipelineRsyslogDestination { * @ignore */ static readonly attributeTypeMap: AttributeTypeMap = { + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, id: { baseName: "id", type: "string", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineSampleProcessor.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineSampleProcessor.ts index 5c38f6749e54..cafad1b79072 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineSampleProcessor.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineSampleProcessor.ts @@ -6,6 +6,10 @@ import { ObservabilityPipelineSampleProcessorType } from "./ObservabilityPipelin * The `sample` processor allows probabilistic sampling of logs at a fixed rate. */ export class ObservabilityPipelineSampleProcessor { + /** + * Optional list of fields to group events by. Each group is sampled independently. + */ + "groupBy"?: Array; /** * The unique identifier for this component. Used to reference this component in other parts of the pipeline (for example, as the `input` to downstream components). */ @@ -45,6 +49,10 @@ export class ObservabilityPipelineSampleProcessor { * @ignore */ static readonly attributeTypeMap: AttributeTypeMap = { + groupBy: { + baseName: "group_by", + type: "Array", + }, id: { baseName: "id", type: "string", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineSentinelOneDestination.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineSentinelOneDestination.ts index 8c90f731fe95..118a96553292 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineSentinelOneDestination.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineSentinelOneDestination.ts @@ -1,5 +1,6 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; import { ObservabilityPipelineSentinelOneDestinationRegion } from "./ObservabilityPipelineSentinelOneDestinationRegion"; import { ObservabilityPipelineSentinelOneDestinationType } from "./ObservabilityPipelineSentinelOneDestinationType"; @@ -7,6 +8,10 @@ import { ObservabilityPipelineSentinelOneDestinationType } from "./Observability * The `sentinel_one` destination sends logs to SentinelOne. */ export class ObservabilityPipelineSentinelOneDestination { + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * The unique identifier for this component. */ @@ -38,6 +43,10 @@ export class ObservabilityPipelineSentinelOneDestination { * @ignore */ static readonly attributeTypeMap: AttributeTypeMap = { + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, id: { baseName: "id", type: "string", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineSplunkHecDestination.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineSplunkHecDestination.ts index 53e0329745eb..fd7714b0e0bd 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineSplunkHecDestination.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineSplunkHecDestination.ts @@ -1,5 +1,6 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; import { ObservabilityPipelineSplunkHecDestinationEncoding } from "./ObservabilityPipelineSplunkHecDestinationEncoding"; import { ObservabilityPipelineSplunkHecDestinationType } from "./ObservabilityPipelineSplunkHecDestinationType"; @@ -12,6 +13,10 @@ export class ObservabilityPipelineSplunkHecDestination { * If `false`, Splunk assigns the time the event was received. */ "autoExtractTimestamp"?: boolean; + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * Encoding format for log events. */ @@ -55,6 +60,10 @@ export class ObservabilityPipelineSplunkHecDestination { baseName: "auto_extract_timestamp", type: "boolean", }, + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, encoding: { baseName: "encoding", type: "ObservabilityPipelineSplunkHecDestinationEncoding", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineSumoLogicDestination.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineSumoLogicDestination.ts index 7e365cedd79d..17667f6b24d0 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineSumoLogicDestination.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineSumoLogicDestination.ts @@ -1,5 +1,6 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; import { ObservabilityPipelineSumoLogicDestinationEncoding } from "./ObservabilityPipelineSumoLogicDestinationEncoding"; import { ObservabilityPipelineSumoLogicDestinationHeaderCustomFieldsItem } from "./ObservabilityPipelineSumoLogicDestinationHeaderCustomFieldsItem"; import { ObservabilityPipelineSumoLogicDestinationType } from "./ObservabilityPipelineSumoLogicDestinationType"; @@ -8,6 +9,10 @@ import { ObservabilityPipelineSumoLogicDestinationType } from "./ObservabilityPi * The `sumo_logic` destination forwards logs to Sumo Logic. */ export class ObservabilityPipelineSumoLogicDestination { + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * The output encoding format. */ @@ -55,6 +60,10 @@ export class ObservabilityPipelineSumoLogicDestination { * @ignore */ static readonly attributeTypeMap: AttributeTypeMap = { + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, encoding: { baseName: "encoding", type: "ObservabilityPipelineSumoLogicDestinationEncoding", diff --git a/services/observability_pipelines/src/v2/models/ObservabilityPipelineSyslogNgDestination.ts b/services/observability_pipelines/src/v2/models/ObservabilityPipelineSyslogNgDestination.ts index fdf0686e9135..136e37161e78 100644 --- a/services/observability_pipelines/src/v2/models/ObservabilityPipelineSyslogNgDestination.ts +++ b/services/observability_pipelines/src/v2/models/ObservabilityPipelineSyslogNgDestination.ts @@ -1,5 +1,6 @@ import { AttributeTypeMap } from "@datadog/datadog-api-client"; +import { ObservabilityPipelineBufferOptions } from "./ObservabilityPipelineBufferOptions"; import { ObservabilityPipelineSyslogNgDestinationType } from "./ObservabilityPipelineSyslogNgDestinationType"; import { ObservabilityPipelineTls } from "./ObservabilityPipelineTls"; @@ -7,6 +8,10 @@ import { ObservabilityPipelineTls } from "./ObservabilityPipelineTls"; * The `syslog_ng` destination forwards logs to an external `syslog-ng` server over TCP or UDP using the syslog protocol. */ export class ObservabilityPipelineSyslogNgDestination { + /** + * Configuration for buffer settings on destination components. + */ + "buffer"?: ObservabilityPipelineBufferOptions; /** * The unique identifier for this component. */ @@ -42,6 +47,10 @@ export class ObservabilityPipelineSyslogNgDestination { * @ignore */ static readonly attributeTypeMap: AttributeTypeMap = { + buffer: { + baseName: "buffer", + type: "ObservabilityPipelineBufferOptions", + }, id: { baseName: "id", type: "string", diff --git a/services/observability_pipelines/src/v2/models/TypingInfo.ts b/services/observability_pipelines/src/v2/models/TypingInfo.ts index b67725954821..9941db5a1324 100644 --- a/services/observability_pipelines/src/v2/models/TypingInfo.ts +++ b/services/observability_pipelines/src/v2/models/TypingInfo.ts @@ -27,6 +27,7 @@ import { ObservabilityPipelineDatadogAgentSource } from "./ObservabilityPipeline import { ObservabilityPipelineDatadogLogsDestination } from "./ObservabilityPipelineDatadogLogsDestination"; import { ObservabilityPipelineDatadogTagsProcessor } from "./ObservabilityPipelineDatadogTagsProcessor"; import { ObservabilityPipelineDedupeProcessor } from "./ObservabilityPipelineDedupeProcessor"; +import { ObservabilityPipelineDiskBufferOptions } from "./ObservabilityPipelineDiskBufferOptions"; import { ObservabilityPipelineElasticsearchDestination } from "./ObservabilityPipelineElasticsearchDestination"; import { ObservabilityPipelineEnrichmentTableFile } from "./ObservabilityPipelineEnrichmentTableFile"; import { ObservabilityPipelineEnrichmentTableFileEncoding } from "./ObservabilityPipelineEnrichmentTableFileEncoding"; @@ -52,6 +53,8 @@ import { ObservabilityPipelineKafkaSource } from "./ObservabilityPipelineKafkaSo import { ObservabilityPipelineKafkaSourceLibrdkafkaOption } from "./ObservabilityPipelineKafkaSourceLibrdkafkaOption"; import { ObservabilityPipelineKafkaSourceSasl } from "./ObservabilityPipelineKafkaSourceSasl"; import { ObservabilityPipelineLogstashSource } from "./ObservabilityPipelineLogstashSource"; +import { ObservabilityPipelineMemoryBufferOptions } from "./ObservabilityPipelineMemoryBufferOptions"; +import { ObservabilityPipelineMemoryBufferSizeOptions } from "./ObservabilityPipelineMemoryBufferSizeOptions"; import { ObservabilityPipelineMetadataEntry } from "./ObservabilityPipelineMetadataEntry"; import { ObservabilityPipelineNewRelicDestination } from "./ObservabilityPipelineNewRelicDestination"; import { ObservabilityPipelineOcsfMapperProcessor } from "./ObservabilityPipelineOcsfMapperProcessor"; @@ -144,6 +147,8 @@ export const TypingInfo: ModelTypingInfo = { ObservabilityPipelineAmazonSecurityLakeDestinationType: [ "amazon_security_lake", ], + ObservabilityPipelineBufferOptionsDiskType: ["disk"], + ObservabilityPipelineBufferOptionsMemoryType: ["memory"], ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm: ["gzip", "zlib"], ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding: [ @@ -350,6 +355,11 @@ export const TypingInfo: ModelTypingInfo = { ObservabilityPipelineThrottleProcessorType: ["throttle"], }, oneOfMap: { + ObservabilityPipelineBufferOptions: [ + "ObservabilityPipelineDiskBufferOptions", + "ObservabilityPipelineMemoryBufferOptions", + "ObservabilityPipelineMemoryBufferSizeOptions", + ], ObservabilityPipelineConfigDestinationItem: [ "ObservabilityPipelineDatadogLogsDestination", "ObservabilityPipelineAmazonS3Destination", @@ -484,6 +494,8 @@ export const TypingInfo: ModelTypingInfo = { ObservabilityPipelineDatadogTagsProcessor: ObservabilityPipelineDatadogTagsProcessor, ObservabilityPipelineDedupeProcessor: ObservabilityPipelineDedupeProcessor, + ObservabilityPipelineDiskBufferOptions: + ObservabilityPipelineDiskBufferOptions, ObservabilityPipelineElasticsearchDestination: ObservabilityPipelineElasticsearchDestination, ObservabilityPipelineEnrichmentTableFile: @@ -525,6 +537,10 @@ export const TypingInfo: ModelTypingInfo = { ObservabilityPipelineKafkaSourceLibrdkafkaOption, ObservabilityPipelineKafkaSourceSasl: ObservabilityPipelineKafkaSourceSasl, ObservabilityPipelineLogstashSource: ObservabilityPipelineLogstashSource, + ObservabilityPipelineMemoryBufferOptions: + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions: + ObservabilityPipelineMemoryBufferSizeOptions, ObservabilityPipelineMetadataEntry: ObservabilityPipelineMetadataEntry, ObservabilityPipelineNewRelicDestination: ObservabilityPipelineNewRelicDestination,