diff --git a/.generated-info b/.generated-info index ba5de8a7a1..69961b2e92 100644 --- a/.generated-info +++ b/.generated-info @@ -1,4 +1,4 @@ { - "spec_repo_commit": "69305be", - "generated": "2025-08-05 16:20:40.645" + "spec_repo_commit": "884871f", + "generated": "2025-08-05 21:31:29.263" } diff --git a/.generator/schemas/v2/openapi.yaml b/.generator/schemas/v2/openapi.yaml index 5da536bf8c..fe85236ddd 100644 --- a/.generator/schemas/v2/openapi.yaml +++ b/.generator/schemas/v2/openapi.yaml @@ -4946,6 +4946,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. @@ -24998,6 +25000,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 @@ -26630,6 +26634,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 @@ -26708,6 +26714,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 @@ -26827,6 +26835,28 @@ 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 ObservabilityPipelineConfig: description: Specifies the pipeline's configuration, including its sources, processors, and destinations. @@ -26982,6 +27012,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 @@ -27083,12 +27115,27 @@ 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 + maximum: 536870912000 + minimum: 268435488 + 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 @@ -27573,6 +27620,8 @@ components: properties: auth: $ref: '#/components/schemas/ObservabilityPipelineGcpAuth' + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' customer_id: description: The Google Chronicle customer ID. example: abcdefg123456789 @@ -27639,6 +27688,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 @@ -27949,6 +28000,32 @@ 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 + maximum: 13743895347 + minimum: 1 + type: integer + type: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptionsMemoryType' + type: object + ObservabilityPipelineMemoryBufferSizeOptions: + description: Options for configuring a memory buffer by queue length. + properties: + max_events: + description: The `ObservabilityPipelineMemoryBufferSizeOptions` `max_events`. + example: 500 + format: int64 + maximum: 268435456 + minimum: 1 + type: integer + type: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptionsMemoryType' + type: object ObservabilityPipelineMetadataEntry: description: A custom metadata entry. properties: @@ -27972,6 +28049,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 @@ -28109,6 +28188,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 @@ -28683,6 +28764,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 @@ -29157,6 +29240,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 @@ -29241,6 +29326,8 @@ components: ' example: true type: boolean + buffer: + $ref: '#/components/schemas/ObservabilityPipelineBufferOptions' encoding: $ref: '#/components/schemas/ObservabilityPipelineSplunkHecDestinationEncoding' id: @@ -29354,6 +29441,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: @@ -29457,6 +29546,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/docs/datadog_api_client.v2.model.rst b/docs/datadog_api_client.v2.model.rst index a1972b9342..4b2748cca5 100644 --- a/docs/datadog_api_client.v2.model.rst +++ b/docs/datadog_api_client.v2.model.rst @@ -11855,6 +11855,27 @@ datadog\_api\_client.v2.model.observability\_pipeline\_aws\_auth module :members: :show-inheritance: +datadog\_api\_client.v2.model.observability\_pipeline\_buffer\_options module +----------------------------------------------------------------------------- + +.. automodule:: datadog_api_client.v2.model.observability_pipeline_buffer_options + :members: + :show-inheritance: + +datadog\_api\_client.v2.model.observability\_pipeline\_buffer\_options\_disk\_type module +----------------------------------------------------------------------------------------- + +.. automodule:: datadog_api_client.v2.model.observability_pipeline_buffer_options_disk_type + :members: + :show-inheritance: + +datadog\_api\_client.v2.model.observability\_pipeline\_buffer\_options\_memory\_type module +------------------------------------------------------------------------------------------- + +.. automodule:: datadog_api_client.v2.model.observability_pipeline_buffer_options_memory_type + :members: + :show-inheritance: + datadog\_api\_client.v2.model.observability\_pipeline\_config module -------------------------------------------------------------------- @@ -11953,6 +11974,13 @@ datadog\_api\_client.v2.model.observability\_pipeline\_dedupe\_processor\_type m :members: :show-inheritance: +datadog\_api\_client.v2.model.observability\_pipeline\_disk\_buffer\_options module +----------------------------------------------------------------------------------- + +.. automodule:: datadog_api_client.v2.model.observability_pipeline_disk_buffer_options + :members: + :show-inheritance: + datadog\_api\_client.v2.model.observability\_pipeline\_elasticsearch\_destination module ---------------------------------------------------------------------------------------- @@ -12296,6 +12324,20 @@ datadog\_api\_client.v2.model.observability\_pipeline\_logstash\_source\_type mo :members: :show-inheritance: +datadog\_api\_client.v2.model.observability\_pipeline\_memory\_buffer\_options module +------------------------------------------------------------------------------------- + +.. automodule:: datadog_api_client.v2.model.observability_pipeline_memory_buffer_options + :members: + :show-inheritance: + +datadog\_api\_client.v2.model.observability\_pipeline\_memory\_buffer\_size\_options module +------------------------------------------------------------------------------------------- + +.. automodule:: datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options + :members: + :show-inheritance: + datadog\_api\_client.v2.model.observability\_pipeline\_metadata\_entry module ----------------------------------------------------------------------------- diff --git a/src/datadog_api_client/v2/model/azure_storage_destination.py b/src/datadog_api_client/v2/model/azure_storage_destination.py index 283e2df4aa..11c78496d6 100644 --- a/src/datadog_api_client/v2/model/azure_storage_destination.py +++ b/src/datadog_api_client/v2/model/azure_storage_destination.py @@ -14,16 +14,28 @@ if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.azure_storage_destination_type import AzureStorageDestinationType + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class AzureStorageDestination(ModelNormal): @cached_property def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.azure_storage_destination_type import AzureStorageDestinationType return { "blob_prefix": (str,), + "buffer": (ObservabilityPipelineBufferOptions,), "container_name": (str,), "id": (str,), "inputs": ([str],), @@ -32,6 +44,7 @@ def openapi_types(_): attribute_map = { "blob_prefix": "blob_prefix", + "buffer": "buffer", "container_name": "container_name", "id": "id", "inputs": "inputs", @@ -45,6 +58,13 @@ def __init__( inputs: List[str], type: AzureStorageDestinationType, blob_prefix: Union[str, UnsetType] = unset, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, **kwargs, ): """ @@ -53,6 +73,9 @@ def __init__( :param blob_prefix: Optional prefix for blobs written to the container. :type blob_prefix: str, optional + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param container_name: The name of the Azure Blob Storage container to store logs in. :type container_name: str @@ -67,6 +90,8 @@ def __init__( """ if blob_prefix is not unset: kwargs["blob_prefix"] = blob_prefix + if buffer is not unset: + kwargs["buffer"] = buffer super().__init__(kwargs) self_.container_name = container_name diff --git a/src/datadog_api_client/v2/model/microsoft_sentinel_destination.py b/src/datadog_api_client/v2/model/microsoft_sentinel_destination.py index 44868adb77..1d4d005b60 100644 --- a/src/datadog_api_client/v2/model/microsoft_sentinel_destination.py +++ b/src/datadog_api_client/v2/model/microsoft_sentinel_destination.py @@ -3,24 +3,38 @@ # Copyright 2019-Present Datadog, Inc. from __future__ import annotations -from typing import List, TYPE_CHECKING +from typing import List, Union, TYPE_CHECKING from datadog_api_client.model_utils import ( ModelNormal, cached_property, + unset, + UnsetType, ) if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.microsoft_sentinel_destination_type import MicrosoftSentinelDestinationType + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class MicrosoftSentinelDestination(ModelNormal): @cached_property def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.microsoft_sentinel_destination_type import MicrosoftSentinelDestinationType return { + "buffer": (ObservabilityPipelineBufferOptions,), "client_id": (str,), "dcr_immutable_id": (str,), "id": (str,), @@ -31,6 +45,7 @@ def openapi_types(_): } attribute_map = { + "buffer": "buffer", "client_id": "client_id", "dcr_immutable_id": "dcr_immutable_id", "id": "id", @@ -49,11 +64,21 @@ def __init__( table: str, tenant_id: str, type: MicrosoftSentinelDestinationType, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, **kwargs, ): """ The ``microsoft_sentinel`` destination forwards logs to Microsoft Sentinel. + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param client_id: Azure AD client ID used for authentication. :type client_id: str @@ -75,6 +100,8 @@ def __init__( :param type: The destination type. The value should always be ``microsoft_sentinel``. :type type: MicrosoftSentinelDestinationType """ + if buffer is not unset: + kwargs["buffer"] = buffer super().__init__(kwargs) self_.client_id = client_id diff --git a/src/datadog_api_client/v2/model/observability_pipeline_amazon_open_search_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_amazon_open_search_destination.py index 639d156f8b..518ff59fc3 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_amazon_open_search_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_amazon_open_search_destination.py @@ -17,9 +17,19 @@ from datadog_api_client.v2.model.observability_pipeline_amazon_open_search_destination_auth import ( ObservabilityPipelineAmazonOpenSearchDestinationAuth, ) + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_amazon_open_search_destination_type import ( ObservabilityPipelineAmazonOpenSearchDestinationType, ) + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class ObservabilityPipelineAmazonOpenSearchDestination(ModelNormal): @@ -28,12 +38,14 @@ def openapi_types(_): from datadog_api_client.v2.model.observability_pipeline_amazon_open_search_destination_auth import ( ObservabilityPipelineAmazonOpenSearchDestinationAuth, ) + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_amazon_open_search_destination_type import ( ObservabilityPipelineAmazonOpenSearchDestinationType, ) return { "auth": (ObservabilityPipelineAmazonOpenSearchDestinationAuth,), + "buffer": (ObservabilityPipelineBufferOptions,), "bulk_index": (str,), "id": (str,), "inputs": ([str],), @@ -42,6 +54,7 @@ def openapi_types(_): attribute_map = { "auth": "auth", + "buffer": "buffer", "bulk_index": "bulk_index", "id": "id", "inputs": "inputs", @@ -54,6 +67,13 @@ def __init__( id: str, inputs: List[str], type: ObservabilityPipelineAmazonOpenSearchDestinationType, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, bulk_index: Union[str, UnsetType] = unset, **kwargs, ): @@ -64,6 +84,9 @@ def __init__( The ``strategy`` field determines whether basic or AWS-based authentication is used. :type auth: ObservabilityPipelineAmazonOpenSearchDestinationAuth + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param bulk_index: The index to write logs to. :type bulk_index: str, optional @@ -76,6 +99,8 @@ def __init__( :param type: The destination type. The value should always be ``amazon_opensearch``. :type type: ObservabilityPipelineAmazonOpenSearchDestinationType """ + if buffer is not unset: + kwargs["buffer"] = buffer if bulk_index is not unset: kwargs["bulk_index"] = bulk_index super().__init__(kwargs) diff --git a/src/datadog_api_client/v2/model/observability_pipeline_amazon_s3_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_amazon_s3_destination.py index 1a7af99838..99c74ad3fe 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_amazon_s3_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_amazon_s3_destination.py @@ -15,6 +15,7 @@ if TYPE_CHECKING: from datadog_api_client.v2.model.observability_pipeline_aws_auth import ObservabilityPipelineAwsAuth + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_amazon_s3_destination_storage_class import ( ObservabilityPipelineAmazonS3DestinationStorageClass, ) @@ -22,12 +23,22 @@ from datadog_api_client.v2.model.observability_pipeline_amazon_s3_destination_type import ( ObservabilityPipelineAmazonS3DestinationType, ) + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class ObservabilityPipelineAmazonS3Destination(ModelNormal): @cached_property def openapi_types(_): from datadog_api_client.v2.model.observability_pipeline_aws_auth import ObservabilityPipelineAwsAuth + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_amazon_s3_destination_storage_class import ( ObservabilityPipelineAmazonS3DestinationStorageClass, ) @@ -39,6 +50,7 @@ def openapi_types(_): return { "auth": (ObservabilityPipelineAwsAuth,), "bucket": (str,), + "buffer": (ObservabilityPipelineBufferOptions,), "id": (str,), "inputs": ([str],), "key_prefix": (str,), @@ -51,6 +63,7 @@ def openapi_types(_): attribute_map = { "auth": "auth", "bucket": "bucket", + "buffer": "buffer", "id": "id", "inputs": "inputs", "key_prefix": "key_prefix", @@ -69,6 +82,13 @@ def __init__( storage_class: ObservabilityPipelineAmazonS3DestinationStorageClass, type: ObservabilityPipelineAmazonS3DestinationType, auth: Union[ObservabilityPipelineAwsAuth, UnsetType] = unset, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, key_prefix: Union[str, UnsetType] = unset, tls: Union[ObservabilityPipelineTls, UnsetType] = unset, **kwargs, @@ -83,6 +103,9 @@ def __init__( :param bucket: S3 bucket name. :type bucket: str + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param id: Unique identifier for the destination component. :type id: str @@ -106,6 +129,8 @@ def __init__( """ if auth is not unset: kwargs["auth"] = auth + if buffer is not unset: + kwargs["buffer"] = buffer if key_prefix is not unset: kwargs["key_prefix"] = key_prefix if tls is not unset: diff --git a/src/datadog_api_client/v2/model/observability_pipeline_buffer_options.py b/src/datadog_api_client/v2/model/observability_pipeline_buffer_options.py new file mode 100644 index 0000000000..543c618698 --- /dev/null +++ b/src/datadog_api_client/v2/model/observability_pipeline_buffer_options.py @@ -0,0 +1,54 @@ +# 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. +from __future__ import annotations + + +from datadog_api_client.model_utils import ( + ModelComposed, + cached_property, +) + + +class ObservabilityPipelineBufferOptions(ModelComposed): + def __init__(self, **kwargs): + """ + Configuration for buffer settings on destination components. + + :param max_size: Maximum size of the disk buffer. + :type max_size: int, optional + + :param type: The type of the buffer that will be configured, a disk buffer. + :type type: ObservabilityPipelineBufferOptionsDiskType, optional + + :param max_events: The `ObservabilityPipelineMemoryBufferSizeOptions` `max_events`. + :type max_events: int, optional + """ + super().__init__(kwargs) + + @cached_property + def _composed_schemas(_): + # we need this here to make our import statements work + # we must store _composed_schemas in here so the code is only run + # when we invoke this method. If we kept this at the class + # level we would get an error because the class level + # code would be run when this module is imported, and these composed + # classes don't exist yet because their module has not finished + # loading + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) + + return { + "oneOf": [ + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + ], + } diff --git a/src/datadog_api_client/v2/model/observability_pipeline_buffer_options_disk_type.py b/src/datadog_api_client/v2/model/observability_pipeline_buffer_options_disk_type.py new file mode 100644 index 0000000000..f3eb53231d --- /dev/null +++ b/src/datadog_api_client/v2/model/observability_pipeline_buffer_options_disk_type.py @@ -0,0 +1,35 @@ +# 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. +from __future__ import annotations + + +from datadog_api_client.model_utils import ( + ModelSimple, + cached_property, +) + +from typing import ClassVar + + +class ObservabilityPipelineBufferOptionsDiskType(ModelSimple): + """ + The type of the buffer that will be configured, a disk buffer. + + :param value: If omitted defaults to "disk". Must be one of ["disk"]. + :type value: str + """ + + allowed_values = { + "disk", + } + DISK: ClassVar["ObservabilityPipelineBufferOptionsDiskType"] + + @cached_property + def openapi_types(_): + return { + "value": (str,), + } + + +ObservabilityPipelineBufferOptionsDiskType.DISK = ObservabilityPipelineBufferOptionsDiskType("disk") diff --git a/src/datadog_api_client/v2/model/observability_pipeline_buffer_options_memory_type.py b/src/datadog_api_client/v2/model/observability_pipeline_buffer_options_memory_type.py new file mode 100644 index 0000000000..3c51d5c1b1 --- /dev/null +++ b/src/datadog_api_client/v2/model/observability_pipeline_buffer_options_memory_type.py @@ -0,0 +1,35 @@ +# 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. +from __future__ import annotations + + +from datadog_api_client.model_utils import ( + ModelSimple, + cached_property, +) + +from typing import ClassVar + + +class ObservabilityPipelineBufferOptionsMemoryType(ModelSimple): + """ + The type of the buffer that will be configured, a memory buffer. + + :param value: If omitted defaults to "memory". Must be one of ["memory"]. + :type value: str + """ + + allowed_values = { + "memory", + } + MEMORY: ClassVar["ObservabilityPipelineBufferOptionsMemoryType"] + + @cached_property + def openapi_types(_): + return { + "value": (str,), + } + + +ObservabilityPipelineBufferOptionsMemoryType.MEMORY = ObservabilityPipelineBufferOptionsMemoryType("memory") diff --git a/src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py b/src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py index 553e9fdc6c..6030d9d0bb 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py @@ -15,6 +15,9 @@ def __init__(self, **kwargs): """ A destination for the pipeline. + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param id: The unique identifier for this component. :type id: str diff --git a/src/datadog_api_client/v2/model/observability_pipeline_datadog_logs_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_datadog_logs_destination.py index b519b48735..5554a4a554 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_datadog_logs_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_datadog_logs_destination.py @@ -3,43 +3,74 @@ # Copyright 2019-Present Datadog, Inc. from __future__ import annotations -from typing import List, TYPE_CHECKING +from typing import List, Union, TYPE_CHECKING from datadog_api_client.model_utils import ( ModelNormal, cached_property, + unset, + UnsetType, ) if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_datadog_logs_destination_type import ( ObservabilityPipelineDatadogLogsDestinationType, ) + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class ObservabilityPipelineDatadogLogsDestination(ModelNormal): @cached_property def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_datadog_logs_destination_type import ( ObservabilityPipelineDatadogLogsDestinationType, ) return { + "buffer": (ObservabilityPipelineBufferOptions,), "id": (str,), "inputs": ([str],), "type": (ObservabilityPipelineDatadogLogsDestinationType,), } attribute_map = { + "buffer": "buffer", "id": "id", "inputs": "inputs", "type": "type", } - def __init__(self_, id: str, inputs: List[str], type: ObservabilityPipelineDatadogLogsDestinationType, **kwargs): + def __init__( + self_, + id: str, + inputs: List[str], + type: ObservabilityPipelineDatadogLogsDestinationType, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, + **kwargs, + ): """ The ``datadog_logs`` destination forwards logs to Datadog Log Management. + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param id: The unique identifier for this component. :type id: str @@ -49,6 +80,8 @@ def __init__(self_, id: str, inputs: List[str], type: ObservabilityPipelineDatad :param type: The destination type. The value should always be ``datadog_logs``. :type type: ObservabilityPipelineDatadogLogsDestinationType """ + if buffer is not unset: + kwargs["buffer"] = buffer super().__init__(kwargs) self_.id = id diff --git a/src/datadog_api_client/v2/model/observability_pipeline_disk_buffer_options.py b/src/datadog_api_client/v2/model/observability_pipeline_disk_buffer_options.py new file mode 100644 index 0000000000..3104dcf197 --- /dev/null +++ b/src/datadog_api_client/v2/model/observability_pipeline_disk_buffer_options.py @@ -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. +from __future__ import annotations + +from typing import Union, TYPE_CHECKING + +from datadog_api_client.model_utils import ( + ModelNormal, + cached_property, + unset, + UnsetType, +) + + +if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_buffer_options_disk_type import ( + ObservabilityPipelineBufferOptionsDiskType, + ) + + +class ObservabilityPipelineDiskBufferOptions(ModelNormal): + validations = { + "max_size": { + "inclusive_maximum": 536870912000, + "inclusive_minimum": 268435488, + }, + } + + @cached_property + def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_buffer_options_disk_type import ( + ObservabilityPipelineBufferOptionsDiskType, + ) + + return { + "max_size": (int,), + "type": (ObservabilityPipelineBufferOptionsDiskType,), + } + + attribute_map = { + "max_size": "max_size", + "type": "type", + } + + def __init__( + self_, + max_size: Union[int, UnsetType] = unset, + type: Union[ObservabilityPipelineBufferOptionsDiskType, UnsetType] = unset, + **kwargs, + ): + """ + Options for configuring a disk buffer. + + :param max_size: Maximum size of the disk buffer. + :type max_size: int, optional + + :param type: The type of the buffer that will be configured, a disk buffer. + :type type: ObservabilityPipelineBufferOptionsDiskType, optional + """ + if max_size is not unset: + kwargs["max_size"] = max_size + if type is not unset: + kwargs["type"] = type + super().__init__(kwargs) diff --git a/src/datadog_api_client/v2/model/observability_pipeline_elasticsearch_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_elasticsearch_destination.py index 8ce413b7ef..0689f64e11 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_elasticsearch_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_elasticsearch_destination.py @@ -17,9 +17,19 @@ from datadog_api_client.v2.model.observability_pipeline_elasticsearch_destination_api_version import ( ObservabilityPipelineElasticsearchDestinationApiVersion, ) + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_elasticsearch_destination_type import ( ObservabilityPipelineElasticsearchDestinationType, ) + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class ObservabilityPipelineElasticsearchDestination(ModelNormal): @@ -28,12 +38,14 @@ def openapi_types(_): from datadog_api_client.v2.model.observability_pipeline_elasticsearch_destination_api_version import ( ObservabilityPipelineElasticsearchDestinationApiVersion, ) + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_elasticsearch_destination_type import ( ObservabilityPipelineElasticsearchDestinationType, ) return { "api_version": (ObservabilityPipelineElasticsearchDestinationApiVersion,), + "buffer": (ObservabilityPipelineBufferOptions,), "bulk_index": (str,), "id": (str,), "inputs": ([str],), @@ -42,6 +54,7 @@ def openapi_types(_): attribute_map = { "api_version": "api_version", + "buffer": "buffer", "bulk_index": "bulk_index", "id": "id", "inputs": "inputs", @@ -54,6 +67,13 @@ def __init__( inputs: List[str], type: ObservabilityPipelineElasticsearchDestinationType, api_version: Union[ObservabilityPipelineElasticsearchDestinationApiVersion, UnsetType] = unset, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, bulk_index: Union[str, UnsetType] = unset, **kwargs, ): @@ -63,6 +83,9 @@ def __init__( :param api_version: The Elasticsearch API version to use. Set to ``auto`` to auto-detect. :type api_version: ObservabilityPipelineElasticsearchDestinationApiVersion, optional + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param bulk_index: The index to write logs to in Elasticsearch. :type bulk_index: str, optional @@ -77,6 +100,8 @@ def __init__( """ if api_version is not unset: kwargs["api_version"] = api_version + if buffer is not unset: + kwargs["buffer"] = buffer if bulk_index is not unset: kwargs["bulk_index"] = bulk_index super().__init__(kwargs) diff --git a/src/datadog_api_client/v2/model/observability_pipeline_google_chronicle_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_google_chronicle_destination.py index cdfbc1b816..8a6a50beac 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_google_chronicle_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_google_chronicle_destination.py @@ -15,18 +15,29 @@ if TYPE_CHECKING: from datadog_api_client.v2.model.observability_pipeline_gcp_auth import ObservabilityPipelineGcpAuth + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_google_chronicle_destination_encoding import ( ObservabilityPipelineGoogleChronicleDestinationEncoding, ) from datadog_api_client.v2.model.observability_pipeline_google_chronicle_destination_type import ( ObservabilityPipelineGoogleChronicleDestinationType, ) + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class ObservabilityPipelineGoogleChronicleDestination(ModelNormal): @cached_property def openapi_types(_): from datadog_api_client.v2.model.observability_pipeline_gcp_auth import ObservabilityPipelineGcpAuth + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_google_chronicle_destination_encoding import ( ObservabilityPipelineGoogleChronicleDestinationEncoding, ) @@ -36,6 +47,7 @@ def openapi_types(_): return { "auth": (ObservabilityPipelineGcpAuth,), + "buffer": (ObservabilityPipelineBufferOptions,), "customer_id": (str,), "encoding": (ObservabilityPipelineGoogleChronicleDestinationEncoding,), "id": (str,), @@ -46,6 +58,7 @@ def openapi_types(_): attribute_map = { "auth": "auth", + "buffer": "buffer", "customer_id": "customer_id", "encoding": "encoding", "id": "id", @@ -61,6 +74,13 @@ def __init__( id: str, inputs: List[str], type: ObservabilityPipelineGoogleChronicleDestinationType, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, encoding: Union[ObservabilityPipelineGoogleChronicleDestinationEncoding, UnsetType] = unset, log_type: Union[str, UnsetType] = unset, **kwargs, @@ -71,6 +91,9 @@ def __init__( :param auth: GCP credentials used to authenticate with Google Cloud Storage. :type auth: ObservabilityPipelineGcpAuth + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param customer_id: The Google Chronicle customer ID. :type customer_id: str @@ -89,6 +112,8 @@ def __init__( :param type: The destination type. The value should always be ``google_chronicle``. :type type: ObservabilityPipelineGoogleChronicleDestinationType """ + if buffer is not unset: + kwargs["buffer"] = buffer if encoding is not unset: kwargs["encoding"] = encoding if log_type is not unset: diff --git a/src/datadog_api_client/v2/model/observability_pipeline_google_cloud_storage_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_google_cloud_storage_destination.py index baf750038b..9f04c4a023 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_google_cloud_storage_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_google_cloud_storage_destination.py @@ -18,6 +18,7 @@ ObservabilityPipelineGoogleCloudStorageDestinationAcl, ) from datadog_api_client.v2.model.observability_pipeline_gcp_auth import ObservabilityPipelineGcpAuth + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_metadata_entry import ObservabilityPipelineMetadataEntry from datadog_api_client.v2.model.observability_pipeline_google_cloud_storage_destination_storage_class import ( ObservabilityPipelineGoogleCloudStorageDestinationStorageClass, @@ -25,6 +26,15 @@ from datadog_api_client.v2.model.observability_pipeline_google_cloud_storage_destination_type import ( ObservabilityPipelineGoogleCloudStorageDestinationType, ) + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class ObservabilityPipelineGoogleCloudStorageDestination(ModelNormal): @@ -34,6 +44,7 @@ def openapi_types(_): ObservabilityPipelineGoogleCloudStorageDestinationAcl, ) from datadog_api_client.v2.model.observability_pipeline_gcp_auth import ObservabilityPipelineGcpAuth + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_metadata_entry import ObservabilityPipelineMetadataEntry from datadog_api_client.v2.model.observability_pipeline_google_cloud_storage_destination_storage_class import ( ObservabilityPipelineGoogleCloudStorageDestinationStorageClass, @@ -46,6 +57,7 @@ def openapi_types(_): "acl": (ObservabilityPipelineGoogleCloudStorageDestinationAcl,), "auth": (ObservabilityPipelineGcpAuth,), "bucket": (str,), + "buffer": (ObservabilityPipelineBufferOptions,), "id": (str,), "inputs": ([str],), "key_prefix": (str,), @@ -58,6 +70,7 @@ def openapi_types(_): "acl": "acl", "auth": "auth", "bucket": "bucket", + "buffer": "buffer", "id": "id", "inputs": "inputs", "key_prefix": "key_prefix", @@ -75,6 +88,13 @@ def __init__( inputs: List[str], storage_class: ObservabilityPipelineGoogleCloudStorageDestinationStorageClass, type: ObservabilityPipelineGoogleCloudStorageDestinationType, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, key_prefix: Union[str, UnsetType] = unset, metadata: Union[List[ObservabilityPipelineMetadataEntry], UnsetType] = unset, **kwargs, @@ -92,6 +112,9 @@ def __init__( :param bucket: Name of the GCS bucket. :type bucket: str + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param id: Unique identifier for the destination component. :type id: str @@ -110,6 +133,8 @@ def __init__( :param type: The destination type. Always ``google_cloud_storage``. :type type: ObservabilityPipelineGoogleCloudStorageDestinationType """ + if buffer is not unset: + kwargs["buffer"] = buffer if key_prefix is not unset: kwargs["key_prefix"] = key_prefix if metadata is not unset: diff --git a/src/datadog_api_client/v2/model/observability_pipeline_memory_buffer_options.py b/src/datadog_api_client/v2/model/observability_pipeline_memory_buffer_options.py new file mode 100644 index 0000000000..2f513549c2 --- /dev/null +++ b/src/datadog_api_client/v2/model/observability_pipeline_memory_buffer_options.py @@ -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. +from __future__ import annotations + +from typing import Union, TYPE_CHECKING + +from datadog_api_client.model_utils import ( + ModelNormal, + cached_property, + unset, + UnsetType, +) + + +if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_buffer_options_memory_type import ( + ObservabilityPipelineBufferOptionsMemoryType, + ) + + +class ObservabilityPipelineMemoryBufferOptions(ModelNormal): + validations = { + "max_size": { + "inclusive_maximum": 13743895347, + "inclusive_minimum": 1, + }, + } + + @cached_property + def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_buffer_options_memory_type import ( + ObservabilityPipelineBufferOptionsMemoryType, + ) + + return { + "max_size": (int,), + "type": (ObservabilityPipelineBufferOptionsMemoryType,), + } + + attribute_map = { + "max_size": "max_size", + "type": "type", + } + + def __init__( + self_, + max_size: Union[int, UnsetType] = unset, + type: Union[ObservabilityPipelineBufferOptionsMemoryType, UnsetType] = unset, + **kwargs, + ): + """ + Options for configuring a memory buffer by byte size. + + :param max_size: Maximum size of the disk buffer. + :type max_size: int, optional + + :param type: The type of the buffer that will be configured, a memory buffer. + :type type: ObservabilityPipelineBufferOptionsMemoryType, optional + """ + if max_size is not unset: + kwargs["max_size"] = max_size + if type is not unset: + kwargs["type"] = type + super().__init__(kwargs) diff --git a/src/datadog_api_client/v2/model/observability_pipeline_memory_buffer_size_options.py b/src/datadog_api_client/v2/model/observability_pipeline_memory_buffer_size_options.py new file mode 100644 index 0000000000..2dcafddcd0 --- /dev/null +++ b/src/datadog_api_client/v2/model/observability_pipeline_memory_buffer_size_options.py @@ -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. +from __future__ import annotations + +from typing import Union, TYPE_CHECKING + +from datadog_api_client.model_utils import ( + ModelNormal, + cached_property, + unset, + UnsetType, +) + + +if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_buffer_options_memory_type import ( + ObservabilityPipelineBufferOptionsMemoryType, + ) + + +class ObservabilityPipelineMemoryBufferSizeOptions(ModelNormal): + validations = { + "max_events": { + "inclusive_maximum": 268435456, + "inclusive_minimum": 1, + }, + } + + @cached_property + def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_buffer_options_memory_type import ( + ObservabilityPipelineBufferOptionsMemoryType, + ) + + return { + "max_events": (int,), + "type": (ObservabilityPipelineBufferOptionsMemoryType,), + } + + attribute_map = { + "max_events": "max_events", + "type": "type", + } + + def __init__( + self_, + max_events: Union[int, UnsetType] = unset, + type: Union[ObservabilityPipelineBufferOptionsMemoryType, UnsetType] = unset, + **kwargs, + ): + """ + Options for configuring a memory buffer by queue length. + + :param max_events: The ``ObservabilityPipelineMemoryBufferSizeOptions`` ``max_events``. + :type max_events: int, optional + + :param type: The type of the buffer that will be configured, a memory buffer. + :type type: ObservabilityPipelineBufferOptionsMemoryType, optional + """ + if max_events is not unset: + kwargs["max_events"] = max_events + if type is not unset: + kwargs["type"] = type + super().__init__(kwargs) diff --git a/src/datadog_api_client/v2/model/observability_pipeline_new_relic_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_new_relic_destination.py index ec0cb39481..e437d0714a 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_new_relic_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_new_relic_destination.py @@ -3,26 +3,39 @@ # Copyright 2019-Present Datadog, Inc. from __future__ import annotations -from typing import List, TYPE_CHECKING +from typing import List, Union, TYPE_CHECKING from datadog_api_client.model_utils import ( ModelNormal, cached_property, + unset, + UnsetType, ) if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_new_relic_destination_region import ( ObservabilityPipelineNewRelicDestinationRegion, ) from datadog_api_client.v2.model.observability_pipeline_new_relic_destination_type import ( ObservabilityPipelineNewRelicDestinationType, ) + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class ObservabilityPipelineNewRelicDestination(ModelNormal): @cached_property def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_new_relic_destination_region import ( ObservabilityPipelineNewRelicDestinationRegion, ) @@ -31,6 +44,7 @@ def openapi_types(_): ) return { + "buffer": (ObservabilityPipelineBufferOptions,), "id": (str,), "inputs": ([str],), "region": (ObservabilityPipelineNewRelicDestinationRegion,), @@ -38,6 +52,7 @@ def openapi_types(_): } attribute_map = { + "buffer": "buffer", "id": "id", "inputs": "inputs", "region": "region", @@ -50,11 +65,21 @@ def __init__( inputs: List[str], region: ObservabilityPipelineNewRelicDestinationRegion, type: ObservabilityPipelineNewRelicDestinationType, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, **kwargs, ): """ The ``new_relic`` destination sends logs to the New Relic platform. + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param id: The unique identifier for this component. :type id: str @@ -67,6 +92,8 @@ def __init__( :param type: The destination type. The value should always be ``new_relic``. :type type: ObservabilityPipelineNewRelicDestinationType """ + if buffer is not unset: + kwargs["buffer"] = buffer super().__init__(kwargs) self_.id = id diff --git a/src/datadog_api_client/v2/model/observability_pipeline_open_search_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_open_search_destination.py index d817a4b558..be7b5e7730 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_open_search_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_open_search_destination.py @@ -14,19 +14,31 @@ if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_open_search_destination_type import ( ObservabilityPipelineOpenSearchDestinationType, ) + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class ObservabilityPipelineOpenSearchDestination(ModelNormal): @cached_property def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_open_search_destination_type import ( ObservabilityPipelineOpenSearchDestinationType, ) return { + "buffer": (ObservabilityPipelineBufferOptions,), "bulk_index": (str,), "id": (str,), "inputs": ([str],), @@ -34,6 +46,7 @@ def openapi_types(_): } attribute_map = { + "buffer": "buffer", "bulk_index": "bulk_index", "id": "id", "inputs": "inputs", @@ -45,12 +58,22 @@ def __init__( id: str, inputs: List[str], type: ObservabilityPipelineOpenSearchDestinationType, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, bulk_index: Union[str, UnsetType] = unset, **kwargs, ): """ The ``opensearch`` destination writes logs to an OpenSearch cluster. + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param bulk_index: The index to write logs to. :type bulk_index: str, optional @@ -63,6 +86,8 @@ def __init__( :param type: The destination type. The value should always be ``opensearch``. :type type: ObservabilityPipelineOpenSearchDestinationType """ + if buffer is not unset: + kwargs["buffer"] = buffer if bulk_index is not unset: kwargs["bulk_index"] = bulk_index super().__init__(kwargs) diff --git a/src/datadog_api_client/v2/model/observability_pipeline_rsyslog_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_rsyslog_destination.py index 486442d4aa..a09ccda931 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_rsyslog_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_rsyslog_destination.py @@ -14,10 +14,20 @@ if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_tls import ObservabilityPipelineTls from datadog_api_client.v2.model.observability_pipeline_rsyslog_destination_type import ( ObservabilityPipelineRsyslogDestinationType, ) + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class ObservabilityPipelineRsyslogDestination(ModelNormal): @@ -29,12 +39,14 @@ class ObservabilityPipelineRsyslogDestination(ModelNormal): @cached_property def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_tls import ObservabilityPipelineTls from datadog_api_client.v2.model.observability_pipeline_rsyslog_destination_type import ( ObservabilityPipelineRsyslogDestinationType, ) return { + "buffer": (ObservabilityPipelineBufferOptions,), "id": (str,), "inputs": ([str],), "keepalive": (int,), @@ -43,6 +55,7 @@ def openapi_types(_): } attribute_map = { + "buffer": "buffer", "id": "id", "inputs": "inputs", "keepalive": "keepalive", @@ -55,6 +68,13 @@ def __init__( id: str, inputs: List[str], type: ObservabilityPipelineRsyslogDestinationType, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, keepalive: Union[int, UnsetType] = unset, tls: Union[ObservabilityPipelineTls, UnsetType] = unset, **kwargs, @@ -62,6 +82,9 @@ def __init__( """ The ``rsyslog`` destination forwards logs to an external ``rsyslog`` server over TCP or UDP using the syslog protocol. + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param id: The unique identifier for this component. :type id: str @@ -77,6 +100,8 @@ def __init__( :param type: The destination type. The value should always be ``rsyslog``. :type type: ObservabilityPipelineRsyslogDestinationType """ + if buffer is not unset: + kwargs["buffer"] = buffer if keepalive is not unset: kwargs["keepalive"] = keepalive if tls is not unset: diff --git a/src/datadog_api_client/v2/model/observability_pipeline_sentinel_one_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_sentinel_one_destination.py index 924aa9b0f5..d19c296e36 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_sentinel_one_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_sentinel_one_destination.py @@ -3,26 +3,39 @@ # Copyright 2019-Present Datadog, Inc. from __future__ import annotations -from typing import List, TYPE_CHECKING +from typing import List, Union, TYPE_CHECKING from datadog_api_client.model_utils import ( ModelNormal, cached_property, + unset, + UnsetType, ) if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_sentinel_one_destination_region import ( ObservabilityPipelineSentinelOneDestinationRegion, ) from datadog_api_client.v2.model.observability_pipeline_sentinel_one_destination_type import ( ObservabilityPipelineSentinelOneDestinationType, ) + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class ObservabilityPipelineSentinelOneDestination(ModelNormal): @cached_property def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_sentinel_one_destination_region import ( ObservabilityPipelineSentinelOneDestinationRegion, ) @@ -31,6 +44,7 @@ def openapi_types(_): ) return { + "buffer": (ObservabilityPipelineBufferOptions,), "id": (str,), "inputs": ([str],), "region": (ObservabilityPipelineSentinelOneDestinationRegion,), @@ -38,6 +52,7 @@ def openapi_types(_): } attribute_map = { + "buffer": "buffer", "id": "id", "inputs": "inputs", "region": "region", @@ -50,11 +65,21 @@ def __init__( inputs: List[str], region: ObservabilityPipelineSentinelOneDestinationRegion, type: ObservabilityPipelineSentinelOneDestinationType, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, **kwargs, ): """ The ``sentinel_one`` destination sends logs to SentinelOne. + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param id: The unique identifier for this component. :type id: str @@ -67,6 +92,8 @@ def __init__( :param type: The destination type. The value should always be ``sentinel_one``. :type type: ObservabilityPipelineSentinelOneDestinationType """ + if buffer is not unset: + kwargs["buffer"] = buffer super().__init__(kwargs) self_.id = id diff --git a/src/datadog_api_client/v2/model/observability_pipeline_splunk_hec_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_splunk_hec_destination.py index e36b4aee74..49665d08f3 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_splunk_hec_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_splunk_hec_destination.py @@ -14,17 +14,28 @@ if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_splunk_hec_destination_encoding import ( ObservabilityPipelineSplunkHecDestinationEncoding, ) from datadog_api_client.v2.model.observability_pipeline_splunk_hec_destination_type import ( ObservabilityPipelineSplunkHecDestinationType, ) + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class ObservabilityPipelineSplunkHecDestination(ModelNormal): @cached_property def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_splunk_hec_destination_encoding import ( ObservabilityPipelineSplunkHecDestinationEncoding, ) @@ -34,6 +45,7 @@ def openapi_types(_): return { "auto_extract_timestamp": (bool,), + "buffer": (ObservabilityPipelineBufferOptions,), "encoding": (ObservabilityPipelineSplunkHecDestinationEncoding,), "id": (str,), "index": (str,), @@ -44,6 +56,7 @@ def openapi_types(_): attribute_map = { "auto_extract_timestamp": "auto_extract_timestamp", + "buffer": "buffer", "encoding": "encoding", "id": "id", "index": "index", @@ -58,6 +71,13 @@ def __init__( inputs: List[str], type: ObservabilityPipelineSplunkHecDestinationType, auto_extract_timestamp: Union[bool, UnsetType] = unset, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, encoding: Union[ObservabilityPipelineSplunkHecDestinationEncoding, UnsetType] = unset, index: Union[str, UnsetType] = unset, sourcetype: Union[str, UnsetType] = unset, @@ -70,6 +90,9 @@ def __init__( If ``false`` , Splunk assigns the time the event was received. :type auto_extract_timestamp: bool, optional + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param encoding: Encoding format for log events. :type encoding: ObservabilityPipelineSplunkHecDestinationEncoding, optional @@ -90,6 +113,8 @@ def __init__( """ if auto_extract_timestamp is not unset: kwargs["auto_extract_timestamp"] = auto_extract_timestamp + if buffer is not unset: + kwargs["buffer"] = buffer if encoding is not unset: kwargs["encoding"] = encoding if index is not unset: diff --git a/src/datadog_api_client/v2/model/observability_pipeline_sumo_logic_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_sumo_logic_destination.py index d49e3044f8..488c595631 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_sumo_logic_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_sumo_logic_destination.py @@ -14,6 +14,7 @@ if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_sumo_logic_destination_encoding import ( ObservabilityPipelineSumoLogicDestinationEncoding, ) @@ -23,11 +24,21 @@ from datadog_api_client.v2.model.observability_pipeline_sumo_logic_destination_type import ( ObservabilityPipelineSumoLogicDestinationType, ) + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class ObservabilityPipelineSumoLogicDestination(ModelNormal): @cached_property def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_sumo_logic_destination_encoding import ( ObservabilityPipelineSumoLogicDestinationEncoding, ) @@ -39,6 +50,7 @@ def openapi_types(_): ) return { + "buffer": (ObservabilityPipelineBufferOptions,), "encoding": (ObservabilityPipelineSumoLogicDestinationEncoding,), "header_custom_fields": ([ObservabilityPipelineSumoLogicDestinationHeaderCustomFieldsItem],), "header_host_name": (str,), @@ -50,6 +62,7 @@ def openapi_types(_): } attribute_map = { + "buffer": "buffer", "encoding": "encoding", "header_custom_fields": "header_custom_fields", "header_host_name": "header_host_name", @@ -65,6 +78,13 @@ def __init__( id: str, inputs: List[str], type: ObservabilityPipelineSumoLogicDestinationType, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, encoding: Union[ObservabilityPipelineSumoLogicDestinationEncoding, UnsetType] = unset, header_custom_fields: Union[ List[ObservabilityPipelineSumoLogicDestinationHeaderCustomFieldsItem], UnsetType @@ -77,6 +97,9 @@ def __init__( """ The ``sumo_logic`` destination forwards logs to Sumo Logic. + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param encoding: The output encoding format. :type encoding: ObservabilityPipelineSumoLogicDestinationEncoding, optional @@ -101,6 +124,8 @@ def __init__( :param type: The destination type. The value should always be ``sumo_logic``. :type type: ObservabilityPipelineSumoLogicDestinationType """ + if buffer is not unset: + kwargs["buffer"] = buffer if encoding is not unset: kwargs["encoding"] = encoding if header_custom_fields is not unset: diff --git a/src/datadog_api_client/v2/model/observability_pipeline_syslog_ng_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_syslog_ng_destination.py index 4984e69b5e..eb2a8c309d 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_syslog_ng_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_syslog_ng_destination.py @@ -14,10 +14,20 @@ if TYPE_CHECKING: + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_tls import ObservabilityPipelineTls from datadog_api_client.v2.model.observability_pipeline_syslog_ng_destination_type import ( ObservabilityPipelineSyslogNgDestinationType, ) + from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, + ) + from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, + ) class ObservabilityPipelineSyslogNgDestination(ModelNormal): @@ -29,12 +39,14 @@ class ObservabilityPipelineSyslogNgDestination(ModelNormal): @cached_property def openapi_types(_): + from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions from datadog_api_client.v2.model.observability_pipeline_tls import ObservabilityPipelineTls from datadog_api_client.v2.model.observability_pipeline_syslog_ng_destination_type import ( ObservabilityPipelineSyslogNgDestinationType, ) return { + "buffer": (ObservabilityPipelineBufferOptions,), "id": (str,), "inputs": ([str],), "keepalive": (int,), @@ -43,6 +55,7 @@ def openapi_types(_): } attribute_map = { + "buffer": "buffer", "id": "id", "inputs": "inputs", "keepalive": "keepalive", @@ -55,6 +68,13 @@ def __init__( id: str, inputs: List[str], type: ObservabilityPipelineSyslogNgDestinationType, + buffer: Union[ + ObservabilityPipelineBufferOptions, + ObservabilityPipelineDiskBufferOptions, + ObservabilityPipelineMemoryBufferOptions, + ObservabilityPipelineMemoryBufferSizeOptions, + UnsetType, + ] = unset, keepalive: Union[int, UnsetType] = unset, tls: Union[ObservabilityPipelineTls, UnsetType] = unset, **kwargs, @@ -62,6 +82,9 @@ def __init__( """ The ``syslog_ng`` destination forwards logs to an external ``syslog-ng`` server over TCP or UDP using the syslog protocol. + :param buffer: Configuration for buffer settings on destination components. + :type buffer: ObservabilityPipelineBufferOptions, optional + :param id: The unique identifier for this component. :type id: str @@ -77,6 +100,8 @@ def __init__( :param type: The destination type. The value should always be ``syslog_ng``. :type type: ObservabilityPipelineSyslogNgDestinationType """ + if buffer is not unset: + kwargs["buffer"] = buffer if keepalive is not unset: kwargs["keepalive"] = keepalive if tls is not unset: diff --git a/src/datadog_api_client/v2/models/__init__.py b/src/datadog_api_client/v2/models/__init__.py index c87e8e8199..f95cdec30f 100644 --- a/src/datadog_api_client/v2/models/__init__.py +++ b/src/datadog_api_client/v2/models/__init__.py @@ -2174,6 +2174,13 @@ ObservabilityPipelineAmazonS3SourceType, ) from datadog_api_client.v2.model.observability_pipeline_aws_auth import ObservabilityPipelineAwsAuth +from datadog_api_client.v2.model.observability_pipeline_buffer_options import ObservabilityPipelineBufferOptions +from datadog_api_client.v2.model.observability_pipeline_buffer_options_disk_type import ( + ObservabilityPipelineBufferOptionsDiskType, +) +from datadog_api_client.v2.model.observability_pipeline_buffer_options_memory_type import ( + ObservabilityPipelineBufferOptionsMemoryType, +) from datadog_api_client.v2.model.observability_pipeline_config import ObservabilityPipelineConfig from datadog_api_client.v2.model.observability_pipeline_config_destination_item import ( ObservabilityPipelineConfigDestinationItem, @@ -2204,6 +2211,9 @@ from datadog_api_client.v2.model.observability_pipeline_dedupe_processor_type import ( ObservabilityPipelineDedupeProcessorType, ) +from datadog_api_client.v2.model.observability_pipeline_disk_buffer_options import ( + ObservabilityPipelineDiskBufferOptions, +) from datadog_api_client.v2.model.observability_pipeline_elasticsearch_destination import ( ObservabilityPipelineElasticsearchDestination, ) @@ -2330,6 +2340,12 @@ from datadog_api_client.v2.model.observability_pipeline_logstash_source_type import ( ObservabilityPipelineLogstashSourceType, ) +from datadog_api_client.v2.model.observability_pipeline_memory_buffer_options import ( + ObservabilityPipelineMemoryBufferOptions, +) +from datadog_api_client.v2.model.observability_pipeline_memory_buffer_size_options import ( + ObservabilityPipelineMemoryBufferSizeOptions, +) from datadog_api_client.v2.model.observability_pipeline_metadata_entry import ObservabilityPipelineMetadataEntry from datadog_api_client.v2.model.observability_pipeline_metric_value import ObservabilityPipelineMetricValue from datadog_api_client.v2.model.observability_pipeline_new_relic_destination import ( @@ -5510,6 +5526,9 @@ "ObservabilityPipelineAmazonS3Source", "ObservabilityPipelineAmazonS3SourceType", "ObservabilityPipelineAwsAuth", + "ObservabilityPipelineBufferOptions", + "ObservabilityPipelineBufferOptionsDiskType", + "ObservabilityPipelineBufferOptionsMemoryType", "ObservabilityPipelineConfig", "ObservabilityPipelineConfigDestinationItem", "ObservabilityPipelineConfigProcessorItem", @@ -5524,6 +5543,7 @@ "ObservabilityPipelineDedupeProcessor", "ObservabilityPipelineDedupeProcessorMode", "ObservabilityPipelineDedupeProcessorType", + "ObservabilityPipelineDiskBufferOptions", "ObservabilityPipelineElasticsearchDestination", "ObservabilityPipelineElasticsearchDestinationApiVersion", "ObservabilityPipelineElasticsearchDestinationType", @@ -5574,6 +5594,8 @@ "ObservabilityPipelineKafkaSourceType", "ObservabilityPipelineLogstashSource", "ObservabilityPipelineLogstashSourceType", + "ObservabilityPipelineMemoryBufferOptions", + "ObservabilityPipelineMemoryBufferSizeOptions", "ObservabilityPipelineMetadataEntry", "ObservabilityPipelineMetricValue", "ObservabilityPipelineNewRelicDestination",