o
    `j                     @   s  d dl mZ ddlmZmZ ddlmZmZmZm	Z	m
Z
mZmZ G dd deZG dd deZG d	d
 d
eZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZeeeeegZeeeeegZdS )    )BytesIO   )RequestResponse)ArrayCompactArrayCompactStringInt16Int32SchemaTaggedFieldsc                       sX   e Zd ZdZdZedefdedefdefdeffZddiZ	e
d fd
d	Z  ZS )BaseApiVersionsResponse   r   
error_codeapi_keysapi_keymin_versionmax_versionapi_versionsFc                    st   t |tr	t|}| }|rt|}|r| | t|}|| |dkr1t	j|||dS t
 j|||dS )Nr   )headerframed)
isinstancebytesr   tellr
   decodeparse_headerr	   seekApiVersionsResponse_v0super)clsdatar   r   currnbyteserr	__class__ ]/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/old/api_versions.pyr      s   




zBaseApiVersionsResponse.decode)FF)__name__
__module____qualname__API_KEYAPI_VERSIONr   r	   r   SCHEMAALIASESclassmethodr   __classcell__r&   r&   r$   r'   r      s    r   c                   @   sB   e Zd ZdZdZedefdedefdefdeffZddiZ	d	S )
r   r   r   r   r   r   r   r   r   N)
r(   r)   r*   r+   r,   r   r	   r   r-   r.   r&   r&   r&   r'   r   $   s    r   c                   @   s@   e Zd ZdZdZedefdedefdefdeffdefZ	d	S )
ApiVersionsResponse_v1r   r   r   r   r   r   r   throttle_time_msN)
r(   r)   r*   r+   r,   r   r	   r   r
   r-   r&   r&   r&   r'   r1   1   s    r1   c                   @      e Zd ZdZdZejZdS )ApiVersionsResponse_v2r      N)r(   r)   r*   r+   r,   r1   r-   r&   r&   r&   r'   r4   >       
r4   c                	   @   sL   e Zd ZdZdZedefdedefdefdefdeffd	e	fdefZ
d
S )ApiVersionsResponse_v3r      r   r   r   r   r   tagsr2   N)r(   r)   r*   r+   r,   r   r	   r   r   r
   r-   r&   r&   r&   r'   r7   D   s    r7   c                   @   r3   )ApiVersionsResponse_v4r      N)r(   r)   r*   r+   r,   r7   r-   r&   r&   r&   r'   r:   T   r6   r:   c                   @   s   e Zd ZdZdZe ZdS )ApiVersionsRequest_v0r   r   N)r(   r)   r*   r+   r,   r   r-   r&   r&   r&   r'   r<   Z   r6   r<   c                   @   r3   )ApiVersionsRequest_v1r   r   N)r(   r)   r*   r+   r,   r<   r-   r&   r&   r&   r'   r=   `   r6   r=   c                   @   r3   )ApiVersionsRequest_v2r   r5   N)r(   r)   r*   r+   r,   r=   r-   r&   r&   r&   r'   r>   f   r6   r>   c                   @   s8   e Zd ZdZdZededfdedfdefZdZ	dS )	ApiVersionsRequest_v3r   r8   client_software_namezutf-8client_software_versionr9   TN)
r(   r)   r*   r+   r,   r   r   r   r-   FLEXIBLE_VERSIONr&   r&   r&   r'   r?   l   s    

r?   c                   @   s   e Zd ZdZdZejZdZdS )ApiVersionsRequest_v4r   r;   TN)r(   r)   r*   r+   r,   r?   r-   rB   r&   r&   r&   r'   rC   w   s
    rC   N)ior   apir   r   typesr   r   r   r	   r
   r   r   r   r   r1   r4   r7   r:   r<   r=   r>   r?   rC   ApiVersionsRequestApiVersionsResponser&   r&   r&   r'   <module>   s(    $