API: Update APIs for Elasticsearch 7.10

Author: sethmlarson

elasticsearch/_async/client/ml.py

@@ -1413,7 +1413,7 @@ async def delete_trained_model(self, model_id, params=None, headers=None):
         """
         Deletes an existing trained inference model that is currently not referenced by
         an ingest pipeline.
-        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/delete-inference.html>`_
+        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/delete-trained-models.html>`_
 
         :arg model_id: The ID of the trained model to delete
         """
@@ -1422,7 +1422,7 @@ async def delete_trained_model(self, model_id, params=None, headers=None):
 
         return await self.transport.perform_request(
             "DELETE",
-            _make_path("_ml", "inference", model_id),
+            _make_path("_ml", "trained_models", model_id),
             params=params,
             headers=headers,
         )
@@ -1459,7 +1459,7 @@ async def explain_data_frame_analytics(
     async def get_trained_models(self, model_id=None, params=None, headers=None):
         """
         Retrieves configuration information for a trained inference model.
-        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/get-inference.html>`_
+        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/get-trained-models.html>`_
 
         :arg model_id: The ID of the trained models to fetch
         :arg allow_no_match: Whether to ignore if a wildcard expression
@@ -1488,7 +1488,7 @@ async def get_trained_models(self, model_id=None, params=None, headers=None):
 
         return await self.transport.perform_request(
             "GET",
-            _make_path("_ml", "inference", model_id),
+            _make_path("_ml", "trained_models", model_id),
             params=params,
             headers=headers,
         )
@@ -1497,7 +1497,7 @@ async def get_trained_models(self, model_id=None, params=None, headers=None):
     async def get_trained_models_stats(self, model_id=None, params=None, headers=None):
         """
         Retrieves usage information for trained inference models.
-        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/get-inference-stats.html>`_
+        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/get-trained-models-stats.html>`_
 
         :arg model_id: The ID of the trained models stats to fetch
         :arg allow_no_match: Whether to ignore if a wildcard expression
@@ -1513,7 +1513,7 @@ async def get_trained_models_stats(self, model_id=None, params=None, headers=Non
 
         return await self.transport.perform_request(
             "GET",
-            _make_path("_ml", "inference", model_id, "_stats"),
+            _make_path("_ml", "trained_models", model_id, "_stats"),
             params=params,
             headers=headers,
         )
@@ -1522,7 +1522,7 @@ async def get_trained_models_stats(self, model_id=None, params=None, headers=Non
     async def put_trained_model(self, model_id, body, params=None, headers=None):
         """
         Creates an inference trained model.
-        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/put-inference.html>`_
+        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/put-trained-models.html>`_
 
         :arg model_id: The ID of the trained models to store
         :arg body: The trained model configuration
@@ -1533,7 +1533,7 @@ async def put_trained_model(self, model_id, body, params=None, headers=None):
 
         return await self.transport.perform_request(
             "PUT",
-            _make_path("_ml", "inference", model_id),
+            _make_path("_ml", "trained_models", model_id),
             params=params,
             headers=headers,
             body=body,

elasticsearch/_async/client/security.py

@@ -530,3 +530,22 @@ async def clear_cached_privileges(self, application, params=None, headers=None):
             params=params,
             headers=headers,
         )
+
+    @query_params()
+    async def clear_api_key_cache(self, ids, params=None, headers=None):
+        """
+        Clear a subset or all entries from the API key cache.
+        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/security-api-clear-api-key-cache.html>`_
+
+        :arg ids: A comma-separated list of IDs of API keys to clear
+            from the cache
+        """
+        if ids in SKIP_IN_PATH:
+            raise ValueError("Empty value passed for a required argument 'ids'.")
+
+        return await self.transport.perform_request(
+            "POST",
+            _make_path("_security", "api_key", ids, "_clear_cache"),
+            params=params,
+            headers=headers,
+        )

elasticsearch/_async/client/security.pyi

@@ -418,3 +418,17 @@ class SecurityClient(NamespacedClient):
         params: Optional[MutableMapping[str, Any]] = ...,
         headers: Optional[MutableMapping[str, str]] = ...,
     ) -> Any: ...
+    async def clear_api_key_cache(
+        self,
+        ids: 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] = ...,
+        params: Optional[MutableMapping[str, Any]] = ...,
+        headers: Optional[MutableMapping[str, str]] = ...,
+    ) -> Any: ...

elasticsearch/client/ml.py

@@ -1399,7 +1399,7 @@ def delete_trained_model(self, model_id, params=None, headers=None):
         """
         Deletes an existing trained inference model that is currently not referenced by
         an ingest pipeline.
-        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/delete-inference.html>`_
+        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/delete-trained-models.html>`_
 
         :arg model_id: The ID of the trained model to delete
         """
@@ -1408,7 +1408,7 @@ def delete_trained_model(self, model_id, params=None, headers=None):
 
         return self.transport.perform_request(
             "DELETE",
-            _make_path("_ml", "inference", model_id),
+            _make_path("_ml", "trained_models", model_id),
             params=params,
             headers=headers,
         )
@@ -1445,7 +1445,7 @@ def explain_data_frame_analytics(
     def get_trained_models(self, model_id=None, params=None, headers=None):
         """
         Retrieves configuration information for a trained inference model.
-        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/get-inference.html>`_
+        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/get-trained-models.html>`_
 
         :arg model_id: The ID of the trained models to fetch
         :arg allow_no_match: Whether to ignore if a wildcard expression
@@ -1474,7 +1474,7 @@ def get_trained_models(self, model_id=None, params=None, headers=None):
 
         return self.transport.perform_request(
             "GET",
-            _make_path("_ml", "inference", model_id),
+            _make_path("_ml", "trained_models", model_id),
             params=params,
             headers=headers,
         )
@@ -1483,7 +1483,7 @@ def get_trained_models(self, model_id=None, params=None, headers=None):
     def get_trained_models_stats(self, model_id=None, params=None, headers=None):
         """
         Retrieves usage information for trained inference models.
-        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/get-inference-stats.html>`_
+        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/get-trained-models-stats.html>`_
 
         :arg model_id: The ID of the trained models stats to fetch
         :arg allow_no_match: Whether to ignore if a wildcard expression
@@ -1499,7 +1499,7 @@ def get_trained_models_stats(self, model_id=None, params=None, headers=None):
 
         return self.transport.perform_request(
             "GET",
-            _make_path("_ml", "inference", model_id, "_stats"),
+            _make_path("_ml", "trained_models", model_id, "_stats"),
             params=params,
             headers=headers,
         )
@@ -1508,7 +1508,7 @@ def get_trained_models_stats(self, model_id=None, params=None, headers=None):
     def put_trained_model(self, model_id, body, params=None, headers=None):
         """
         Creates an inference trained model.
-        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/put-inference.html>`_
+        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/put-trained-models.html>`_
 
         :arg model_id: The ID of the trained models to store
         :arg body: The trained model configuration
@@ -1519,7 +1519,7 @@ def put_trained_model(self, model_id, body, params=None, headers=None):
 
         return self.transport.perform_request(
             "PUT",
-            _make_path("_ml", "inference", model_id),
+            _make_path("_ml", "trained_models", model_id),
             params=params,
             headers=headers,
             body=body,

elasticsearch/client/security.py

@@ -528,3 +528,22 @@ def clear_cached_privileges(self, application, params=None, headers=None):
             params=params,
             headers=headers,
         )
+
+    @query_params()
+    def clear_api_key_cache(self, ids, params=None, headers=None):
+        """
+        Clear a subset or all entries from the API key cache.
+        `<https://www.elastic.co/guide/en/elasticsearch/reference/7.x/security-api-clear-api-key-cache.html>`_
+
+        :arg ids: A comma-separated list of IDs of API keys to clear
+            from the cache
+        """
+        if ids in SKIP_IN_PATH:
+            raise ValueError("Empty value passed for a required argument 'ids'.")
+
+        return self.transport.perform_request(
+            "POST",
+            _make_path("_security", "api_key", ids, "_clear_cache"),
+            params=params,
+            headers=headers,
+        )

elasticsearch/client/security.pyi

@@ -418,3 +418,17 @@ class SecurityClient(NamespacedClient):
         params: Optional[MutableMapping[str, Any]] = ...,
         headers: Optional[MutableMapping[str, str]] = ...,
     ) -> Any: ...
+    def clear_api_key_cache(
+        self,
+        ids: 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] = ...,
+        params: Optional[MutableMapping[str, Any]] = ...,
+        headers: Optional[MutableMapping[str, str]] = ...,
+    ) -> Any: ...