Skip to content

Commit

Permalink
Using async HTTPx client
Browse files Browse the repository at this point in the history
  • Loading branch information
JohnPreston committed Apr 2, 2024
1 parent 26e5d81 commit 63d8e31
Show file tree
Hide file tree
Showing 15 changed files with 952 additions and 61 deletions.
2 changes: 1 addition & 1 deletion .isort.cfg
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
[settings]
known_third_party = pytest,requests,testcontainers
known_third_party = httpx,pytest,requests,testcontainers
33 changes: 30 additions & 3 deletions kafka_schema_registry_admin/__init__.py
Original file line number Diff line number Diff line change
@@ -1,12 +1,39 @@
# SPDX-License-Identifier: Apache License 2.0
# Copyright 2021 John Mille <[email protected]>
# Copyright 2024 John Mille <[email protected]>

"""Top-level package for Kafka schema registry admin."""

from __future__ import annotations

__author__ = """JohnPreston"""
__email__ = "[email protected]"
__version__ = "0.4.1"

from .kafka_schema_registry_admin import CompatibilityMode, RegistryMode, SchemaRegistry
from enum import Enum


class RegistryMode(Enum):
IMPORT = "IMPORT"
READONLY = "READONLY"
READWRITE = "READWRITE"


class CompatibilityMode(Enum):
BACKWARD = "BACKWARD"
BACKWARD_TRANSITIVE = "BACKWARD_TRANSITIVE"
FORWARD = "FORWARD"
FORWARD_TRANSITIVE = "FORWARD_TRANSITIVE"
FULL = "FULL"
FULL_TRANSITIVE = "FULL_TRANSITIVE"
NONE = "NONE"


class Type(Enum):
AVRO = "AVRO"
JSON = "JSON"
PROTOBUFF = "PROTOBUF"


from .kafka_schema_registry_admin import SchemaRegistry

__all__ = ["SchemaRegistry", "RegistryMode", "CompatibilityMode"]
__all__ = ["SchemaRegistry"]
Loading

0 comments on commit 63d8e31

Please sign in to comment.