Skip to content

Commit 212278b

Browse files
elasticmachineelasticmachine
committed
Auto-generated API code
1 parent 913a2a8 commit 212278b

File tree

22 files changed

+737
-356
lines changed

22 files changed

+737
-356
lines changed

‎elasticsearch/_async/client/__init__.py

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -3798,8 +3798,7 @@ async def open_point_in_time(
37983798
:param expand_wildcards: The type of index that wildcard patterns can match.
37993799
If the request can target data streams, this argument determines whether
38003800
wildcard expressions match hidden data streams. It supports comma-separated
3801-
values, such as `open,hidden`. Valid values are: `all`, `open`, `closed`,
3802-
`hidden`, `none`.
3801+
values, such as `open,hidden`.
38033802
:param ignore_unavailable: If `false`, the request returns an error if it targets
38043803
a missing or closed index.
38053804
:param index_filter: Filter indices if the provided query rewrites to `match_none`
@@ -5695,7 +5694,7 @@ async def search_shards(
56955694
:param expand_wildcards: Type of index that wildcard patterns can match. If the
56965695
request can target data streams, this argument determines whether wildcard
56975696
expressions match hidden data streams. Supports comma-separated values, such
5698-
as `open,hidden`. Valid values are: `all`, `open`, `closed`, `hidden`, `none`.
5697+
as `open,hidden`.
56995698
:param ignore_unavailable: If `false`, the request returns an error if it targets
57005699
a missing or closed index.
57015700
:param local: If `true`, the request retrieves information from the local node
@@ -5807,8 +5806,7 @@ async def search_template(
58075806
:param expand_wildcards: The type of index that wildcard patterns can match.
58085807
If the request can target data streams, this argument determines whether
58095808
wildcard expressions match hidden data streams. Supports comma-separated
5810-
values, such as `open,hidden`. Valid values are: `all`, `open`, `closed`,
5811-
`hidden`, `none`.
5809+
values, such as `open,hidden`.
58125810
:param explain: If `true`, returns detailed information about score calculation
58135811
as part of each hit. If you specify both this and the `explain` query parameter,
58145812
the API uses only the query parameter.
@@ -6519,8 +6517,7 @@ async def update_by_query(
65196517
:param expand_wildcards: The type of index that wildcard patterns can match.
65206518
If the request can target data streams, this argument determines whether
65216519
wildcard expressions match hidden data streams. It supports comma-separated
6522-
values, such as `open,hidden`. Valid values are: `all`, `open`, `closed`,
6523-
`hidden`, `none`.
6520+
values, such as `open,hidden`.
65246521
:param from_: Skips the specified number of documents.
65256522
:param ignore_unavailable: If `false`, the request returns an error if it targets
65266523
a missing or closed index.

‎elasticsearch/_async/client/cat.py

Lines changed: 201 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1774,7 +1774,200 @@ async def nodes(
17741774
filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
17751775
format: t.Optional[str] = None,
17761776
full_id: t.Optional[t.Union[bool, str]] = None,
1777-
h: t.Optional[t.Union[str, t.Sequence[str]]] = None,
1777+
h: t.Optional[
1778+
t.Union[
1779+
t.Sequence[
1780+
t.Union[
1781+
str,
1782+
t.Literal[
1783+
"build",
1784+
"completion.size",
1785+
"cpu",
1786+
"disk.avail",
1787+
"disk.total",
1788+
"disk.used",
1789+
"disk.used_percent",
1790+
"fielddata.evictions",
1791+
"fielddata.memory_size",
1792+
"file_desc.current",
1793+
"file_desc.max",
1794+
"file_desc.percent",
1795+
"flush.total",
1796+
"flush.total_time",
1797+
"get.current",
1798+
"get.exists_time",
1799+
"get.exists_total",
1800+
"get.missing_time",
1801+
"get.missing_total",
1802+
"get.time",
1803+
"get.total",
1804+
"heap.current",
1805+
"heap.max",
1806+
"heap.percent",
1807+
"http_address",
1808+
"id",
1809+
"indexing.delete_current",
1810+
"indexing.delete_time",
1811+
"indexing.delete_total",
1812+
"indexing.index_current",
1813+
"indexing.index_failed",
1814+
"indexing.index_failed_due_to_version_conflict",
1815+
"indexing.index_time",
1816+
"indexing.index_total",
1817+
"ip",
1818+
"jdk",
1819+
"load_15m",
1820+
"load_1m",
1821+
"load_5m",
1822+
"mappings.total_count",
1823+
"mappings.total_estimated_overhead_in_bytes",
1824+
"master",
1825+
"merges.current",
1826+
"merges.current_docs",
1827+
"merges.current_size",
1828+
"merges.total",
1829+
"merges.total_docs",
1830+
"merges.total_size",
1831+
"merges.total_time",
1832+
"name",
1833+
"node.role",
1834+
"pid",
1835+
"port",
1836+
"query_cache.evictions",
1837+
"query_cache.hit_count",
1838+
"query_cache.memory_size",
1839+
"query_cache.miss_count",
1840+
"ram.current",
1841+
"ram.max",
1842+
"ram.percent",
1843+
"refresh.time",
1844+
"refresh.total",
1845+
"request_cache.evictions",
1846+
"request_cache.hit_count",
1847+
"request_cache.memory_size",
1848+
"request_cache.miss_count",
1849+
"script.cache_evictions",
1850+
"script.compilations",
1851+
"search.fetch_current",
1852+
"search.fetch_time",
1853+
"search.fetch_total",
1854+
"search.open_contexts",
1855+
"search.query_current",
1856+
"search.query_time",
1857+
"search.query_total",
1858+
"search.scroll_current",
1859+
"search.scroll_time",
1860+
"search.scroll_total",
1861+
"segments.count",
1862+
"segments.fixed_bitset_memory",
1863+
"segments.index_writer_memory",
1864+
"segments.memory",
1865+
"segments.version_map_memory",
1866+
"shard_stats.total_count",
1867+
"suggest.current",
1868+
"suggest.time",
1869+
"suggest.total",
1870+
"uptime",
1871+
"version",
1872+
],
1873+
]
1874+
],
1875+
t.Union[
1876+
str,
1877+
t.Literal[
1878+
"build",
1879+
"completion.size",
1880+
"cpu",
1881+
"disk.avail",
1882+
"disk.total",
1883+
"disk.used",
1884+
"disk.used_percent",
1885+
"fielddata.evictions",
1886+
"fielddata.memory_size",
1887+
"file_desc.current",
1888+
"file_desc.max",
1889+
"file_desc.percent",
1890+
"flush.total",
1891+
"flush.total_time",
1892+
"get.current",
1893+
"get.exists_time",
1894+
"get.exists_total",
1895+
"get.missing_time",
1896+
"get.missing_total",
1897+
"get.time",
1898+
"get.total",
1899+
"heap.current",
1900+
"heap.max",
1901+
"heap.percent",
1902+
"http_address",
1903+
"id",
1904+
"indexing.delete_current",
1905+
"indexing.delete_time",
1906+
"indexing.delete_total",
1907+
"indexing.index_current",
1908+
"indexing.index_failed",
1909+
"indexing.index_failed_due_to_version_conflict",
1910+
"indexing.index_time",
1911+
"indexing.index_total",
1912+
"ip",
1913+
"jdk",
1914+
"load_15m",
1915+
"load_1m",
1916+
"load_5m",
1917+
"mappings.total_count",
1918+
"mappings.total_estimated_overhead_in_bytes",
1919+
"master",
1920+
"merges.current",
1921+
"merges.current_docs",
1922+
"merges.current_size",
1923+
"merges.total",
1924+
"merges.total_docs",
1925+
"merges.total_size",
1926+
"merges.total_time",
1927+
"name",
1928+
"node.role",
1929+
"pid",
1930+
"port",
1931+
"query_cache.evictions",
1932+
"query_cache.hit_count",
1933+
"query_cache.memory_size",
1934+
"query_cache.miss_count",
1935+
"ram.current",
1936+
"ram.max",
1937+
"ram.percent",
1938+
"refresh.time",
1939+
"refresh.total",
1940+
"request_cache.evictions",
1941+
"request_cache.hit_count",
1942+
"request_cache.memory_size",
1943+
"request_cache.miss_count",
1944+
"script.cache_evictions",
1945+
"script.compilations",
1946+
"search.fetch_current",
1947+
"search.fetch_time",
1948+
"search.fetch_total",
1949+
"search.open_contexts",
1950+
"search.query_current",
1951+
"search.query_time",
1952+
"search.query_total",
1953+
"search.scroll_current",
1954+
"search.scroll_time",
1955+
"search.scroll_total",
1956+
"segments.count",
1957+
"segments.fixed_bitset_memory",
1958+
"segments.index_writer_memory",
1959+
"segments.memory",
1960+
"segments.version_map_memory",
1961+
"shard_stats.total_count",
1962+
"suggest.current",
1963+
"suggest.time",
1964+
"suggest.total",
1965+
"uptime",
1966+
"version",
1967+
],
1968+
],
1969+
]
1970+
] = None,
17781971
help: t.Optional[bool] = None,
17791972
human: t.Optional[bool] = None,
17801973
include_unloaded_segments: t.Optional[bool] = None,
@@ -1801,16 +1994,17 @@ async def nodes(
18011994
to `text`, `json`, `cbor`, `yaml`, or `smile`.
18021995
:param full_id: If `true`, return the full node ID. If `false`, return the shortened
18031996
node ID.
1804-
:param h: List of columns to appear in the response. Supports simple wildcards.
1997+
:param h: A comma-separated list of columns names to display. It supports simple
1998+
wildcards.
18051999
:param help: When set to `true` will output available columns. This option can't
18062000
be combined with any other query string option.
18072001
:param include_unloaded_segments: If true, the response includes information
18082002
from segments that are not loaded into memory.
1809-
:param master_timeout: Period to wait for a connection to the master node.
1810-
:param s: List of columns that determine how the table should be sorted. Sorting
1811-
defaults to ascending and can be changed by setting `:asc` or `:desc` as
1812-
a suffix to the column name.
1813-
:param time: Unit used to display time values.
2003+
:param master_timeout: The period to wait for a connection to the master node.
2004+
:param s: A comma-separated list of column names or aliases that determines the
2005+
sort order. Sorting defaults to ascending and can be changed by setting `:asc`
2006+
or `:desc` as a suffix to the column name.
2007+
:param time: The unit used to display time values.
18142008
:param v: When set to `true` will enable verbose output.
18152009
"""
18162010
__path_parts: t.Dict[str, str] = {}

‎elasticsearch/_async/client/cluster.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -870,9 +870,9 @@ async def put_settings(
870870
871871
:param flat_settings: Return settings in flat format (default: false)
872872
:param master_timeout: Explicit operation timeout for connection to master node
873-
:param persistent:
873+
:param persistent: The settings that persist after the cluster restarts.
874874
:param timeout: Explicit operation timeout
875-
:param transient:
875+
:param transient: The settings that do not persist after the cluster restarts.
876876
"""
877877
__path_parts: t.Dict[str, str] = {}
878878
__path = "/_cluster/settings"
@@ -928,7 +928,7 @@ async def remote_info(
928928
This API returns information that reflects current state on the local cluster.
929929
The <code>connected</code> field does not necessarily reflect whether a remote cluster is down or unavailable, only whether there is currently an open connection to it.
930930
Elasticsearch does not spontaneously try to reconnect to a disconnected remote cluster.
931-
To trigger a reconnection, attempt a cross-cluster search, ES|QL cross-cluster search, or try the <a href="https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-indices-resolve-cluster">resolve cluster endpoint</a>.</p>
931+
To trigger a reconnection, attempt a cross-cluster search, ES|QL cross-cluster search, or try the <code>/_resolve/cluster</code> endpoint.</p>
932932
</blockquote>
933933
934934

‎elasticsearch/_async/client/esql.py

Lines changed: 17 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,8 @@ class EsqlClient(NamespacedClient):
3131
"columnar",
3232
"filter",
3333
"include_ccs_metadata",
34+
"keep_alive",
35+
"keep_on_completion",
3436
"locale",
3537
"params",
3638
"profile",
@@ -147,10 +149,6 @@ async def async_query(
147149
__query["format"] = format
148150
if human is not None:
149151
__query["human"] = human
150-
if keep_alive is not None:
151-
__query["keep_alive"] = keep_alive
152-
if keep_on_completion is not None:
153-
__query["keep_on_completion"] = keep_on_completion
154152
if pretty is not None:
155153
__query["pretty"] = pretty
156154
if not __body:
@@ -162,6 +160,10 @@ async def async_query(
162160
__body["filter"] = filter
163161
if include_ccs_metadata is not None:
164162
__body["include_ccs_metadata"] = include_ccs_metadata
163+
if keep_alive is not None:
164+
__body["keep_alive"] = keep_alive
165+
if keep_on_completion is not None:
166+
__body["keep_on_completion"] = keep_on_completion
165167
if locale is not None:
166168
__body["locale"] = locale
167169
if params is not None:
@@ -244,6 +246,14 @@ async def async_query_get(
244246
drop_null_columns: t.Optional[bool] = None,
245247
error_trace: t.Optional[bool] = None,
246248
filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
249+
format: t.Optional[
250+
t.Union[
251+
str,
252+
t.Literal[
253+
"arrow", "cbor", "csv", "json", "smile", "tsv", "txt", "yaml"
254+
],
255+
]
256+
] = None,
247257
human: t.Optional[bool] = None,
248258
keep_alive: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
249259
pretty: t.Optional[bool] = None,
@@ -269,6 +279,7 @@ async def async_query_get(
269279
will be removed from the `columns` and `values` portion of the results. If
270280
`true`, the response will include an extra section under the name `all_columns`
271281
which has the name of all the columns.
282+
:param format: A short version of the Accept header, for example `json` or `yaml`.
272283
:param keep_alive: The period for which the query and its results are stored
273284
in the cluster. When this period expires, the query and its results are deleted,
274285
even if the query is still ongoing.
@@ -289,6 +300,8 @@ async def async_query_get(
289300
__query["error_trace"] = error_trace
290301
if filter_path is not None:
291302
__query["filter_path"] = filter_path
303+
if format is not None:
304+
__query["format"] = format
292305
if human is not None:
293306
__query["human"] = human
294307
if keep_alive is not None:

0 commit comments

Comments
 (0)