5i"dZddlmZddlmZmZddlmZddgZdZ dZ d Z d Z d Z d Zd ZdZGddeZGddZy)z$ event-stream library for `awscrt`. )IntEnum)AnyUnion)UUID HeaderTypeHeaderiiiiillcReZdZdZdZ dZ dZ dZ dZ dZ dZ d Z d Z d Z d Zy )rz-Supported types for the value within a Headerr ct|SN)str)self format_specs }/home/marpiech/ifpan-abm-pgxpred/analysis/marpiech-gwas-test/venv/lib/python3.12/site-packages/awscrt/eventstream/__init__.py __format__zHeaderType.__format__Ds 4yN)__name__ __module__ __qualname____doc__ BOOL_TRUE BOOL_FALSEBYTEINT16INT32INT64BYTE_BUFSTRING TIMESTAMPrrrrrrsl7I3J3 D$ E% E% E%H F(I/ D+rc&eZdZdZdededefdZedede ddfdZ edede ddfdZ edede ddfd Z edede ddfd Zedede ddfd Zededeeefddfd Zedededdfd Zedede ddfdZedededdfdZedZdZedefdZedefdZedefdZdedefdZde fdZde fdZ de fdZ!de fdZ"de fdZ#deeeffdZ$defdZ%de fdZ&defdZ'dZ(d Z)y!)"rzA header in an event-stream message. Each header has a name, value, and type. :class:`HeaderType` enumerates the supported value types. Create a header with one of the Header.from_X() functions. namevalue header_typec.||_||_||_yr)_name_value_type)rr+r,r-s r__init__zHeader.__init__Rs    rreturncf|r||dtjS||dtjS)zWCreate a Header of type :attr:`~HeaderType.BOOL_TRUE` or :attr:`~HeaderType.BOOL_FALSE`TF)rr r!clsr+r,s r from_boolzHeader.from_boolXs1 tT:#7#78 8tUJ$9$9: :rct|}|tks |tkDrtdj ||||t j S)zcCreate a Header of type :attr:`~HeaderType.BYTE` The value must fit in an 8-bit signed intz(Value {} cannot fit in signed 8-bit byte)int _BYTE_MIN _BYTE_MAX ValueErrorformatrr"r5s r from_bytezHeader.from_byte`sF E  9  1GNNuUV V4 00rct|}|tks |tkDrtdj ||||t j S)zeCreate a Header of type :attr:`~HeaderType.INT16` The value must fit in an 16-bit signed intz(Value {} cannot fit in signed 16-bit int)r9 _INT16_MIN _INT16_MAXr<r=rr#r5s r from_int16zHeader.from_int16jH E  : !3GNNuUV V4 0 011rct|}|tks |tkDrtdj ||||t j S)zeCreate a Header of type :attr:`~HeaderType.INT32` The value must fit in an 32-bit signed intz(Value {} cannot fit in signed 32-bit int)r9 _INT32_MIN _INT32_MAXr<r=rr$r5s r from_int32zHeader.from_int32trCrct|}|tks |tkDrtdj ||||t j S)zeCreate a Header of type :attr:`~HeaderType.INT64` The value must fit in an 64-bit signed intz(Value {} cannot fit in signed 64-bit int)r9 _INT64_MIN _INT64_MAXr<r=rr%r5s r from_int64zHeader.from_int64~rCrc2|||tjS)zcCreate a Header of type :attr:`~HeaderType.BYTE_BUF` The value must be a bytes-like object)rr&r5s r from_byte_bufzHeader.from_byte_bufs 4 3 344rcHt|}|||tjS)z2Create a Header of type :attr:`~HeaderType.STRING`)rrr'r5s r from_stringzHeader.from_strings"E 4 1 122rct|}|tks |tkDrtdj ||||t j S)zyCreate a Header of type :attr:`~HeaderType.TIMESTAMP` Value must be a posix timestamp (seconds since Unix epoch)z!Value {} exceeds timestamp limits)r9rIrJr<r=rr(r5s rfrom_timestampzHeader.from_timestampsH E  : !3@GGNO O4 4 455rct|ts#tdjt ||||t jS)zRCreate a Header of type :attr:`~HeaderType.UUID` The value must be a UUIDzValue must be UUID, not {}) isinstancer TypeErrorr=typerr5s r from_uuidzHeader.from_uuids< %&8??U LM M4 00rcv|\}}}t|}|tjk(r t|}||||S)N)bytes)rr)r6 binding_tupler+r,r-s r_from_binding_tuplezHeader._from_binding_tuples?$1 e[ - *// )u%E4 ,,rc|jtjk(r|jj}n |j}|j ||jfSr)r1rrr0rXr/)rr,s r_as_binding_tuplezHeader._as_binding_tuples? :: (KK%%EKKE E4::..rc|jS)z Header name)r/rs rr+z Header.namezzrc|jS)z Header type)r1r^s rrUz Header.typer_rc|jS)zHeader value The header's type determines the value's type. Use the value_as_X() methods for type-checked queries.)r0r^s rr,z Header.values {{rc|j|k7r%tdj|j||jS)NzHeader type is {}, not {})r1rTr=r0)rr-s r _value_aszHeader._value_ass5 :: $7>>tzz;WX X{{rc|jtjk(ry|jtjk(ryt dj |jtjtj)z}Return bool value Raises an exception if type is not :attr:`~HeaderType.BOOL_TRUE` or :attr:`~HeaderType.BOOL_FALSE`TFzHeader type is {}, not {} or {})r1rr r!rTr=r^s r value_as_boolzHeader.value_as_boolsb ::-- - ::.. . - 4 4 $$%% '( (rc@|jtjS)zeReturn value of 8-bit signed int Raises an exception if type is not :attr:`~HeaderType.BYTE`)rcrr"r^s r value_as_bytezHeader.value_as_byte~~joo..rc@|jtjS)zgReturn value of 16-bit signed int Raises an exception if type is not :attr:`~HeaderType.INT16`)rcrr#r^s rvalue_as_int16zHeader.value_as_int16~~j..//rc@|jtjS)zgReturn value of 32-bit signed int Raises an exception if type is not :attr:`~HeaderType.INT32`)rcrr$r^s rvalue_as_int32zHeader.value_as_int32rkrc@|jtjS)zgReturn value of 64-bit signed int Raises an exception if type is not :attr:`~HeaderType.INT64`)rcrr%r^s rvalue_as_int64zHeader.value_as_int64rkrc@|jtjS)z^Return value of bytes Raises an exception if type is not :attr:`~HeaderType.BYTE_BUF`)rcrr&r^s rvalue_as_byte_bufzHeader.value_as_byte_bufs~~j1122rc@|jtjS)z]Return value of string Raises an exception if type is not :attr:`~HeaderType.STRING`)rcrr'r^s rvalue_as_stringzHeader.value_as_strings~~j//00rc@|jtjS)z~Return value of timestamp (seconds since Unix epoch) Raises an exception if type is not :attr:`~HeaderType.TIMESTAMP`)rcrr(r^s rvalue_as_timestampzHeader.value_as_timestamps~~j2233rc@|jtjS)zYReturn value of UUID Raises an exception if type is not :attr:`~HeaderType.UUID`)rcrrr^s r value_as_uuidzHeader.value_as_uuid rhrcdj|jt|j|jj S)Nz {}: {} <{}>)r=r/reprr0r1r+r^s r__str__zHeader.__str__s3## JJ   JJOO rcdj|jjt|jt|j t|j S)Nz{}({}, {}, {}))r= __class__rryr/r0r1r^s r__repr__zHeader.__repr__sF&& NN # #        rN)*rrrrrrrr2 classmethodboolr7r9r>rBrGrKrrX bytearrayrMrOrQrrVrZr\propertyr+rUr,rcrergrjrmrorqrsrurwrzr}r)rrrrIs!S!!:! ;S;;(;;1S11112c2#2(222c2#2(222c2#2(2255U5)3C-D555 3s333833 6#6c6h661S11(11--/cjsZC (t (/s/ 00 00 00 35 )9#:3 11 4C4 /t/  rN)renumrtypingrruuidr__all__r:r;r@rArErFrIrJrrr)rrrsb  "         --`RRr