@@ -15,52 +15,70 @@ def __init__(self, **kwargs):
1515 """
1616 A destination for the pipeline.
1717
18- :param auth_strategy: HTTP authentication strategy .
19- :type auth_strategy: ObservabilityPipelineHttpClientDestinationAuthStrategy , optional
18+ :param api_version: The Elasticsearch API version to use. Set to `auto` to auto-detect .
19+ :type api_version: ObservabilityPipelineElasticsearchDestinationApiVersion , optional
2020
21- :param compression: Compression configuration for HTTP requests.
22- :type compression: ObservabilityPipelineHttpClientDestinationCompression, optional
21+ :param auth: Authentication settings for the Elasticsearch destination.
22+ When `strategy` is `basic`, use `username_key` and `password_key` to reference credentials stored in environment variables or secrets.
23+ :type auth: ObservabilityPipelineElasticsearchDestinationAuth, optional
2324
24- :param custom_key: Name of the environment variable or secret that holds a custom header value (used with custom auth strategies) .
25- :type custom_key: str , optional
25+ :param buffer: Configuration for buffer settings on destination components .
26+ :type buffer: ObservabilityPipelineBufferOptions , optional
2627
27- :param encoding: Encoding format for log events.
28- :type encoding: ObservabilityPipelineHttpClientDestinationEncoding
28+ :param bulk_index: The name of the index to write events to in Elasticsearch.
29+ :type bulk_index: str, optional
30+
31+ :param compression: Compression algorithm applied when sending data to Elasticsearch.
32+ :type compression: ObservabilityPipelineElasticsearchDestinationCompression, optional
33+
34+ :param data_stream: Configuration options for writing to Elasticsearch Data Streams instead of a fixed index.
35+ :type data_stream: ObservabilityPipelineElasticsearchDestinationDataStream, optional
36+
37+ :param endpoint_url_key: Name of the environment variable or secret that holds the Elasticsearch endpoint URL.
38+ :type endpoint_url_key: str, optional
2939
3040 :param id: The unique identifier for this component.
3141 :type id: str
3242
33- :param inputs: A list of component IDs whose output is used as the input for this component.
43+ :param id_key: The name of the field used as the document ID in Elasticsearch.
44+ :type id_key: str, optional
45+
46+ :param inputs: A list of component IDs whose output is used as the `input` for this component.
3447 :type inputs: [str]
3548
36- :param password_key: Name of the environment variable or secret that holds the password (used when `auth_strategy` is `basic`).
37- :type password_key: str, optional
49+ :param pipeline: The name of an Elasticsearch ingest pipeline to apply to events before indexing.
50+ :type pipeline: str, optional
51+
52+ :param request_retry_partial: When `true`, retries failed partial bulk requests. This is useful when some events in a batch fail while others succeed.
53+ :type request_retry_partial: bool, optional
3854
3955 :param tls: Configuration for enabling TLS encryption between the pipeline component and external services.
4056 :type tls: ObservabilityPipelineTls, optional
4157
58+ :param type: The destination type. The value should always be `elasticsearch`.
59+ :type type: ObservabilityPipelineElasticsearchDestinationType
60+
61+ :param auth_strategy: HTTP authentication strategy.
62+ :type auth_strategy: ObservabilityPipelineHttpClientDestinationAuthStrategy, optional
63+
64+ :param custom_key: Name of the environment variable or secret that holds a custom header value (used with custom auth strategies).
65+ :type custom_key: str, optional
66+
67+ :param encoding: Encoding format for log events.
68+ :type encoding: ObservabilityPipelineHttpClientDestinationEncoding
69+
70+ :param password_key: Name of the environment variable or secret that holds the password (used when `auth_strategy` is `basic`).
71+ :type password_key: str, optional
72+
4273 :param token_key: Name of the environment variable or secret that holds the bearer token (used when `auth_strategy` is `bearer`).
4374 :type token_key: str, optional
4475
45- :param type: The destination type. The value should always be `http_client`.
46- :type type: ObservabilityPipelineHttpClientDestinationType
47-
4876 :param uri_key: Name of the environment variable or secret that holds the HTTP endpoint URI.
4977 :type uri_key: str, optional
5078
5179 :param username_key: Name of the environment variable or secret that holds the username (used when `auth_strategy` is `basic`).
5280 :type username_key: str, optional
5381
54- :param auth: Authentication settings for the Amazon OpenSearch destination.
55- The `strategy` field determines whether basic or AWS-based authentication is used.
56- :type auth: ObservabilityPipelineAmazonOpenSearchDestinationAuth
57-
58- :param buffer: Configuration for buffer settings on destination components.
59- :type buffer: ObservabilityPipelineBufferOptions, optional
60-
61- :param bulk_index: The index to write logs to.
62- :type bulk_index: str, optional
63-
6482 :param bucket: S3 bucket name.
6583 :type bucket: str
6684
@@ -88,18 +106,9 @@ def __init__(self, **kwargs):
88106 :param container_name: The name of the Azure Blob Storage container to store logs in.
89107 :type container_name: str
90108
91- :param endpoint_url_key: Name of the environment variable or secret that holds the CloudPrem endpoint URL.
92- :type endpoint_url_key: str, optional
93-
94109 :param routes: A list of routing rules that forward matching logs to Datadog using dedicated API keys.
95110 :type routes: [ObservabilityPipelineDatadogLogsDestinationRoute], optional
96111
97- :param api_version: The Elasticsearch API version to use. Set to `auto` to auto-detect.
98- :type api_version: ObservabilityPipelineElasticsearchDestinationApiVersion, optional
99-
100- :param data_stream: Configuration options for writing to Elasticsearch Data Streams instead of a fixed index.
101- :type data_stream: ObservabilityPipelineElasticsearchDestinationDataStream, optional
102-
103112 :param customer_id: The Google Chronicle customer ID.
104113 :type customer_id: str
105114
@@ -217,6 +226,9 @@ def _composed_schemas(_):
217226 # code would be run when this module is imported, and these composed
218227 # classes don't exist yet because their module has not finished
219228 # loading
229+ from datadog_api_client .v2 .model .observability_pipeline_elasticsearch_destination import (
230+ ObservabilityPipelineElasticsearchDestination ,
231+ )
220232 from datadog_api_client .v2 .model .observability_pipeline_http_client_destination import (
221233 ObservabilityPipelineHttpClientDestination ,
222234 )
@@ -242,9 +254,6 @@ def _composed_schemas(_):
242254 from datadog_api_client .v2 .model .observability_pipeline_datadog_logs_destination import (
243255 ObservabilityPipelineDatadogLogsDestination ,
244256 )
245- from datadog_api_client .v2 .model .observability_pipeline_elasticsearch_destination import (
246- ObservabilityPipelineElasticsearchDestination ,
247- )
248257 from datadog_api_client .v2 .model .observability_pipeline_google_chronicle_destination import (
249258 ObservabilityPipelineGoogleChronicleDestination ,
250259 )
@@ -288,6 +297,7 @@ def _composed_schemas(_):
288297
289298 return {
290299 "oneOf" : [
300+ ObservabilityPipelineElasticsearchDestination ,
291301 ObservabilityPipelineHttpClientDestination ,
292302 ObservabilityPipelineAmazonOpenSearchDestination ,
293303 ObservabilityPipelineAmazonS3Destination ,
@@ -297,7 +307,6 @@ def _composed_schemas(_):
297307 ObservabilityPipelineCloudPremDestination ,
298308 ObservabilityPipelineCrowdStrikeNextGenSiemDestination ,
299309 ObservabilityPipelineDatadogLogsDestination ,
300- ObservabilityPipelineElasticsearchDestination ,
301310 ObservabilityPipelineGoogleChronicleDestination ,
302311 ObservabilityPipelineGoogleCloudStorageDestination ,
303312 ObservabilityPipelineGooglePubSubDestination ,
0 commit comments