
    9h                       S SK Jr  S SKrS SKJr  S SKJrJrJrJ	r	  SSK
Jr  SSKJrJrJrJrJrJr   " S S	\5      r " S
 S\5      r " S S\5      r " S S\5      r " S S\\R.                  S9r " S S\\R.                  S9rSS jrg)    )annotationsN)BytesIO)AnyClassVarOptionalUnion   )Struct)ArrayInt16Int32SchemaStringTaggedFieldsc            	      r   ^  \ rS rSr\" S\4S\4S\4S\" S5      45      r S	       S
U 4S jjjr	Sr
U =r$ )RequestHeader_v0   api_keyapi_versioncorrelation_id	client_idutf-8c                P   > [         TU ]  UR                  UR                  X#5        g Nsuper__init__API_KEYAPI_VERSION)selfrequestr   r   	__class__s       ZC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/protocol/api.pyr   RequestHeader_v0.__init__   s#     	OOW00.	
     )r   aiokafka)r!   Requestr   intr   strreturnNone)__name__
__module____qualname____firstlineno__r   r   r   r   SCHEMAr   __static_attributes____classcell__r"   s   @r#   r   r      sb    	E		5!	fWo&	F KU

03
DG
	
 
r%   r   c            	      |   ^  \ rS rSr\" S\4S\4S\4S\" S5      4S\45      r	   S
       SU 4S jjjr
S	rU =r$ )RequestHeader_v1   r   r   r   r   r   tagsc                d   > [         TU ]  UR                  UR                  X#U=(       d    0 5        g r   r   )r    r!   r   r   r8   r"   s        r#   r   RequestHeader_v1.__init__%   s*     	OOW00.TZUW	
r%   r&   )r   r'   N)r!   r(   r   r)   r   r*   r8   zOptional[dict[int, bytes]])r-   r.   r/   r0   r   r   r   r   r   r1   r   r2   r3   r4   s   @r#   r6   r6      st    	E		5!	fWo&	F  #+/	
	
 	
 		

 )	
 	
r%   r6   c                  (    \ rS rSr\" S\45      rSrg)ResponseHeader_v01   r   r&   N)r-   r.   r/   r0   r   r   r1   r2   r&   r%   r#   r<   r<   1   s    	5!Fr%   r<   c                  .    \ rS rSr\" S\4S\45      rSrg)ResponseHeader_v17   r   r8   r&   N)	r-   r.   r/   r0   r   r   r   r1   r2   r&   r%   r#   r?   r?   7   s    	5!	Fr%   r?   c                  (   \ rS rSr% SrS\S'   \\R                  SS j5       5       r	\\R                  SS j5       5       r
\\R                  SS j5       5       r\\R                  SS j5       5       rSS	 jrSS
 jr      SS jr    SS jrSrg)r(   >   FzClassVar[bool]FLEXIBLE_VERSIONc                    g)z"Integer identifier for api requestNr&   r    s    r#   r   Request.API_KEYA       r%   c                    g)zInteger of api request versionNr&   rE   s    r#   r   Request.API_VERSIONF   rG   r%   c                    g)z2The Response class associated with the api requestNr&   rE   s    r#   RESPONSE_TYPERequest.RESPONSE_TYPEK   rG   r%   c                    g)z:An instance of Schema() representing the request structureNr&   rE   s    r#   r1   Request.SCHEMAP   rG   r%   c                    g)zJOverride this method if an api request does not always generate a responseTr&   rE   s    r#   expect_responseRequest.expect_responseU   s    r%   c                .    [        U R                  U 5      $ r   
_to_objectr1   rE   s    r#   	to_objectRequest.to_objectY       $++t,,r%   c                L    U R                   (       a
  [        XUS9$ [        XUS9$ )N)r   r   )rC   r6   r   )r    r   r   s      r#   build_request_headerRequest.build_request_header\   s3       #y   9
 	
r%   c                x    U R                   (       a  [        R                  U5      $ [        R                  U5      $ r   )rC   r?   decoder<   )r    read_buffers     r#   parse_response_headerRequest.parse_response_headerg   s/       $++K88 ''44r%   r&   Nr+   r)   )r+   ztype[Response]r+   r   )r+   boolr+   dict[str, Any])r   r)   r   r*   r+   z)Union[RequestHeader_v0, RequestHeader_v1])r]   zUnion[BytesIO, bytes]r+   z+Union[ResponseHeader_v0, ResponseHeader_v1])r-   r.   r/   r0   rC   __annotations__propertyabcabstractmethodr   r   rK   r1   rP   rU   rY   r^   r2   r&   r%   r#   r(   r(   >   s    ',n,1  1 -  - A  A I  I-	
!	
.1	
	2	
505	45r%   r(   )	metaclassc                      \ rS rSr\\R                  SS j5       5       r\\R                  SS j5       5       r\\R                  S	S j5       5       r	S
S jr
Srg)Responseo   c                    g)z+Integer identifier for api request/responseNr&   rE   s    r#   r   Response.API_KEYp   rG   r%   c                    g)z'Integer of api request/response versionNr&   rE   s    r#   r   Response.API_VERSIONu   rG   r%   c                    g)z;An instance of Schema() representing the response structureNr&   rE   s    r#   r1   Response.SCHEMAz   rG   r%   c                .    [        U R                  U 5      $ r   rS   rE   s    r#   rU   Response.to_object   rW   r%   r&   Nr`   ra   rc   )r-   r.   r/   r0   rf   rg   rh   r   r   r1   rU   r2   r&   r%   r#   rk   rk   o   sm    :  : 6  6 J  J-r%   rk   c                   0 n[        [        U R                  U R                  5      5       H  u  nu  pE[	        U[
        5      (       a  UR                  U5      nOX   n[	        U[        5      (       a  [        XV5      X$'   MW  [	        U[        5      (       aP  [	        UR                  [        5      (       a+  U Vs/ s H  n[        UR                  U5      PM     snX$'   M  XbU'   M  XbU'   M     U$ s  snf r   )	enumeratezipnamesfields
isinstancer
   get_itemr   rT   r   array_of)schemadataobjidxname_typevalxs           r#   rT   rT      s    C'FLL&--(HI]ddF##--%C)CeV$$"5.CIu%%%..&11DGHCqZ:CH	D	I J  J Is   ; C2)r}   r   r~   zUnion[Struct, dict[int, Any]]r+   rd   )
__future__r   rg   ior   typingr   r   r   r   structr
   typesr   r   r   r   r   r   r   r6   r<   r?   ABCMetar(   rk   rT   r&   r%   r#   <module>r      sw    " 
  1 1  D D
v 
 
v 
,  .5f .5b-v -(r%   