Add ingestion_mode to ADX destination

.generator/schemas/v2/openapi.yaml

@@ -85302,6 +85302,8 @@ components:
             Defaults to `DESTINATION_AZURE_DATA_EXPLORER_INGESTION_ENDPOINT` (prefixed with `DD_OP_` at runtime).
           example: AZURE_DATA_EXPLORER_INGESTION_ENDPOINT
           type: string
+        ingestion_mode:
+          $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationIngestionMode"
         inputs:
           description: A list of component IDs whose output is used as the `input` for this component.
           example: ["filter-processor"]
@@ -85493,22 +85495,35 @@ components:
           description: Maximum batch size in bytes.
           example: 2000000
           format: int64
-          maximum: 4000000
-          minimum: 1
           type: integer
         max_events:
           description: Maximum number of events per batch before it is flushed.
           example: 1000
           format: int64
-          minimum: 1
           type: integer
         timeout_secs:
           description: Maximum number of seconds to wait before flushing a partial batch.
           example: 1
           format: int64
-          minimum: 1
           type: integer
       type: object
+    ObservabilityPipelineAzureDataExplorerDestinationIngestionMode:
+      default: streaming
+      description: |-
+        The ingestion method used to send data to Azure Data Explorer.
+
+        - `streaming`: Sends events directly to the table using streaming ingestion.
+        - `queue`: Sends events through queued (batched) ingestion.
+
+        Defaults to `streaming`.
+      enum:
+        - streaming
+        - queue
+      example: queue
+      type: string
+      x-enum-varnames:
+        - STREAMING
+        - QUEUE
     ObservabilityPipelineAzureDataExplorerDestinationManagedIdentityIdType:
       description: The type of the user-assigned managed identity ID.
       enum:

src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination.py

@@ -25,6 +25,9 @@
     from datadog_api_client.v2.model.observability_pipeline_azure_storage_destination_compression_gzip import (
         ObservabilityPipelineAzureStorageDestinationCompressionGzip,
     )
+    from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_ingestion_mode import (
+        ObservabilityPipelineAzureDataExplorerDestinationIngestionMode,
+    )
     from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_type import (
         ObservabilityPipelineAzureDataExplorerDestinationType,
     )
@@ -70,6 +73,9 @@ def openapi_types(_):
         from datadog_api_client.v2.model.observability_pipeline_azure_storage_destination_compression_gzip import (
             ObservabilityPipelineAzureStorageDestinationCompressionGzip,
         )
+        from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_ingestion_mode import (
+            ObservabilityPipelineAzureDataExplorerDestinationIngestionMode,
+        )
         from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_type import (
             ObservabilityPipelineAzureDataExplorerDestinationType,
         )
@@ -82,6 +88,7 @@ def openapi_types(_):
             "database": (str,),
             "id": (str,),
             "ingestion_endpoint_key": (str,),
+            "ingestion_mode": (ObservabilityPipelineAzureDataExplorerDestinationIngestionMode,),
             "inputs": ([str],),
             "mapping_reference": (str, none_type),
             "table": (str,),
@@ -97,6 +104,7 @@ def openapi_types(_):
         "database": "database",
         "id": "id",
         "ingestion_endpoint_key": "ingestion_endpoint_key",
+        "ingestion_mode": "ingestion_mode",
         "inputs": "inputs",
         "mapping_reference": "mapping_reference",
         "table": "table",
@@ -130,6 +138,7 @@ def __init__(
         ] = unset,
         compression: Union[ObservabilityPipelineAzureStorageDestinationCompressionGzip, UnsetType] = unset,
         ingestion_endpoint_key: Union[str, UnsetType] = unset,
+        ingestion_mode: Union[ObservabilityPipelineAzureDataExplorerDestinationIngestionMode, UnsetType] = unset,
         mapping_reference: Union[str, none_type, UnsetType] = unset,
         token_scope: Union[str, UnsetType] = unset,
         **kwargs,
