Skip to content

Commit cb389d9

Browse files
Auto-generated API code (#2729)
1 parent d5ce56f commit cb389d9

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

54 files changed

+4002
-556
lines changed

elasticsearch/_async/client/__init__.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -626,12 +626,14 @@ async def bulk(
626626
error_trace: t.Optional[bool] = None,
627627
filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
628628
human: t.Optional[bool] = None,
629+
list_executed_pipelines: t.Optional[bool] = None,
629630
pipeline: t.Optional[str] = None,
630631
pretty: t.Optional[bool] = None,
631632
refresh: t.Optional[
632633
t.Union[bool, str, t.Literal["false", "true", "wait_for"]]
633634
] = None,
634635
require_alias: t.Optional[bool] = None,
636+
require_data_stream: t.Optional[bool] = None,
635637
routing: t.Optional[str] = None,
636638
source: t.Optional[t.Union[bool, t.Union[str, t.Sequence[str]]]] = None,
637639
source_excludes: t.Optional[t.Union[str, t.Sequence[str]]] = None,
@@ -651,6 +653,8 @@ async def bulk(
651653
:param operations:
652654
:param index: Name of the data stream, index, or index alias to perform bulk
653655
actions on.
656+
:param list_executed_pipelines: If `true`, the response will include the ingest
657+
pipelines that were executed for each index or create.
654658
:param pipeline: ID of the pipeline to use to preprocess incoming documents.
655659
If the index has a default ingest pipeline specified, then setting the value
656660
to `_none` disables the default ingest pipeline for this request. If a final
@@ -661,6 +665,8 @@ async def bulk(
661665
make this operation visible to search, if `false` do nothing with refreshes.
662666
Valid values: `true`, `false`, `wait_for`.
663667
:param require_alias: If `true`, the request’s actions must target an index alias.
668+
:param require_data_stream: If `true`, the request's actions must target a data
669+
stream (existing or to-be-created).
664670
:param routing: Custom value used to route operations to a specific shard.
665671
:param source: `true` or `false` to return the `_source` field or not, or a list
666672
of fields to return.
@@ -694,6 +700,8 @@ async def bulk(
694700
__query["filter_path"] = filter_path
695701
if human is not None:
696702
__query["human"] = human
703+
if list_executed_pipelines is not None:
704+
__query["list_executed_pipelines"] = list_executed_pipelines
697705
if pipeline is not None:
698706
__query["pipeline"] = pipeline
699707
if pretty is not None:
@@ -702,6 +710,8 @@ async def bulk(
702710
__query["refresh"] = refresh
703711
if require_alias is not None:
704712
__query["require_alias"] = require_alias
713+
if require_data_stream is not None:
714+
__query["require_data_stream"] = require_data_stream
705715
if routing is not None:
706716
__query["routing"] = routing
707717
if source is not None:

elasticsearch/_async/client/cat.py

Lines changed: 71 additions & 90 deletions
Large diffs are not rendered by default.

elasticsearch/_async/client/ccr.py

Lines changed: 70 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,8 @@ async def delete_auto_follow_pattern(
3636
pretty: t.Optional[bool] = None,
3737
) -> ObjectApiResponse[t.Any]:
3838
"""
39-
Deletes auto-follow patterns.
39+
Delete auto-follow patterns. Delete a collection of cross-cluster replication
40+
auto-follow patterns.
4041
4142
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/ccr-delete-auto-follow-pattern.html>`_
4243
@@ -111,7 +112,10 @@ async def follow(
111112
body: t.Optional[t.Dict[str, t.Any]] = None,
112113
) -> ObjectApiResponse[t.Any]:
113114
"""
114-
Creates a new follower index configured to follow the referenced leader index.
115+
Create a follower. Create a cross-cluster replication follower index that follows
116+
a specific leader index. When the API returns, the follower index exists and
117+
cross-cluster replication starts replicating operations from the leader index
118+
to the follower index.
115119
116120
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/ccr-put-follow.html>`_
117121
@@ -231,8 +235,10 @@ async def follow_info(
231235
pretty: t.Optional[bool] = None,
232236
) -> ObjectApiResponse[t.Any]:
233237
"""
234-
Retrieves information about all follower indices, including parameters and status
235-
for each follower index
238+
Get follower information. Get information about all cross-cluster replication
239+
follower indices. For example, the results include follower index names, leader
240+
index names, replication options, and whether the follower indices are active
241+
or paused.
236242
237243
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/ccr-get-follow-info.html>`_
238244
@@ -273,8 +279,9 @@ async def follow_stats(
273279
pretty: t.Optional[bool] = None,
274280
) -> ObjectApiResponse[t.Any]:
275281
"""
276-
Retrieves follower stats. return shard-level stats about the following tasks
277-
associated with each shard for the specified indices.
282+
Get follower stats. Get cross-cluster replication follower stats. The API returns
283+
shard-level stats about the "following tasks" associated with each shard for
284+
the specified indices.
278285
279286
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/ccr-get-follow-stats.html>`_
280287
@@ -327,7 +334,23 @@ async def forget_follower(
327334
body: t.Optional[t.Dict[str, t.Any]] = None,
328335
) -> ObjectApiResponse[t.Any]:
329336
"""
330-
Removes the follower retention leases from the leader.
337+
Forget a follower. Remove the cross-cluster replication follower retention leases
338+
from the leader. A following index takes out retention leases on its leader index.
339+
These leases are used to increase the likelihood that the shards of the leader
340+
index retain the history of operations that the shards of the following index
341+
need to run replication. When a follower index is converted to a regular index
342+
by the unfollow API (either by directly calling the API or by index lifecycle
343+
management tasks), these leases are removed. However, removal of the leases can
344+
fail, for example when the remote cluster containing the leader index is unavailable.
345+
While the leases will eventually expire on their own, their extended existence
346+
can cause the leader index to hold more history than necessary and prevent index
347+
lifecycle management from performing some operations on the leader index. This
348+
API exists to enable manually removing the leases when the unfollow API is unable
349+
to do so. NOTE: This API does not stop replication by a following index. If you
350+
use this API with a follower index that is still actively following, the following
351+
index will add back retention leases on the leader. The only purpose of this
352+
API is to handle the case of failure to remove the following retention leases
353+
after the unfollow API is invoked.
331354
332355
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/ccr-post-forget-follower.html>`_
333356
@@ -383,8 +406,7 @@ async def get_auto_follow_pattern(
383406
pretty: t.Optional[bool] = None,
384407
) -> ObjectApiResponse[t.Any]:
385408
"""
386-
Gets configured auto-follow patterns. Returns the specified auto-follow pattern
387-
collection.
409+
Get auto-follow patterns. Get cross-cluster replication auto-follow patterns.
388410
389411
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/ccr-get-auto-follow-pattern.html>`_
390412
@@ -428,7 +450,14 @@ async def pause_auto_follow_pattern(
428450
pretty: t.Optional[bool] = None,
429451
) -> ObjectApiResponse[t.Any]:
430452
"""
431-
Pauses an auto-follow pattern
453+
Pause an auto-follow pattern. Pause a cross-cluster replication auto-follow pattern.
454+
When the API returns, the auto-follow pattern is inactive. New indices that are
455+
created on the remote cluster and match the auto-follow patterns are ignored.
456+
You can resume auto-following with the resume auto-follow pattern API. When it
457+
resumes, the auto-follow pattern is active again and automatically configures
458+
follower indices for newly created indices on the remote cluster that match its
459+
patterns. Remote indices that were created while the pattern was paused will
460+
also be followed, unless they have been deleted or closed in the interim.
432461
433462
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/ccr-pause-auto-follow-pattern.html>`_
434463
@@ -469,8 +498,10 @@ async def pause_follow(
469498
pretty: t.Optional[bool] = None,
470499
) -> ObjectApiResponse[t.Any]:
471500
"""
472-
Pauses a follower index. The follower index will not fetch any additional operations
473-
from the leader index.
501+
Pause a follower. Pause a cross-cluster replication follower index. The follower
502+
index will not fetch any additional operations from the leader index. You can
503+
resume following with the resume follower API. You can pause and resume a follower
504+
index to change the configuration of the following task.
474505
475506
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/ccr-post-pause-follow.html>`_
476507
@@ -545,9 +576,14 @@ async def put_auto_follow_pattern(
545576
body: t.Optional[t.Dict[str, t.Any]] = None,
546577
) -> ObjectApiResponse[t.Any]:
547578
"""
548-
Creates a new named collection of auto-follow patterns against a specified remote
549-
cluster. Newly created indices on the remote cluster matching any of the specified
550-
patterns will be automatically configured as follower indices.
579+
Create or update auto-follow patterns. Create a collection of cross-cluster replication
580+
auto-follow patterns for a remote cluster. Newly created indices on the remote
581+
cluster that match any of the patterns are automatically configured as follower
582+
indices. Indices on the remote cluster that were created before the auto-follow
583+
pattern was created will not be auto-followed even if they match the pattern.
584+
This API can also be used to update auto-follow patterns. NOTE: Follower indices
585+
that were configured automatically before updating an auto-follow pattern will
586+
remain unchanged even if they do not match against the new patterns.
551587
552588
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/ccr-put-auto-follow-pattern.html>`_
553589
@@ -671,7 +707,11 @@ async def resume_auto_follow_pattern(
671707
pretty: t.Optional[bool] = None,
672708
) -> ObjectApiResponse[t.Any]:
673709
"""
674-
Resumes an auto-follow pattern that has been paused
710+
Resume an auto-follow pattern. Resume a cross-cluster replication auto-follow
711+
pattern that was paused. The auto-follow pattern will resume configuring following
712+
indices for newly created indices that match its patterns on the remote cluster.
713+
Remote indices created while the pattern was paused will also be followed unless
714+
they have been deleted or closed in the interim.
675715
676716
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/ccr-resume-auto-follow-pattern.html>`_
677717
@@ -736,7 +776,11 @@ async def resume_follow(
736776
body: t.Optional[t.Dict[str, t.Any]] = None,
737777
) -> ObjectApiResponse[t.Any]:
738778
"""
739-
Resumes a follower index that has been paused
779+
Resume a follower. Resume a cross-cluster replication follower index that was
780+
paused. The follower index could have been paused with the pause follower API.
781+
Alternatively it could be paused due to replication that cannot be retried due
782+
to failures during following tasks. When this API returns, the follower index
783+
will resume fetching operations from the leader index.
740784
741785
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/ccr-post-resume-follow.html>`_
742786
@@ -818,7 +862,8 @@ async def stats(
818862
pretty: t.Optional[bool] = None,
819863
) -> ObjectApiResponse[t.Any]:
820864
"""
821-
Gets all stats related to cross-cluster replication.
865+
Get cross-cluster replication stats. This API returns stats about auto-following
866+
and the same shard-level stats as the get follower stats API.
822867
823868
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/ccr-get-stats.html>`_
824869
"""
@@ -854,8 +899,13 @@ async def unfollow(
854899
pretty: t.Optional[bool] = None,
855900
) -> ObjectApiResponse[t.Any]:
856901
"""
857-
Stops the following task associated with a follower index and removes index metadata
858-
and settings associated with cross-cluster replication.
902+
Unfollow an index. Convert a cross-cluster replication follower index to a regular
903+
index. The API stops the following task associated with a follower index and
904+
removes index metadata and settings associated with cross-cluster replication.
905+
The follower index must be paused and closed before you call the unfollow API.
906+
NOTE: Currently cross-cluster replication does not support converting an existing
907+
regular index to a follower index. Converting a follower index to a regular index
908+
is an irreversible operation.
859909
860910
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/ccr-post-unfollow.html>`_
861911

0 commit comments

Comments
 (0)