Refactor for async support

Author: rohitsanj

src/confluent_kafka/schema_registry/__init__.py

@@ -35,7 +35,13 @@
   ServerConfig
 )
 
-_MAGIC_BYTE = 0
+from .common import (
+    _MAGIC_BYTE,
+    topic_subject_name_strategy,
+    topic_record_subject_name_strategy,
+    record_subject_name_strategy,
+    reference_subject_name_strategy
+)
 
 __all__ = [
   "ConfigCompatibilityLevel",
@@ -57,59 +63,3 @@
   "topic_record_subject_name_strategy",
   "record_subject_name_strategy"
 ]
-
-
-def topic_subject_name_strategy(ctx, record_name: Optional[str]) -> Optional[str]:
-    """
-    Constructs a subject name in the form of {topic}-key|value.
-
-    Args:
-        ctx (SerializationContext): Metadata pertaining to the serialization
-            operation.
-
-        record_name (Optional[str]): Record name.
-
-    """
-    return ctx.topic + "-" + ctx.field
-
-
-def topic_record_subject_name_strategy(ctx, record_name: Optional[str]) -> Optional[str]:
-    """
-    Constructs a subject name in the form of {topic}-{record_name}.
-
-    Args:
-        ctx (SerializationContext): Metadata pertaining to the serialization
-            operation.
-
-        record_name (Optional[str]): Record name.
-
-    """
-    return ctx.topic + "-" + record_name if record_name is not None else None
-
-
-def record_subject_name_strategy(ctx, record_name: Optional[str]) -> Optional[str]:
-    """
-    Constructs a subject name in the form of {record_name}.
-
-    Args:
-        ctx (SerializationContext): Metadata pertaining to the serialization
-            operation.
-
-        record_name (Optional[str]): Record name.
-
-    """
-    return record_name if record_name is not None else None
-
-
-def reference_subject_name_strategy(ctx, schema_ref: SchemaReference) -> Optional[str]:
-    """
-    Constructs a subject reference name in the form of {reference name}.
-
-    Args:
-        ctx (SerializationContext): Metadata pertaining to the serialization
-            operation.
-
-        schema_ref (SchemaReference): SchemaReference instance.
-
-    """
-    return schema_ref.name if schema_ref is not None else None

src/confluent_kafka/schema_registry/_sync/__init__.py

@@ -0,0 +1,17 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+#
+# Copyright 2020 Confluent Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#