9hSSKJrJr SSKJr "SS\5r"SS\5r"SS \5r"S S \5r"S S \5r \R5 "SS5r g))ABCabstractmethod)cimplc\rSrSrSr0r\\S55r\ S5r \ S5r \ S5r \ S5r \ S5rS rS rS rg ) OffsetSpeczc Used in `AdminClient.list_offsets` to specify the desired offsets of the partition being queried. cgNselfs gC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\confluent_kafka/admin/_listoffsets.py_valueOffsetSpec._values c0[5Ul[5Ul[ 5UlUR R[RUR[RUR[RUR 05 gr ) MaxTimestampSpec_max_timestamp EarliestSpec _earliest LatestSpec_latest_valuesupdaterOFFSET_SPEC_MAX_TIMESTAMPOFFSET_SPEC_EARLIESTOFFSET_SPEC_LATESTclss r _fill_valuesOffsetSpec._fill_valuesse-/$  l    + +S-?-?  & &  $ $ckk  rcUR$r )rrs rearliestOffsetSpec.earliest*s }}rcUR$r )rrs rlatestOffsetSpec.latest.s {{rcUR$r )rrs r max_timestampOffsetSpec.max_timestamp2s!!!rc[U5$r ) TimestampSpec)r timestamps r for_timestampOffsetSpec.for_timestamp6s Y''rcNUS:aURU$URU5$Nr)rr/)r indexs r__new__OffsetSpec.__new__:s+ 19;;u% %$$U+ +rcj[U[5(d[$URUR:$r ) isinstancerNotImplementedr)rothers r__lt__OffsetSpec.__lt__Bs(%,,! !{{U\\))rr N)__name__ __module__ __qualname____firstlineno____doc__rpropertyrr classmethodr!r$r'r*r/r4r:__static_attributes__r rrrrsG     ""((,*rrc4\rSrSrSr\S5rSrSrSr g)r-Hz Used in a `AdminClient.list_offsets` call to retrieve the earliest offset whose timestamp is greater than or equal to the given timestamp in the corresponding partition. Parameters ---------- timestamp: int timestamp in milliseconds. cUR$r r.r s rrTimestampSpec._valueTs ~~rc,[RU5$r objectr4)r _s rr4TimestampSpec.__new__X~~c""rcXlgr rG)rr.s r__init__TimestampSpec.__init__[s"rrGN) r<r=r>r?r@rArr4rPrCr rrr-r-Hs% ##rr-c.\rSrSrSrSr\S5rSrg)r_z Used in a `AdminClient.list_offsets` call to retrieve the offset with the largest timestamp, that could not correspond to the latest one as timestamps can be specified client-side. c,[RU5$r rJrs rr4MaxTimestampSpec.__new__frNrc"[R$r )rrr s rrMaxTimestampSpec._valueis...rr N r<r=r>r?r@r4rArrCr rrrr_s  #//rrc.\rSrSrSrSr\S5rSrg)rnz\ Used in a `AdminClient.list_offsets` call to retrieve the queried partition latest offset. c,[RU5$r rJrs rr4LatestSpec.__new__srNrc"[R$r )rrr s rrLatestSpec._valuevs'''rr NrXr rrrrns #((rrc.\rSrSrSrSr\S5rSrg)r{z^ Used in a `AdminClient.list_offsets` call to retrieve the queried partition earliest offset. c,[RU5$r rJrs rr4EarliestSpec.__new__rNrc"[R$r )rrr s rrEarliestSpec._values)))rr NrXr rrrr{s #**rrc\rSrSrSrSrSrg)ListOffsetsResultInfoa ListOffsetsResultInfo Result of a `AdminClient.list_offsets` call associated to a partition. Parameters ---------- offset: int The offset returned by the list_offsets call. timestamp: int The timestamp in milliseconds corresponding to the offset. Not available (-1) when querying for the earliest or the latest offsets. leader_epoch: int The leader epoch corresponding to the offset (optional). cXXlX lX0lURS:aSUlggr2)offsetr. leader_epoch)rrir.rjs rrPListOffsetsResultInfo.__init__s- "(   q $D  !r)rjrir.N)r<r=r>r?r@rPrCr rrrfrfs  %rrfN) abcrrrrr-rrrr!rfr rrrnsb$2*2*j#J#. /z / ( ( *: * %%r