9h nSSKrSSKrSSKrSSKJr SSKJr SrSrSSK r S\ 4Sjr S\ 4Sjr S\ 4S jrS\ 4S jrSS \S \\S\4S jjrS \S\4SjrSS \S\ S\S\4SjjrS \S\ 4SjrS \S\4SjrSS \S\S\4SjjrS \S\4SjrSS \S\\S\4SjjrS \S\4Sjrg!\ a Sr Nf=f)N)Optional)Buffer) iSNAPrYrr bccccccBiireturncg)NTrSC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/codec.pyhas_gziprs rc[SL$Ncramjamrrr has_snappyr $ rc[SL$rrrrrhas_zstdrrrc[SL$rrrrrhas_lz4rrrpayload compresslevelcU(dSn[R"5n[R"USUS9nUR U5 UR 5 UR 5$!UR 5 f=f)N w)fileobjmoder)ioBytesIOgzipGzipFilewriteclosegetvalue)rrbufgzippers r gzip_encoder,!s\  **,CmmCcOG g  <<>  s A''A9c[R"U5n[R"USS9nUR 5UR 5 $!UR 5 f=f)Nr)r!r")r#r$r%r&readr()rr*r+s r gzip_decoder02sC **W CmmCc2G||~  s A Axerial_compatiblexerial_blocksizec^^[5(d [S5eU(d[RR T5$[ R "5n[[[5H.upEUR[R"SU-U55 M0 [T5mUU4Sj[S[T5T55Hdn[RR U5n[U5nUR[R"SU55 URU5 Mf UR!5$)aEncodes the given data with snappy compression. If xerial_compatible is set then the stream is encoded in a fashion compatible with the xerial snappy library. The block size (xerial_blocksize) controls how frequent the blocking occurs 32k is the default in the xerial library. The format winds up being: +-------------+------------+--------------+------------+--------------+ | Header | Block1 len | Block1 data | Blockn len | Blockn data | +-------------+------------+--------------+------------+--------------+ | 16 bytes | BE int32 | snappy bytes | BE int32 | snappy bytes | +-------------+------------+--------------+------------+--------------+ It is important to note that the blocksize is the amount of uncompressed data presented to snappy at each block, whereas the blocklen is the number of bytes that will be present in the stream; so the length will always be <= blocksize. Snappy codec is not available!c32># UH nTXT-v M g7frr).0irr2s r snappy_encode..es#9A (()9sr!i)rNotImplementedErrorrsnappy compress_rawr#r$zip_XERIAL_V1_FORMAT_XERIAL_V1_HEADERr'structpack memoryviewrangelenr)) rr1r2outfmtdatchunkblock block_sizes ` ` r snappy_encoderM>s8 <<!"ABB ~~**733 **,C)+<= &++cCi-.>!Gq#g,(89++E2Z  &++dJ/0 % <<>rc[U5n[U5S:a*[R"S[-USS5nU[ :H$g)aDetects if the data given might have been encoded with the blocking mode of the xerial snappy library. This mode writes a magic header of the format: +--------+--------------+------------+---------+--------+ | Marker | Magic String | Null / Pad | Version | Compat | +--------+--------------+------------+---------+--------+ | byte | c-string | byte | int32 | int32 | +--------+--------------+------------+---------+--------+ | -126 | 'SNAPPY' | | | | +--------+--------------+------------+---------+--------+ The pad appears to be to ensure that SNAPPY is a valid cstring The version is the version of this format as written by xerial, in the wild this is currently 1 as such we only support v1. Compat is there to claim the minimum supported version that can read a xerial block stream, presently in the wild this is 1. r5NF)rDrFrBunpackr@rA)rheaders r_detect_xerial_streamrRqsE,!G 7|bs%66 E*** rc[5(d [S5e[U5(a[R"5n[ U5SSn[ U5nSnXC:a^[R"SX$S5SnUS- nXE-nUR[RRX$U55 UnXC:aM^URS5 UR5$[[RRU55$)Nr4rOrr;)rr<rRr#r$rDrFrB unpack_fromr'rr=decompress_rawseekr/bytes)rrGbytlengthcursorrLends r snappy_decoder]s <<!"ABBW%%jjl!"#&So++D#g,?BJ aKF%C IIgnn33CsOD EF o  xxzW^^227;<??''e%(J ""$ %%rc[5(d [S5e[[RR U55$)Nr`)rr<rXrrc decompressrs r lz4_decoderls/ 99!">?? ''0 11rc[5(d [S5eUcSn[[RR XS95$)NZstd codec is not available)r^)rr<rXrzstdre)rr^s r zstd_encoderqs> ::!"?@@ } &&w&< ==rc[5(d [S5e[[RR U55$)Nrn)rr<rXrrprjrks r zstd_decoderss/ ::!"?@@ ((1 22rr)Ti)r)r%r#rBtypingrtyping_extensionsrrAr@r ImportErrorboolrrrrintrXr,r0rMrRr]rhrlrqrsrrrrysQ $G  $D$ "  E NW0 0(,0GJ0 0f6d:=6=e=2 & &s &5 &2252 > > > >33E3yGsB))B43B4