Auto-generated API code (#3459)

Co-authored-by: Elastic Machine <elasticmachine@users.noreply.github.com>

Author: elastic-vault-github-plugin-prod[bot]

docs/reference/api-reference.md

@@ -0,0 +1,90 @@
+/*
+ * Copyright Elasticsearch B.V. and contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+// This file was automatically generated by elastic/elastic-client-generator-js
+// DO NOT MODIFY IT BY HAND. Instead, modify the source open api file,
+// and elastic/elastic-client-generator-js to regenerate this file again.
+
+import {
+  Transport,
+  TransportRequestMetadata,
+  TransportRequestOptions,
+  TransportRequestOptionsWithMeta,
+  TransportRequestOptionsWithOutMeta,
+  TransportResult
+} from '@elastic/transport'
+import * as T from '../types'
+import { kAcceptedParams } from '../../symbols'
+
+interface That {
+  transport: Transport
+  [kAcceptedParams]: Record<string, { path: string[], body: string[], query: string[] }>
+}
+
+export default class DataRecovery {
+  transport: Transport
+  [kAcceptedParams]: Record<string, { path: string[], body: string[], query: string[] }>
+  constructor (transport: Transport) {
+    this.transport = transport
+    this[kAcceptedParams] = {
+      'data_recovery.get_recovery_points': {
+        path: [],
+        body: [],
+        query: [
+          'end_time_before',
+          'master_timeout',
+          'size'
+        ]
+      }
+    }
+  }
+
+  /**
+    * Get recovery points. Get recovery points from the platform-managed data recovery repository. This API is intended for internal operator use. Recovery points are returned in descending order by end time. Repository, snapshot, and policy identifiers are not exposed.
+    */
+  async getRecoveryPoints (this: That, params?: T.DataRecoveryGetRecoveryPointsRequest, options?: TransportRequestOptionsWithOutMeta): Promise<T.DataRecoveryGetRecoveryPointsResponse>
+  async getRecoveryPoints (this: That, params?: T.DataRecoveryGetRecoveryPointsRequest, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.DataRecoveryGetRecoveryPointsResponse, unknown>>
+  async getRecoveryPoints (this: That, params?: T.DataRecoveryGetRecoveryPointsRequest, options?: TransportRequestOptions): Promise<T.DataRecoveryGetRecoveryPointsResponse>
+  async getRecoveryPoints (this: That, params?: T.DataRecoveryGetRecoveryPointsRequest, options?: TransportRequestOptions): Promise<any> {
+    const {
+      path: acceptedPath
+    } = this[kAcceptedParams]['data_recovery.get_recovery_points']
+
+    const userQuery = params?.querystring
+    const querystring: Record<string, any> = userQuery != null ? { ...userQuery } : {}
+
+    let body: Record<string, any> | string | undefined
+    const userBody = params?.body
+    if (userBody != null) {
+      if (typeof userBody === 'string') {
+        body = userBody
+      } else {
+        body = { ...userBody }
+      }
+    }
+
+    params = params ?? {}
+    for (const key in params) {
+      if (acceptedPath.includes(key)) {
+        continue
+      } else if (key !== 'body' && key !== 'querystring') {
+        // @ts-expect-error
+        querystring[key] = params[key]
+      }
+    }
+
+    const method = 'GET'
+    const path = '/_data_recovery/points'
+    const meta: TransportRequestMetadata = {
+      name: 'data_recovery.get_recovery_points',
+      acceptedParams: {
+        path: [],
+        body: [],
+        query: ['end_time_before', 'master_timeout', 'size']
+      }
+    }
+    return await this.transport.request({ path, method, querystring, body, meta }, options)
+  }
+}

src/api/api/data_recovery.ts

@@ -211,6 +211,14 @@ export default class Esql {
           'drop_null_columns',
           'allow_partial_results'
         ]
+      },
+      'esql.test_data_source_connection': {
+        path: [],
+        body: [
+          'type',
+          'settings'
+        ],
+        query: []
       }
     }
   }
@@ -1090,4 +1098,63 @@ export default class Esql {
     }
     return await this.transport.request({ path, method, querystring, body, meta }, options)
   }
