Update APIs to 7.16-SNAPSHOT

Author: sethmlarson

elasticsearch/_async/client/fleet.py

@@ -78,7 +78,7 @@ async def msearch(self, body, index=None, params=None, headers=None):
         body = _bulk_body(self.transport.serializer, body)
         return await self.transport.perform_request(
             "POST",
-            _make_path(index, "_fleet", "_msearch"),
+            _make_path(index, "_fleet", "_fleet_msearch"),
             params=params,
             headers=headers,
             body=body,
@@ -117,7 +117,7 @@ async def search(self, index, body=None, params=None, headers=None):
 
         return await self.transport.perform_request(
             "POST",
-            _make_path(index, "_fleet", "_search"),
+            _make_path(index, "_fleet", "_fleet_search"),
             params=params,
             headers=headers,
             body=body,

elasticsearch/_async/client/nodes.py

@@ -138,6 +138,7 @@ async def stats(
         "ignore_idle_threads",
         "interval",
         "snapshots",
+        "sort",
         "threads",
         "timeout",
         "type",
@@ -159,11 +160,13 @@ async def hot_threads(self, node_id=None, params=None, headers=None):
         :arg interval: The interval for the second sampling of threads
         :arg snapshots: Number of samples of thread stacktrace (default:
             10)
+        :arg sort: The sort order for 'cpu' type (default: total)  Valid
+            choices: cpu, total
         :arg threads: Specify the number of threads to provide
             information for (default: 3)
         :arg timeout: Explicit operation timeout
         :arg type: The type to sample (default: cpu)  Valid choices:
-            cpu, wait, block
+            cpu, wait, block, mem
         """
         return await self.transport.perform_request(
             "GET",

elasticsearch/_async/client/nodes.pyi

@@ -103,6 +103,7 @@ class NodesClient(NamespacedClient):
         ignore_idle_threads: Optional[bool] = ...,
         interval: Optional[Any] = ...,
         snapshots: Optional[Any] = ...,
+        sort: Optional[Any] = ...,
         threads: Optional[Any] = ...,
         timeout: Optional[Any] = ...,
         type: Optional[Any] = ...,

elasticsearch/client/fleet.py

@@ -78,7 +78,7 @@ def msearch(self, body, index=None, params=None, headers=None):
         body = _bulk_body(self.transport.serializer, body)
         return self.transport.perform_request(
             "POST",
-            _make_path(index, "_fleet", "_msearch"),
+            _make_path(index, "_fleet", "_fleet_msearch"),
             params=params,
             headers=headers,
             body=body,
@@ -117,7 +117,7 @@ def search(self, index, body=None, params=None, headers=None):
 
         return self.transport.perform_request(
             "POST",
-            _make_path(index, "_fleet", "_search"),
+            _make_path(index, "_fleet", "_fleet_search"),
             params=params,
             headers=headers,
             body=body,

elasticsearch/client/nodes.py

@@ -138,6 +138,7 @@ def stats(
         "ignore_idle_threads",
         "interval",
         "snapshots",
+        "sort",
         "threads",
         "timeout",
         "type",
@@ -159,11 +160,13 @@ def hot_threads(self, node_id=None, params=None, headers=None):
         :arg interval: The interval for the second sampling of threads
         :arg snapshots: Number of samples of thread stacktrace (default:
             10)
+        :arg sort: The sort order for 'cpu' type (default: total)  Valid
+            choices: cpu, total
         :arg threads: Specify the number of threads to provide
             information for (default: 3)
         :arg timeout: Explicit operation timeout
         :arg type: The type to sample (default: cpu)  Valid choices:
-            cpu, wait, block
+            cpu, wait, block, mem
         """
         return self.transport.perform_request(
             "GET",

elasticsearch/client/nodes.pyi

@@ -103,6 +103,7 @@ class NodesClient(NamespacedClient):
         ignore_idle_threads: Optional[bool] = ...,
         interval: Optional[Any] = ...,
         snapshots: Optional[Any] = ...,
+        sort: Optional[Any] = ...,
         threads: Optional[Any] = ...,
         timeout: Optional[Any] = ...,
         type: Optional[Any] = ...,