Update APIs on master

Author: sethmlarson

elasticsearch/_async/client/indices.py

@@ -1241,7 +1241,8 @@ async def delete_data_stream(self, name, params=None, headers=None):
  Deletes a data stream.
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/data-streams.html>`_
 
- :arg name: The name of the data stream
+ :arg name: A comma-separated list of data streams to delete; use
+ `*` to delete all data streams
  """
  if name in SKIP_IN_PATH:
  raise ValueError("Empty value passed for a required argument 'name'.")
@@ -1370,8 +1371,8 @@ async def get_data_stream(self, name=None, params=None, headers=None):
  Returns data streams.
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/data-streams.html>`_
 
- :arg name: The name or wildcard expression of the requested data
- streams
+ :arg name: A comma-separated list of data streams to get; use
+ `*` to get all data streams
  """
  return await self.transport.perform_request(
  "GET", _make_path("_data_stream", name), params=params, headers=headers
@@ -1419,3 +1420,37 @@ async def resolve_index(self, name, params=None, headers=None):
  return await self.transport.perform_request(
  "GET", _make_path("_resolve", "index", name), params=params, headers=headers
  )
+
+ @query_params(
+ "allow_no_indices",
+ "expand_wildcards",
+ "ignore_unavailable",
+ "master_timeout",
+ "timeout",
+ )
+ async def add_block(self, index, block, params=None, headers=None):
+ """
+ Adds a block to an index.
+ `<https://www.elastic.co/guide/en/elasticsearch/reference/master/indices-blocks.html>`_
+
+ :arg index: A comma separated list of indices to add a block to
+ :arg block: The block to add (one of read, write, read_only or
+ metadata)
+ :arg allow_no_indices: Whether to ignore if a wildcard indices
+ expression resolves into no concrete indices. (This includes `_all`
+ string or when no indices have been specified)
+ :arg expand_wildcards: Whether to expand wildcard expression to
+ concrete indices that are open, closed or both. Valid choices: open,
+ closed, hidden, none, all Default: open
+ :arg ignore_unavailable: Whether specified concrete indices
+ should be ignored when unavailable (missing or closed)
+ :arg master_timeout: Specify timeout for connection to master
+ :arg timeout: Explicit operation timeout
+ """
+ for param in (index, block):
+ if param in SKIP_IN_PATH:
+ raise ValueError("Empty value passed for a required argument.")
+
+ return await self.transport.perform_request(
+ "PUT", _make_path(index, "_block", block), params=params, headers=headers
+ )

elasticsearch/_async/client/ml.py

@@ -1529,3 +1529,24 @@ async def update_model_snapshot(
  headers=headers,
  body=body,
  )
+
+ @query_params()
+ async def update_data_frame_analytics(self, id, body, params=None, headers=None):
+ """
+ Updates certain properties of a data frame analytics job.
+ `<https://www.elastic.co/guide/en/elasticsearch/reference/master/update-dfanalytics.html>`_
+
+ :arg id: The ID of the data frame analytics to update
+ :arg body: The data frame analytics settings to update
+ """
+ for param in (id, body):
+ if param in SKIP_IN_PATH:
+ raise ValueError("Empty value passed for a required argument.")
+
+ return await self.transport.perform_request(
+ "POST",
+ _make_path("_ml", "data_frame", "analytics", id, "_update"),
+ params=params,
+ headers=headers,
+ body=body,
+ )

elasticsearch/_async/client/security.py

@@ -510,3 +510,23 @@ async def get_builtin_privileges(self, params=None, headers=None):
  return await self.transport.perform_request(
  "GET", "/_security/privilege/_builtin", params=params, headers=headers
  )
+
+ @query_params()
+ async def clear_cached_privileges(self, application, params=None, headers=None):
+ """
+ Evicts application privileges from the native application privileges cache.
+ `<https://www.elastic.co/guide/en/elasticsearch/reference/master/security-api-clear-privilege-cache.html>`_
+
+ :arg application: A comma-separated list of application names
+ """
+ if application in SKIP_IN_PATH:
+ raise ValueError(
+ "Empty value passed for a required argument 'application'."
+ )
+
+ return await self.transport.perform_request(
+ "POST",
+ _make_path("_security", "privilege", application, "_clear_cache"),
+ params=params,
+ headers=headers,
+ )

elasticsearch/_async/client/xpack.py

@@ -23,12 +23,14 @@ def __getattr__(self, attr_name):
  return getattr(self.client, attr_name)
 
  # AUTO-GENERATED-API-DEFINITIONS #
- @query_params("categories")
+ @query_params("accept_enterprise", "categories")
  async def info(self, params=None, headers=None):
  """
  Retrieves information about the installed X-Pack features.
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/info-api.html>`_
 
+ :arg accept_enterprise: Supported for backwards compatibility
+ with 7.x. If this param is used it must be set to true
  :arg categories: Comma-separated list of info categories. Can be
  any of: build, license, features
  """

elasticsearch/client/indices.py

@@ -1239,7 +1239,8 @@ def delete_data_stream(self, name, params=None, headers=None):
  Deletes a data stream.
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/data-streams.html>`_
 