+
+  /**
+    * Test an ES|QL data source connection. Tests whether the supplied data source configuration can establish a live connection. The data source does not need to exist in cluster state: this endpoint is intended for validating a new configuration before saving it. The request body accepts the same `type` and `settings` fields as the create or update data source API.
+    * @see {@link https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-esql-data-source-test-connection | Elasticsearch API documentation}
+    */
+  async testDataSourceConnection (this: That, params: T.EsqlTestDataSourceConnectionRequest, options?: TransportRequestOptionsWithOutMeta): Promise<T.EsqlTestDataSourceConnectionResponse>
+  async testDataSourceConnection (this: That, params: T.EsqlTestDataSourceConnectionRequest, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.EsqlTestDataSourceConnectionResponse, unknown>>
+  async testDataSourceConnection (this: That, params: T.EsqlTestDataSourceConnectionRequest, options?: TransportRequestOptions): Promise<T.EsqlTestDataSourceConnectionResponse>
+  async testDataSourceConnection (this: That, params: T.EsqlTestDataSourceConnectionRequest, options?: TransportRequestOptions): Promise<any> {
+    const {
+      path: acceptedPath,
+      body: acceptedBody,
+      query: acceptedQuery
+    } = this[kAcceptedParams]['esql.test_data_source_connection']
+
+    const userQuery = params?.querystring
+    const querystring: Record<string, any> = userQuery != null ? { ...userQuery } : {}
+
+    let body: Record<string, any> | string | undefined
+    const userBody = params?.body
+    if (userBody != null) {
+      if (typeof userBody === 'string') {
+        body = userBody
+      } else {
+        body = { ...userBody }
+      }
+    }
+
+    for (const key in params) {
+      if (acceptedBody.includes(key)) {
+        body = body ?? {}
+        // @ts-expect-error
+        body[key] = params[key]
+      } else if (acceptedPath.includes(key)) {
+        continue
+      } else if (key !== 'body' && key !== 'querystring') {
+        if (acceptedQuery.includes(key) || commonQueryParams.includes(key)) {
+          // @ts-expect-error
+          querystring[key] = params[key]
+        } else {
+          body = body ?? {}
+          // @ts-expect-error
+          body[key] = params[key]
+        }
+      }
+    }
+
+    const method = 'POST'
+    const path = '/_query/data_source/_test'
+    const meta: TransportRequestMetadata = {
+      name: 'esql.test_data_source_connection',
+      acceptedParams: {
+        path: [],
+        body: ['type', 'settings'],
+        query: []
+      }
+    }
+    return await this.transport.request({ path, method, querystring, body, meta }, options)
+  }
 }

src/api/api/esql.ts

@@ -109,6 +109,17 @@ export default class Inference {
           'timeout'
         ]
       },
