o
    `jJ	                     @   s   d dl mZ ddlmZ d dlmZ dZG dd dZG dd	 d	eeZG d
d de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ZdS )    )IntEnum   )
ApiMessage)
EnumHelperc                   @   s   e Zd ZdZdZdZdS )OffsetResetStrategyr   r   N)__name__
__module____qualname__LATESTEARLIESTNONE r   r   ]/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/consumer/offsets.pyr   	   s    r   c                   @   s   e Zd ZdZdZdS )IsolationLevelr      N)r	   r
   r   READ_UNCOMMITTEDREAD_COMMITTEDr   r   r   r   r      s    r   c                   @   s    e Zd ZdZdZdZdZdZdS )
OffsetSpecr   r   N)r	   r
   r   r   r   MAX_TIMESTAMPEARLIEST_LOCALLATEST_TIEREDr   r   r   r   r      s    r   c                   @   s   e Zd ZdZdZdd ZdS )OffsetTimestampa6  Millisecond-timestamp spec for partition offset lookup.

    Wraps an int so it can be distinguished from a bare offset. Use with
    :meth:`KafkaAdminClient.reset_group_offsets` (and anywhere else a spec
    may be mixed with explicit offsets) to request "earliest offset whose
    timestamp is >= N ms".
    r   c                 C   s   dt |  dS )NzOffsetTimestamp()int)selfr   r   r   __repr__'   s   zOffsetTimestamp.__repr__N)r	   r
   r   __doc__	__slots__r!   r   r   r   r   r      s    r   c                   @   s$   e Zd Zedd Zedd ZdS )ListOffsetsRequestc                 C   s6   t |}|t jkrdS |t jkrdS |t jkrdS dS )N      	   r   )r   r   r   r   )clstsr   r   r   min_version_for_timestamp,   s   


z,ListOffsetsRequest.min_version_for_timestampc                 C   s   t |dkrdS dS )Nr   r   r   )r(   ilr   r   r   min_version_for_isolation_level8   s   z2ListOffsetsRequest.min_version_for_isolation_levelN)r	   r
   r   classmethodr*   r,   r   r   r   r   r$   +   s
    
r$   c                   @      e Zd ZdS )ListOffsetsResponseNr	   r
   r   r   r   r   r   r/   ?       r/   c                   @   r.   )OffsetForLeaderEpochRequestNr0   r   r   r   r   r2   B   r1   r2   c                   @   r.   )OffsetForLeaderEpochResponseNr0   r   r   r   r   r3   C   r1   r3   )	UNKNOWN_OFFSETr   r   r   r   r$   r/   r2   r3   N)enumr   api_messager   
kafka.utilr   r4   r   r   r   r   r   r$   r/   r2   r3   __all__r   r   r   r   <module>   s    	