@@ -161,6 +170,14 @@ def __init__(
             Defaults to ``DESTINATION_AZURE_DATA_EXPLORER_INGESTION_ENDPOINT`` (prefixed with ``DD_OP_`` at runtime).
         :type ingestion_endpoint_key: str, optional
 
+        :param ingestion_mode: The ingestion method used to send data to Azure Data Explorer.
+
+            * ``streaming`` : Sends events directly to the table using streaming ingestion.
+            * ``queue`` : Sends events through queued (batched) ingestion.
+
+            Defaults to ``streaming``.
+        :type ingestion_mode: ObservabilityPipelineAzureDataExplorerDestinationIngestionMode, optional
+
         :param inputs: A list of component IDs whose output is used as the ``input`` for this component.
         :type inputs: [str]
 
@@ -185,6 +202,8 @@ def __init__(
             kwargs["compression"] = compression
         if ingestion_endpoint_key is not unset:
             kwargs["ingestion_endpoint_key"] = ingestion_endpoint_key
+        if ingestion_mode is not unset:
+            kwargs["ingestion_mode"] = ingestion_mode
         if mapping_reference is not unset:
             kwargs["mapping_reference"] = mapping_reference
         if token_scope is not unset:

src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination_batch.py

@@ -14,19 +14,6 @@
 
 
 class ObservabilityPipelineAzureDataExplorerDestinationBatch(ModelNormal):
-    validations = {
-        "max_bytes": {
-            "inclusive_maximum": 4000000,
-            "inclusive_minimum": 1,
-        },
-        "max_events": {
-            "inclusive_minimum": 1,
-        },
-        "timeout_secs": {
-            "inclusive_minimum": 1,
-        },
-    }
-
     @cached_property
     def openapi_types(_):
         return {

src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination_ingestion_mode.py

@@ -0,0 +1,47 @@
+# 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 ObservabilityPipelineAzureDataExplorerDestinationIngestionMode(ModelSimple):
+    """
+    The ingestion method used to send data to Azure Data Explorer.
+
+        - `streaming`: Sends events directly to the table using streaming ingestion.
+        - `queue`: Sends events through queued (batched) ingestion.
+
+        Defaults to `streaming`.
+
+    :param value: If omitted defaults to "streaming". Must be one of ["streaming", "queue"].
+    :type value: str
+    """
+
+    allowed_values = {
+        "streaming",
+        "queue",
+    }
+    STREAMING: ClassVar["ObservabilityPipelineAzureDataExplorerDestinationIngestionMode"]
+    QUEUE: ClassVar["ObservabilityPipelineAzureDataExplorerDestinationIngestionMode"]
+
+    @cached_property
+    def openapi_types(_):
+        return {
+            "value": (str,),
+        }
+
+
+ObservabilityPipelineAzureDataExplorerDestinationIngestionMode.STREAMING = (
+    ObservabilityPipelineAzureDataExplorerDestinationIngestionMode("streaming")
+)
+ObservabilityPipelineAzureDataExplorerDestinationIngestionMode.QUEUE = (
+    ObservabilityPipelineAzureDataExplorerDestinationIngestionMode("queue")
+)

src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py

@@ -123,6 +123,14 @@ def __init__(self, **kwargs):
             Defaults to `DESTINATION_AZURE_DATA_EXPLORER_INGESTION_ENDPOINT` (prefixed with `DD_OP_` at runtime).
         :type ingestion_endpoint_key: str, optional
 
+        :param ingestion_mode: The ingestion method used to send data to Azure Data Explorer.
+
+            - `streaming`: Sends events directly to the table using streaming ingestion.
+            - `queue`: Sends events through queued (batched) ingestion.
+
+            Defaults to `streaming`.
+        :type ingestion_mode: ObservabilityPipelineAzureDataExplorerDestinationIngestionMode, optional
+
         :param mapping_reference: The name of a pre-created ingestion mapping on the table used to map incoming events to columns. Supports template syntax.
         :type mapping_reference: str, none_type, optional
 

src/datadog_api_client/v2/models/__init__.py

@@ -6983,6 +6983,9 @@
 from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_batch import (
     ObservabilityPipelineAzureDataExplorerDestinationBatch,
 )
+from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_ingestion_mode import (
+    ObservabilityPipelineAzureDataExplorerDestinationIngestionMode,
+)
 from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_managed_identity_id_type import (
     ObservabilityPipelineAzureDataExplorerDestinationManagedIdentityIdType,
 )
@@ -17897,6 +17900,7 @@
     "ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity",
     "ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentityKind",
     "ObservabilityPipelineAzureDataExplorerDestinationBatch",
+    "ObservabilityPipelineAzureDataExplorerDestinationIngestionMode",
     "ObservabilityPipelineAzureDataExplorerDestinationManagedIdentityIdType",
     "ObservabilityPipelineAzureDataExplorerDestinationType",
     "ObservabilityPipelineAzureDataExplorerManagedIdentityClientAssertion",