Skip to content

Commit

Permalink
Auto-generated code for main (#90)
Browse files Browse the repository at this point in the history 
Auto-generated API code
  • Loading branch information
@elasticmachine
elasticmachine authored Oct 14, 2024
1 parent de2fbd4 commit 86e050b
Show file tree
Hide file tree
Showing 6 changed files with 630 additions and 392 deletions.
36 changes: 0 additions & 36 deletions elasticsearch_serverless/_async/client/enrich.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -213,39 +213,3 @@ async def put_policy(
endpoint_id="enrich.put_policy",
path_parts=__path_parts,
)

@_rewrite_parameters()
async def stats(
self,
*,
error_trace: t.Optional[bool] = None,
filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
human: t.Optional[bool] = None,
pretty: t.Optional[bool] = None,
) -> ObjectApiResponse[t.Any]:
"""
Get enrich stats. Returns enrich coordinator statistics and information about
enrich policies that are currently executing.
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/enrich-stats-api.html>`_
"""
__path_parts: t.Dict[str, str] = {}
__path = "/_enrich/_stats"
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
__query["error_trace"] = error_trace
if filter_path is not None:
__query["filter_path"] = filter_path
if human is not None:
__query["human"] = human
if pretty is not None:
__query["pretty"] = pretty
__headers = {"accept": "application/json"}
return await self.perform_request( # type: ignore[return-value]
"GET",
__path,
params=__query,
headers=__headers,
endpoint_id="enrich.stats",
path_parts=__path_parts,
)
160 changes: 0 additions & 160 deletions elasticsearch_serverless/_async/client/indices.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -487,68 +487,6 @@ async def delete_alias(
path_parts=__path_parts,
)

@_rewrite_parameters()
async def delete_data_lifecycle(
self,
*,
name: t.Union[str, t.Sequence[str]],
error_trace: t.Optional[bool] = None,
expand_wildcards: t.Optional[
t.Union[
t.Sequence[
t.Union[str, t.Literal["all", "closed", "hidden", "none", "open"]]
],
t.Union[str, t.Literal["all", "closed", "hidden", "none", "open"]],
]
] = None,
filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
human: t.Optional[bool] = None,
master_timeout: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
pretty: t.Optional[bool] = None,
timeout: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
) -> ObjectApiResponse[t.Any]:
"""
Delete data stream lifecycles. Removes the data stream lifecycle from a data
stream, rendering it not managed by the data stream lifecycle.
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/data-streams-delete-lifecycle.html>`_
:param name: A comma-separated list of data streams of which the data stream
lifecycle will be deleted; use `*` to get all data streams
:param expand_wildcards: Whether wildcard expressions should get expanded to
open or closed indices (default: open)
:param master_timeout: Specify timeout for connection to master
:param timeout: Explicit timestamp for the document
"""
if name in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'name'")
__path_parts: t.Dict[str, str] = {"name": _quote(name)}
__path = f'/_data_stream/{__path_parts["name"]}/_lifecycle'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
__query["error_trace"] = error_trace
if expand_wildcards is not None:
__query["expand_wildcards"] = expand_wildcards
if filter_path is not None:
__query["filter_path"] = filter_path
if human is not None:
__query["human"] = human
if master_timeout is not None:
__query["master_timeout"] = master_timeout
if pretty is not None:
__query["pretty"] = pretty
if timeout is not None:
__query["timeout"] = timeout
__headers = {"accept": "application/json"}
return await self.perform_request( # type: ignore[return-value]
"DELETE",
__path,
params=__query,
headers=__headers,
endpoint_id="indices.delete_data_lifecycle",
path_parts=__path_parts,
)

@_rewrite_parameters()
async def delete_data_stream(
self,
Expand Down Expand Up @@ -2196,104 +2134,6 @@ async def put_settings(
path_parts=__path_parts,
)

@_rewrite_parameters(
body_fields=(
"aliases",
"index_patterns",
"mappings",
"order",
"settings",
"version",
),
)
async def put_template(
self,
*,
name: str,
aliases: t.Optional[t.Mapping[str, t.Mapping[str, t.Any]]] = None,
cause: t.Optional[str] = None,
create: t.Optional[bool] = None,
error_trace: t.Optional[bool] = None,
filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
human: t.Optional[bool] = None,
index_patterns: t.Optional[t.Union[str, t.Sequence[str]]] = None,
mappings: t.Optional[t.Mapping[str, t.Any]] = None,
master_timeout: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
order: t.Optional[int] = None,
pretty: t.Optional[bool] = None,
settings: t.Optional[t.Mapping[str, t.Any]] = None,
version: t.Optional[int] = None,
body: t.Optional[t.Dict[str, t.Any]] = None,
) -> ObjectApiResponse[t.Any]:
"""
Create or update an index template. Index templates define settings, mappings,
and aliases that can be applied automatically to new indices.
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/indices-templates-v1.html>`_
:param name: The name of the template
:param aliases: Aliases for the index.
:param cause:
:param create: If true, this request cannot replace or update existing index
templates.
:param index_patterns: Array of wildcard expressions used to match the names
of indices during creation.
:param mappings: Mapping for fields in the index.
: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
returns an error.
:param order: Order in which Elasticsearch applies this template if index matches
multiple templates. Templates with lower 'order' values are merged first.
Templates with higher 'order' values are merged later, overriding templates
with lower values.
:param settings: Configuration options for the index.
:param version: Version number used to manage index templates externally. This
number is not automatically generated by Elasticsearch.
"""
if name in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'name'")
__path_parts: t.Dict[str, str] = {"name": _quote(name)}
__path = f'/_template/{__path_parts["name"]}'
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
if cause is not None:
__query["cause"] = cause
if create is not None:
__query["create"] = create
if error_trace is not None:
__query["error_trace"] = error_trace
if filter_path is not None:
__query["filter_path"] = filter_path
if human is not None:
__query["human"] = human
if master_timeout is not None:
__query["master_timeout"] = master_timeout
if pretty is not None:
__query["pretty"] = pretty
if not __body:
if aliases is not None:
__body["aliases"] = aliases
if index_patterns is not None:
__body["index_patterns"] = index_patterns
if mappings is not None:
__body["mappings"] = mappings
if order is not None:
__body["order"] = order
if settings is not None:
__body["settings"] = settings
if version is not None:
__body["version"] = version
__headers = {"accept": "application/json", "content-type": "application/json"}
return await self.perform_request( # type: ignore[return-value]
"PUT",
__path,
params=__query,
headers=__headers,
body=__body,
endpoint_id="indices.put_template",
path_parts=__path_parts,
)

@_rewrite_parameters()
async def refresh(
self,
Expand Down
Loading

0 comments on commit 86e050b

Please sign in to comment.