streams and project namespaces

Author: miguelgrinberg

elasticsearch/_async/client/project.py

@@ -15,8 +15,19 @@
 #  specific language governing permissions and limitations
 #  under the License.
 
-class C:
+import typing as t
 
+from elastic_transport import ObjectApiResponse
+
+from ._base import NamespacedClient
+from .utils import (
+    Stability,
+    _rewrite_parameters,
+    _stability_warning,
+)
+
+
+class StreamsClient(NamespacedClient):
     @_rewrite_parameters()
     @_stability_warning(Stability.EXPERIMENTAL)
     async def tags(

elasticsearch/_async/client/streams.py

@@ -15,8 +15,20 @@
 #  specific language governing permissions and limitations
 #  under the License.
 
-class C:
 
+import typing as t
+
+from elastic_transport import ObjectApiResponse, TextApiResponse
+
+from ._base import NamespacedClient
+from .utils import (
+    Stability,
+    _rewrite_parameters,
+    _stability_warning,
+)
+
+
+class StreamsClient(NamespacedClient):
     @_rewrite_parameters()
     @_stability_warning(Stability.EXPERIMENTAL)
     async def logs_disable(

elasticsearch/_sync/client/project.py

@@ -15,8 +15,19 @@
 #  specific language governing permissions and limitations
 #  under the License.
 
-class C:
+import typing as t
 
+from elastic_transport import ObjectApiResponse
+
+from ._base import NamespacedClient
+from .utils import (
+    Stability,
+    _rewrite_parameters,
+    _stability_warning,
+)
+
+
+class StreamsClient(NamespacedClient):
     @_rewrite_parameters()
     @_stability_warning(Stability.EXPERIMENTAL)
     def tags(

elasticsearch/_sync/client/streams.py

@@ -15,8 +15,20 @@
 #  specific language governing permissions and limitations
 #  under the License.
 
-class C:
 
+import typing as t
+
+from elastic_transport import ObjectApiResponse, TextApiResponse
+
+from ._base import NamespacedClient
+from .utils import (
+    Stability,
+    _rewrite_parameters,
+    _stability_warning,
+)
+
+
+class StreamsClient(NamespacedClient):
     @_rewrite_parameters()
     @_stability_warning(Stability.EXPERIMENTAL)
     def logs_disable(