
    9h                     x   S SK JrJr  S SKJrJrJrJrJrJ	r	J
r
  Sr " S S5      r " S S\5      r " S S	\5      r " S
 S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r\\\\\\/r\\\\\\/rg)   )RequestResponse)ArrayInt8Int16Int32Int64SchemaStringc                        \ rS rSrSrSrSrSrg)OffsetResetStrategy   r        N)__name__
__module____qualname____firstlineno__LATESTEARLIESTNONE__static_attributes__r       ]C:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/protocol/offset.pyr   r      s    FHDr   r   c                   z    \ rS rSrSrSr\" S\" S\" S5      4S\" S\	4S	\
4S
\" \5      45      45      45      rSrg)OffsetResponse_v0      r   topicstopicutf-8
partitions	partition
error_codeoffsetsr   Nr   r   r   r   API_KEYAPI_VERSIONr
   r   r   r   r   r	   SCHEMAr   r   r   r   r   r      s^    GK&/* $e,%u-"E%L1
	
Fr   r   c                   t    \ rS rSrSrSr\" S\" S\" S5      4S\" S\	4S	\
4S
\4S\45      45      45      rSrg)OffsetResponse_v1"   r    r   r!   r"   r#   r$   r%   r&   	timestampoffsetr   Nr(   r   r   r   r-   r-   "   sb    GK&/* $e,%u-$e,!5)		
Fr   r-   c                   z    \ rS rSrSrSr\" S\4S\" S\	" S5      4S\" S\4S	\
4S
\4S\45      45      45      rSrg)OffsetResponse_v28   r    throttle_time_msr!   r"   r#   r$   r%   r&   r/   r0   r   N)r   r   r   r   r)   r*   r
   r   r   r   r   r	   r+   r   r   r   r   r2   r2   8   sj    GK	U#&/* $e,%u-$e,!5)		
Fr   r2   c                   8    \ rS rSrSrSrSr\R                  rSr	g)OffsetResponse_v3O   zB
on quota violation, brokers send out responses before throttling
r       r   N)
r   r   r   r   __doc__r)   r*   r2   r+   r   r   r   r   r6   r6   O        GK%%Fr   r6   c                       \ rS rSrSrSrSr\" S\4S\	" S\
" S5      4S	\	" S
\4S\4S\4S\4S\45      45      45      rSrg)OffsetResponse_v4Y   z
Add leader_epoch to response
r       r4   r!   r"   r#   r$   r%   r&   r/   r0   leader_epochr   N)r   r   r   r   r9   r)   r*   r
   r   r   r   r   r	   r+   r   r   r   r   r<   r<   Y   sy     GK	U#&/* $e,%u-$e,!5)'/		
Fr   r<   c                   8    \ rS rSrSrSrSr\R                  rSr	g)OffsetResponse_v5u   z-
adds a new error code, OFFSET_NOT_AVAILABLE
r       r   N)
r   r   r   r   r9   r)   r*   r<   r+   r   r   r   r   rA   rA   u   r:   r   rA   c                       \ rS rSrSrSr\r\" S\	4S\
" S\" S5      4S\
" S	\	4S
\4S\	45      45      45      rSS0rSrg)OffsetRequest_v0   r    r   
replica_idr!   r"   r#   r$   r%   r/   max_offsetsr   r   N)r   r   r   r   r)   r*   r   RESPONSE_TYPEr
   r   r   r   r	   r+   DEFAULTSr   r   r   r   rE   rE      ss    GK%M	u&/* $e,$e,&.
	
F" b!Hr   rE   c                   z    \ rS rSrSrSr\r\" S\	4S\
" S\" S5      4S\
" S	\	4S
\45      45      45      rSS0rSrg)OffsetRequest_v1   r    r   rG   r!   r"   r#   r$   r%   r/   r   r   N)r   r   r   r   r)   r*   r-   rI   r
   r   r   r   r	   r+   rJ   r   r   r   r   rL   rL      sd    GK%M	u&/*uk5%9K;OPQ	
	F b!Hr   rL   c                       \ rS rSrSrSr\r\" S\	4S\
4S\" S\" S5      4S\" S	\	4S
\45      45      45      rSS0rSrg)OffsetRequest_v2   r    rG   isolation_levelr!   r"   r#   r$   r%   r/   r   r   N)r   r   r   r   r)   r*   r2   rI   r
   r   r   r   r   r	   r+   rJ   r   r   r   r   rO   rO      sl    GK%M	u	D!&/*uk5%9K;OPQ	

F b!Hr   rO   c                   @    \ rS rSrSrSr\r\R                  r	SS0r
Srg)OffsetRequest_v3   r    r8   rG   r   r   N)r   r   r   r   r)   r*   r6   rI   rO   r+   rJ   r   r   r   r   rS   rS      &    GK%M$$Fb!Hr   rS   c                       \ rS rSrSrSrSr\r\	" S\
4S\4S\" S\" S	5      4S
\" S\
4S\4S\45      45      45      rSS0rSrg)OffsetRequest_v4   z%
Add current_leader_epoch to request
r    r>   rG   rQ   r!   r"   r#   r$   r%   current_leader_epochr/   r   r   N)r   r   r   r   r9   r)   r*   r<   rI   r
   r   r   r   r   r	   r+   rJ   r   r   r   r   rW   rW      s     GK%M	u	D!&/* $e,/7$e,
	
F$ b!Hr   rW   c                   @    \ rS rSrSrSr\r\R                  r	SS0r
Srg)OffsetRequest_v5   r    rC   rG   r   r   N)r   r   r   r   r)   r*   rA   rI   rW   r+   rJ   r   r   r   r   r[   r[      rU   r   r[   N)apir   r   typesr   r   r   r   r	   r
   r   UNKNOWN_OFFSETr   r   r-   r2   r6   r<   rA   rE   rL   rO   rS   rW   r[   OffsetRequestOffsetResponser   r   r   <module>rb      s    " C C C  * , .& & 8& &"w "0"w """w "$"w ""w ":"w "  r   