Generate cat client from API specs (#529)

Signed-off-by: saimedhi <[email protected]>
This commit is contained in:
Sai Medhini Reddy Maryada
2023-10-09 17:55:51 -04:00
committed by GitHub
parent e4c59e4732
commit 388fb9d983
5 changed files with 861 additions and 618 deletions
+1
View File
@@ -10,6 +10,7 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
- Generate `ingest` client from API specs ([#513](https://github.com/opensearch-project/opensearch-py/pull/513))
- Generate `dangling_indices` client from API specs ([#511](https://github.com/opensearch-project/opensearch-py/pull/511))
- Generate `nodes` client from API specs ([#514](https://github.com/opensearch-project/opensearch-py/pull/514))
- Generate `cat` client from API specs ([#529](https://github.com/opensearch-project/opensearch-py/pull/529))
### Deprecated
- Deprecated point-in-time APIs (list_all_point_in_time, create_point_in_time, delete_point_in_time) and Security Client APIs (health_check and update_audit_config) ([#502](https://github.com/opensearch-project/opensearch-py/pull/502))
### Removed
File diff suppressed because it is too large Load Diff
+65 -20
View File
@@ -24,6 +24,15 @@
# specific language governing permissions and limitations
# under the License.
# ----------------------------------------------------
# THIS CODE IS GENERATED AND MANUAL EDITS WILL BE LOST.
#
# To contribute, kindly make essential modifications through either the "opensearch-py client generator":
# https://github.com/opensearch-project/opensearch-py/blob/main/utils/generate-api.py
# or the "OpenSearch API specification" available at:
# https://github.com/opensearch-project/opensearch-api-specification/blob/main/OpenSearch.openapi.json
# -----------------------------------------------------
from typing import Any, Collection, MutableMapping, Optional, Tuple, Union
from .utils import NamespacedClient
@@ -57,12 +66,12 @@ class CatClient(NamespacedClient):
*,
node_id: Optional[Any] = ...,
bytes: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -143,6 +152,7 @@ class CatClient(NamespacedClient):
*,
index: Optional[Any] = ...,
bytes: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
expand_wildcards: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
@@ -151,7 +161,6 @@ class CatClient(NamespacedClient):
include_unloaded_segments: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
pri: Optional[Any] = ...,
s: Optional[Any] = ...,
time: Optional[Any] = ...,
@@ -171,12 +180,12 @@ class CatClient(NamespacedClient):
async def master(
self,
*,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -194,11 +203,12 @@ class CatClient(NamespacedClient):
async def cluster_manager(
self,
*,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -217,14 +227,13 @@ class CatClient(NamespacedClient):
self,
*,
bytes: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
full_id: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
include_unloaded_segments: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
time: Optional[Any] = ...,
v: Optional[Any] = ...,
@@ -270,12 +279,12 @@ class CatClient(NamespacedClient):
*,
index: Optional[Any] = ...,
bytes: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
time: Optional[Any] = ...,
v: Optional[Any] = ...,
@@ -296,9 +305,11 @@ class CatClient(NamespacedClient):
*,
index: Optional[Any] = ...,
bytes: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -316,12 +327,12 @@ class CatClient(NamespacedClient):
async def pending_tasks(
self,
*,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
time: Optional[Any] = ...,
v: Optional[Any] = ...,
@@ -341,12 +352,12 @@ class CatClient(NamespacedClient):
self,
*,
thread_pool_patterns: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
size: Optional[Any] = ...,
v: Optional[Any] = ...,
@@ -387,13 +398,12 @@ class CatClient(NamespacedClient):
async def plugins(
self,
*,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
include_bootstrap: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -411,12 +421,12 @@ class CatClient(NamespacedClient):
async def nodeattrs(
self,
*,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -434,12 +444,12 @@ class CatClient(NamespacedClient):
async def repositories(
self,
*,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -458,12 +468,12 @@ class CatClient(NamespacedClient):
self,
*,
repository: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
ignore_unavailable: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
time: Optional[Any] = ...,
v: Optional[Any] = ...,
@@ -508,12 +518,12 @@ class CatClient(NamespacedClient):
self,
*,
name: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -528,17 +538,52 @@ class CatClient(NamespacedClient):
params: Optional[MutableMapping[str, Any]] = ...,
headers: Optional[MutableMapping[str, str]] = ...,
) -> Any: ...
async def transforms(
async def all_pit_segments(
self,
*,
transform_id: Optional[Any] = ...,
allow_no_match: Optional[Any] = ...,
pretty: Optional[bool] = ...,
human: Optional[bool] = ...,
error_trace: Optional[bool] = ...,
format: Optional[str] = ...,
filter_path: Optional[Union[str, Collection[str]]] = ...,
request_timeout: Optional[Union[int, float]] = ...,
ignore: Optional[Union[int, Collection[int]]] = ...,
opaque_id: Optional[str] = ...,
http_auth: Optional[Union[str, Tuple[str, str]]] = ...,
api_key: Optional[Union[str, Tuple[str, str]]] = ...,
params: Optional[MutableMapping[str, Any]] = ...,
headers: Optional[MutableMapping[str, str]] = ...,
) -> Any: ...
async def pit_segments(
self,
*,
body: Optional[Any] = ...,
pretty: Optional[bool] = ...,
human: Optional[bool] = ...,
error_trace: Optional[bool] = ...,
format: Optional[str] = ...,
filter_path: Optional[Union[str, Collection[str]]] = ...,
request_timeout: Optional[Union[int, float]] = ...,
ignore: Optional[Union[int, Collection[int]]] = ...,
opaque_id: Optional[str] = ...,
http_auth: Optional[Union[str, Tuple[str, str]]] = ...,
api_key: Optional[Union[str, Tuple[str, str]]] = ...,
params: Optional[MutableMapping[str, Any]] = ...,
headers: Optional[MutableMapping[str, str]] = ...,
) -> Any: ...
async def segment_replication(
self,
*,
index: Optional[Any] = ...,
active_only: Optional[Any] = ...,
bytes: Optional[Any] = ...,
completed_only: Optional[Any] = ...,
detailed: Optional[Any] = ...,
format: Optional[Any] = ...,
from_: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
s: Optional[Any] = ...,
size: Optional[Any] = ...,
shards: Optional[Any] = ...,
time: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
+365 -288
View File
File diff suppressed because it is too large Load Diff
+65 -20
View File
@@ -24,6 +24,15 @@
# specific language governing permissions and limitations
# under the License.
# ----------------------------------------------------
# THIS CODE IS GENERATED AND MANUAL EDITS WILL BE LOST.
#
# To contribute, kindly make essential modifications through either the "opensearch-py client generator":
# https://github.com/opensearch-project/opensearch-py/blob/main/utils/generate-api.py
# or the "OpenSearch API specification" available at:
# https://github.com/opensearch-project/opensearch-api-specification/blob/main/OpenSearch.openapi.json
# -----------------------------------------------------
from typing import Any, Collection, MutableMapping, Optional, Tuple, Union
from .utils import NamespacedClient
@@ -57,12 +66,12 @@ class CatClient(NamespacedClient):
*,
node_id: Optional[Any] = ...,
bytes: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -143,6 +152,7 @@ class CatClient(NamespacedClient):
*,
index: Optional[Any] = ...,
bytes: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
expand_wildcards: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
@@ -151,7 +161,6 @@ class CatClient(NamespacedClient):
include_unloaded_segments: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
pri: Optional[Any] = ...,
s: Optional[Any] = ...,
time: Optional[Any] = ...,
@@ -171,12 +180,12 @@ class CatClient(NamespacedClient):
def master(
self,
*,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -194,11 +203,12 @@ class CatClient(NamespacedClient):
def cluster_manager(
self,
*,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -217,14 +227,13 @@ class CatClient(NamespacedClient):
self,
*,
bytes: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
full_id: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
include_unloaded_segments: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
time: Optional[Any] = ...,
v: Optional[Any] = ...,
@@ -270,12 +279,12 @@ class CatClient(NamespacedClient):
*,
index: Optional[Any] = ...,
bytes: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
time: Optional[Any] = ...,
v: Optional[Any] = ...,
@@ -296,9 +305,11 @@ class CatClient(NamespacedClient):
*,
index: Optional[Any] = ...,
bytes: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -316,12 +327,12 @@ class CatClient(NamespacedClient):
def pending_tasks(
self,
*,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
time: Optional[Any] = ...,
v: Optional[Any] = ...,
@@ -341,12 +352,12 @@ class CatClient(NamespacedClient):
self,
*,
thread_pool_patterns: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
size: Optional[Any] = ...,
v: Optional[Any] = ...,
@@ -387,13 +398,12 @@ class CatClient(NamespacedClient):
def plugins(
self,
*,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
include_bootstrap: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -411,12 +421,12 @@ class CatClient(NamespacedClient):
def nodeattrs(
self,
*,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -434,12 +444,12 @@ class CatClient(NamespacedClient):
def repositories(
self,
*,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -458,12 +468,12 @@ class CatClient(NamespacedClient):
self,
*,
repository: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
ignore_unavailable: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
time: Optional[Any] = ...,
v: Optional[Any] = ...,
@@ -508,12 +518,12 @@ class CatClient(NamespacedClient):
self,
*,
name: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
format: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
local: Optional[Any] = ...,
master_timeout: Optional[Any] = ...,
cluster_manager_timeout: Optional[Any] = ...,
s: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,
@@ -528,17 +538,52 @@ class CatClient(NamespacedClient):
params: Optional[MutableMapping[str, Any]] = ...,
headers: Optional[MutableMapping[str, str]] = ...,
) -> Any: ...
def transforms(
def all_pit_segments(
self,
*,
transform_id: Optional[Any] = ...,
allow_no_match: Optional[Any] = ...,
pretty: Optional[bool] = ...,
human: Optional[bool] = ...,
error_trace: Optional[bool] = ...,
format: Optional[str] = ...,
filter_path: Optional[Union[str, Collection[str]]] = ...,
request_timeout: Optional[Union[int, float]] = ...,
ignore: Optional[Union[int, Collection[int]]] = ...,
opaque_id: Optional[str] = ...,
http_auth: Optional[Union[str, Tuple[str, str]]] = ...,
api_key: Optional[Union[str, Tuple[str, str]]] = ...,
params: Optional[MutableMapping[str, Any]] = ...,
headers: Optional[MutableMapping[str, str]] = ...,
) -> Any: ...
def pit_segments(
self,
*,
body: Optional[Any] = ...,
pretty: Optional[bool] = ...,
human: Optional[bool] = ...,
error_trace: Optional[bool] = ...,
format: Optional[str] = ...,
filter_path: Optional[Union[str, Collection[str]]] = ...,
request_timeout: Optional[Union[int, float]] = ...,
ignore: Optional[Union[int, Collection[int]]] = ...,
opaque_id: Optional[str] = ...,
http_auth: Optional[Union[str, Tuple[str, str]]] = ...,
api_key: Optional[Union[str, Tuple[str, str]]] = ...,
params: Optional[MutableMapping[str, Any]] = ...,
headers: Optional[MutableMapping[str, str]] = ...,
) -> Any: ...
def segment_replication(
self,
*,
index: Optional[Any] = ...,
active_only: Optional[Any] = ...,
bytes: Optional[Any] = ...,
completed_only: Optional[Any] = ...,
detailed: Optional[Any] = ...,
format: Optional[Any] = ...,
from_: Optional[Any] = ...,
h: Optional[Any] = ...,
help: Optional[Any] = ...,
s: Optional[Any] = ...,
size: Optional[Any] = ...,
shards: Optional[Any] = ...,
time: Optional[Any] = ...,
v: Optional[Any] = ...,
pretty: Optional[bool] = ...,