nextcloud / fulltextsearch_elasticsearch

lib/Vendor/Elastic/Elasticsearch/Endpoints/Ssl.php

Indentation +29 added lines, -29 removed lines

@@ -25,33 +25,33 @@
  */
 class Ssl extends AbstractEndpoint
 {
-    /**
-     * Retrieves information about the X.509 certificates used to encrypt communications in the cluster.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/security-api-ssl.html
-     *
-     * @param array{
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function certificates(array $params = [])
-    {
-        $url = '/_ssl/certificates';
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'ssl.certificates');
-        return $this->client->sendRequest($request);
-    }
+	/**
+	 * Retrieves information about the X.509 certificates used to encrypt communications in the cluster.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/security-api-ssl.html
+	 *
+	 * @param array{
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function certificates(array $params = [])
+	{
+		$url = '/_ssl/certificates';
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'ssl.certificates');
+		return $this->client->sendRequest($request);
+	}
 }

lib/Vendor/Elastic/Elasticsearch/Endpoints/Shutdown.php

Indentation +101 added lines, -101 removed lines

@@ -25,105 +25,105 @@
  */
 class Shutdown extends AbstractEndpoint
 {
-    /**
-     * Removes a node from the shutdown list. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current
-     *
-     * @param array{
-     *     node_id: string, // (REQUIRED) The node id of node to be removed from the shutdown state
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function deleteNode(array $params = [])
-    {
-        $this->checkRequiredParameters(['node_id'], $params);
-        $url = '/_nodes/' . $this->encode($params['node_id']) . '/shutdown';
-        $method = 'DELETE';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['node_id'], $request, 'shutdown.delete_node');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Retrieve status of a node or nodes that are currently marked as shutting down. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current
-     *
-     * @param array{
-     *     node_id: string, //  Which node for which to retrieve the shutdown status
-     *     master_timeout: time, // Timeout for processing on master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function getNode(array $params = [])
-    {
-        if (isset($params['node_id'])) {
-            $url = '/_nodes/' . $this->encode($params['node_id']) . '/shutdown';
-            $method = 'GET';
-        } else {
-            $url = '/_nodes/shutdown';
-            $method = 'GET';
-        }
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['node_id'], $request, 'shutdown.get_node');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Adds a node to be shut down. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current
-     *
-     * @param array{
-     *     node_id: string, // (REQUIRED) The node id of node to be shut down
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) The shutdown type definition to register
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function putNode(array $params = [])
-    {
-        $this->checkRequiredParameters(['node_id', 'body'], $params);
-        $url = '/_nodes/' . $this->encode($params['node_id']) . '/shutdown';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['node_id'], $request, 'shutdown.put_node');
-        return $this->client->sendRequest($request);
-    }
+	/**
+	 * Removes a node from the shutdown list. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current
+	 *
+	 * @param array{
+	 *     node_id: string, // (REQUIRED) The node id of node to be removed from the shutdown state
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function deleteNode(array $params = [])
+	{
+		$this->checkRequiredParameters(['node_id'], $params);
+		$url = '/_nodes/' . $this->encode($params['node_id']) . '/shutdown';
+		$method = 'DELETE';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['node_id'], $request, 'shutdown.delete_node');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Retrieve status of a node or nodes that are currently marked as shutting down. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current
+	 *
+	 * @param array{
+	 *     node_id: string, //  Which node for which to retrieve the shutdown status
+	 *     master_timeout: time, // Timeout for processing on master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function getNode(array $params = [])
+	{
+		if (isset($params['node_id'])) {
+			$url = '/_nodes/' . $this->encode($params['node_id']) . '/shutdown';
+			$method = 'GET';
+		} else {
+			$url = '/_nodes/shutdown';
+			$method = 'GET';
+		}
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['node_id'], $request, 'shutdown.get_node');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Adds a node to be shut down. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current
+	 *
+	 * @param array{
+	 *     node_id: string, // (REQUIRED) The node id of node to be shut down
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) The shutdown type definition to register
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function putNode(array $params = [])
+	{
+		$this->checkRequiredParameters(['node_id', 'body'], $params);
+		$url = '/_nodes/' . $this->encode($params['node_id']) . '/shutdown';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['node_id'], $request, 'shutdown.put_node');
+		return $this->client->sendRequest($request);
+	}
 }

lib/Vendor/Elastic/Elasticsearch/Endpoints/Enrich.php

Indentation +167 added lines, -167 removed lines

@@ -25,171 +25,171 @@
  */
 class Enrich extends AbstractEndpoint
 {
-    /**
-     * Deletes an existing enrich policy and its enrich index.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/delete-enrich-policy-api.html
-     *
-     * @param array{
-     *     name: string, // (REQUIRED) The name of the enrich policy
-     *     master_timeout: time, // Timeout for processing on master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function deletePolicy(array $params = [])
-    {
-        $this->checkRequiredParameters(['name'], $params);
-        $url = '/_enrich/policy/' . $this->encode($params['name']);
-        $method = 'DELETE';
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['name'], $request, 'enrich.delete_policy');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Creates the enrich index for an existing enrich policy.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/execute-enrich-policy-api.html
-     *
-     * @param array{
-     *     name: string, // (REQUIRED) The name of the enrich policy
-     *     wait_for_completion: boolean, // Should the request should block until the execution is complete.
-     *     master_timeout: time, // Timeout for processing on master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function executePolicy(array $params = [])
-    {
-        $this->checkRequiredParameters(['name'], $params);
-        $url = '/_enrich/policy/' . $this->encode($params['name']) . '/_execute';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['wait_for_completion', 'master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['name'], $request, 'enrich.execute_policy');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Gets information about an enrich policy.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/get-enrich-policy-api.html
-     *
-     * @param array{
-     *     name: list, //  A comma-separated list of enrich policy names
-     *     master_timeout: time, // Timeout for processing on master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function getPolicy(array $params = [])
-    {
-        if (isset($params['name'])) {
-            $url = '/_enrich/policy/' . $this->encode($params['name']);
-            $method = 'GET';
-        } else {
-            $url = '/_enrich/policy';
-            $method = 'GET';
-        }
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['name'], $request, 'enrich.get_policy');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Creates a new enrich policy.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/put-enrich-policy-api.html
-     *
-     * @param array{
-     *     name: string, // (REQUIRED) The name of the enrich policy
-     *     master_timeout: time, // Timeout for processing on master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) The enrich policy to register
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function putPolicy(array $params = [])
-    {
-        $this->checkRequiredParameters(['name', 'body'], $params);
-        $url = '/_enrich/policy/' . $this->encode($params['name']);
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['name'], $request, 'enrich.put_policy');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Gets enrich coordinator statistics and information about enrich policies that are currently executing.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/enrich-stats-api.html
-     *
-     * @param array{
-     *     master_timeout: time, // Timeout for processing on master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function stats(array $params = [])
-    {
-        $url = '/_enrich/_stats';
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'enrich.stats');
-        return $this->client->sendRequest($request);
-    }
+	/**
+	 * Deletes an existing enrich policy and its enrich index.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/delete-enrich-policy-api.html
+	 *
+	 * @param array{
+	 *     name: string, // (REQUIRED) The name of the enrich policy
+	 *     master_timeout: time, // Timeout for processing on master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function deletePolicy(array $params = [])
+	{
+		$this->checkRequiredParameters(['name'], $params);
+		$url = '/_enrich/policy/' . $this->encode($params['name']);
+		$method = 'DELETE';
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['name'], $request, 'enrich.delete_policy');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Creates the enrich index for an existing enrich policy.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/execute-enrich-policy-api.html
+	 *
+	 * @param array{
+	 *     name: string, // (REQUIRED) The name of the enrich policy
+	 *     wait_for_completion: boolean, // Should the request should block until the execution is complete.
+	 *     master_timeout: time, // Timeout for processing on master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function executePolicy(array $params = [])
+	{
+		$this->checkRequiredParameters(['name'], $params);
+		$url = '/_enrich/policy/' . $this->encode($params['name']) . '/_execute';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['wait_for_completion', 'master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['name'], $request, 'enrich.execute_policy');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Gets information about an enrich policy.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/get-enrich-policy-api.html
+	 *
+	 * @param array{
+	 *     name: list, //  A comma-separated list of enrich policy names
+	 *     master_timeout: time, // Timeout for processing on master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function getPolicy(array $params = [])
+	{
+		if (isset($params['name'])) {
+			$url = '/_enrich/policy/' . $this->encode($params['name']);
+			$method = 'GET';
+		} else {
+			$url = '/_enrich/policy';
+			$method = 'GET';
+		}
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['name'], $request, 'enrich.get_policy');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Creates a new enrich policy.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/put-enrich-policy-api.html
+	 *
+	 * @param array{
+	 *     name: string, // (REQUIRED) The name of the enrich policy
+	 *     master_timeout: time, // Timeout for processing on master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) The enrich policy to register
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function putPolicy(array $params = [])
+	{
+		$this->checkRequiredParameters(['name', 'body'], $params);
+		$url = '/_enrich/policy/' . $this->encode($params['name']);
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['name'], $request, 'enrich.put_policy');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Gets enrich coordinator statistics and information about enrich policies that are currently executing.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/enrich-stats-api.html
+	 *
+	 * @param array{
+	 *     master_timeout: time, // Timeout for processing on master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function stats(array $params = [])
+	{
+		$url = '/_enrich/_stats';
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'enrich.stats');
+		return $this->client->sendRequest($request);
+	}
 }

Spacing +5 added lines, -5 removed lines

@@ -11,7 +11,7 @@ 
  * Elasticsearch B.V licenses this file to you under the MIT License.
  * See the LICENSE file in the project root for more information.
  */
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Endpoints;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Exception\ClientResponseException;
@@ -50,7 +50,7 @@ 
     public function deletePolicy(array $params = [])
     {
         $this->checkRequiredParameters(['name'], $params);
-        $url = '/_enrich/policy/' . $this->encode($params['name']);
+        $url = '/_enrich/policy/'.$this->encode($params['name']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -84,7 +84,7 @@ 
     public function executePolicy(array $params = [])
     {
         $this->checkRequiredParameters(['name'], $params);
-        $url = '/_enrich/policy/' . $this->encode($params['name']) . '/_execute';
+        $url = '/_enrich/policy/'.$this->encode($params['name']).'/_execute';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['wait_for_completion', 'master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -116,7 +116,7 @@ 
     public function getPolicy(array $params = [])
     {
         if (isset($params['name'])) {
-            $url = '/_enrich/policy/' . $this->encode($params['name']);
+            $url = '/_enrich/policy/'.$this->encode($params['name']);
             $method = 'GET';
         } else {
             $url = '/_enrich/policy';
@@ -154,7 +154,7 @@ 
     public function putPolicy(array $params = [])
     {
         $this->checkRequiredParameters(['name', 'body'], $params);
-        $url = '/_enrich/policy/' . $this->encode($params['name']);
+        $url = '/_enrich/policy/'.$this->encode($params['name']);
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];

lib/Vendor/Elastic/Elasticsearch/Endpoints/Sql.php

Indentation +194 added lines, -194 removed lines

@@ -25,198 +25,198 @@
  */
 class Sql extends AbstractEndpoint
 {
-    /**
-     * Clears the SQL cursor
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/clear-sql-cursor-api.html
-     *
-     * @param array{
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) Specify the cursor value in the `cursor` element to clean the cursor.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function clearCursor(array $params = [])
-    {
-        $this->checkRequiredParameters(['body'], $params);
-        $url = '/_sql/close';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'sql.clear_cursor');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Deletes an async SQL search or a stored synchronous SQL search. If the search is still running, the API cancels it.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/delete-async-sql-search-api.html
-     *
-     * @param array{
-     *     id: string, // (REQUIRED) The async search ID
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function deleteAsync(array $params = [])
-    {
-        $this->checkRequiredParameters(['id'], $params);
-        $url = '/_sql/async/delete/' . $this->encode($params['id']);
-        $method = 'DELETE';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['id'], $request, 'sql.delete_async');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Returns the current status and available results for an async SQL search or stored synchronous SQL search
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/get-async-sql-search-api.html
-     *
-     * @param array{
-     *     id: string, // (REQUIRED) The async search ID
-     *     delimiter: string, // Separator for CSV results
-     *     format: string, // Short version of the Accept header, e.g. json, yaml
-     *     keep_alive: time, // Retention period for the search and its results
-     *     wait_for_completion_timeout: time, // Duration to wait for complete results
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function getAsync(array $params = [])
-    {
-        $this->checkRequiredParameters(['id'], $params);
-        $url = '/_sql/async/' . $this->encode($params['id']);
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['delimiter', 'format', 'keep_alive', 'wait_for_completion_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['id'], $request, 'sql.get_async');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Returns the current status of an async SQL search or a stored synchronous SQL search
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/get-async-sql-search-status-api.html
-     *
-     * @param array{
-     *     id: string, // (REQUIRED) The async search ID
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function getAsyncStatus(array $params = [])
-    {
-        $this->checkRequiredParameters(['id'], $params);
-        $url = '/_sql/async/status/' . $this->encode($params['id']);
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['id'], $request, 'sql.get_async_status');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Executes a SQL request
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/sql-search-api.html
-     *
-     * @param array{
-     *     format: string, // a short version of the Accept header, e.g. json, yaml
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) Use the `query` element to start a query. Use the `cursor` element to continue a query.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function query(array $params = [])
-    {
-        $this->checkRequiredParameters(['body'], $params);
-        $url = '/_sql';
-        $method = empty($params['body']) ? 'GET' : 'POST';
-        $url = $this->addQueryString($url, $params, ['format', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'sql.query');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Translates SQL into Elasticsearch queries
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/sql-translate-api.html
-     *
-     * @param array{
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) Specify the query in the `query` element.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function translate(array $params = [])
-    {
-        $this->checkRequiredParameters(['body'], $params);
-        $url = '/_sql/translate';
-        $method = empty($params['body']) ? 'GET' : 'POST';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'sql.translate');
-        return $this->client->sendRequest($request);
-    }
+	/**
+	 * Clears the SQL cursor
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/clear-sql-cursor-api.html
+	 *
+	 * @param array{
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) Specify the cursor value in the `cursor` element to clean the cursor.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function clearCursor(array $params = [])
+	{
+		$this->checkRequiredParameters(['body'], $params);
+		$url = '/_sql/close';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'sql.clear_cursor');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Deletes an async SQL search or a stored synchronous SQL search. If the search is still running, the API cancels it.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/delete-async-sql-search-api.html
+	 *
+	 * @param array{
+	 *     id: string, // (REQUIRED) The async search ID
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function deleteAsync(array $params = [])
+	{
+		$this->checkRequiredParameters(['id'], $params);
+		$url = '/_sql/async/delete/' . $this->encode($params['id']);
+		$method = 'DELETE';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['id'], $request, 'sql.delete_async');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Returns the current status and available results for an async SQL search or stored synchronous SQL search
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/get-async-sql-search-api.html
+	 *
+	 * @param array{
+	 *     id: string, // (REQUIRED) The async search ID
+	 *     delimiter: string, // Separator for CSV results
+	 *     format: string, // Short version of the Accept header, e.g. json, yaml
+	 *     keep_alive: time, // Retention period for the search and its results
+	 *     wait_for_completion_timeout: time, // Duration to wait for complete results
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function getAsync(array $params = [])
+	{
+		$this->checkRequiredParameters(['id'], $params);
+		$url = '/_sql/async/' . $this->encode($params['id']);
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['delimiter', 'format', 'keep_alive', 'wait_for_completion_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['id'], $request, 'sql.get_async');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Returns the current status of an async SQL search or a stored synchronous SQL search
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/get-async-sql-search-status-api.html
+	 *
+	 * @param array{
+	 *     id: string, // (REQUIRED) The async search ID
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function getAsyncStatus(array $params = [])
+	{
+		$this->checkRequiredParameters(['id'], $params);
+		$url = '/_sql/async/status/' . $this->encode($params['id']);
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['id'], $request, 'sql.get_async_status');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Executes a SQL request
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/sql-search-api.html
+	 *
+	 * @param array{
+	 *     format: string, // a short version of the Accept header, e.g. json, yaml
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) Use the `query` element to start a query. Use the `cursor` element to continue a query.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function query(array $params = [])
+	{
+		$this->checkRequiredParameters(['body'], $params);
+		$url = '/_sql';
+		$method = empty($params['body']) ? 'GET' : 'POST';
+		$url = $this->addQueryString($url, $params, ['format', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'sql.query');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Translates SQL into Elasticsearch queries
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/sql-translate-api.html
+	 *
+	 * @param array{
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) Specify the query in the `query` element.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function translate(array $params = [])
+	{
+		$this->checkRequiredParameters(['body'], $params);
+		$url = '/_sql/translate';
+		$method = empty($params['body']) ? 'GET' : 'POST';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'sql.translate');
+		return $this->client->sendRequest($request);
+	}
 }

lib/Vendor/Elastic/Elasticsearch/Endpoints/Eql.php

Indentation +134 added lines, -134 removed lines

@@ -25,138 +25,138 @@
  */
 class Eql extends AbstractEndpoint
 {
-    /**
-     * Deletes an async EQL search by ID. If the search is still running, the search request will be cancelled. Otherwise, the saved search results are deleted.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/eql-search-api.html
-     *
-     * @param array{
-     *     id: string, // (REQUIRED) The async search ID
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function delete(array $params = [])
-    {
-        $this->checkRequiredParameters(['id'], $params);
-        $url = '/_eql/search/' . $this->encode($params['id']);
-        $method = 'DELETE';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['id'], $request, 'eql.delete');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Returns async results from previously executed Event Query Language (EQL) search
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/eql-search-api.html
-     *
-     * @param array{
-     *     id: string, // (REQUIRED) The async search ID
-     *     wait_for_completion_timeout: time, // Specify the time that the request should block waiting for the final response
-     *     keep_alive: time, // Update the time interval in which the results (partial or final) for this search will be available
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function get(array $params = [])
-    {
-        $this->checkRequiredParameters(['id'], $params);
-        $url = '/_eql/search/' . $this->encode($params['id']);
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['wait_for_completion_timeout', 'keep_alive', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['id'], $request, 'eql.get');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Returns the status of a previously submitted async or stored Event Query Language (EQL) search
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/eql-search-api.html
-     *
-     * @param array{
-     *     id: string, // (REQUIRED) The async search ID
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function getStatus(array $params = [])
-    {
-        $this->checkRequiredParameters(['id'], $params);
-        $url = '/_eql/search/status/' . $this->encode($params['id']);
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['id'], $request, 'eql.get_status');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Returns results matching a query expressed in Event Query Language (EQL)
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/eql-search-api.html
-     *
-     * @param array{
-     *     index: string, // (REQUIRED) The name of the index to scope the operation
-     *     wait_for_completion_timeout: time, // Specify the time that the request should block waiting for the final response
-     *     keep_on_completion: boolean, // Control whether the response should be stored in the cluster if it completed within the provided [wait_for_completion] time (default: false)
-     *     keep_alive: time, // Update the time interval in which the results (partial or final) for this search will be available
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) Eql request body. Use the `query` to limit the query scope.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function search(array $params = [])
-    {
-        $this->checkRequiredParameters(['index', 'body'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_eql/search';
-        $method = empty($params['body']) ? 'GET' : 'POST';
-        $url = $this->addQueryString($url, $params, ['wait_for_completion_timeout', 'keep_on_completion', 'keep_alive', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['index'], $request, 'eql.search');
-        return $this->client->sendRequest($request);
-    }
+	/**
+	 * Deletes an async EQL search by ID. If the search is still running, the search request will be cancelled. Otherwise, the saved search results are deleted.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/eql-search-api.html
+	 *
+	 * @param array{
+	 *     id: string, // (REQUIRED) The async search ID
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function delete(array $params = [])
+	{
+		$this->checkRequiredParameters(['id'], $params);
+		$url = '/_eql/search/' . $this->encode($params['id']);
+		$method = 'DELETE';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['id'], $request, 'eql.delete');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Returns async results from previously executed Event Query Language (EQL) search
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/eql-search-api.html
+	 *
+	 * @param array{
+	 *     id: string, // (REQUIRED) The async search ID
+	 *     wait_for_completion_timeout: time, // Specify the time that the request should block waiting for the final response
+	 *     keep_alive: time, // Update the time interval in which the results (partial or final) for this search will be available
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function get(array $params = [])
+	{
+		$this->checkRequiredParameters(['id'], $params);
+		$url = '/_eql/search/' . $this->encode($params['id']);
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['wait_for_completion_timeout', 'keep_alive', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['id'], $request, 'eql.get');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Returns the status of a previously submitted async or stored Event Query Language (EQL) search
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/eql-search-api.html
+	 *
+	 * @param array{
+	 *     id: string, // (REQUIRED) The async search ID
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function getStatus(array $params = [])
+	{
+		$this->checkRequiredParameters(['id'], $params);
+		$url = '/_eql/search/status/' . $this->encode($params['id']);
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['id'], $request, 'eql.get_status');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Returns results matching a query expressed in Event Query Language (EQL)
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/eql-search-api.html
+	 *
+	 * @param array{
+	 *     index: string, // (REQUIRED) The name of the index to scope the operation
+	 *     wait_for_completion_timeout: time, // Specify the time that the request should block waiting for the final response
+	 *     keep_on_completion: boolean, // Control whether the response should be stored in the cluster if it completed within the provided [wait_for_completion] time (default: false)
+	 *     keep_alive: time, // Update the time interval in which the results (partial or final) for this search will be available
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) Eql request body. Use the `query` to limit the query scope.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function search(array $params = [])
+	{
+		$this->checkRequiredParameters(['index', 'body'], $params);
+		$url = '/' . $this->encode($params['index']) . '/_eql/search';
+		$method = empty($params['body']) ? 'GET' : 'POST';
+		$url = $this->addQueryString($url, $params, ['wait_for_completion_timeout', 'keep_on_completion', 'keep_alive', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['index'], $request, 'eql.search');
+		return $this->client->sendRequest($request);
+	}
 }

lib/Vendor/Elastic/Elasticsearch/Endpoints/Ilm.php

Indentation +349 added lines, -349 removed lines

@@ -25,353 +25,353 @@
  */
 class Ilm extends AbstractEndpoint
 {
-    /**
-     * Deletes the specified lifecycle policy definition. A currently used policy cannot be deleted.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-delete-lifecycle.html
-     *
-     * @param array{
-     *     policy: string, // (REQUIRED) The name of the index lifecycle policy
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function deleteLifecycle(array $params = [])
-    {
-        $this->checkRequiredParameters(['policy'], $params);
-        $url = '/_ilm/policy/' . $this->encode($params['policy']);
-        $method = 'DELETE';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['policy'], $request, 'ilm.delete_lifecycle');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Retrieves information about the index's current lifecycle state, such as the currently executing phase, action, and step.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-explain-lifecycle.html
-     *
-     * @param array{
-     *     index: string, // (REQUIRED) The name of the index to explain
-     *     only_managed: boolean, // filters the indices included in the response to ones managed by ILM
-     *     only_errors: boolean, // filters the indices included in the response to ones in an ILM error state, implies only_managed
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function explainLifecycle(array $params = [])
-    {
-        $this->checkRequiredParameters(['index'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ilm/explain';
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['only_managed', 'only_errors', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['index'], $request, 'ilm.explain_lifecycle');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Returns the specified policy definition. Includes the policy version and last modified date.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-get-lifecycle.html
-     *
-     * @param array{
-     *     policy: string, //  The name of the index lifecycle policy
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function getLifecycle(array $params = [])
-    {
-        if (isset($params['policy'])) {
-            $url = '/_ilm/policy/' . $this->encode($params['policy']);
-            $method = 'GET';
-        } else {
-            $url = '/_ilm/policy';
-            $method = 'GET';
-        }
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['policy'], $request, 'ilm.get_lifecycle');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Retrieves the current index lifecycle management (ILM) status.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-get-status.html
-     *
-     * @param array{
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function getStatus(array $params = [])
-    {
-        $url = '/_ilm/status';
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'ilm.get_status');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Migrates the indices and ILM policies away from custom node attribute allocation routing to data tiers routing
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-migrate-to-data-tiers.html
-     *
-     * @param array{
-     *     dry_run: boolean, // If set to true it will simulate the migration, providing a way to retrieve the ILM policies and indices that need to be migrated. The default is false
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, //  Optionally specify a legacy index template name to delete and optionally specify a node attribute name used for index shard routing (defaults to "data")
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function migrateToDataTiers(array $params = [])
-    {
-        $url = '/_ilm/migrate_to_data_tiers';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['dry_run', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'ilm.migrate_to_data_tiers');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Manually moves an index into the specified step and executes that step.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-move-to-step.html
-     *
-     * @param array{
-     *     index: string, // (REQUIRED) The name of the index whose lifecycle step is to change
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, //  The new lifecycle step to move to
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function moveToStep(array $params = [])
-    {
-        $this->checkRequiredParameters(['index'], $params);
-        $url = '/_ilm/move/' . $this->encode($params['index']);
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['index'], $request, 'ilm.move_to_step');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Creates a lifecycle policy
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-put-lifecycle.html
-     *
-     * @param array{
-     *     policy: string, // (REQUIRED) The name of the index lifecycle policy
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, //  The lifecycle policy definition to register
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function putLifecycle(array $params = [])
-    {
-        $this->checkRequiredParameters(['policy'], $params);
-        $url = '/_ilm/policy/' . $this->encode($params['policy']);
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['policy'], $request, 'ilm.put_lifecycle');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Removes the assigned lifecycle policy and stops managing the specified index
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-remove-policy.html
-     *
-     * @param array{
-     *     index: string, // (REQUIRED) The name of the index to remove policy on
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function removePolicy(array $params = [])
-    {
-        $this->checkRequiredParameters(['index'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ilm/remove';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['index'], $request, 'ilm.remove_policy');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Retries executing the policy for an index that is in the ERROR step.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-retry-policy.html
-     *
-     * @param array{
-     *     index: string, // (REQUIRED) The name of the indices (comma-separated) whose failed lifecycle step is to be retry
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function retry(array $params = [])
-    {
-        $this->checkRequiredParameters(['index'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ilm/retry';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['index'], $request, 'ilm.retry');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Start the index lifecycle management (ILM) plugin.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-start.html
-     *
-     * @param array{
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function start(array $params = [])
-    {
-        $url = '/_ilm/start';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'ilm.start');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Halts all lifecycle management operations and stops the index lifecycle management (ILM) plugin
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-stop.html
-     *
-     * @param array{
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function stop(array $params = [])
-    {
-        $url = '/_ilm/stop';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'ilm.stop');
-        return $this->client->sendRequest($request);
-    }
+	/**
+	 * Deletes the specified lifecycle policy definition. A currently used policy cannot be deleted.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-delete-lifecycle.html
+	 *
+	 * @param array{
+	 *     policy: string, // (REQUIRED) The name of the index lifecycle policy
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function deleteLifecycle(array $params = [])
+	{
+		$this->checkRequiredParameters(['policy'], $params);
+		$url = '/_ilm/policy/' . $this->encode($params['policy']);
+		$method = 'DELETE';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['policy'], $request, 'ilm.delete_lifecycle');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Retrieves information about the index's current lifecycle state, such as the currently executing phase, action, and step.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-explain-lifecycle.html
+	 *
+	 * @param array{
+	 *     index: string, // (REQUIRED) The name of the index to explain
+	 *     only_managed: boolean, // filters the indices included in the response to ones managed by ILM
+	 *     only_errors: boolean, // filters the indices included in the response to ones in an ILM error state, implies only_managed
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function explainLifecycle(array $params = [])
+	{
+		$this->checkRequiredParameters(['index'], $params);
+		$url = '/' . $this->encode($params['index']) . '/_ilm/explain';
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['only_managed', 'only_errors', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['index'], $request, 'ilm.explain_lifecycle');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Returns the specified policy definition. Includes the policy version and last modified date.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-get-lifecycle.html
+	 *
+	 * @param array{
+	 *     policy: string, //  The name of the index lifecycle policy
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function getLifecycle(array $params = [])
+	{
+		if (isset($params['policy'])) {
+			$url = '/_ilm/policy/' . $this->encode($params['policy']);
+			$method = 'GET';
+		} else {
+			$url = '/_ilm/policy';
+			$method = 'GET';
+		}
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['policy'], $request, 'ilm.get_lifecycle');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Retrieves the current index lifecycle management (ILM) status.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-get-status.html
+	 *
+	 * @param array{
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function getStatus(array $params = [])
+	{
+		$url = '/_ilm/status';
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'ilm.get_status');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Migrates the indices and ILM policies away from custom node attribute allocation routing to data tiers routing
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-migrate-to-data-tiers.html
+	 *
+	 * @param array{
+	 *     dry_run: boolean, // If set to true it will simulate the migration, providing a way to retrieve the ILM policies and indices that need to be migrated. The default is false
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, //  Optionally specify a legacy index template name to delete and optionally specify a node attribute name used for index shard routing (defaults to "data")
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function migrateToDataTiers(array $params = [])
+	{
+		$url = '/_ilm/migrate_to_data_tiers';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['dry_run', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'ilm.migrate_to_data_tiers');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Manually moves an index into the specified step and executes that step.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-move-to-step.html
+	 *
+	 * @param array{
+	 *     index: string, // (REQUIRED) The name of the index whose lifecycle step is to change
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, //  The new lifecycle step to move to
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function moveToStep(array $params = [])
+	{
+		$this->checkRequiredParameters(['index'], $params);
+		$url = '/_ilm/move/' . $this->encode($params['index']);
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['index'], $request, 'ilm.move_to_step');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Creates a lifecycle policy
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-put-lifecycle.html
+	 *
+	 * @param array{
+	 *     policy: string, // (REQUIRED) The name of the index lifecycle policy
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, //  The lifecycle policy definition to register
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function putLifecycle(array $params = [])
+	{
+		$this->checkRequiredParameters(['policy'], $params);
+		$url = '/_ilm/policy/' . $this->encode($params['policy']);
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['policy'], $request, 'ilm.put_lifecycle');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Removes the assigned lifecycle policy and stops managing the specified index
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-remove-policy.html
+	 *
+	 * @param array{
+	 *     index: string, // (REQUIRED) The name of the index to remove policy on
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function removePolicy(array $params = [])
+	{
+		$this->checkRequiredParameters(['index'], $params);
+		$url = '/' . $this->encode($params['index']) . '/_ilm/remove';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['index'], $request, 'ilm.remove_policy');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Retries executing the policy for an index that is in the ERROR step.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-retry-policy.html
+	 *
+	 * @param array{
+	 *     index: string, // (REQUIRED) The name of the indices (comma-separated) whose failed lifecycle step is to be retry
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function retry(array $params = [])
+	{
+		$this->checkRequiredParameters(['index'], $params);
+		$url = '/' . $this->encode($params['index']) . '/_ilm/retry';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['index'], $request, 'ilm.retry');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Start the index lifecycle management (ILM) plugin.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-start.html
+	 *
+	 * @param array{
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function start(array $params = [])
+	{
+		$url = '/_ilm/start';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'ilm.start');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Halts all lifecycle management operations and stops the index lifecycle management (ILM) plugin
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-stop.html
+	 *
+	 * @param array{
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function stop(array $params = [])
+	{
+		$url = '/_ilm/stop';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'ilm.stop');
+		return $this->client->sendRequest($request);
+	}
 }

lib/Vendor/Elastic/Elasticsearch/Endpoints/Ccr.php

Indentation +435 added lines, -435 removed lines

@@ -25,439 +25,439 @@
  */
 class Ccr extends AbstractEndpoint
 {
-    /**
-     * Deletes auto-follow patterns.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-delete-auto-follow-pattern.html
-     *
-     * @param array{
-     *     name: string, // (REQUIRED) The name of the auto follow pattern.
-     *     master_timeout: time, // Explicit operation timeout for connection to master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function deleteAutoFollowPattern(array $params = [])
-    {
-        $this->checkRequiredParameters(['name'], $params);
-        $url = '/_ccr/auto_follow/' . $this->encode($params['name']);
-        $method = 'DELETE';
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['name'], $request, 'ccr.delete_auto_follow_pattern');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Creates a new follower index configured to follow the referenced leader index.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-put-follow.html
-     *
-     * @param array{
-     *     index: string, // (REQUIRED) The name of the follower index
-     *     wait_for_active_shards: string, // Sets the number of shard copies that must be active before returning. Defaults to 0. Set to `all` for all shard copies, otherwise set to any non-negative value less than or equal to the total number of copies for the shard (number of replicas + 1)
-     *     master_timeout: time, // Explicit operation timeout for connection to master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) The name of the leader index and other optional ccr related parameters
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function follow(array $params = [])
-    {
-        $this->checkRequiredParameters(['index', 'body'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/follow';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['wait_for_active_shards', 'master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.follow');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Retrieves information about all follower indices, including parameters and status for each follower index
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-get-follow-info.html
-     *
-     * @param array{
-     *     index: list, // (REQUIRED) A comma-separated list of index patterns; use `_all` to perform the operation on all indices
-     *     master_timeout: time, // Explicit operation timeout for connection to master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function followInfo(array $params = [])
-    {
-        $this->checkRequiredParameters(['index'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/info';
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.follow_info');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Retrieves follower stats. return shard-level stats about the following tasks associated with each shard for the specified indices.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-get-follow-stats.html
-     *
-     * @param array{
-     *     index: list, // (REQUIRED) A comma-separated list of index patterns; use `_all` to perform the operation on all indices
-     *     timeout: time, // Explicit operation timeout
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function followStats(array $params = [])
-    {
-        $this->checkRequiredParameters(['index'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/stats';
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.follow_stats');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Removes the follower retention leases from the leader.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-post-forget-follower.html
-     *
-     * @param array{
-     *     index: string, // (REQUIRED) the name of the leader index for which specified follower retention leases should be removed
-     *     timeout: time, // Explicit operation timeout
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) the name and UUID of the follower index, the name of the cluster containing the follower index, and the alias from the perspective of that cluster for the remote cluster containing the leader index
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function forgetFollower(array $params = [])
-    {
-        $this->checkRequiredParameters(['index', 'body'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/forget_follower';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.forget_follower');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Gets configured auto-follow patterns. Returns the specified auto-follow pattern collection.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-get-auto-follow-pattern.html
-     *
-     * @param array{
-     *     name: string, //  The name of the auto follow pattern.
-     *     master_timeout: time, // Explicit operation timeout for connection to master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function getAutoFollowPattern(array $params = [])
-    {
-        if (isset($params['name'])) {
-            $url = '/_ccr/auto_follow/' . $this->encode($params['name']);
-            $method = 'GET';
-        } else {
-            $url = '/_ccr/auto_follow';
-            $method = 'GET';
-        }
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['name'], $request, 'ccr.get_auto_follow_pattern');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Pauses an auto-follow pattern
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-pause-auto-follow-pattern.html
-     *
-     * @param array{
-     *     name: string, // (REQUIRED) The name of the auto follow pattern that should pause discovering new indices to follow.
-     *     master_timeout: time, // Explicit operation timeout for connection to master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function pauseAutoFollowPattern(array $params = [])
-    {
-        $this->checkRequiredParameters(['name'], $params);
-        $url = '/_ccr/auto_follow/' . $this->encode($params['name']) . '/pause';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['name'], $request, 'ccr.pause_auto_follow_pattern');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Pauses a follower index. The follower index will not fetch any additional operations from the leader index.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-post-pause-follow.html
-     *
-     * @param array{
-     *     index: string, // (REQUIRED) The name of the follower index that should pause following its leader index.
-     *     master_timeout: time, // Explicit operation timeout for connection to master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function pauseFollow(array $params = [])
-    {
-        $this->checkRequiredParameters(['index'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/pause_follow';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.pause_follow');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Creates a new named collection of auto-follow patterns against a specified remote cluster. Newly created indices on the remote cluster matching any of the specified patterns will be automatically configured as follower indices.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-put-auto-follow-pattern.html
-     *
-     * @param array{
-     *     name: string, // (REQUIRED) The name of the auto follow pattern.
-     *     master_timeout: time, // Explicit operation timeout for connection to master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) The specification of the auto follow pattern
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function putAutoFollowPattern(array $params = [])
-    {
-        $this->checkRequiredParameters(['name', 'body'], $params);
-        $url = '/_ccr/auto_follow/' . $this->encode($params['name']);
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['name'], $request, 'ccr.put_auto_follow_pattern');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Resumes an auto-follow pattern that has been paused
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-resume-auto-follow-pattern.html
-     *
-     * @param array{
-     *     name: string, // (REQUIRED) The name of the auto follow pattern to resume discovering new indices to follow.
-     *     master_timeout: time, // Explicit operation timeout for connection to master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function resumeAutoFollowPattern(array $params = [])
-    {
-        $this->checkRequiredParameters(['name'], $params);
-        $url = '/_ccr/auto_follow/' . $this->encode($params['name']) . '/resume';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['name'], $request, 'ccr.resume_auto_follow_pattern');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Resumes a follower index that has been paused
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-post-resume-follow.html
-     *
-     * @param array{
-     *     index: string, // (REQUIRED) The name of the follow index to resume following.
-     *     master_timeout: time, // Explicit operation timeout for connection to master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, //  The name of the leader index and other optional ccr related parameters
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function resumeFollow(array $params = [])
-    {
-        $this->checkRequiredParameters(['index'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/resume_follow';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.resume_follow');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Gets all stats related to cross-cluster replication.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-get-stats.html
-     *
-     * @param array{
-     *     timeout: time, // Explicit operation timeout
-     *     master_timeout: time, // Explicit operation timeout for connection to master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function stats(array $params = [])
-    {
-        $url = '/_ccr/stats';
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['timeout', 'master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'ccr.stats');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Stops the following task associated with a follower index and removes index metadata and settings associated with cross-cluster replication.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-post-unfollow.html
-     *
-     * @param array{
-     *     index: string, // (REQUIRED) The name of the follower index that should be turned into a regular index.
-     *     master_timeout: time, // Explicit operation timeout for connection to master node
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function unfollow(array $params = [])
-    {
-        $this->checkRequiredParameters(['index'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/unfollow';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.unfollow');
-        return $this->client->sendRequest($request);
-    }
+	/**
+	 * Deletes auto-follow patterns.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-delete-auto-follow-pattern.html
+	 *
+	 * @param array{
+	 *     name: string, // (REQUIRED) The name of the auto follow pattern.
+	 *     master_timeout: time, // Explicit operation timeout for connection to master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function deleteAutoFollowPattern(array $params = [])
+	{
+		$this->checkRequiredParameters(['name'], $params);
+		$url = '/_ccr/auto_follow/' . $this->encode($params['name']);
+		$method = 'DELETE';
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['name'], $request, 'ccr.delete_auto_follow_pattern');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Creates a new follower index configured to follow the referenced leader index.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-put-follow.html
+	 *
+	 * @param array{
+	 *     index: string, // (REQUIRED) The name of the follower index
+	 *     wait_for_active_shards: string, // Sets the number of shard copies that must be active before returning. Defaults to 0. Set to `all` for all shard copies, otherwise set to any non-negative value less than or equal to the total number of copies for the shard (number of replicas + 1)
+	 *     master_timeout: time, // Explicit operation timeout for connection to master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) The name of the leader index and other optional ccr related parameters
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function follow(array $params = [])
+	{
+		$this->checkRequiredParameters(['index', 'body'], $params);
+		$url = '/' . $this->encode($params['index']) . '/_ccr/follow';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['wait_for_active_shards', 'master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.follow');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Retrieves information about all follower indices, including parameters and status for each follower index
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-get-follow-info.html
+	 *
+	 * @param array{
+	 *     index: list, // (REQUIRED) A comma-separated list of index patterns; use `_all` to perform the operation on all indices
+	 *     master_timeout: time, // Explicit operation timeout for connection to master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function followInfo(array $params = [])
+	{
+		$this->checkRequiredParameters(['index'], $params);
+		$url = '/' . $this->encode($params['index']) . '/_ccr/info';
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.follow_info');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Retrieves follower stats. return shard-level stats about the following tasks associated with each shard for the specified indices.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-get-follow-stats.html
+	 *
+	 * @param array{
+	 *     index: list, // (REQUIRED) A comma-separated list of index patterns; use `_all` to perform the operation on all indices
+	 *     timeout: time, // Explicit operation timeout
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function followStats(array $params = [])
+	{
+		$this->checkRequiredParameters(['index'], $params);
+		$url = '/' . $this->encode($params['index']) . '/_ccr/stats';
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.follow_stats');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Removes the follower retention leases from the leader.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-post-forget-follower.html
+	 *
+	 * @param array{
+	 *     index: string, // (REQUIRED) the name of the leader index for which specified follower retention leases should be removed
+	 *     timeout: time, // Explicit operation timeout
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) the name and UUID of the follower index, the name of the cluster containing the follower index, and the alias from the perspective of that cluster for the remote cluster containing the leader index
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function forgetFollower(array $params = [])
+	{
+		$this->checkRequiredParameters(['index', 'body'], $params);
+		$url = '/' . $this->encode($params['index']) . '/_ccr/forget_follower';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.forget_follower');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Gets configured auto-follow patterns. Returns the specified auto-follow pattern collection.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-get-auto-follow-pattern.html
+	 *
+	 * @param array{
+	 *     name: string, //  The name of the auto follow pattern.
+	 *     master_timeout: time, // Explicit operation timeout for connection to master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function getAutoFollowPattern(array $params = [])
+	{
+		if (isset($params['name'])) {
+			$url = '/_ccr/auto_follow/' . $this->encode($params['name']);
+			$method = 'GET';
+		} else {
+			$url = '/_ccr/auto_follow';
+			$method = 'GET';
+		}
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['name'], $request, 'ccr.get_auto_follow_pattern');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Pauses an auto-follow pattern
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-pause-auto-follow-pattern.html
+	 *
+	 * @param array{
+	 *     name: string, // (REQUIRED) The name of the auto follow pattern that should pause discovering new indices to follow.
+	 *     master_timeout: time, // Explicit operation timeout for connection to master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function pauseAutoFollowPattern(array $params = [])
+	{
+		$this->checkRequiredParameters(['name'], $params);
+		$url = '/_ccr/auto_follow/' . $this->encode($params['name']) . '/pause';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['name'], $request, 'ccr.pause_auto_follow_pattern');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Pauses a follower index. The follower index will not fetch any additional operations from the leader index.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-post-pause-follow.html
+	 *
+	 * @param array{
+	 *     index: string, // (REQUIRED) The name of the follower index that should pause following its leader index.
+	 *     master_timeout: time, // Explicit operation timeout for connection to master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function pauseFollow(array $params = [])
+	{
+		$this->checkRequiredParameters(['index'], $params);
+		$url = '/' . $this->encode($params['index']) . '/_ccr/pause_follow';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.pause_follow');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Creates a new named collection of auto-follow patterns against a specified remote cluster. Newly created indices on the remote cluster matching any of the specified patterns will be automatically configured as follower indices.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-put-auto-follow-pattern.html
+	 *
+	 * @param array{
+	 *     name: string, // (REQUIRED) The name of the auto follow pattern.
+	 *     master_timeout: time, // Explicit operation timeout for connection to master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) The specification of the auto follow pattern
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function putAutoFollowPattern(array $params = [])
+	{
+		$this->checkRequiredParameters(['name', 'body'], $params);
+		$url = '/_ccr/auto_follow/' . $this->encode($params['name']);
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['name'], $request, 'ccr.put_auto_follow_pattern');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Resumes an auto-follow pattern that has been paused
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-resume-auto-follow-pattern.html
+	 *
+	 * @param array{
+	 *     name: string, // (REQUIRED) The name of the auto follow pattern to resume discovering new indices to follow.
+	 *     master_timeout: time, // Explicit operation timeout for connection to master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function resumeAutoFollowPattern(array $params = [])
+	{
+		$this->checkRequiredParameters(['name'], $params);
+		$url = '/_ccr/auto_follow/' . $this->encode($params['name']) . '/resume';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['name'], $request, 'ccr.resume_auto_follow_pattern');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Resumes a follower index that has been paused
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-post-resume-follow.html
+	 *
+	 * @param array{
+	 *     index: string, // (REQUIRED) The name of the follow index to resume following.
+	 *     master_timeout: time, // Explicit operation timeout for connection to master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, //  The name of the leader index and other optional ccr related parameters
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function resumeFollow(array $params = [])
+	{
+		$this->checkRequiredParameters(['index'], $params);
+		$url = '/' . $this->encode($params['index']) . '/_ccr/resume_follow';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.resume_follow');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Gets all stats related to cross-cluster replication.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-get-stats.html
+	 *
+	 * @param array{
+	 *     timeout: time, // Explicit operation timeout
+	 *     master_timeout: time, // Explicit operation timeout for connection to master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function stats(array $params = [])
+	{
+		$url = '/_ccr/stats';
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['timeout', 'master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'ccr.stats');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Stops the following task associated with a follower index and removes index metadata and settings associated with cross-cluster replication.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-post-unfollow.html
+	 *
+	 * @param array{
+	 *     index: string, // (REQUIRED) The name of the follower index that should be turned into a regular index.
+	 *     master_timeout: time, // Explicit operation timeout for connection to master node
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function unfollow(array $params = [])
+	{
+		$this->checkRequiredParameters(['index'], $params);
+		$url = '/' . $this->encode($params['index']) . '/_ccr/unfollow';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['index'], $request, 'ccr.unfollow');
+		return $this->client->sendRequest($request);
+	}
 }

Spacing +13 added lines, -13 removed lines

@@ -11,7 +11,7 @@ 
  * Elasticsearch B.V licenses this file to you under the MIT License.
  * See the LICENSE file in the project root for more information.
  */
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Endpoints;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Exception\ClientResponseException;
@@ -50,7 +50,7 @@ 
     public function deleteAutoFollowPattern(array $params = [])
     {
         $this->checkRequiredParameters(['name'], $params);
-        $url = '/_ccr/auto_follow/' . $this->encode($params['name']);
+        $url = '/_ccr/auto_follow/'.$this->encode($params['name']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -85,7 +85,7 @@ 
     public function follow(array $params = [])
     {
         $this->checkRequiredParameters(['index', 'body'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/follow';
+        $url = '/'.$this->encode($params['index']).'/_ccr/follow';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['wait_for_active_shards', 'master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -118,7 +118,7 @@ 
     public function followInfo(array $params = [])
     {
         $this->checkRequiredParameters(['index'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/info';
+        $url = '/'.$this->encode($params['index']).'/_ccr/info';
         $method = 'GET';
         $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -151,7 +151,7 @@ 
     public function followStats(array $params = [])
     {
         $this->checkRequiredParameters(['index'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/stats';
+        $url = '/'.$this->encode($params['index']).'/_ccr/stats';
         $method = 'GET';
         $url = $this->addQueryString($url, $params, ['timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -185,7 +185,7 @@ 
     public function forgetFollower(array $params = [])
     {
         $this->checkRequiredParameters(['index', 'body'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/forget_follower';
+        $url = '/'.$this->encode($params['index']).'/_ccr/forget_follower';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -217,7 +217,7 @@ 
     public function getAutoFollowPattern(array $params = [])
     {
         if (isset($params['name'])) {
-            $url = '/_ccr/auto_follow/' . $this->encode($params['name']);
+            $url = '/_ccr/auto_follow/'.$this->encode($params['name']);
             $method = 'GET';
         } else {
             $url = '/_ccr/auto_follow';
@@ -254,7 +254,7 @@ 
     public function pauseAutoFollowPattern(array $params = [])
     {
         $this->checkRequiredParameters(['name'], $params);
-        $url = '/_ccr/auto_follow/' . $this->encode($params['name']) . '/pause';
+        $url = '/_ccr/auto_follow/'.$this->encode($params['name']).'/pause';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -287,7 +287,7 @@ 
     public function pauseFollow(array $params = [])
     {
         $this->checkRequiredParameters(['index'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/pause_follow';
+        $url = '/'.$this->encode($params['index']).'/_ccr/pause_follow';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -321,7 +321,7 @@ 
     public function putAutoFollowPattern(array $params = [])
     {
         $this->checkRequiredParameters(['name', 'body'], $params);
-        $url = '/_ccr/auto_follow/' . $this->encode($params['name']);
+        $url = '/_ccr/auto_follow/'.$this->encode($params['name']);
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -354,7 +354,7 @@ 
     public function resumeAutoFollowPattern(array $params = [])
     {
         $this->checkRequiredParameters(['name'], $params);
-        $url = '/_ccr/auto_follow/' . $this->encode($params['name']) . '/resume';
+        $url = '/_ccr/auto_follow/'.$this->encode($params['name']).'/resume';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -388,7 +388,7 @@ 
     public function resumeFollow(array $params = [])
     {
         $this->checkRequiredParameters(['index'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/resume_follow';
+        $url = '/'.$this->encode($params['index']).'/_ccr/resume_follow';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -452,7 +452,7 @@ 
     public function unfollow(array $params = [])
     {
         $this->checkRequiredParameters(['index'], $params);
-        $url = '/' . $this->encode($params['index']) . '/_ccr/unfollow';
+        $url = '/'.$this->encode($params['index']).'/_ccr/unfollow';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];

lib/Vendor/Elastic/Elasticsearch/Endpoints/Connector.php

Indentation +1014 added lines, -1014 removed lines

@@ -25,1018 +25,1018 @@
  */
 class Connector extends AbstractEndpoint
 {
-    /**
-     * Updates the last_seen timestamp in the connector document.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/check-in-connector-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function checkIn(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_check_in';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.check_in');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Deletes a connector.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/delete-connector-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be deleted.
-     *     delete_sync_jobs: boolean, // Determines whether associated sync jobs are also deleted.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function delete(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']);
-        $method = 'DELETE';
-        $url = $this->addQueryString($url, $params, ['delete_sync_jobs', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.delete');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Returns the details about a connector.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/get-connector-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be returned.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function get(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']);
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.get');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the stats of last sync in the connector document.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-last-sync-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) Object with stats related to the last connector sync run.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function lastSync(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_last_sync';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.last_sync');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Lists all connectors.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/list-connector-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     from: int, // Starting offset (default: 0)
-     *     size: int, // Specifies a max number of results to get (default: 100)
-     *     index_name: list, // A comma-separated list of connector index names to fetch connector documents for
-     *     connector_name: list, // A comma-separated list of connector names to fetch connector documents for
-     *     service_type: list, // A comma-separated list of connector service types to fetch connector documents for
-     *     query: string, // A search string for querying connectors, filtering results by matching against connector names, descriptions, and index names
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function list(array $params = [])
-    {
-        $url = '/_connector';
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['from', 'size', 'index_name', 'connector_name', 'service_type', 'query', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'connector.list');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Creates a connector.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/create-connector-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, //  The connector configuration.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function post(array $params = [])
-    {
-        $url = '/_connector';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'connector.post');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Creates or updates a connector.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/create-connector-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, //  The unique identifier of the connector to be created or updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, //  The connector configuration.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function put(array $params = [])
-    {
-        if (isset($params['connector_id'])) {
-            $url = '/_connector/' . $this->encode($params['connector_id']);
-            $method = 'PUT';
-        } else {
-            $url = '/_connector';
-            $method = 'PUT';
-        }
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.put');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Cancels a connector sync job.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/cancel-connector-sync-job-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to be canceled
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function syncJobCancel(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_sync_job_id'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_cancel';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_cancel');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Checks in a connector sync job (refreshes 'last_seen').
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/check-in-connector-sync-job-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to be checked in
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function syncJobCheckIn(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_sync_job_id'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_check_in';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_check_in');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Claims a connector sync job.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/claim-connector-sync-job-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to be claimed.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) Data to claim a sync job.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function syncJobClaim(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_sync_job_id', 'body'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_claim';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_claim');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Deletes a connector sync job.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/delete-connector-sync-job-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to be deleted.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function syncJobDelete(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_sync_job_id'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']);
-        $method = 'DELETE';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_delete');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Sets an error for a connector sync job.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/set-connector-sync-job-error-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to set an error for.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) The error to set in the connector sync job.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function syncJobError(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_sync_job_id', 'body'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_error';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_error');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Returns the details about a connector sync job.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/get-connector-sync-job-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to be returned.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function syncJobGet(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_sync_job_id'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']);
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_get');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Lists all connector sync jobs.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/list-connector-sync-jobs-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     from: int, // Starting offset (default: 0)
-     *     size: int, // specifies a max number of results to get (default: 100)
-     *     status: string, // Sync job status, which sync jobs are fetched for
-     *     connector_id: string, // Id of the connector to fetch the sync jobs for
-     *     job_type: list, // A comma-separated list of job types
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function syncJobList(array $params = [])
-    {
-        $url = '/_connector/_sync_job';
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['from', 'size', 'status', 'connector_id', 'job_type', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'connector.sync_job_list');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Creates a connector sync job.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/create-connector-sync-job-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) The connector sync job data.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function syncJobPost(array $params = [])
-    {
-        $this->checkRequiredParameters(['body'], $params);
-        $url = '/_connector/_sync_job';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'connector.sync_job_post');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the stats fields in the connector sync job document.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/set-connector-sync-job-stats-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) The stats to update for the connector sync job.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function syncJobUpdateStats(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_sync_job_id', 'body'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_stats';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_update_stats');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Activates the draft filtering rules if they are in a validated state.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-filtering-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updateActiveFiltering(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_filtering/_activate';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_active_filtering');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the API key id and/or API key secret id fields in the connector document.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-api-key-id-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) An object containing the connector's API key id and/or Connector Secret document id for that API key.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updateApiKeyId(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_api_key_id';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_api_key_id');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the connector configuration.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-configuration-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) Mapping between field names to configuration.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updateConfiguration(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_configuration';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_configuration');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the error field in the connector document.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-error-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) An object containing the connector's error.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updateError(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_error';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_error');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the connector features in the connector document.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-features-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) An object containing the connector's features definition.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updateFeatures(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_features';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_features');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the filtering field in the connector document.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-filtering-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) A list of connector filtering configurations.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updateFiltering(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_filtering';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_filtering');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the validation info of the draft filtering rules.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-filtering-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) Validation info for the draft filtering rules
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updateFilteringValidation(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_filtering/_validation';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_filtering_validation');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the index name of the connector.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-index-name-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) An object containing the connector's index name.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updateIndexName(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_index_name';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_index_name');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the name and/or description fields in the connector document.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-name-description-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) An object containing the connector's name and/or description.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updateName(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_name';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_name');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the is_native flag of the connector.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/connector-apis.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) An object containing the connector's is_native flag
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updateNative(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_native';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_native');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the pipeline field in the connector document.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-pipeline-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) An object with connector ingest pipeline configuration.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updatePipeline(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_pipeline';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_pipeline');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the scheduling field in the connector document.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-scheduling-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) An object containing the connector's scheduling configuration.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updateScheduling(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_scheduling';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_scheduling');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the service type of the connector.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-service-type-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) An object containing the connector's service type.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updateServiceType(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_service_type';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_service_type');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Updates the status of the connector.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-status-api.html
-     * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
-     *
-     * @param array{
-     *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) An object containing the connector's status.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function updateStatus(array $params = [])
-    {
-        $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_status';
-        $method = 'PUT';
-        $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_status');
-        return $this->client->sendRequest($request);
-    }
+	/**
+	 * Updates the last_seen timestamp in the connector document.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/check-in-connector-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function checkIn(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_check_in';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.check_in');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Deletes a connector.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/delete-connector-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be deleted.
+	 *     delete_sync_jobs: boolean, // Determines whether associated sync jobs are also deleted.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function delete(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']);
+		$method = 'DELETE';
+		$url = $this->addQueryString($url, $params, ['delete_sync_jobs', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.delete');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Returns the details about a connector.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/get-connector-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be returned.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function get(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']);
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.get');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the stats of last sync in the connector document.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-last-sync-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) Object with stats related to the last connector sync run.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function lastSync(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_last_sync';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.last_sync');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Lists all connectors.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/list-connector-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     from: int, // Starting offset (default: 0)
+	 *     size: int, // Specifies a max number of results to get (default: 100)
+	 *     index_name: list, // A comma-separated list of connector index names to fetch connector documents for
+	 *     connector_name: list, // A comma-separated list of connector names to fetch connector documents for
+	 *     service_type: list, // A comma-separated list of connector service types to fetch connector documents for
+	 *     query: string, // A search string for querying connectors, filtering results by matching against connector names, descriptions, and index names
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function list(array $params = [])
+	{
+		$url = '/_connector';
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['from', 'size', 'index_name', 'connector_name', 'service_type', 'query', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'connector.list');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Creates a connector.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/create-connector-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, //  The connector configuration.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function post(array $params = [])
+	{
+		$url = '/_connector';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'connector.post');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Creates or updates a connector.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/create-connector-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, //  The unique identifier of the connector to be created or updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, //  The connector configuration.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function put(array $params = [])
+	{
+		if (isset($params['connector_id'])) {
+			$url = '/_connector/' . $this->encode($params['connector_id']);
+			$method = 'PUT';
+		} else {
+			$url = '/_connector';
+			$method = 'PUT';
+		}
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.put');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Cancels a connector sync job.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/cancel-connector-sync-job-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to be canceled
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function syncJobCancel(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_sync_job_id'], $params);
+		$url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_cancel';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_cancel');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Checks in a connector sync job (refreshes 'last_seen').
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/check-in-connector-sync-job-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to be checked in
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function syncJobCheckIn(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_sync_job_id'], $params);
+		$url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_check_in';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_check_in');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Claims a connector sync job.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/claim-connector-sync-job-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to be claimed.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) Data to claim a sync job.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function syncJobClaim(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_sync_job_id', 'body'], $params);
+		$url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_claim';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_claim');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Deletes a connector sync job.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/delete-connector-sync-job-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to be deleted.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function syncJobDelete(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_sync_job_id'], $params);
+		$url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']);
+		$method = 'DELETE';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_delete');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Sets an error for a connector sync job.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/set-connector-sync-job-error-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to set an error for.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) The error to set in the connector sync job.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function syncJobError(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_sync_job_id', 'body'], $params);
+		$url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_error';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_error');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Returns the details about a connector sync job.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/get-connector-sync-job-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to be returned.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function syncJobGet(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_sync_job_id'], $params);
+		$url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']);
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_get');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Lists all connector sync jobs.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/list-connector-sync-jobs-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     from: int, // Starting offset (default: 0)
+	 *     size: int, // specifies a max number of results to get (default: 100)
+	 *     status: string, // Sync job status, which sync jobs are fetched for
+	 *     connector_id: string, // Id of the connector to fetch the sync jobs for
+	 *     job_type: list, // A comma-separated list of job types
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function syncJobList(array $params = [])
+	{
+		$url = '/_connector/_sync_job';
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['from', 'size', 'status', 'connector_id', 'job_type', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'connector.sync_job_list');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Creates a connector sync job.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/create-connector-sync-job-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) The connector sync job data.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function syncJobPost(array $params = [])
+	{
+		$this->checkRequiredParameters(['body'], $params);
+		$url = '/_connector/_sync_job';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'connector.sync_job_post');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the stats fields in the connector sync job document.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/set-connector-sync-job-stats-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_sync_job_id: string, // (REQUIRED) The unique identifier of the connector sync job to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) The stats to update for the connector sync job.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function syncJobUpdateStats(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_sync_job_id', 'body'], $params);
+		$url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_stats';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_sync_job_id'], $request, 'connector.sync_job_update_stats');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Activates the draft filtering rules if they are in a validated state.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-filtering-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updateActiveFiltering(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_filtering/_activate';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_active_filtering');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the API key id and/or API key secret id fields in the connector document.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-api-key-id-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) An object containing the connector's API key id and/or Connector Secret document id for that API key.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updateApiKeyId(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_api_key_id';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_api_key_id');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the connector configuration.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-configuration-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) Mapping between field names to configuration.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updateConfiguration(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_configuration';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_configuration');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the error field in the connector document.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-error-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) An object containing the connector's error.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updateError(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_error';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_error');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the connector features in the connector document.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-features-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) An object containing the connector's features definition.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updateFeatures(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_features';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_features');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the filtering field in the connector document.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-filtering-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) A list of connector filtering configurations.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updateFiltering(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_filtering';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_filtering');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the validation info of the draft filtering rules.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-filtering-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) Validation info for the draft filtering rules
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updateFilteringValidation(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_filtering/_validation';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_filtering_validation');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the index name of the connector.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-index-name-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) An object containing the connector's index name.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updateIndexName(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_index_name';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_index_name');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the name and/or description fields in the connector document.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-name-description-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) An object containing the connector's name and/or description.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updateName(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_name';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_name');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the is_native flag of the connector.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/connector-apis.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) An object containing the connector's is_native flag
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updateNative(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_native';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_native');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the pipeline field in the connector document.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-pipeline-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) An object with connector ingest pipeline configuration.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updatePipeline(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_pipeline';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_pipeline');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the scheduling field in the connector document.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-scheduling-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) An object containing the connector's scheduling configuration.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updateScheduling(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_scheduling';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_scheduling');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the service type of the connector.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-service-type-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) An object containing the connector's service type.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updateServiceType(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_service_type';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_service_type');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Updates the status of the connector.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/update-connector-status-api.html
+	 * @internal This API is EXPERIMENTAL and may be changed or removed completely in a future release
+	 *
+	 * @param array{
+	 *     connector_id: string, // (REQUIRED) The unique identifier of the connector to be updated.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) An object containing the connector's status.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function updateStatus(array $params = [])
+	{
+		$this->checkRequiredParameters(['connector_id', 'body'], $params);
+		$url = '/_connector/' . $this->encode($params['connector_id']) . '/_status';
+		$method = 'PUT';
+		$url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['connector_id'], $request, 'connector.update_status');
+		return $this->client->sendRequest($request);
+	}
 }

Spacing +27 added lines, -27 removed lines

@@ -11,7 +11,7 @@ 
  * Elasticsearch B.V licenses this file to you under the MIT License.
  * See the LICENSE file in the project root for more information.
  */
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Endpoints;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Exception\ClientResponseException;
@@ -50,7 +50,7 @@ 
     public function checkIn(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_check_in';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_check_in';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -84,7 +84,7 @@ 
     public function delete(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']);
+        $url = '/_connector/'.$this->encode($params['connector_id']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['delete_sync_jobs', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -117,7 +117,7 @@ 
     public function get(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']);
+        $url = '/_connector/'.$this->encode($params['connector_id']);
         $method = 'GET';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -151,7 +151,7 @@ 
     public function lastSync(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_last_sync';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_last_sync';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -251,7 +251,7 @@ 
     public function put(array $params = [])
     {
         if (isset($params['connector_id'])) {
-            $url = '/_connector/' . $this->encode($params['connector_id']);
+            $url = '/_connector/'.$this->encode($params['connector_id']);
             $method = 'PUT';
         } else {
             $url = '/_connector';
@@ -288,7 +288,7 @@ 
     public function syncJobCancel(array $params = [])
     {
         $this->checkRequiredParameters(['connector_sync_job_id'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_cancel';
+        $url = '/_connector/_sync_job/'.$this->encode($params['connector_sync_job_id']).'/_cancel';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -321,7 +321,7 @@ 
     public function syncJobCheckIn(array $params = [])
     {
         $this->checkRequiredParameters(['connector_sync_job_id'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_check_in';
+        $url = '/_connector/_sync_job/'.$this->encode($params['connector_sync_job_id']).'/_check_in';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -355,7 +355,7 @@ 
     public function syncJobClaim(array $params = [])
     {
         $this->checkRequiredParameters(['connector_sync_job_id', 'body'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_claim';
+        $url = '/_connector/_sync_job/'.$this->encode($params['connector_sync_job_id']).'/_claim';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -388,7 +388,7 @@ 
     public function syncJobDelete(array $params = [])
     {
         $this->checkRequiredParameters(['connector_sync_job_id'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']);
+        $url = '/_connector/_sync_job/'.$this->encode($params['connector_sync_job_id']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -422,7 +422,7 @@ 
     public function syncJobError(array $params = [])
     {
         $this->checkRequiredParameters(['connector_sync_job_id', 'body'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_error';
+        $url = '/_connector/_sync_job/'.$this->encode($params['connector_sync_job_id']).'/_error';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -455,7 +455,7 @@ 
     public function syncJobGet(array $params = [])
     {
         $this->checkRequiredParameters(['connector_sync_job_id'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']);
+        $url = '/_connector/_sync_job/'.$this->encode($params['connector_sync_job_id']);
         $method = 'GET';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -556,7 +556,7 @@ 
     public function syncJobUpdateStats(array $params = [])
     {
         $this->checkRequiredParameters(['connector_sync_job_id', 'body'], $params);
-        $url = '/_connector/_sync_job/' . $this->encode($params['connector_sync_job_id']) . '/_stats';
+        $url = '/_connector/_sync_job/'.$this->encode($params['connector_sync_job_id']).'/_stats';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -589,7 +589,7 @@ 
     public function updateActiveFiltering(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_filtering/_activate';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_filtering/_activate';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -623,7 +623,7 @@ 
     public function updateApiKeyId(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_api_key_id';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_api_key_id';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -657,7 +657,7 @@ 
     public function updateConfiguration(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_configuration';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_configuration';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -691,7 +691,7 @@ 
     public function updateError(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_error';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_error';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -725,7 +725,7 @@ 
     public function updateFeatures(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_features';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_features';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -759,7 +759,7 @@ 
     public function updateFiltering(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_filtering';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_filtering';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -793,7 +793,7 @@ 
     public function updateFilteringValidation(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_filtering/_validation';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_filtering/_validation';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -827,7 +827,7 @@ 
     public function updateIndexName(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_index_name';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_index_name';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -861,7 +861,7 @@ 
     public function updateName(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_name';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_name';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -895,7 +895,7 @@ 
     public function updateNative(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_native';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_native';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -929,7 +929,7 @@ 
     public function updatePipeline(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_pipeline';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_pipeline';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -963,7 +963,7 @@ 
     public function updateScheduling(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_scheduling';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_scheduling';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -997,7 +997,7 @@ 
     public function updateServiceType(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_service_type';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_service_type';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1031,7 +1031,7 @@ 
     public function updateStatus(array $params = [])
     {
         $this->checkRequiredParameters(['connector_id', 'body'], $params);
-        $url = '/_connector/' . $this->encode($params['connector_id']) . '/_status';
+        $url = '/_connector/'.$this->encode($params['connector_id']).'/_status';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];

lib/Vendor/Elastic/Elasticsearch/Endpoints/Esql.php

Indentation +103 added lines, -103 removed lines

@@ -25,107 +25,107 @@
  */
 class Esql extends AbstractEndpoint
 {
-    /**
-     * Executes an ESQL request asynchronously
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/esql-async-query-api.html
-     *
-     * @param array{
-     *     format: string, // a short version of the Accept header, e.g. json, yaml
-     *     delimiter: string, // The character to use between values within a CSV row. Only valid for the csv format.
-     *     drop_null_columns: boolean, // Should entirely null columns be removed from the results? Their name and type will be returning in a new `all_columns` section.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) Use the `query` element to start a query. Use `columnar` to format the answer.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function asyncQuery(array $params = [])
-    {
-        $this->checkRequiredParameters(['body'], $params);
-        $url = '/_query/async';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['format', 'delimiter', 'drop_null_columns', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'esql.async_query');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Retrieves the results of a previously submitted async query request given its ID.
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/esql-async-query-get-api.html
-     *
-     * @param array{
-     *     id: string, // (REQUIRED) The async query ID
-     *     wait_for_completion_timeout: time, // Specify the time that the request should block waiting for the final response
-     *     keep_alive: time, // Specify the time interval in which the results (partial or final) for this search will be available
-     *     drop_null_columns: boolean, // Should entirely null columns be removed from the results? Their name and type will be returning in a new `all_columns` section.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     * } $params
-     *
-     * @throws MissingParameterException if a required parameter is missing
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function asyncQueryGet(array $params = [])
-    {
-        $this->checkRequiredParameters(['id'], $params);
-        $url = '/_query/async/' . $this->encode($params['id']);
-        $method = 'GET';
-        $url = $this->addQueryString($url, $params, ['wait_for_completion_timeout', 'keep_alive', 'drop_null_columns', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, ['id'], $request, 'esql.async_query_get');
-        return $this->client->sendRequest($request);
-    }
-    /**
-     * Executes an ESQL request
-     *
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/esql-query-api.html
-     *
-     * @param array{
-     *     format: string, // a short version of the Accept header, e.g. json, yaml
-     *     delimiter: string, // The character to use between values within a CSV row. Only valid for the csv format.
-     *     drop_null_columns: boolean, // Should entirely null columns be removed from the results? Their name and type will be returning in a new `all_columns` section.
-     *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
-     *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
-     *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
-     *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
-     *     filter_path: list, // A comma-separated list of filters used to reduce the response.
-     *     body: array, // (REQUIRED) Use the `query` element to start a query. Use `columnar` to format the answer.
-     * } $params
-     *
-     * @throws NoNodeAvailableException if all the hosts are offline
-     * @throws ClientResponseException if the status code of response is 4xx
-     * @throws ServerResponseException if the status code of response is 5xx
-     *
-     * @return Elasticsearch|Promise
-     */
-    public function query(array $params = [])
-    {
-        $this->checkRequiredParameters(['body'], $params);
-        $url = '/_query';
-        $method = 'POST';
-        $url = $this->addQueryString($url, $params, ['format', 'delimiter', 'drop_null_columns', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
-        $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
-        $request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
-        $request = $this->addOtelAttributes($params, [], $request, 'esql.query');
-        return $this->client->sendRequest($request);
-    }
+	/**
+	 * Executes an ESQL request asynchronously
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/esql-async-query-api.html
+	 *
+	 * @param array{
+	 *     format: string, // a short version of the Accept header, e.g. json, yaml
+	 *     delimiter: string, // The character to use between values within a CSV row. Only valid for the csv format.
+	 *     drop_null_columns: boolean, // Should entirely null columns be removed from the results? Their name and type will be returning in a new `all_columns` section.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) Use the `query` element to start a query. Use `columnar` to format the answer.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function asyncQuery(array $params = [])
+	{
+		$this->checkRequiredParameters(['body'], $params);
+		$url = '/_query/async';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['format', 'delimiter', 'drop_null_columns', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'esql.async_query');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Retrieves the results of a previously submitted async query request given its ID.
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/master/esql-async-query-get-api.html
+	 *
+	 * @param array{
+	 *     id: string, // (REQUIRED) The async query ID
+	 *     wait_for_completion_timeout: time, // Specify the time that the request should block waiting for the final response
+	 *     keep_alive: time, // Specify the time interval in which the results (partial or final) for this search will be available
+	 *     drop_null_columns: boolean, // Should entirely null columns be removed from the results? Their name and type will be returning in a new `all_columns` section.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 * } $params
+	 *
+	 * @throws MissingParameterException if a required parameter is missing
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function asyncQueryGet(array $params = [])
+	{
+		$this->checkRequiredParameters(['id'], $params);
+		$url = '/_query/async/' . $this->encode($params['id']);
+		$method = 'GET';
+		$url = $this->addQueryString($url, $params, ['wait_for_completion_timeout', 'keep_alive', 'drop_null_columns', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, ['id'], $request, 'esql.async_query_get');
+		return $this->client->sendRequest($request);
+	}
+	/**
+	 * Executes an ESQL request
+	 *
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/esql-query-api.html
+	 *
+	 * @param array{
+	 *     format: string, // a short version of the Accept header, e.g. json, yaml
+	 *     delimiter: string, // The character to use between values within a CSV row. Only valid for the csv format.
+	 *     drop_null_columns: boolean, // Should entirely null columns be removed from the results? Their name and type will be returning in a new `all_columns` section.
+	 *     pretty: boolean, // Pretty format the returned JSON response. (DEFAULT: false)
+	 *     human: boolean, // Return human readable values for statistics. (DEFAULT: true)
+	 *     error_trace: boolean, // Include the stack trace of returned errors. (DEFAULT: false)
+	 *     source: string, // The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
+	 *     filter_path: list, // A comma-separated list of filters used to reduce the response.
+	 *     body: array, // (REQUIRED) Use the `query` element to start a query. Use `columnar` to format the answer.
+	 * } $params
+	 *
+	 * @throws NoNodeAvailableException if all the hosts are offline
+	 * @throws ClientResponseException if the status code of response is 4xx
+	 * @throws ServerResponseException if the status code of response is 5xx
+	 *
+	 * @return Elasticsearch|Promise
+	 */
+	public function query(array $params = [])
+	{
+		$this->checkRequiredParameters(['body'], $params);
+		$url = '/_query';
+		$method = 'POST';
+		$url = $this->addQueryString($url, $params, ['format', 'delimiter', 'drop_null_columns', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
+		$headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
+		$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
+		$request = $this->addOtelAttributes($params, [], $request, 'esql.query');
+		return $this->client->sendRequest($request);
+	}
 }