o
    EDi                     @   sT   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d
S )c                   @   s<   e Zd ZdZdZdZdZdZdZdZ	g dZ
ed	d
 ZdS )ClientPacketTypesz,
    Packet types that client transmits
                       )HelloQueryDataCancelPingTablesStatusRequestc                 C   "   z| j | W S  ty   Y dS w NzUnknown packet
_types_str
IndexErrorclspacket r   S/var/www/Datamplify/venv/lib/python3.10/site-packages/clickhouse_driver/protocol.pyto_str   
   zClientPacketTypes.to_strN)__name__
__module____qualname____doc__HELLOQUERYDATACANCELPINGTABLES_STATUS_REQUESTr   classmethodr   r   r   r   r   r      s    r   c                   @   sx   e Zd ZdZdZdZdZdZdZdZ	dZ
d	Zd
ZdZdZdZdZdZdZdZdZdZg dZedd Zedd ZdS )ServerPacketTypesz-
    Packet types that server transmits.
    r   r   r   r   r   r            	   
                        )r   r
   	ExceptionProgressPongEndOfStreamProfileInfoTotalsExtremesTablesStatusResponseLogTableColumns	PartUUIDsReadTaskRequestProfileEventsMergeTreeAllRangesAnnouncementMergeTreeReadTaskRequestTimezoneUpdatec                 C   r   r   r   r   r   r   r   r   g   r   zServerPacketTypes.to_strc                 C   s   || j krdS dS )Nr   r   )TABLE_COLUMNSr   r   r   r   strings_in_messagen   s   
z$ServerPacketTypes.strings_in_messageN)r   r   r   r   r   r    	EXCEPTIONPROGRESSPONGEND_OF_STREAMPROFILE_INFOTOTALSEXTREMESTABLES_STATUS_RESPONSELOGrB   
PART_UUIDSREAD_TASK_REQUESTPROFILE_EVENTS"MERGE_TREE_ALL_RANGES_ANNOUNCEMENTMERGE_TREE_READ_TASK_REQUESTTIMEZONE_UPDATEr   r$   r   rC   r   r   r   r   r%   &   s2    
r%   c                   @      e Zd ZdZdZdS )Compressionr   r   N)r   r   r   DISABLEDENABLEDr   r   r   r   rT   u       rT   c                   @   s   e Zd ZdZdZdZdS )CompressionMethodr   r   r   N)r   r   r   LZ4LZ4HCZSTDr   r   r   r   rX   z   s    rX   c                   @   rS   )CompressionMethodByte      N)r   r   r   rY   r[   r   r   r   r   r\      rW   r\   N)objectr   r%   rT   rX   r\   r   r   r   r   <module>   s
   $O