
    9h~                         S SK Jr  SSKJrJrJrJrJrJrJ	r	J
r
JrJrJrJrJrJrJr  S r/ SQrS\\   S\\   4S jrS\\   S\\   4S jrS\\   S\\   4S	 jrS
\S\\   4S jrg)    )Optional   )ConfigCompatibilityLevelMetadataMetadataPropertiesMetadataTagsRegisteredSchemaRuleRuleKindRuleMode
RuleParamsRuleSetSchemaSchemaRegistryClientSchemaRegistryErrorSchemaReferenceServerConfig)r   r   r   r   r	   r
   r   r   r   r   r   r   r   r   r   topic_subject_name_strategy"topic_record_subject_name_strategyrecord_subject_name_strategyrecord_namereturnc                 :    U R                   S-   U R                  -   $ )z
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.

-)topicfieldctxr   s     mC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\confluent_kafka/schema_registry/__init__.pyr   r   >   s     99s?SYY&&    c                 0    Ub  U R                   S-   U-   $ S$ )z
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.

Nr   )r   r   s     r   r   r   L   s!     -8,C399s?[(MMr    c                     Ub  U$ S$ )z
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.

N r   s     r   r   r   Z   s     &1;;t;r    
schema_refc                 $    Ub  UR                   $ S$ )z
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.

N)name)r   r$   s     r   reference_subject_name_strategyr'   h   s     )4:??>$>r    N)typingr   schema_registry_clientr   r   r   r   r	   r
   r   r   r   r   r   r   r   r   r   _MAGIC_BYTE__all__strr   r   r   r'   r#   r    r   <module>r-      s   $     $ ,'(3- 'HSM 'N# N8TW= N<8C= <Xc] <?_ ?RU ?r    