- :arg name: The name of the data stream
+ :arg name: A comma-separated list of data streams to delete; use
+ `*` to delete all data streams
  """
  if name in SKIP_IN_PATH:
  raise ValueError("Empty value passed for a required argument 'name'.")
@@ -1368,8 +1369,8 @@ def get_data_stream(self, name=None, params=None, headers=None):
  Returns data streams.
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/data-streams.html>`_
 
- :arg name: The name or wildcard expression of the requested data
- streams
+ :arg name: A comma-separated list of data streams to get; use
+ `*` to get all data streams
  """
  return self.transport.perform_request(
  "GET", _make_path("_data_stream", name), params=params, headers=headers
@@ -1417,3 +1418,37 @@ def resolve_index(self, name, params=None, headers=None):
  return self.transport.perform_request(
  "GET", _make_path("_resolve", "index", name), params=params, headers=headers
  )
+
+ @query_params(
+ "allow_no_indices",
+ "expand_wildcards",
+ "ignore_unavailable",
+ "master_timeout",
+ "timeout",
+ )
+ def add_block(self, index, block, params=None, headers=None):
+ """
+ Adds a block to an index.
+ `<https://www.elastic.co/guide/en/elasticsearch/reference/master/indices-blocks.html>`_
+
+ :arg index: A comma separated list of indices to add a block to
+ :arg block: The block to add (one of read, write, read_only or
+ metadata)
+ :arg allow_no_indices: Whether to ignore if a wildcard indices
+ expression resolves into no concrete indices. (This includes `_all`
+ string or when no indices have been specified)
+ :arg expand_wildcards: Whether to expand wildcard expression to
+ concrete indices that are open, closed or both. Valid choices: open,
+ closed, hidden, none, all Default: open
+ :arg ignore_unavailable: Whether specified concrete indices
+ should be ignored when unavailable (missing or closed)
+ :arg master_timeout: Specify timeout for connection to master
+ :arg timeout: Explicit operation timeout
+ """
+ for param in (index, block):
+ if param in SKIP_IN_PATH:
+ raise ValueError("Empty value passed for a required argument.")
+
+ return self.transport.perform_request(
+ "PUT", _make_path(index, "_block", block), params=params, headers=headers
+ )

elasticsearch/client/ml.py

@@ -1515,3 +1515,24 @@ def update_model_snapshot(
  headers=headers,
  body=body,
  )
+
+ @query_params()
+ def update_data_frame_analytics(self, id, body, params=None, headers=None):
+ """
+ Updates certain properties of a data frame analytics job.
+ `<https://www.elastic.co/guide/en/elasticsearch/reference/master/update-dfanalytics.html>`_
+
+ :arg id: The ID of the data frame analytics to update
+ :arg body: The data frame analytics settings to update
+ """
+ for param in (id, body):
+ if param in SKIP_IN_PATH:
+ raise ValueError("Empty value passed for a required argument.")
+
+ return self.transport.perform_request(
+ "POST",
+ _make_path("_ml", "data_frame", "analytics", id, "_update"),
+ params=params,
+ headers=headers,
+ body=body,
+ )

elasticsearch/client/security.py

@@ -508,3 +508,23 @@ def get_builtin_privileges(self, params=None, headers=None):
  return self.transport.perform_request(
  "GET", "/_security/privilege/_builtin", params=params, headers=headers
  )
+
+ @query_params()
+ def clear_cached_privileges(self, application, params=None, headers=None):
+ """
+ Evicts application privileges from the native application privileges cache.
+ `<https://www.elastic.co/guide/en/elasticsearch/reference/master/security-api-clear-privilege-cache.html>`_
+
+ :arg application: A comma-separated list of application names
+ """
+ if application in SKIP_IN_PATH:
+ raise ValueError(
+ "Empty value passed for a required argument 'application'."
+ )
+
+ return self.transport.perform_request(
+ "POST",
+ _make_path("_security", "privilege", application, "_clear_cache"),
+ params=params,
+ headers=headers,
+ )

elasticsearch/client/xpack.py

@@ -23,12 +23,14 @@ def __getattr__(self, attr_name):
  return getattr(self.client, attr_name)
 
  # AUTO-GENERATED-API-DEFINITIONS #
- @query_params("categories")
+ @query_params("accept_enterprise", "categories")
  def info(self, params=None, headers=None):
  """
  Retrieves information about the installed X-Pack features.
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/info-api.html>`_
 
+ :arg accept_enterprise: Supported for backwards compatibility
+ with 7.x. If this param is used it must be set to true
  :arg categories: Comma-separated list of info categories. Can be
  any of: build, license, features
  """