Skip to content

Commit 474593a

Browse files
elasticmachineelasticmachine
committed
Auto-generated API code
1 parent 9cf3a54 commit 474593a

32 files changed

+1359
-249
lines changed

‎elasticsearch/_async/client/__init__.py‎

Lines changed: 23 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -555,7 +555,7 @@ async def bulk(
555555
] = None,
556556
require_alias: t.Optional[bool] = None,
557557
require_data_stream: t.Optional[bool] = None,
558-
routing: t.Optional[str] = None,
558+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
559559
source: t.Optional[t.Union[bool, t.Union[str, t.Sequence[str]]]] = None,
560560
source_excludes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
561561
source_includes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
@@ -898,7 +898,7 @@ async def count(
898898
project_routing: t.Optional[str] = None,
899899
q: t.Optional[str] = None,
900900
query: t.Optional[t.Mapping[str, t.Any]] = None,
901-
routing: t.Optional[str] = None,
901+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
902902
terminate_after: t.Optional[int] = None,
903903
body: t.Optional[t.Dict[str, t.Any]] = None,
904904
) -> ObjectApiResponse[t.Any]:
@@ -1053,7 +1053,7 @@ async def create(
10531053
] = None,
10541054
require_alias: t.Optional[bool] = None,
10551055
require_data_stream: t.Optional[bool] = None,
1056-
routing: t.Optional[str] = None,
1056+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
10571057
timeout: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
10581058
version: t.Optional[int] = None,
10591059
version_type: t.Optional[
@@ -1232,7 +1232,7 @@ async def delete(
12321232
refresh: t.Optional[
12331233
t.Union[bool, str, t.Literal["false", "true", "wait_for"]]
12341234
] = None,
1235-
routing: t.Optional[str] = None,
1235+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
12361236
timeout: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
12371237
version: t.Optional[int] = None,
12381238
version_type: t.Optional[
@@ -1375,7 +1375,7 @@ async def delete_by_query(
13751375
refresh: t.Optional[bool] = None,
13761376
request_cache: t.Optional[bool] = None,
13771377
requests_per_second: t.Optional[float] = None,
1378-
routing: t.Optional[str] = None,
1378+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
13791379
scroll: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
13801380
scroll_size: t.Optional[int] = None,
13811381
search_timeout: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
@@ -1769,7 +1769,7 @@ async def exists(
17691769
pretty: t.Optional[bool] = None,
17701770
realtime: t.Optional[bool] = None,
17711771
refresh: t.Optional[bool] = None,
1772-
routing: t.Optional[str] = None,
1772+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
17731773
source: t.Optional[t.Union[bool, t.Union[str, t.Sequence[str]]]] = None,
17741774
source_excludes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
17751775
source_includes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
@@ -1899,7 +1899,7 @@ async def exists_source(
18991899
pretty: t.Optional[bool] = None,
19001900
realtime: t.Optional[bool] = None,
19011901
refresh: t.Optional[bool] = None,
1902-
routing: t.Optional[str] = None,
1902+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
19031903
source: t.Optional[t.Union[bool, t.Union[str, t.Sequence[str]]]] = None,
19041904
source_excludes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
19051905
source_includes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
@@ -2010,7 +2010,7 @@ async def explain(
20102010
pretty: t.Optional[bool] = None,
20112011
q: t.Optional[str] = None,
20122012
query: t.Optional[t.Mapping[str, t.Any]] = None,
2013-
routing: t.Optional[str] = None,
2013+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
20142014
source: t.Optional[t.Union[bool, t.Union[str, t.Sequence[str]]]] = None,
20152015
source_excludes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
20162016
source_includes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
@@ -2139,7 +2139,7 @@ async def field_caps(
21392139
] = None,
21402140
fields: t.Optional[t.Union[str, t.Sequence[str]]] = None,
21412141
filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
2142-
filters: t.Optional[str] = None,
2142+
filters: t.Optional[t.Union[str, t.Sequence[str]]] = None,
21432143
human: t.Optional[bool] = None,
21442144
ignore_unavailable: t.Optional[bool] = None,
21452145
include_empty_fields: t.Optional[bool] = None,
@@ -2279,7 +2279,7 @@ async def get(
22792279
pretty: t.Optional[bool] = None,
22802280
realtime: t.Optional[bool] = None,
22812281
refresh: t.Optional[bool] = None,
2282-
routing: t.Optional[str] = None,
2282+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
22832283
source: t.Optional[t.Union[bool, t.Union[str, t.Sequence[str]]]] = None,
22842284
source_exclude_vectors: t.Optional[bool] = None,
22852285
source_excludes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
@@ -2571,7 +2571,7 @@ async def get_source(
25712571
pretty: t.Optional[bool] = None,
25722572
realtime: t.Optional[bool] = None,
25732573
refresh: t.Optional[bool] = None,
2574-
routing: t.Optional[str] = None,
2574+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
25752575
source: t.Optional[t.Union[bool, t.Union[str, t.Sequence[str]]]] = None,
25762576
source_excludes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
25772577
source_includes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
@@ -2753,7 +2753,7 @@ async def index(
27532753
] = None,
27542754
require_alias: t.Optional[bool] = None,
27552755
require_data_stream: t.Optional[bool] = None,
2756-
routing: t.Optional[str] = None,
2756+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
27572757
timeout: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
27582758
version: t.Optional[int] = None,
27592759
version_type: t.Optional[
@@ -3037,7 +3037,7 @@ async def mget(
30373037
pretty: t.Optional[bool] = None,
30383038
realtime: t.Optional[bool] = None,
30393039
refresh: t.Optional[bool] = None,
3040-
routing: t.Optional[str] = None,
3040+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
30413041
source: t.Optional[t.Union[bool, t.Union[str, t.Sequence[str]]]] = None,
30423042
source_excludes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
30433043
source_includes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
@@ -3174,7 +3174,7 @@ async def msearch(
31743174
pretty: t.Optional[bool] = None,
31753175
project_routing: t.Optional[str] = None,
31763176
rest_total_hits_as_int: t.Optional[bool] = None,
3177-
routing: t.Optional[str] = None,
3177+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
31783178
search_type: t.Optional[
31793179
t.Union[str, t.Literal["dfs_query_then_fetch", "query_then_fetch"]]
31803180
] = None,
@@ -3440,7 +3440,7 @@ async def mtermvectors(
34403440
preference: t.Optional[str] = None,
34413441
pretty: t.Optional[bool] = None,
34423442
realtime: t.Optional[bool] = None,
3443-
routing: t.Optional[str] = None,
3443+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
34443444
term_statistics: t.Optional[bool] = None,
34453445
version: t.Optional[int] = None,
34463446
version_type: t.Optional[
@@ -3570,7 +3570,7 @@ async def open_point_in_time(
35703570
preference: t.Optional[str] = None,
35713571
pretty: t.Optional[bool] = None,
35723572
project_routing: t.Optional[str] = None,
3573-
routing: t.Optional[str] = None,
3573+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
35743574
body: t.Optional[t.Dict[str, t.Any]] = None,
35753575
) -> ObjectApiResponse[t.Any]:
35763576
"""
@@ -4418,7 +4418,7 @@ async def search(
44184418
] = None,
44194419
rest_total_hits_as_int: t.Optional[bool] = None,
44204420
retriever: t.Optional[t.Mapping[str, t.Any]] = None,
4421-
routing: t.Optional[str] = None,
4421+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
44224422
runtime_mappings: t.Optional[t.Mapping[str, t.Mapping[str, t.Any]]] = None,
44234423
script_fields: t.Optional[t.Mapping[str, t.Mapping[str, t.Any]]] = None,
44244424
scroll: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
@@ -5359,7 +5359,7 @@ async def search_shards(
53595359
master_timeout: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
53605360
preference: t.Optional[str] = None,
53615361
pretty: t.Optional[bool] = None,
5362-
routing: t.Optional[str] = None,
5362+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
53635363
) -> ObjectApiResponse[t.Any]:
53645364
"""
53655365
.. raw:: html
@@ -5468,7 +5468,7 @@ async def search_template(
54685468
profile: t.Optional[bool] = None,
54695469
project_routing: t.Optional[str] = None,
54705470
rest_total_hits_as_int: t.Optional[bool] = None,
5471-
routing: t.Optional[str] = None,
5471+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
54725472
scroll: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
54735473
search_type: t.Optional[
54745474
t.Union[str, t.Literal["dfs_query_then_fetch", "query_then_fetch"]]
@@ -5605,7 +5605,7 @@ async def search_template(
56055605
async def terms_enum(
56065606
self,
56075607
*,
5608-
index: str,
5608+
index: t.Union[str, t.Sequence[str]],
56095609
field: t.Optional[str] = None,
56105610
case_insensitive: t.Optional[bool] = None,
56115611
error_trace: t.Optional[bool] = None,
@@ -5731,7 +5731,7 @@ async def termvectors(
57315731
preference: t.Optional[str] = None,
57325732
pretty: t.Optional[bool] = None,
57335733
realtime: t.Optional[bool] = None,
5734-
routing: t.Optional[str] = None,
5734+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
57355735
term_statistics: t.Optional[bool] = None,
57365736
version: t.Optional[int] = None,
57375737
version_type: t.Optional[
@@ -5915,7 +5915,7 @@ async def update(
59155915
] = None,
59165916
require_alias: t.Optional[bool] = None,
59175917
retry_on_conflict: t.Optional[int] = None,
5918-
routing: t.Optional[str] = None,
5918+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
59195919
script: t.Optional[t.Mapping[str, t.Any]] = None,
59205920
scripted_upsert: t.Optional[bool] = None,
59215921
source: t.Optional[t.Union[bool, t.Mapping[str, t.Any]]] = None,
@@ -6095,7 +6095,7 @@ async def update_by_query(
60956095
refresh: t.Optional[bool] = None,
60966096
request_cache: t.Optional[bool] = None,
60976097
requests_per_second: t.Optional[float] = None,
6098-
routing: t.Optional[str] = None,
6098+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
60996099
script: t.Optional[t.Mapping[str, t.Any]] = None,
61006100
scroll: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
61016101
scroll_size: t.Optional[int] = None,

‎elasticsearch/_async/client/async_search.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -295,7 +295,7 @@ async def submit(
295295
t.Union[t.Mapping[str, t.Any], t.Sequence[t.Mapping[str, t.Any]]]
296296
] = None,
297297
rest_total_hits_as_int: t.Optional[bool] = None,
298-
routing: t.Optional[str] = None,
298+
routing: t.Optional[t.Union[str, t.Sequence[str]]] = None,
299299
runtime_mappings: t.Optional[t.Mapping[str, t.Mapping[str, t.Any]]] = None,
300300
script_fields: t.Optional[t.Mapping[str, t.Mapping[str, t.Any]]] = None,
301301
search_after: t.Optional[

‎elasticsearch/_async/client/cat.py‎

Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3310,10 +3310,20 @@ async def segments(
33103310
self,
33113311
*,
33123312
index: t.Optional[t.Union[str, t.Sequence[str]]] = None,
3313+
allow_closed: t.Optional[bool] = None,
3314+
allow_no_indices: t.Optional[bool] = None,
33133315
bytes: t.Optional[
33143316
t.Union[str, t.Literal["b", "gb", "kb", "mb", "pb", "tb"]]
33153317
] = None,
33163318
error_trace: t.Optional[bool] = None,
3319+
expand_wildcards: t.Optional[
3320+
t.Union[
3321+
t.Sequence[
3322+
t.Union[str, t.Literal["all", "closed", "hidden", "none", "open"]]
3323+
],
3324+
t.Union[str, t.Literal["all", "closed", "hidden", "none", "open"]],
3325+
]
3326+
] = None,
33173327
filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
33183328
format: t.Optional[str] = None,
33193329
h: t.Optional[
@@ -3364,6 +3374,8 @@ async def segments(
33643374
] = None,
33653375
help: t.Optional[bool] = None,
33663376
human: t.Optional[bool] = None,
3377+
ignore_throttled: t.Optional[bool] = None,
3378+
ignore_unavailable: t.Optional[bool] = None,
33673379
local: t.Optional[bool] = None,
33683380
master_timeout: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
33693381
pretty: t.Optional[bool] = None,
@@ -3387,6 +3399,14 @@ async def segments(
33873399
:param index: A comma-separated list of data streams, indices, and aliases used
33883400
to limit the request. Supports wildcards (`*`). To target all data streams
33893401
and indices, omit this parameter or use `*` or `_all`.
3402+
:param allow_closed: If true, allow closed indices to be returned in the response
3403+
otherwise if false, keep the legacy behaviour of throwing an exception if
3404+
index pattern matches closed indices
3405+
:param allow_no_indices: If false, the request returns an error if any wildcard
3406+
expression, index alias, or _all value targets only missing or closed indices.
3407+
This behavior applies even if the request targets other open indices. For
3408+
example, a request targeting foo*,bar* returns an error if an index starts
3409+
with foo but no index starts with bar.
33903410
:param bytes: Sets the units for columns that contain a byte-size value. Note
33913411
that byte-size value units work in terms of powers of 1024. For instance
33923412
`1kb` means 1024 bytes, not 1000 bytes. If omitted, byte-size values are
@@ -3395,12 +3415,20 @@ async def segments(
33953415
least `1.0`. If given, byte-size values are rendered as an integer with no
33963416
suffix, representing the value of the column in the chosen unit. Values that
33973417
are not an exact multiple of the chosen unit are rounded down.
3418+
:param expand_wildcards: Type of index that wildcard expressions can match. If
3419+
the request can target data streams, this argument determines whether wildcard
3420+
expressions match hidden data streams. Supports comma-separated values, such
3421+
as open,hidden.
33983422
:param format: Specifies the format to return the columnar data in, can be set
33993423
to `text`, `json`, `cbor`, `yaml`, or `smile`.
34003424
:param h: A comma-separated list of columns names to display. It supports simple
34013425
wildcards.
34023426
:param help: When set to `true` will output available columns. This option can't
34033427
be combined with any other query string option.
3428+
:param ignore_throttled: If true, concrete, expanded or aliased indices are ignored
3429+
when frozen.
3430+
:param ignore_unavailable: If true, missing or closed indices are not included
3431+
in the response.
34043432
:param local: If `true`, the request computes the list of selected nodes from
34053433
the local cluster state. If `false` the list of selected nodes are computed
34063434
from the cluster state of the master node. In both cases the coordinating
@@ -3425,10 +3453,16 @@ async def segments(
34253453
__path_parts = {}
34263454
__path = "/_cat/segments"
34273455
__query: t.Dict[str, t.Any] = {}
3456+
if allow_closed is not None:
3457+
__query["allow_closed"] = allow_closed
3458+
if allow_no_indices is not None:
3459+
__query["allow_no_indices"] = allow_no_indices
34283460
if bytes is not None:
34293461
__query["bytes"] = bytes
34303462
if error_trace is not None:
34313463
__query["error_trace"] = error_trace
3464+
if expand_wildcards is not None:
3465+
__query["expand_wildcards"] = expand_wildcards
34323466
if filter_path is not None:
34333467
__query["filter_path"] = filter_path
34343468
if format is not None:
@@ -3439,6 +3473,10 @@ async def segments(
34393473
__query["help"] = help
34403474
if human is not None:
34413475
__query["human"] = human
3476+
if ignore_throttled is not None:
3477+
__query["ignore_throttled"] = ignore_throttled
3478+
if ignore_unavailable is not None:
3479+
__query["ignore_unavailable"] = ignore_unavailable
34423480
if local is not None:
34433481
__query["local"] = local
34443482
if master_timeout is not None:

‎elasticsearch/_async/client/cluster.py‎

Lines changed: 34 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1068,7 +1068,40 @@ async def reroute(
10681068
async def state(
10691069
self,
10701070
*,
1071-
metric: t.Optional[t.Union[str, t.Sequence[str]]] = None,
1071+
metric: t.Optional[
1072+
t.Union[
1073+
t.Sequence[
1074+
t.Union[
1075+
str,
1076+
t.Literal[
1077+
"_all",
1078+
"blocks",
1079+
"customs",
1080+
"master_node",
1081+
"metadata",
1082+
"nodes",
1083+
"routing_nodes",
1084+
"routing_table",
1085+
"version",
1086+
],
1087+
]
1088+
],
1089+
t.Union[
1090+
str,
1091+
t.Literal[
1092+
"_all",
1093+
"blocks",
1094+
"customs",
1095+
"master_node",
1096+
"metadata",
1097+
"nodes",
1098+
"routing_nodes",
1099+
"routing_table",
1100+
"version",
1101+
],
1102+
],
1103+
]
1104+
] = None,
10721105
index: t.Optional[t.Union[str, t.Sequence[str]]] = None,
10731106
allow_no_indices: t.Optional[bool] = None,
10741107
error_trace: t.Optional[bool] = None,

‎elasticsearch/_async/client/eql.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -296,7 +296,7 @@ async def search(
296296
Defaults to 10
297297
:param tiebreaker_field: Field used to sort hits with the same timestamp in ascending
298298
order
299-
:param timestamp_field: Field containing event timestamp. Default "@timestamp"
299+
:param timestamp_field: Field containing event timestamp.
300300
:param wait_for_completion_timeout:
301301
"""
302302
if index in SKIP_IN_PATH:

0 commit comments

Comments
 (0)