o
    FDio
                     @   sJ   G d d dZ G dd dZG dd dZG dd dZG dd	 d	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 )ClientPacketz,
    Packet types that client transmits
                       )HelloQueryDataCancelPingTablesStatusRequestc                 C   s   |dkrdS | j | S )Nr   Unknown packet
_types_strclspacket r   N/var/www/Datamplify/venv/lib/python3.10/site-packages/asynch/proto/protocol.pyto_str   s   zClientPacket.to_strN)__name__
__module____qualname____doc__HELLOQUERYDATACANCELPINGTABLES_STATUS_REQUESTr   classmethodr   r   r   r   r   r      s    r   c                   @   sl   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g dZedd Zedd ZdS )ServerPacketz-
    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ProfileEventsc                 C   s"   |d u rdS |dkrdS | j | S )NzConnection closed by remoter+   r   r   r   r   r   r   r   d   s   zServerPacket.to_strc                 C   s   || j krdS dS )Nr   r   )TABLE_COLUMNSr   r   r   r   strings_in_messagek   s   
zServerPacket.strings_in_messageN)r   r   r   r   r   r   	EXCEPTIONPROGRESSPONGEND_OF_STREAMPROFILE_INFOTOTALSEXTREMESTABLES_STATUS_RESPONSELOGr9   
PART_UUIDSREAD_TASK_REQUESTPROFILE_EVENTSr   r!   r   r:   r   r   r   r   r"   !   s,    
r"   c                   @      e Zd ZdZdZdS )Compressionr   r   N)r   r   r   DISABLEDENABLEDr   r   r   r   rH   r       rH   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   rL   w   s    rL   c                   @   rG   )CompressionMethodByte      N)r   r   r   rM   rO   r   r   r   r   rP   }   rK   rP   N)r   r"   rH   rL   rP   r   r   r   r   <module>   s
     Q