Get all schemas via /schemas endpoint (#14)

Author: JohnPreston

kafka_schema_registry_admin/async_schema_registry.py

@@ -239,6 +239,11 @@ async def delete_subject(
                 permanent_url, async_client=self.get_async_client(async_client)
             )
 
+    async def get_all_schemas(self, async_client: httpx.AsyncClient = None) -> Response:
+        url: str = "/schemas"
+        req = self.client.get(url, async_client=self.get_async_client(async_client))
+        return await req
+
     async def get_schema_types(
         self, async_client: httpx.AsyncClient = None
     ) -> Response:

kafka_schema_registry_admin/kafka_schema_registry_admin.py

@@ -189,6 +189,16 @@ def delete_subject(
             permanent_url = f"{url}?permanent=true"
             return self.client.delete(permanent_url)
 
+    def get_all_schemas(self) -> Response:
+        """
+        Method to get the list of subjects in the schema registry
+        Undocumented??
+
+        :raises: requests.exceptions.HTTPError
+        """
+        url_path: str = "/schemas"
+        return self.client.get(url_path)
+
     def get_schema_types(self) -> Response:
         """
         Method to get the list of schema types and return the request object

tests/test_async_subjects_schemas.py

@@ -88,6 +88,8 @@ async def test_get_all_subjects(async_local_registry):
     assert isinstance(r, list) and r
     r = await async_local_registry.get_all_subjects(subject_prefix="test-subject4")
     assert "test-subject4" in r.json()
+    r = await async_local_registry.get_all_schemas()
+    assert r.json()
 
 
 @pytest.mark.asyncio(scope="session")

tests/test_subjects_schemas.py

@@ -83,6 +83,8 @@ def test_get_all_subjects(local_registry):
     assert isinstance(r, list) and r
     r = local_registry.get_all_subjects(subject_prefix="test-subject4")
     assert "test-subject4" in r.json()
+    r = local_registry.get_all_schemas()
+    assert r.json()
 
 
 def test_get_all_schema_types(local_registry):