From 17ceee20f5a718ffcbf618a54334d42d866a88e6 Mon Sep 17 00:00:00 2001
From: Elastic Machine
Date: Mon, 12 May 2025 06:03:10 +0000
Subject: [PATCH] Auto-generated API code
---
elasticsearch/_async/client/__init__.py | 86 +++---
elasticsearch/_async/client/async_search.py | 8 +-
elasticsearch/_async/client/autoscaling.py | 8 +-
elasticsearch/_async/client/cat.py | 260 +++++++++++++++---
elasticsearch/_async/client/ccr.py | 26 +-
elasticsearch/_async/client/cluster.py | 28 +-
elasticsearch/_async/client/connector.py | 60 ++--
.../_async/client/dangling_indices.py | 6 +-
elasticsearch/_async/client/enrich.py | 10 +-
elasticsearch/_async/client/eql.py | 6 +-
elasticsearch/_async/client/esql.py | 18 +-
elasticsearch/_async/client/features.py | 4 +-
elasticsearch/_async/client/fleet.py | 6 +-
elasticsearch/_async/client/graph.py | 2 +-
elasticsearch/_async/client/ilm.py | 22 +-
elasticsearch/_async/client/indices.py | 110 ++++----
elasticsearch/_async/client/inference.py | 122 ++------
elasticsearch/_async/client/ingest.py | 18 +-
elasticsearch/_async/client/license.py | 12 +-
elasticsearch/_async/client/logstash.py | 6 +-
elasticsearch/_async/client/migration.py | 6 +-
elasticsearch/_async/client/ml.py | 140 +++++-----
elasticsearch/_async/client/nodes.py | 14 +-
elasticsearch/_async/client/query_rules.py | 16 +-
elasticsearch/_async/client/rollup.py | 16 +-
.../_async/client/search_application.py | 20 +-
.../_async/client/searchable_snapshots.py | 8 +-
elasticsearch/_async/client/security.py | 128 ++++-----
elasticsearch/_async/client/shutdown.py | 6 +-
elasticsearch/_async/client/simulate.py | 2 +-
elasticsearch/_async/client/slm.py | 18 +-
elasticsearch/_async/client/snapshot.py | 26 +-
elasticsearch/_async/client/sql.py | 12 +-
elasticsearch/_async/client/ssl.py | 2 +-
elasticsearch/_async/client/synonyms.py | 14 +-
elasticsearch/_async/client/tasks.py | 6 +-
elasticsearch/_async/client/text_structure.py | 8 +-
elasticsearch/_async/client/transform.py | 18 +-
elasticsearch/_async/client/xpack.py | 2 +-
elasticsearch/_sync/client/__init__.py | 86 +++---
elasticsearch/_sync/client/async_search.py | 8 +-
elasticsearch/_sync/client/autoscaling.py | 8 +-
elasticsearch/_sync/client/cat.py | 260 +++++++++++++++---
elasticsearch/_sync/client/ccr.py | 26 +-
elasticsearch/_sync/client/cluster.py | 28 +-
elasticsearch/_sync/client/connector.py | 60 ++--
.../_sync/client/dangling_indices.py | 6 +-
elasticsearch/_sync/client/enrich.py | 10 +-
elasticsearch/_sync/client/eql.py | 6 +-
elasticsearch/_sync/client/esql.py | 18 +-
elasticsearch/_sync/client/features.py | 4 +-
elasticsearch/_sync/client/fleet.py | 6 +-
elasticsearch/_sync/client/graph.py | 2 +-
elasticsearch/_sync/client/ilm.py | 22 +-
elasticsearch/_sync/client/indices.py | 110 ++++----
elasticsearch/_sync/client/inference.py | 122 ++------
elasticsearch/_sync/client/ingest.py | 18 +-
elasticsearch/_sync/client/license.py | 12 +-
elasticsearch/_sync/client/logstash.py | 6 +-
elasticsearch/_sync/client/migration.py | 6 +-
elasticsearch/_sync/client/ml.py | 140 +++++-----
elasticsearch/_sync/client/nodes.py | 14 +-
elasticsearch/_sync/client/query_rules.py | 16 +-
elasticsearch/_sync/client/rollup.py | 16 +-
.../_sync/client/search_application.py | 20 +-
.../_sync/client/searchable_snapshots.py | 8 +-
elasticsearch/_sync/client/security.py | 128 ++++-----
elasticsearch/_sync/client/shutdown.py | 6 +-
elasticsearch/_sync/client/simulate.py | 2 +-
elasticsearch/_sync/client/slm.py | 18 +-
elasticsearch/_sync/client/snapshot.py | 26 +-
elasticsearch/_sync/client/sql.py | 12 +-
elasticsearch/_sync/client/ssl.py | 2 +-
elasticsearch/_sync/client/synonyms.py | 14 +-
elasticsearch/_sync/client/tasks.py | 6 +-
elasticsearch/_sync/client/text_structure.py | 8 +-
elasticsearch/_sync/client/transform.py | 18 +-
elasticsearch/_sync/client/xpack.py | 2 +-
elasticsearch/dsl/query.py | 44 ++-
elasticsearch/dsl/types.py | 12 +-
80 files changed, 1453 insertions(+), 1163 deletions(-)
diff --git a/elasticsearch/_async/client/__init__.py b/elasticsearch/_async/client/__init__.py
index cf34c6284..cad97a98e 100644
--- a/elasticsearch/_async/client/__init__.py
+++ b/elasticsearch/_async/client/__init__.py
@@ -731,7 +731,7 @@ async def bulk(
The other two shards that make up the index do not participate in the _bulk
request at all.
- ``_
+ ``_
:param operations:
:param index: The name of the data stream, index, or index alias to perform bulk
@@ -856,7 +856,7 @@ async def clear_scroll(
Clear the search context and results for a scrolling search.
- ``_
+ ``_
:param scroll_id: The scroll IDs to clear. To clear all scroll IDs, use `_all`.
"""
@@ -913,7 +913,7 @@ async def close_point_in_time(
However, keeping points in time has a cost; close them as soon as they are no longer required for search requests.
- ``_
+ ``_
:param id: The ID of the point-in-time.
"""
@@ -997,7 +997,7 @@ async def count(
This means that replicas increase the scalability of the count.
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and aliases to
search. It supports wildcards (`*`). To search all data streams and indices,
@@ -1199,7 +1199,7 @@ async def create(
The _shards
section of the API response reveals the number of shard copies on which replication succeeded and failed.
- ``_
+ ``_
:param index: The name of the data stream or index to target. If the target doesn't
exist and matches the name or wildcard (`*`) pattern of an index template
@@ -1366,7 +1366,7 @@ async def delete(
It then gets redirected into the primary shard within that ID group and replicated (if needed) to shard replicas within that ID group.
- ``_
+ ``_
:param index: The name of the target index.
:param id: A unique identifier for the document.
@@ -1555,7 +1555,7 @@ async def delete_by_query(
The get task status API will continue to list the delete by query task until this task checks that it has been cancelled and terminates itself.
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and aliases to
search. It supports wildcards (`*`). To search all data streams or indices,
@@ -1752,7 +1752,7 @@ async def delete_by_query_rethrottle(
Rethrottling that speeds up the query takes effect immediately but rethrotting that slows down the query takes effect after completing the current batch to prevent scroll timeouts.
- ``_
+ ``_
:param task_id: The ID for the task.
:param requests_per_second: The throttle for this request in sub-requests per
@@ -1802,7 +1802,7 @@ async def delete_script(
Deletes a stored script or search template.
- ``_
+ ``_
:param id: The identifier for the stored script or search template.
:param master_timeout: The period to wait for a connection to the master node.
@@ -1886,7 +1886,7 @@ async def exists(
Elasticsearch cleans up deleted documents in the background as you continue to index more data.
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and aliases. It
supports wildcards (`*`).
@@ -2009,7 +2009,7 @@ async def exists_source(
A document's source is not available if it is disabled in the mapping.
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and aliases. It
supports wildcards (`*`).
@@ -2115,7 +2115,7 @@ async def explain(
It computes a score explanation for a query and a specific document.
- ``_
+ ``_
:param index: Index names that are used to limit the request. Only a single index
name can be provided to this parameter.
@@ -2250,7 +2250,7 @@ async def field_caps(
For example, a runtime field with a type of keyword is returned the same as any other field that belongs to the keyword
family.
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and aliases used
to limit the request. Supports wildcards (*). To target all data streams
@@ -2411,7 +2411,7 @@ async def get(
Elasticsearch cleans up deleted documents in the background as you continue to index more data.
- ``_
+ ``_
:param index: The name of the index that contains the document.
:param id: A unique document identifier.
@@ -2518,7 +2518,7 @@ async def get_script(
Retrieves a stored script or search template.
- ``_
+ ``_
:param id: The identifier for the stored script or search template.
:param master_timeout: The period to wait for the master node. If the master
@@ -2567,7 +2567,7 @@ async def get_script_context(
Get a list of supported script contexts and their methods.
- ``_
+ ``_
"""
__path_parts: t.Dict[str, str] = {}
__path = "/_script_context"
@@ -2606,7 +2606,7 @@ async def get_script_languages(
Get a list of available script types, languages, and contexts.
- ``_
+ ``_
"""
__path_parts: t.Dict[str, str] = {}
__path = "/_script_language"
@@ -2671,7 +2671,7 @@ async def get_source(
- ``_
+ ``_
:param index: The name of the index that contains the document.
:param id: A unique document identifier.
@@ -2771,7 +2771,7 @@ async def health_report(
When setting up automated polling of the API for health status, set verbose to false to disable the more expensive analysis logic.
- ``_
+ ``_
:param feature: A feature of the cluster, as returned by the top-level health
report API.
@@ -2936,7 +2936,7 @@ async def index(
- ``_
+ ``_
:param index: The name of the data stream or index to target. If the target doesn't
exist and matches the name or wildcard (`*`) pattern of an index template
@@ -3068,7 +3068,7 @@ async def info(
Get basic build, version, and cluster information.
- ``_
+ ``_
"""
__path_parts: t.Dict[str, str] = {}
__path = "/"
@@ -3142,7 +3142,7 @@ async def knn_search(
- ``_
+ ``_
:param index: A comma-separated list of index names to search; use `_all` or
to perform the operation on all indices.
@@ -3258,7 +3258,7 @@ async def mget(
You can include the stored_fields
query parameter in the request URI to specify the defaults to use when there are no per-document instructions.
- ``_
+ ``_
:param index: Name of the index to retrieve documents from when `ids` are specified,
or when a document in the `docs` array does not specify an index.
@@ -3393,7 +3393,7 @@ async def msearch(
When sending requests to this endpoint the Content-Type
header should be set to application/x-ndjson
.
- ``_
+ ``_
:param searches:
:param index: Comma-separated list of data streams, indices, and index aliases
@@ -3539,7 +3539,7 @@ async def msearch_template(
- ``_
+ ``_
:param search_templates:
:param index: A comma-separated list of data streams, indices, and aliases to
@@ -3644,7 +3644,7 @@ async def mtermvectors(
The mapping used is determined by the specified _index
.
- ``_
+ ``_
:param index: The name of the index that contains the documents.
:param docs: An array of existing or artificial documents.
@@ -3785,7 +3785,7 @@ async def open_point_in_time(
You can check how many point-in-times (that is, search contexts) are open with the nodes stats API.
- ``_
+ ``_
:param index: A comma-separated list of index names to open point in time; use
`_all` or empty string to perform the operation on all indices
@@ -3883,7 +3883,7 @@ async def put_script(
Creates or updates a stored script or search template.
- ``_
+ ``_
:param id: The identifier for the stored script or search template. It must be
unique within the cluster.
@@ -3973,7 +3973,7 @@ async def rank_eval(
Evaluate the quality of ranked search results over a set of typical search queries.
- ``_
+ ``_
:param requests: A set of typical search requests, together with their provided
ratings.
@@ -4205,7 +4205,7 @@ async def reindex(
It is not possible to configure SSL in the body of the reindex request.
- ``_
+ ``_
:param dest: The destination you are copying to.
:param source: The source you are copying from.
@@ -4329,7 +4329,7 @@ async def reindex_rethrottle(
This behavior prevents scroll timeouts.
- ``_
+ ``_
:param task_id: The task identifier, which can be found by using the tasks API.
:param requests_per_second: The throttle for this request in sub-requests per
@@ -4385,7 +4385,7 @@ async def render_search_template(
Render a search template as a search request body.
- ``_
+ ``_
:param id: The ID of the search template to render. If no `source` is specified,
this or the `id` request body parameter is required.
@@ -4479,7 +4479,7 @@ async def scripts_painless_execute(
Each context requires a script, but additional parameters depend on the context you're using for that script.
- ``_
+ ``_
:param context: The context that the script should run in. NOTE: Result ordering
in the field contexts is not guaranteed.
@@ -4552,7 +4552,7 @@ async def scroll(
IMPORTANT: Results from a scrolling search reflect the state of the index at the time of the initial search request. Subsequent indexing or document changes only affect later search and scroll requests.
- ``_
+ ``_
:param scroll_id: The scroll ID of the search.
:param rest_total_hits_as_int: If true, the API response’s hit.total property
@@ -4758,7 +4758,7 @@ async def search(
This situation can occur because the splitting criterion is based on Lucene document IDs, which are not stable across changes to the index.
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and aliases to
search. It supports wildcards (`*`). To search all data streams and indices,
@@ -5509,7 +5509,7 @@ async def search_mvt(
Elasticsearch uses the H3 resolution that is closest to the corresponding geotile density.
- ``_
+ ``_
:param index: Comma-separated list of data streams, indices, or aliases to search
:param field: Field containing geospatial data to return
@@ -5683,7 +5683,7 @@ async def search_shards(
If the Elasticsearch security features are enabled, you must have the view_index_metadata
or manage
index privilege for the target data stream, index, or alias.
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and aliases to
search. It supports wildcards (`*`). To search all data streams and indices,
@@ -5794,7 +5794,7 @@ async def search_template(
Run a search with a search template.
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and aliases to
search. It supports wildcards (`*`).
@@ -5937,7 +5937,7 @@ async def terms_enum(
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and index aliases
to search. Wildcard (`*`) expressions are supported. To search all data streams
@@ -6086,7 +6086,7 @@ async def termvectors(
Use routing
only to hit a particular shard.
- ``_
+ ``_
:param index: The name of the index that contains the document.
:param id: A unique identifier for the document.
@@ -6257,7 +6257,7 @@ async def update(
In addition to _source
, you can access the following variables through the ctx
map: _index
, _type
, _id
, _version
, _routing
, and _now
(the current timestamp).
- ``_
+ ``_
:param index: The name of the target index. By default, the index is created
automatically if it doesn't exist.
@@ -6495,7 +6495,7 @@ async def update_by_query(
This API enables you to only modify the source of matching documents; you cannot move them.
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and aliases to
search. It supports wildcards (`*`). To search all data streams or indices,
@@ -6715,7 +6715,7 @@ async def update_by_query_rethrottle(
Rethrottling that speeds up the query takes effect immediately but rethrotting that slows down the query takes effect after completing the current batch to prevent scroll timeouts.
- ``_
+ ``_
:param task_id: The ID for the task.
:param requests_per_second: The throttle for this request in sub-requests per
diff --git a/elasticsearch/_async/client/async_search.py b/elasticsearch/_async/client/async_search.py
index b480e199b..6849e9b3c 100644
--- a/elasticsearch/_async/client/async_search.py
+++ b/elasticsearch/_async/client/async_search.py
@@ -44,7 +44,7 @@ async def delete(
If the Elasticsearch security features are enabled, the deletion of a specific async search is restricted to: the authenticated user that submitted the original search request; users that have the cancel_task
cluster privilege.
- ``_
+ ``_
:param id: A unique identifier for the async search.
"""
@@ -94,7 +94,7 @@ async def get(
If the Elasticsearch security features are enabled, access to the results of a specific async search is restricted to the user or API key that submitted it.
- ``_
+ ``_
:param id: A unique identifier for the async search.
:param keep_alive: The length of time that the async search should be available
@@ -164,7 +164,7 @@ async def status(
- ``_
+ ``_
:param id: A unique identifier for the async search.
:param keep_alive: The length of time that the async search needs to be available.
@@ -346,7 +346,7 @@ async def submit(
The maximum allowed size for a stored async search response can be set by changing the search.max_async_search_response_size
cluster level setting.
- ``_
+ ``_
:param index: A comma-separated list of index names to search; use `_all` or
empty string to perform the operation on all indices
diff --git a/elasticsearch/_async/client/autoscaling.py b/elasticsearch/_async/client/autoscaling.py
index 9999f82e8..8de430f83 100644
--- a/elasticsearch/_async/client/autoscaling.py
+++ b/elasticsearch/_async/client/autoscaling.py
@@ -44,7 +44,7 @@ async def delete_autoscaling_policy(
NOTE: This feature is designed for indirect use by Elasticsearch Service, Elastic Cloud Enterprise, and Elastic Cloud on Kubernetes. Direct use is not supported.
- ``_
+ ``_
:param name: the name of the autoscaling policy
:param master_timeout: Period to wait for a connection to the master node. If
@@ -104,7 +104,7 @@ async def get_autoscaling_capacity(
Do not use this information to make autoscaling decisions.
- ``_
+ ``_
:param master_timeout: Period to wait for a connection to the master node. If
no response is received before the timeout expires, the request fails and
@@ -151,7 +151,7 @@ async def get_autoscaling_policy(
NOTE: This feature is designed for indirect use by Elasticsearch Service, Elastic Cloud Enterprise, and Elastic Cloud on Kubernetes. Direct use is not supported.
- ``_
+ ``_
:param name: the name of the autoscaling policy
:param master_timeout: Period to wait for a connection to the master node. If
@@ -206,7 +206,7 @@ async def put_autoscaling_policy(
NOTE: This feature is designed for indirect use by Elasticsearch Service, Elastic Cloud Enterprise, and Elastic Cloud on Kubernetes. Direct use is not supported.
- ``_
+ ``_
:param name: the name of the autoscaling policy
:param policy:
diff --git a/elasticsearch/_async/client/cat.py b/elasticsearch/_async/client/cat.py
index 2bd625661..58e274d1c 100644
--- a/elasticsearch/_async/client/cat.py
+++ b/elasticsearch/_async/client/cat.py
@@ -65,7 +65,7 @@ async def aliases(
IMPORTANT: CAT APIs are only intended for human consumption using the command line or the Kibana console. They are not intended for use by applications. For application consumption, use the aliases API.
- ``_
+ ``_
:param name: A comma-separated list of aliases to retrieve. Supports wildcards
(`*`). To retrieve all aliases, omit this parameter or use `*` or `_all`.
@@ -161,7 +161,7 @@ async def allocation(
IMPORTANT: CAT APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications.
- ``_
+ ``_
:param node_id: A comma-separated list of node identifiers or names used to limit
the returned information.
@@ -250,7 +250,7 @@ async def component_templates(
They are not intended for use by applications. For application consumption, use the get component template API.
- ``_
+ ``_
:param name: The name of the component template. It accepts wildcard expressions.
If it is omitted, all component templates are returned.
@@ -334,7 +334,7 @@ async def count(
They are not intended for use by applications. For application consumption, use the count API.
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and aliases used
to limit the request. It supports wildcards (`*`). To target all data streams
@@ -412,7 +412,7 @@ async def fielddata(
They are not intended for use by applications. For application consumption, use the nodes stats API.
- ``_
+ ``_
:param fields: Comma-separated list of fields used to limit returned information.
To retrieve all fields, omit this parameter.
@@ -498,7 +498,7 @@ async def health(
You also can use the API to track the recovery of a large cluster over a longer period of time.
- ``_
+ ``_
:param format: Specifies the format to return the columnar data in, can be set
to `text`, `json`, `cbor`, `yaml`, or `smile`.
@@ -556,7 +556,7 @@ async def help(self) -> TextApiResponse:
Get help for the CAT APIs.
- ``_
+ ``_
"""
__path_parts: t.Dict[str, str] = {}
__path = "/_cat"
@@ -623,7 +623,7 @@ async def indices(
They are not intended for use by applications. For application consumption, use an index endpoint.
- ``_
+ ``_
:param index: Comma-separated list of data streams, indices, and aliases used
to limit the request. Supports wildcards (`*`). To target all data streams
@@ -721,7 +721,7 @@ async def master(
IMPORTANT: cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications. For application consumption, use the nodes info API.
- ``_
+ ``_
:param format: Specifies the format to return the columnar data in, can be set
to `text`, `json`, `cbor`, `yaml`, or `smile`.
@@ -899,7 +899,7 @@ async def ml_data_frame_analytics(
application consumption, use the get data frame analytics jobs statistics API.
- ``_
+ ``_
:param id: The ID of the data frame analytics to fetch
:param allow_no_match: Whether to ignore if a wildcard expression matches no
@@ -1067,7 +1067,7 @@ async def ml_datafeeds(
application consumption, use the get datafeed statistics API.
- ``_
+ ``_
:param datafeed_id: A numerical character string that uniquely identifies the
datafeed.
@@ -1433,7 +1433,7 @@ async def ml_jobs(
application consumption, use the get anomaly detection job statistics API.
- ``_
+ ``_
:param job_id: Identifier for the anomaly detection job.
:param allow_no_match: Specifies what to do when the request: * Contains wildcard
@@ -1618,7 +1618,7 @@ async def ml_trained_models(
application consumption, use the get trained models statistics API.
- ``_
+ ``_
:param model_id: A unique identifier for the trained model.
:param allow_no_match: Specifies what to do when the request: contains wildcard
@@ -1711,7 +1711,7 @@ async def nodeattrs(
IMPORTANT: cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications. For application consumption, use the nodes info API.
- ``_
+ ``_
:param format: Specifies the format to return the columnar data in, can be set
to `text`, `json`, `cbor`, `yaml`, or `smile`.
@@ -1774,7 +1774,200 @@ async def nodes(
filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
format: t.Optional[str] = None,
full_id: t.Optional[t.Union[bool, str]] = None,
- h: t.Optional[t.Union[str, t.Sequence[str]]] = None,
+ h: t.Optional[
+ t.Union[
+ t.Sequence[
+ t.Union[
+ str,
+ t.Literal[
+ "build",
+ "completion.size",
+ "cpu",
+ "disk.avail",
+ "disk.total",
+ "disk.used",
+ "disk.used_percent",
+ "fielddata.evictions",
+ "fielddata.memory_size",
+ "file_desc.current",
+ "file_desc.max",
+ "file_desc.percent",
+ "flush.total",
+ "flush.total_time",
+ "get.current",
+ "get.exists_time",
+ "get.exists_total",
+ "get.missing_time",
+ "get.missing_total",
+ "get.time",
+ "get.total",
+ "heap.current",
+ "heap.max",
+ "heap.percent",
+ "http_address",
+ "id",
+ "indexing.delete_current",
+ "indexing.delete_time",
+ "indexing.delete_total",
+ "indexing.index_current",
+ "indexing.index_failed",
+ "indexing.index_failed_due_to_version_conflict",
+ "indexing.index_time",
+ "indexing.index_total",
+ "ip",
+ "jdk",
+ "load_15m",
+ "load_1m",
+ "load_5m",
+ "mappings.total_count",
+ "mappings.total_estimated_overhead_in_bytes",
+ "master",
+ "merges.current",
+ "merges.current_docs",
+ "merges.current_size",
+ "merges.total",
+ "merges.total_docs",
+ "merges.total_size",
+ "merges.total_time",
+ "name",
+ "node.role",
+ "pid",
+ "port",
+ "query_cache.evictions",
+ "query_cache.hit_count",
+ "query_cache.memory_size",
+ "query_cache.miss_count",
+ "ram.current",
+ "ram.max",
+ "ram.percent",
+ "refresh.time",
+ "refresh.total",
+ "request_cache.evictions",
+ "request_cache.hit_count",
+ "request_cache.memory_size",
+ "request_cache.miss_count",
+ "script.cache_evictions",
+ "script.compilations",
+ "search.fetch_current",
+ "search.fetch_time",
+ "search.fetch_total",
+ "search.open_contexts",
+ "search.query_current",
+ "search.query_time",
+ "search.query_total",
+ "search.scroll_current",
+ "search.scroll_time",
+ "search.scroll_total",
+ "segments.count",
+ "segments.fixed_bitset_memory",
+ "segments.index_writer_memory",
+ "segments.memory",
+ "segments.version_map_memory",
+ "shard_stats.total_count",
+ "suggest.current",
+ "suggest.time",
+ "suggest.total",
+ "uptime",
+ "version",
+ ],
+ ]
+ ],
+ t.Union[
+ str,
+ t.Literal[
+ "build",
+ "completion.size",
+ "cpu",
+ "disk.avail",
+ "disk.total",
+ "disk.used",
+ "disk.used_percent",
+ "fielddata.evictions",
+ "fielddata.memory_size",
+ "file_desc.current",
+ "file_desc.max",
+ "file_desc.percent",
+ "flush.total",
+ "flush.total_time",
+ "get.current",
+ "get.exists_time",
+ "get.exists_total",
+ "get.missing_time",
+ "get.missing_total",
+ "get.time",
+ "get.total",
+ "heap.current",
+ "heap.max",
+ "heap.percent",
+ "http_address",
+ "id",
+ "indexing.delete_current",
+ "indexing.delete_time",
+ "indexing.delete_total",
+ "indexing.index_current",
+ "indexing.index_failed",
+ "indexing.index_failed_due_to_version_conflict",
+ "indexing.index_time",
+ "indexing.index_total",
+ "ip",
+ "jdk",
+ "load_15m",
+ "load_1m",
+ "load_5m",
+ "mappings.total_count",
+ "mappings.total_estimated_overhead_in_bytes",
+ "master",
+ "merges.current",
+ "merges.current_docs",
+ "merges.current_size",
+ "merges.total",
+ "merges.total_docs",
+ "merges.total_size",
+ "merges.total_time",
+ "name",
+ "node.role",
+ "pid",
+ "port",
+ "query_cache.evictions",
+ "query_cache.hit_count",
+ "query_cache.memory_size",
+ "query_cache.miss_count",
+ "ram.current",
+ "ram.max",
+ "ram.percent",
+ "refresh.time",
+ "refresh.total",
+ "request_cache.evictions",
+ "request_cache.hit_count",
+ "request_cache.memory_size",
+ "request_cache.miss_count",
+ "script.cache_evictions",
+ "script.compilations",
+ "search.fetch_current",
+ "search.fetch_time",
+ "search.fetch_total",
+ "search.open_contexts",
+ "search.query_current",
+ "search.query_time",
+ "search.query_total",
+ "search.scroll_current",
+ "search.scroll_time",
+ "search.scroll_total",
+ "segments.count",
+ "segments.fixed_bitset_memory",
+ "segments.index_writer_memory",
+ "segments.memory",
+ "segments.version_map_memory",
+ "shard_stats.total_count",
+ "suggest.current",
+ "suggest.time",
+ "suggest.total",
+ "uptime",
+ "version",
+ ],
+ ],
+ ]
+ ] = None,
help: t.Optional[bool] = None,
human: t.Optional[bool] = None,
include_unloaded_segments: t.Optional[bool] = None,
@@ -1794,23 +1987,24 @@ async def nodes(
IMPORTANT: cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications. For application consumption, use the nodes info API.
- ``_
+ ``_
:param bytes: The unit used to display byte values.
:param format: Specifies the format to return the columnar data in, can be set
to `text`, `json`, `cbor`, `yaml`, or `smile`.
:param full_id: If `true`, return the full node ID. If `false`, return the shortened
node ID.
- :param h: List of columns to appear in the response. Supports simple wildcards.
+ :param h: A comma-separated list of columns names to display. It supports simple
+ wildcards.
:param help: When set to `true` will output available columns. This option can't
be combined with any other query string option.
:param include_unloaded_segments: If true, the response includes information
from segments that are not loaded into memory.
- :param master_timeout: Period to wait for a connection to the master node.
- :param s: List of columns that determine how the table should be sorted. Sorting
- defaults to ascending and can be changed by setting `:asc` or `:desc` as
- a suffix to the column name.
- :param time: Unit used to display time values.
+ :param master_timeout: The period to wait for a connection to the master node.
+ :param s: A comma-separated list of column names or aliases that determines the
+ sort order. Sorting defaults to ascending and can be changed by setting `:asc`
+ or `:desc` as a suffix to the column name.
+ :param time: The unit used to display time values.
:param v: When set to `true` will enable verbose output.
"""
__path_parts: t.Dict[str, str] = {}
@@ -1881,7 +2075,7 @@ async def pending_tasks(
IMPORTANT: cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications. For application consumption, use the pending cluster tasks API.
- ``_
+ ``_
:param format: Specifies the format to return the columnar data in, can be set
to `text`, `json`, `cbor`, `yaml`, or `smile`.
@@ -1961,7 +2155,7 @@ async def plugins(
IMPORTANT: cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications. For application consumption, use the nodes info API.
- ``_
+ ``_
:param format: Specifies the format to return the columnar data in, can be set
to `text`, `json`, `cbor`, `yaml`, or `smile`.
@@ -2049,7 +2243,7 @@ async def recovery(
IMPORTANT: cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications. For application consumption, use the index recovery API.
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and aliases used
to limit the request. Supports wildcards (`*`). To target all data streams
@@ -2137,7 +2331,7 @@ async def repositories(
IMPORTANT: cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications. For application consumption, use the get snapshot repository API.
- ``_
+ ``_
:param format: Specifies the format to return the columnar data in, can be set
to `text`, `json`, `cbor`, `yaml`, or `smile`.
@@ -2218,7 +2412,7 @@ async def segments(
IMPORTANT: cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications. For application consumption, use the index segments API.
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and aliases used
to limit the request. Supports wildcards (`*`). To target all data streams
@@ -2312,7 +2506,7 @@ async def shards(
IMPORTANT: cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications.
- ``_
+ ``_
:param index: A comma-separated list of data streams, indices, and aliases used
to limit the request. Supports wildcards (`*`). To target all data streams
@@ -2401,7 +2595,7 @@ async def snapshots(
IMPORTANT: cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications. For application consumption, use the get snapshot API.
- ``_
+ ``_
:param repository: A comma-separated list of snapshot repositories used to limit
the request. Accepts wildcard expressions. `_all` returns all repositories.
@@ -2494,7 +2688,7 @@ async def tasks(
IMPORTANT: cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications. For application consumption, use the task management API.
- ``_
+ ``_
:param actions: The task action names, which are used to limit the response.
:param detailed: If `true`, the response includes detailed information about
@@ -2588,7 +2782,7 @@ async def templates(
IMPORTANT: cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications. For application consumption, use the get index template API.
- ``_
+ ``_
:param name: The name of the template to return. Accepts wildcard expressions.
If omitted, all templates are returned.
@@ -2676,7 +2870,7 @@ async def thread_pool(
IMPORTANT: cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications. For application consumption, use the nodes info API.
- ``_
+ ``_
:param thread_pool_patterns: A comma-separated list of thread pool names used
to limit the request. Accepts wildcard expressions.
@@ -2933,7 +3127,7 @@ async def transforms(
application consumption, use the get transform statistics API.
- ``_
+ ``_
:param transform_id: A transform identifier or a wildcard expression. If you
do not specify one of these options, the API returns information for all
diff --git a/elasticsearch/_async/client/ccr.py b/elasticsearch/_async/client/ccr.py
index cfa80673b..eeef7c7ab 100644
--- a/elasticsearch/_async/client/ccr.py
+++ b/elasticsearch/_async/client/ccr.py
@@ -43,7 +43,7 @@ async def delete_auto_follow_pattern(
Delete a collection of cross-cluster replication auto-follow patterns.
- ``_
+ ``_
:param name: The auto-follow pattern collection to delete.
:param master_timeout: The period to wait for a connection to the master node.
@@ -130,7 +130,7 @@ async def follow(
When the API returns, the follower index exists and cross-cluster replication starts replicating operations from the leader index to the follower index.
- ``_
+ ``_
:param index: The name of the follower index.
:param leader_index: The name of the index in the leader cluster to follow.
@@ -259,7 +259,7 @@ async def follow_info(
For example, the results include follower index names, leader index names, replication options, and whether the follower indices are active or paused.
- ``_
+ ``_
:param index: A comma-delimited list of follower index patterns.
:param master_timeout: The period to wait for a connection to the master node.
@@ -311,7 +311,7 @@ async def follow_stats(
The API returns shard-level stats about the "following tasks" associated with each shard for the specified indices.
- ``_
+ ``_
:param index: A comma-delimited list of index patterns.
:param timeout: The period to wait for a response. If no response is received
@@ -380,7 +380,7 @@ async def forget_follower(
The only purpose of this API is to handle the case of failure to remove the following retention leases after the unfollow API is invoked.
- ``_
+ ``_
:param index: the name of the leader index for which specified follower retention
leases should be removed
@@ -445,7 +445,7 @@ async def get_auto_follow_pattern(
Get cross-cluster replication auto-follow patterns.
- ``_
+ ``_
:param name: The auto-follow pattern collection that you want to retrieve. If
you do not specify a name, the API returns information for all collections.
@@ -505,7 +505,7 @@ async def pause_auto_follow_pattern(
Remote indices that were created while the pattern was paused will also be followed, unless they have been deleted or closed in the interim.
- ``_
+ ``_
:param name: The name of the auto-follow pattern to pause.
:param master_timeout: The period to wait for a connection to the master node.
@@ -559,7 +559,7 @@ async def pause_follow(
You can pause and resume a follower index to change the configuration of the following task.
- ``_
+ ``_
:param index: The name of the follower index.
:param master_timeout: The period to wait for a connection to the master node.
@@ -648,7 +648,7 @@ async def put_auto_follow_pattern(
NOTE: Follower indices that were configured automatically before updating an auto-follow pattern will remain unchanged even if they do not match against the new patterns.
- ``_
+ ``_
:param name: The name of the collection of auto-follow patterns.
:param remote_cluster: The remote cluster containing the leader indices to match
@@ -782,7 +782,7 @@ async def resume_auto_follow_pattern(
Remote indices created while the pattern was paused will also be followed unless they have been deleted or closed in the interim.
- ``_
+ ``_
:param name: The name of the auto-follow pattern to resume.
:param master_timeout: The period to wait for a connection to the master node.
@@ -860,7 +860,7 @@ async def resume_follow(
When this API returns, the follower index will resume fetching operations from the leader index.
- ``_
+ ``_
:param index: The name of the follow index to resume following.
:param master_timeout: Period to wait for a connection to the master node.
@@ -951,7 +951,7 @@ async def stats(
This API returns stats about auto-following and the same shard-level stats as the get follower stats API.
- ``_
+ ``_
:param master_timeout: The period to wait for a connection to the master node.
If the master node is not available before the timeout expires, the request
@@ -1009,7 +1009,7 @@ async def unfollow(
- ``_
+ ``_
:param index: The name of the follower index.
:param master_timeout: The period to wait for a connection to the master node.
diff --git a/elasticsearch/_async/client/cluster.py b/elasticsearch/_async/client/cluster.py
index 7847bbdb6..55f9c4d92 100644
--- a/elasticsearch/_async/client/cluster.py
+++ b/elasticsearch/_async/client/cluster.py
@@ -54,7 +54,7 @@ async def allocation_explain(
This API can be very useful when attempting to diagnose why a shard is unassigned or why a shard continues to remain on its current node when you might expect otherwise.
- ``_
+ ``_
:param current_node: Specifies the node ID or the name of the node to only explain
a shard that is currently located on the specified node.
@@ -130,7 +130,7 @@ async def delete_component_template(
Component templates are building blocks for constructing index templates that specify index mappings, settings, and aliases.
- ``_
+ ``_
:param name: Comma-separated list or wildcard expression of component template
names used to limit the request.
@@ -239,7 +239,7 @@ async def exists_component_template(
Returns information about whether a particular component template exists.
- ``_
+ ``_
:param name: Comma-separated list of component template names used to limit the
request. Wildcard (*) expressions are supported.
@@ -298,7 +298,7 @@ async def get_component_template(
Get information about component templates.
- ``_
+ ``_
:param name: Comma-separated list of component template names used to limit the
request. Wildcard (`*`) expressions are supported.
@@ -365,7 +365,7 @@ async def get_settings(
By default, it returns only settings that have been explicitly defined.
- ``_
+ ``_
:param flat_settings: If `true`, returns settings in flat format.
:param include_defaults: If `true`, returns default cluster settings from the
@@ -457,7 +457,7 @@ async def health(
The cluster status is controlled by the worst index status.
- ``_
+ ``_
:param index: Comma-separated list of data streams, indices, and index aliases
used to limit the request. Wildcard expressions (`*`) are supported. To target
@@ -565,7 +565,7 @@ async def info(
Returns basic information about the cluster.
- ``_
+ ``_
:param target: Limits the information returned to the specific target. Supports
a comma-separated list, such as http,ingest.
@@ -614,7 +614,7 @@ async def pending_tasks(
However, if a user-initiated task such as a create index command causes a cluster state update, the activity of this task might be reported by both task api and pending cluster tasks API.
- ``_
+ ``_
:param local: If `true`, the request retrieves information from the local node
only. If `false`, information is retrieved from the master node.
@@ -761,7 +761,7 @@ async def put_component_template(
To be applied, a component template must be included in an index template's composed_of
list.
- ``_
+ ``_
:param name: Name of the component template to create. Elasticsearch includes
the following built-in component templates: `logs-mappings`; `logs-settings`;
@@ -866,7 +866,7 @@ async def put_settings(
If a cluster becomes unstable, transient settings can clear unexpectedly, resulting in a potentially undesired cluster configuration.
- ``_
+ ``_
:param flat_settings: Return settings in flat format (default: false)
:param master_timeout: Explicit operation timeout for connection to master node
@@ -932,7 +932,7 @@ async def remote_info(
- ``_
+ ``_
"""
__path_parts: t.Dict[str, str] = {}
__path = "/_remote/info"
@@ -989,7 +989,7 @@ async def reroute(
Once the problem has been corrected, allocation can be manually retried by calling the reroute API with the ?retry_failed
URI query parameter, which will attempt a single retry round for these shards.
- ``_
+ ``_
:param commands: Defines the commands to perform.
:param dry_run: If true, then the request simulates the operation. It will calculate
@@ -1094,7 +1094,7 @@ async def state(
Instead, obtain the information you require using other more stable cluster APIs.
- ``_
+ ``_
:param metric: Limit the information returned to the specified metrics
:param index: A comma-separated list of index names; use `_all` or empty string
@@ -1182,7 +1182,7 @@ async def stats(
Get basic index metrics (shard numbers, store size, memory usage) and information about the current nodes that form the cluster (number, roles, os, jvm versions, memory usage, cpu and installed plugins).
- ``_
+ ``_
:param node_id: Comma-separated list of node filters used to limit returned information.
Defaults to all nodes in the cluster.
diff --git a/elasticsearch/_async/client/connector.py b/elasticsearch/_async/client/connector.py
index 2f5080821..9f4b91c32 100644
--- a/elasticsearch/_async/client/connector.py
+++ b/elasticsearch/_async/client/connector.py
@@ -49,7 +49,7 @@ async def check_in(
Update the last_seen
field in the connector and set it to the current timestamp.
- ``_
+ ``_
:param connector_id: The unique identifier of the connector to be checked in
"""
@@ -98,7 +98,7 @@ async def delete(
These need to be removed manually.
- ``_
+ ``_
:param connector_id: The unique identifier of the connector to be deleted
:param delete_sync_jobs: A flag indicating if associated sync jobs should be
@@ -147,7 +147,7 @@ async def get(
Get the details about a connector.
- ``_
+ ``_
:param connector_id: The unique identifier of the connector
"""
@@ -247,7 +247,7 @@ async def last_sync(
This action is used for analytics and monitoring.
- ``_
+ ``_
:param connector_id: The unique identifier of the connector to be updated
:param last_access_control_sync_error:
@@ -346,7 +346,7 @@ async def list(
Get information about all connectors.
- ``_
+ ``_
:param connector_name: A comma-separated list of connector names to fetch connector
documents for
@@ -427,7 +427,7 @@ async def post(
Self-managed connectors (Connector clients) are self-managed on your infrastructure.
- ``_
+ ``_
:param description:
:param index_name:
@@ -509,7 +509,7 @@ async def put(
Create or update a connector.
- ``_
+ ``_
:param connector_id: The unique identifier of the connector to be created or
updated. ID is auto-generated if not provided.
@@ -584,7 +584,7 @@ async def sync_job_cancel(
The connector service is then responsible for setting the status of connector sync jobs to cancelled.
- ``_
+ ``_
:param connector_sync_job_id: The unique identifier of the connector sync job
"""
@@ -635,7 +635,7 @@ async def sync_job_check_in(
This service runs automatically on Elastic Cloud for Elastic managed connectors.
- ``_
+ ``_
:param connector_sync_job_id: The unique identifier of the connector sync job
to be checked in.
@@ -695,7 +695,7 @@ async def sync_job_claim(
This service runs automatically on Elastic Cloud for Elastic managed connectors.
- ``_
+ ``_
:param connector_sync_job_id: The unique identifier of the connector sync job.
:param worker_hostname: The host name of the current system that will run the
@@ -757,7 +757,7 @@ async def sync_job_delete(
This is a destructive action that is not recoverable.
- ``_
+ ``_
:param connector_sync_job_id: The unique identifier of the connector sync job
to be deleted
@@ -811,7 +811,7 @@ async def sync_job_error(
This service runs automatically on Elastic Cloud for Elastic managed connectors.
- ``_
+ ``_
:param connector_sync_job_id: The unique identifier for the connector sync job.
:param error: The error for the connector sync job error field.
@@ -865,7 +865,7 @@ async def sync_job_get(
Get a connector sync job.
- ``_
+ ``_
:param connector_sync_job_id: The unique identifier of the connector sync job
"""
@@ -938,7 +938,7 @@ async def sync_job_list(
Get information about all stored connector sync jobs listed by their creation date in ascending order.
- ``_
+ ``_
:param connector_id: A connector id to fetch connector sync jobs for
:param from_: Starting offset (default: 0)
@@ -1004,7 +1004,7 @@ async def sync_job_post(
Create a connector sync job document in the internal index and initialize its counters and timestamps with default values.
- ``_
+ ``_
:param id: The id of the associated connector
:param job_type:
@@ -1080,7 +1080,7 @@ async def sync_job_update_stats(
This service runs automatically on Elastic Cloud for Elastic managed connectors.
- ``_
+ ``_
:param connector_sync_job_id: The unique identifier of the connector sync job.
:param deleted_document_count: The number of documents the sync job deleted.
@@ -1163,7 +1163,7 @@ async def update_active_filtering(
Activates the valid draft filtering for a connector.
- ``_
+ ``_
:param connector_id: The unique identifier of the connector to be updated
"""
@@ -1216,7 +1216,7 @@ async def update_api_key_id(
Self-managed connectors (connector clients) do not use this field.
- ``_
+ ``_
:param connector_id: The unique identifier of the connector to be updated
:param api_key_id:
@@ -1275,7 +1275,7 @@ async def update_configuration(
Update the configuration field in the connector document.
- ``_
+ ``_
:param connector_id: The unique identifier of the connector to be updated
:param configuration:
@@ -1335,7 +1335,7 @@ async def update_error(
Otherwise, if the error is reset to null, the connector status is updated to connected.
- ``_
+ ``_
:param connector_id: The unique identifier of the connector to be updated
:param error:
@@ -1403,7 +1403,7 @@ async def update_features(
This service runs automatically on Elastic Cloud for Elastic managed connectors.
- ``_
+ ``_
:param connector_id: The unique identifier of the connector to be updated.
:param features:
@@ -1464,7 +1464,7 @@ async def update_filtering(
The filtering property is used to configure sync rules (both basic and advanced) for a connector.
- ``_
+ ``_
:param connector_id: The unique identifier of the connector to be updated
:param advanced_snippet:
@@ -1525,7 +1525,7 @@ async def update_filtering_validation(
Update the draft filtering validation info for a connector.
- ``_
+ `