+      'inference.non_streaming_chat_completion': {
+        path: [
+          'inference_id'
+        ],
+        body: [
+          'chat_completion_request'
+        ],
+        query: [
+          'timeout'
+        ]
+      },
       'inference.put': {
         path: [
           'task_type',
@@ -573,7 +584,7 @@ export default class Inference {
   }
 
   /**
-    * Perform chat completion inference on the service. The chat completion inference API enables real-time responses for chat completion tasks by delivering answers incrementally, reducing response times during computation. It only works with the `chat_completion` task type. NOTE: The `chat_completion` task type is only available within the _stream API and only supports streaming. The Chat completion inference API and the Stream inference API differ in their response structure and capabilities. The Chat completion inference API provides more comprehensive customization options through more fields and function calling support. To determine whether a given inference service supports this task type, please see the page for that service.
+    * Perform streaming chat completion inference on the service. The chat completion inference API enables real-time responses for chat completion tasks by delivering answers incrementally, reducing response times during computation. It only works with the `chat_completion` task type. NOTE: The `chat_completion` task type supports both streaming and non-streaming. The Chat completion inference API and the Stream inference API differ in their response structure and capabilities. The Chat completion inference API provides more comprehensive customization options through more fields and function calling support. To determine whether a given inference service supports this task type, please see the page for that service.
     * @see {@link https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-inference-unified-inference | Elasticsearch API documentation}
     */
   async chatCompletionUnified (this: That, params: T.InferenceChatCompletionUnifiedRequest, options?: TransportRequestOptionsWithOutMeta): Promise<T.InferenceChatCompletionUnifiedResponse>
@@ -1027,6 +1038,58 @@ export default class Inference {
     return await this.transport.request({ path, method, querystring, body, meta }, options)
   }
 
+  /**
+    * Perform non-streaming chat completion inference on the service. The chat completion inference API enables rich responses for chat completion tasks. It only works with the `chat_completion` task type. NOTE: The `chat_completion` task type supports both streaming and non-streaming. The Chat completion inference API provides more comprehensive customization options through more fields and function calling support. To determine whether a given inference service supports this task type, please see the page for that service. These services support non-streaming chat completion inference: - AI21 - Azure OpenAI - Deepseek - Elastic - FireworksAI - Groq - Huggingface - IBMWatsonX - Llama - Mistral - NVIDIA - OpenAI - OpenShiftAI
+    * @see {@link https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-inference-non-streaming-chat-completion | Elasticsearch API documentation}
+    */
+  async nonStreamingChatCompletion (this: That, params: T.InferenceNonStreamingChatCompletionRequest, options?: TransportRequestOptionsWithOutMeta): Promise<T.InferenceNonStreamingChatCompletionResponse>
+  async nonStreamingChatCompletion (this: That, params: T.InferenceNonStreamingChatCompletionRequest, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.InferenceNonStreamingChatCompletionResponse, unknown>>
+  async nonStreamingChatCompletion (this: That, params: T.InferenceNonStreamingChatCompletionRequest, options?: TransportRequestOptions): Promise<T.InferenceNonStreamingChatCompletionResponse>
+  async nonStreamingChatCompletion (this: That, params: T.InferenceNonStreamingChatCompletionRequest, options?: TransportRequestOptions): Promise<any> {
+    const {
+      path: acceptedPath,
+      body: acceptedBody,
+      query: acceptedQuery
+    } = this[kAcceptedParams]['inference.non_streaming_chat_completion']
+
+    const userQuery = params?.querystring
+    const querystring: Record<string, any> = userQuery != null ? { ...userQuery } : {}
+
+    let body: any = params.body ?? undefined
+    for (const key in params) {
+      if (acceptedBody.includes(key)) {
+        // @ts-expect-error
+        body = params[key]
+      } else if (acceptedPath.includes(key)) {
+        continue
+      } else if (key !== 'body' && key !== 'querystring') {
+        if (acceptedQuery.includes(key) || commonQueryParams.includes(key)) {
+          // @ts-expect-error
+          querystring[key] = params[key]
+        } else {
+          body = body ?? {}
+          // @ts-expect-error
+          body[key] = params[key]
+        }
+      }
+    }
+
+    const method = 'POST'
+    const path = `/_inference/chat_completion/${encodeURIComponent(params.inference_id.toString())}`
+    const meta: TransportRequestMetadata = {
+      name: 'inference.non_streaming_chat_completion',
+      pathParts: {
+        inference_id: params.inference_id
+      },
+      acceptedParams: {
+        path: ['inference_id'],
+        body: ['chat_completion_request'],
+        query: ['timeout']
+      }
+    }
+    return await this.transport.request({ path, method, querystring, body, meta }, options)
+  }
+
   /**
     * Create an inference endpoint. IMPORTANT: The inference APIs enable you to use certain services, such as built-in machine learning models (ELSER, E5), models uploaded through Eland, Cohere, OpenAI, Mistral, Azure OpenAI, Google AI Studio, Google Vertex AI, Anthropic, Watsonx.ai, or Hugging Face. For built-in models and models uploaded through Eland, the inference APIs offer an alternative way to use and manage trained models. However, if you do not plan to use the inference APIs to use these models or if you want to use non-NLP models, use the machine learning trained model APIs. The following integrations are available through the inference API. You can find the available task types next to the integration name: * AI21 (`chat_completion`, `completion`) * AlibabaCloud AI Search (`completion`, `rerank`, `sparse_embedding`, `text_embedding`) * Amazon Bedrock (`chat_completion`, `completion`, `text_embedding`) * Amazon SageMaker (`chat_completion`, `completion`, `rerank`, `sparse_embedding`, `text_embedding`) * Anthropic (`chat_completion`, `completion`) * Azure AI Studio (`completion`, `rerank`, `text_embedding`) * Azure OpenAI (`chat_completion`, `completion`, `text_embedding`) * Cohere (`completion`, `rerank`, `text_embedding`) * DeepSeek (`chat_completion`, `completion`) * Elasticsearch (`rerank`, `sparse_embedding`, `text_embedding` - this service is for built-in models and models uploaded through Eland) * ELSER (`sparse_embedding`) * Fireworks AI (`chat_completion`, `completion`, `text_embedding`) * Google AI Studio (`completion`, `text_embedding`) * Google Vertex AI (`chat_completion`, `completion`, `rerank`, `text_embedding`) * Groq (`chat_completion`) * Hugging Face (`chat_completion`, `completion`, `rerank`, `text_embedding`) * JinaAI (`embedding`, `rerank`, `text_embedding`) * Llama (`chat_completion`, `completion`, `text_embedding`) * Mistral (`chat_completion`, `completion`, `text_embedding`) * Nvidia (`chat_completion`, `completion`, `text_embedding`, `rerank`) * OpenAI (`chat_completion`, `completion`, `text_embedding`) * OpenShift AI (`chat_completion`, `completion`, `rerank`, `text_embedding`) * VoyageAI (`rerank`, `text_embedding`) * Watsonx (`chat_completion`, `completion`, `rerank`, `text_embedding`)
     * @see {@link https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-inference-put | Elasticsearch API documentation}

src/api/api/inference.ts

@@ -624,6 +624,7 @@ export default class Ml {
           'indices_options',
           'job_id',
           'max_empty_searches',
+          'max_consecutive_extraction_failures',
           'query',
           'query_delay',
           'runtime_mappings',
@@ -878,6 +879,7 @@ export default class Ml {
           'indices_options',
           'job_id',
           'max_empty_searches',
+          'max_consecutive_extraction_failures',
           'query',
           'query_delay',
           'runtime_mappings',
@@ -3846,7 +3848,7 @@ export default class Ml {
       },
       acceptedParams: {
         path: ['datafeed_id'],
-        body: ['aggregations', 'aggs', 'chunking_config', 'delayed_data_check_config', 'frequency', 'indices', 'indexes', 'indices_options', 'job_id', 'max_empty_searches', 'query', 'query_delay', 'runtime_mappings', 'script_fields', 'scroll_size', 'project_routing', 'headers'],
+        body: ['aggregations', 'aggs', 'chunking_config', 'delayed_data_check_config', 'frequency', 'indices', 'indexes', 'indices_options', 'job_id', 'max_empty_searches', 'max_consecutive_extraction_failures', 'query', 'query_delay', 'runtime_mappings', 'script_fields', 'scroll_size', 'project_routing', 'headers'],
         query: ['allow_no_indices', 'expand_wildcards', 'ignore_throttled', 'ignore_unavailable']
       }
     }
@@ -4865,7 +4867,7 @@ export default class Ml {
       },
       acceptedParams: {
         path: ['datafeed_id'],
-        body: ['aggregations', 'chunking_config', 'delayed_data_check_config', 'frequency', 'indices', 'indexes', 'indices_options', 'job_id', 'max_empty_searches', 'query', 'query_delay', 'runtime_mappings', 'script_fields', 'scroll_size', 'project_routing', '_force_rekeying'],
+        body: ['aggregations', 'chunking_config', 'delayed_data_check_config', 'frequency', 'indices', 'indexes', 'indices_options', 'job_id', 'max_empty_searches', 'max_consecutive_extraction_failures', 'query', 'query_delay', 'runtime_mappings', 'script_fields', 'scroll_size', 'project_routing', '_force_rekeying'],
         query: ['allow_no_indices', 'expand_wildcards', 'ignore_throttled', 'ignore_unavailable']
       }
     }