>pEX/ d dl mZ d dlZd dlmZmZmZ d dlmZ d dl m
Z
m Z m Z m
Z
mZmZmZ dZ G d dee Zd Zd
Z G d d ee Z ed
d Ze G d d Ze G d de Ze G d de Ze G d de Ze G d de Z e G d de Z e G d d e Z e G d d e Z G d d ee Z G d! d"ee Z! G d# d$ee Z" G d% d&ee Z# G d' d(ee Z$e G d) d*e Z%e G d+ d,e Z&e G d- d.e Z'e G d/ d0e Z(e G d1 d2e Z)e G d3 d4e Z*e G d5 d6e Z+ G d7 d8ee Z, G d9 d:ee Z- G d; de Z/e G d? d@e Z0e G dA dBe Z1e G dC dDe Z2e G dE dFe Z3e G dG dHe Z4e G dI dJe Z5e G dK dLe Z6e G dM dNe Z7e G dO dPe Z8e G dQ dRe Z9e G dS dTe Z:e G dU dVe Z;e G dW dXe ZdS )] ) annotationsN) dataclassfieldsreplace)Enum)AnyDictIterableIteratorListOptionalTypeVari ʚ;c > e Zd ZdZdZdZdZdZdZdZ dZ
d Z d
Z d Z
d Zd
S )HeaderzNats-Consumer-Stalled DescriptionzNats-Expected-Last-Msg-IdzNats-Expected-Last-Sequencez#Nats-Expected-Last-Subject-SequencezNats-Expected-StreamzNats-Last-ConsumerzNats-Last-Streamz Nats-Msg-IdzNats-TTLz Nats-RollupStatusN)__name__
__module__ __qualname__CONSUMER_STALLED DESCRIPTIONEXPECTED_LAST_MSG_IDEXPECTED_LAST_SEQUENCE EXPECTED_LAST_SUBJECT_SEQUENCEEXPECTED_STREAM
LAST_CONSUMER LAST_STREAMMSG_IDMSG_TTLROLLUPSTATUS k/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/nats/js/api.pyr r sN . K6 :%J",O(M$K
FG
F
FFFr# r z$JS.APIs _INBOX.c " e Zd ZdZdZdZdZdZdS )
StatusCode503404408409100N)r r r SERVICE_UNAVAILABLE NO_MESSAGESREQUEST_TIMEOUTCONFLICTCONTROL_MESSAGEr" r# r$ r& r& , s( KOHOOOr# r& _BBase)boundc e Zd ZdZed d
Zed d Zed!d Zed d Zed"d Z ed#d Z
e d$d Z d%dZ
d&d Zd S )'r2 zA
Helper dataclass to filter unknown fields from the API.
respDict[str, Any]fieldstrtype
type[Base]returnNonec | |d }|d| |< dS t |t rfd|D | |< dS | | |< dS )z/Convert the field into the given type in place.Nc : g | ]} | S r" )
from_response).0itemr9 s r$
z!Base._convert..D s' EEE4--d33EEEr# )get
isinstancelistr? )r5 r7 r9 datas ` r$ _convertz
Base._convert= sx xxt$$ < DKKK
d
#
# 3EEEEEEEDKKK ,,T22DKKKr# c T | |d }|
|t z }|| |< dS )z=Convert the given field from nanoseconds to seconds in place.N)rC _NANOSECONDr5 r7 vals r$ _convert_nanosecondszBase._convert_nanosecondsH s3 hhud## ? #CU r# rK Optional[float]
Optional[int]c 8 | dS t | t z S )z.Convert the value from seconds to nanoseconds.Nr )intrI )rK s r$ _to_nanosecondszBase._to_nanosecondsP s! ;13$%%%r# c t | |d }| t | | |< dS dS )zBConvert a ISO 8601/RFC 3339 string field into a datetime in place.N)rC r2 _parse_utc_isorJ s r$ _convert_utc_isozBase._convert_utc_isoX s> hhud## ? --c22DKKK ?r# datedatetime.datetimec ~ t | t r| S | j &| t j j } n>| j t j j k r$| t j j } | dd dd S )zConvert a datetime into an ISO 8601/RFC 3339 formatted string.
If datetime does not have timezone information, datetime
is assumed to be in UTC timezone. Strings are passed through as-is
for backwards compatibility.
N)tzinfo+00:00Zz.000000 ) rD r8 rX r datetimetimezoneutc
astimezone isoformat)rU s r$ _to_utc_isozBase._to_utc_iso_ s dC K ; <>y"MMMr# time_stringc : | dd }| dd \ }}| d \ }}|dd }| d| d| }t j | t j j S )zCParse an ISO 8601 timestamp (with nanoseconds) into a UTC datetime.rZ rY . +N )r splitr\
fromisoformatr_ r] r^ )rb s date_partfrac_tzfractzs r$ rS zBase._parse_utc_isoo s
X . . WWS!__ 7==%%bBQBx & &4 & &" & & ..q11<Return a copy of the instance with the passed values replaced.)r )rt rs s r$ evolvez Base.evolve s t&&v&&&r# Dict[str, object]c b i }t | D ]}t | |j }|t |t r| }t |t r:t | dk r't |d t r d |D }|||j < |S )z6Return the object converted into an API-friendly dict.Nr c ` g | ]+}t |t | ,S r" )rD r2 as_dict)r@ vs r$ rB z Base.as_dict.. s/ KKK1z!T7J7JK199;;KKKr# )r getattrrr rD r2 rz rE len)rt resultr7 rK s r$ rz z Base.as_dict s D\\ % %E$
++C{#t$$
$kkmm#t$$
Ls88a<. s +[+[+[RBJJLL+[+[+[r# r r )r rz r r ra r s r$ rz zStreamSource.as_dict sh "" " \+[+[4CZ+[+[+[F' ( *'+'7'78K'L'LF# $
r# r5 r6 r )
r r r r r r r r r r r? rz r r s @r$ r r s
III#'M''''26N6666$(N(((()-H----;?????+ + + + + [+ r# r c D e Zd ZU ded< dZded< dZded< dZded< dS ) StreamSourceInfor8 rr NrN lagactivezOptional[Dict[str, Any]]error)r r r r r r r r" r# r$ r r sN
III C F &*E******r# r c , e Zd ZU dZded< dZded< dS )LostStreamDataNOptional[List[int]]msgsrN bytes)r r r r r r r" r# r$ r r s4 $D$$$$ E r# r c e Zd ZU ded< ded< ded< ded< ded< dZded < dZd
ed < dZd ed
< dZded< ed fd Z xZ
S ) StreamStaterP messagesr first_seqlast_seqconsumer_countNr deletedrN num_deletedzOptional[LostStreamData]lostzOptional[Dict[str, int]]subjectsr5 r6 c ~ | |dt t | S )Nr )rG r r r? r s r$ r? zStreamState.from_response s1 T6>222ww$$T***r# r ) r r r r r r r r r r? r r s @r$ r r s MMMJJJNNNMMM#'G''''!%K%%%%%)D)))))-H----+ + + + + [+ + + + +r# r c e Zd ZdZdZdZdZdS )RetentionPolicyz#How message retention is consideredlimitsinterest workqueueN)r r r r LIMITSINTEREST
WORK_QUEUEr" r# r$ r r s# --
FH JJJr# r c e Zd ZdZdZdZdS ) StorageTypezThe type of storage backendfilememoryN)r r r r FILEMEMORYr" r# r$ r r s %% D
FFFr# r c e Zd ZdZdZdZdS )
DiscardPolicyz/Discard policy when a stream reaches its limitsoldnewN)r r r r OLDNEWr" r# r$ r r s 99
C
CCCr# r c e Zd ZdZdZdZdS )StoreCompressionz
If stream is file-based and a compression algorithm is specified,
the stream data will be compressed on disk.
Valid options are none or s2 for Snappy compression.
Introduced in nats-server 2.10.0.
nones2N)r r r r NONES2r" r# r$ r r s$ D
BBBr# r c e Zd ZdZdZdZdS ) PersistModea1
PersistMode defines the consistency and durability guarantees for stream persistence.
See ADR-56 for details: https://github.com/nats-io/nats-architecture-and-design/blob/main/adr/ADR-56.md
Currently only applicable to R1 (single replica) streams.
Introduced in nats-server 2.12.0.
defaultasyncN)r r r r DEFAULTASYNCr" r# r$ r r s& G
EEEr# r c > e Zd ZU dZdZded< dZded< dZded< dS ) RePublishz
RePublish is for republishing messages once committed to a stream. The original
subject cis remapped from the subject pattern to the destination pattern.
Nr srcdestr headers_only)r r r r r r r r r" r# r$ r r + sQ
C D #'L''''''r# r c : e Zd ZU dZded< ded< d fd Z xZS ) r z0Subject transform to apply to matching messages.r8 r r r; rw c H t }|S r r r s r$ rz zSubjectTransform.as_dict> r r# r )r r r r r rz r r s @r$ r r 7 sW :: HHH
III r# r c 6 e Zd ZU dZdZded< dZded< dZded< dZded < dZ d
ed < dZ
d
ed < dZ d
ed
< e j
Zded< dZded< dZded< dZded< dZd
ed< dZded< dZd
ed< dZded < dZded < d Zd ed < dZd!ed"< dZd#ed$< dZd%ed&< dZded'< dZ ded(< dZ ded)< dZ ded*< dZ d+ed,< dZ d-ed.< dZ!d/ed0< dZ"d/ed1< dZ#d2ed3< dZ$d/ed4< dZ%d/ed5< dZ&d/ed6< dZ'd/ed7< dZ(d8ed9< dZ)d:ed;< e*dB fd> Z+dC fdA Z, xZ-S )D StreamConfigz@
StreamConfig represents the configuration of a stream.
Nr rr descriptionr r zOptional[RetentionPolicy] retentionrN
max_consumersmax_msgs max_byteszOptional[DiscardPolicy]discardFbooldiscard_new_per_subjectrM max_agerP max_msgs_per_subject max_msg_sizeOptional[StorageType]storage num_replicasno_acktemplate_ownerr floatduplicate_windowOptional[Placement] placementzOptional[StreamSource]mirrorz Optional[List[StreamSource]]sourcessealed deny_delete
deny_purgeallow_rollup_hdrsOptional[RePublish] republishzOptional[SubjectTransform]subject_transformr allow_direct
mirror_directzOptional[StoreCompression] compression
allow_msg_ttlallow_msg_schedules allow_atomic
allow_batchedzOptional[PersistMode] persist_modeOptional[Dict[str, str]]metadatar5 r6 c | |d | |d | |dt | |dt | |dt | |dt | |dt
t
| S )Nr r r r r r r )rL rG r r r r r r? r s r$ r? zStreamConfig.from_response s y111 '9::: T; 222 T8\222 T9l333 T; 222 T.0@AAAww$$T***r# r; rw c t }| | j |d< | | j |d< | j rd | j D |d< | j rA| j t j k r,| j t j k rt d| j z | j r)t | j t st d |S )Nr r c 6 g | ]}| S r" r )r@ r s r$ rB z(StreamConfig.as_dict.. s G G G3 G G Gr# r z(nats: invalid store compression type: %sz nats: invalid metadata format)r rz rQ r r r r r r r
ValueErrorr rD dictr s r$ rz zStreamConfig.as_dict s ""%)%9%9$:O%P%P!" 0 0 > >y < H G G$, G G GF9 \!15E5J!J!JtO_cscvOvOv G$JZ Z[[ [ = >DM4!@!@ > <== =
r# r r ).r r r r rr r r r r r r r r r r r r r r r r r r r r r r r r r r r r r
r r r
r r r r r r r? rz r r s @r$ r r C s D !%K%%%%$(H((((+/I////#'M'''' "H"""" #I####'4'8G8888$))))) #G#### """"""$L$$$$%)G))))"&L&&&&F$(N(((( %)I))))%)F)))),0G0000F K J ##### &*I))))488888 $(L'''' %)M(((( /3K2222 %)M(((( +/.... $(L'''' %)M(((( +/L.... *.H----+ + + + + [+
r# r c V e Zd ZU dZded< dZded< dZded< dZded< dZded < dS )
PeerInfoNr rr r currentofflinerN r r ) r r r rr r r r r r r" r# r$ r r sg D "G"""" "G"""" F C r# r c e Zd ZU dZded< dZded< dZded< dZded< dZded < dZ ded
< e
d fd
Z xZ S ) ClusterInfoNr leaderrr zOptional[List[PeerInfo]]replicas
raft_groupr leader_since traffic_accr5 r6 c | |dt d|v r&|d r | |d |d< t | S )Nr r" )rG r rS r r? r s r$ r? zClusterInfo.from_response sc T:x000 T ! !d>&: !##5d>6J#K#KD ww$$T***r# r )
r r r r r rr r r! r" r# r r? r r s @r$ r r s F D )-H---- $J$$$$04L4444!%K%%%%+ + + + + [+ + + + +r# r c e Zd ZU dZded< ded< dZded< dZd ed
< dZd ed < dZd
ed< e d fd Z
xZ S )
StreamInfozM
StreamInfo is the latest information about a stream from JetStream.
r configr stateNzOptional[StreamSourceInfo]r z Optional[List[StreamSourceInfo]]r Optional[ClusterInfo]r r
did_creater5 r6 c ^ | |dt | |dt | |dt | |dt | |dt t | S )Nr' r( r r r )rG r r r r r r? r s r$ r? zStreamInfo.from_response s T8\222 T7K000 T8%5666 T9&6777 T9k222ww$$T***r# r ) r r r r r r r r r* r r? r r s @r$ r& r& s )-F----04G4444%)G))))!%J%%%%+ + + + + [+ + + + +r# r& c * e Zd ZdZdd Zdd Zdd
ZdS )StreamsListIteratorzW
StreamsListIterator is an iterator for streams list responses from JetStream.
offsetrP totalstreamsList[Dict[str, any]]r; r< c > || _ || _ || _ d| _ d S )Nr )r. r/ r0 _index)rt r. r/ r0 s r$ __init__z StreamsListIterator.__init__ s"
r# Iterator[StreamInfo]c | S r r" rt s r$ __iter__z StreamsListIterator.__iter__ s r# r& c | j t | j k r`_
r allexplicitN)r r r r r ALLEXPLICITr" r# r$ r> r> s) D
CHHHr# r> c * e Zd ZdZdZdZdZdZdZdZ dS )
DeliverPolicyag When a consumer is first created, it can specify where in the stream it wants to start receiving messages.
This is the DeliverPolicy, and this enumeration defines allowed values.
References:
* `Consumers, DeliverPolicy/OptStartSeq/OptStartTime `_
r? lastr by_start_sequence
by_start_timelast_per_subjectN)
r r r r rA LASTr BY_START_SEQUENCE
BY_START_TIMELAST_PER_SUBJECTr" r# r$ rD rD s< C D
C+#M)r# rD c e Zd ZdZdZdZdS ) ReplayPolicyaU The replay policy applies when the DeliverPolicy is one of:
* all
* by_start_sequence
* by_start_time
since those deliver policies begin reading the stream at a position other than the end.
References:
* `Consumers, ReplayPolicy `_
instantoriginalN)r r r r INSTANTORIGINALr" r# r$ rN rN s$ GHHHr# rN c e Zd ZU dZdZded< dZded< dZded< ej Z
ded< dZ d ed
< dZ d ed < e
j Zd
ed< dZded< dZd ed< dZded< dZded< dZded< ej Zded< dZd ed< dZded< dZd ed< dZd ed < dZ d ed < dZ ded < dZ d ed < dZ ded!< dZ ded"< dZ!ded#< dZ"d ed$< dZ#d ed%< dZ$d&ed'< dZ%ded(< e&d/ fd+ Z'd0 fd. Z( xZ)S )1ConsumerConfigzxConsumer configuration.
References:
* `Consumers `_
Nr rr durable_namer zOptional[DeliverPolicy]deliver_policyrN r r r zOptional[AckPolicy]
ack_policyrM ack_wait max_deliverzOptional[List[float]]backoffr r filter_subjectszOptional[ReplayPolicy]
replay_policyrate_limit_bps sample_freq max_waitingmax_ack_pendingr flow_controlidle_heartbeatr deliver_subject
deliver_groupinactive_thresholdr mem_storager r pause_untilr5 r6 c ( | |d | |d | |d | |d d|v rd |d D |d< t | S )NrX rb re r rZ c " g | ] }|t z
S r" )rI )r@ rK s r$ rB z0ConsumerConfig.from_response..L s L L LSs[ 0 L L Lr# )rL rT r r? r s r$ r? z ConsumerConfig.from_responseE s z222 '7888 ';<<< T#3444 L LDO L L LDOww$$T***r# r; rw c z t } j j |d< j |d< j |d< j |d< j r fd j D |d< |S )Nr rX rb re c : g | ]} | S r" )rQ )r@ irt s r$ rB z*ConsumerConfig.as_dict..W s' O O OQ!5!5a!8!8 O O Or# rZ ) r rz r ra rQ rX rb re rZ r s ` r$ rz zConsumerConfig.as_dictO s "" *'+'7'78K'L'LF# $ ! 1 1$- @ @z#'#7#78K#L#L '+';';D rB rW rX rY rZ r r[ rN rQ r\ r] r^ r_ r` ra rb r rc rd re r rf r rg r r? rz r r s @r$ rT rT sT D "&L&&&&!%K%%%%.;.?N????#'M''''26N6666&/&8J8888 $H$$$$!%K%%%%%)G))))$(N((((+/O////,8,@M@@@@$(N((((!%K%%%%!%K%%%%%)O))))#'L''''&*N****#'L'''' &*O))))#'M'''' +/.... #'L&&&& #'K&&&& *.H----
"&K%%%%+ + + + + [+ r# rT c ` e Zd ZU ded< ded< dZded< ed
fd Zd fd Z xZS ) SequenceInforP consumer_seq
stream_seqNr last_activer5 r6 c r | |d t | S Nrq )rT r r? r s r$ r? zSequenceInfo.from_responsea s1 T=111ww$$T***r# r; rw c t }| j | | j |d< |S rs )r rz rq ra r s r$ rz zSequenceInfo.as_dictf s? "" '$($4$4T5E$F$FF= !
r# r r ) r r r r rq r r? rz r r s @r$ rn rn [ s OOO/3K3333+ + + + + [+ r# rn c e Zd ZU dZded< ded< ded< ded< d Zd
ed < d Zd
ed < d Zd
ed< d Zd
ed< d Z d
ed< d Z
d
ed< d Z ded< d Z ded< d Z
ded< d Zded< ed fd Zd fd Z xZS )! ConsumerInfoz>
ConsumerInfo represents the info about the consumer.
r8 rr stream_namerT r' rV createdNzOptional[SequenceInfo] delivered ack_floorrN num_ack_pendingnum_redelivered num_waiting num_pendingr) r r
push_boundpausedr pause_remainingr5 r6 c R | |dt | |dt | |dt | |dt | |d t | S )Nry rz r' r rx )rG rn rT r rT r r? r s r$ r? zConsumerInfo.from_response s T; 555 T; 555 T8^444 T9k222 T9---ww$$T***r# r; rw c t }| | j |d< |S )Nrx )r rz ra rx r s r$ rz zConsumerInfo.as_dict s5 "" , ,T\ : :y
r# r r )r r r r r ry rz r{ r| r} r~ r r r r r r? rz r r s @r$ rv rv m sN III (,I,,,,(,I,,,,%)O))))%)O))))!%K%%%%!%K%%%%%)G))))!%J%%%% "F!!!! &*O))))+ + + + + [+ r# rv c : e Zd ZU dZded< dZded< dZded< dS )
ConsumerPausez{
ConsumerPause represents the pause state after a pause or resume operation.
Introduced in nats-server 2.11.0.
r r Nr rg r )r r r r r rg r r" r# r$ r r sI
LLL!%K%%%%%)O))))))r# r c d e Zd ZU dZded< ded< ded< ded< ded< ded< ded < d
ed < d S )
AccountLimitszAccount limits
References:
* `Multi-tenancy & Resource Mgmt `_
rP
max_memory max_storage max_streamsr r` memory_max_stream_bytesstorage_max_stream_bytesr max_bytes_requiredNr r r r r r" r# r$ r r s{ OOO !!!! r# r c d e Zd ZU ded< ded< ded< ded< ded< ed fd
Z xZS ) TierrP r r r0 consumersr r r5 r6 c ~ | |dt t | S )Nr )rG r r r? r s r$ r? zTier.from_response s1 T8]333ww$$T***r# r )r r r r r r? r r s @r$ r r sy KKKLLLLLLNNN+ + + + + [+ + + + +r# r c ( e Zd ZU dZded< ded< dS )APIStatsz API statsrP r/ errorsNr r" r# r$ r r s' OJJJKKKKKr# r c e Zd ZU dZded< ded< ded< ded< ded< d ed
< d Zd ed
< d Zded< ed fd Z xZ S ) AccountInfozAccount information
References:
* `Account Information `_
rP r r r0 r r r r r Nr r zOptional[Dict[str, Tier]]tiersr5 r6 c j | |dt | |dt t | }| dd }|r@i }| D ]"\ }}t | ||< #||_ |S )Nr r r ) rG r r r r? rC itemsr r )ro r5 infor r~ kr{ r s r$ r? zAccountInfo.from_response s T8]333 T5(+++ww$$T**$'' F
2
21 . .q 1 1q DJ r# r )
r r r r r r r r r? r r s @r$ r r s KKKLLLLLLNNNMMM F '+E++++
[
r# r c e Zd ZU dZded< dZded< dZded< dZded< dZd ed
< dZ ded < dZ
d ed
< e dd Z e dd Z
ed fd Z xZS ) RawStreamMsgNr subjectrN r zOptional[bytes]rF hdrsOptional[Dict]headersr r timer; c | j S r )r r7 s r$ sequencezRawStreamMsg.sequence s xr# c | j S )z<
header returns the headers from a message.
)r r7 s r$ headerzRawStreamMsg.header s
|r# r5 r6 c | |d |d< t | S )Nr )rS r r? r s r$ r? zRawStreamMsg.from_response s6 ))$v,77V ww$$T***r# )r; rN )r; r r )r r r r r r rF r r r r propertyr r r r? r r s @r$ r r s !G!!!! C D D "G"""" F (,D,,,,
X X + + + + + [+ + + + +r# r c e Zd ZU dZded< dZded< dZded< d Zd
ed < dZd ed
< dZ ded< dZ
ded< d Z d
ed< dZ ded< dZ
ded< dZded< d fd Z xZS ) KeyValueConfigzB
KeyValueConfig is the configuration of a KeyValue store.
r8 bucketNr r rN max_value_sizere rP historyrM ttlr r r r r r r r r directr; rw c t }| | j |d< |S Nr r rz rQ r r s r$ rz zKeyValueConfig.as_dict 4 "" ,,TX66u
r# r )r r r r r r r r r r r r r r r rz r r s @r$ r r s KKK!%K%%%%$(N((((G C #I####%)G))))H%)I))))%)I)))) !F!!!! r# r c > e Zd ZU dZdZded< dZded< dZded< dS )StreamPurgeRequestzN
StreamPurgeRequest is optional request information to the purge API.
NrN r r filterkeep)r r r r r r r r r" r# r$ r r sQ
C F D r# r c e Zd ZU dZdZded< dZded< dZded< dZded < dZ d
ed < d Z
d
ed< dZ ded< d fd Z xZ
S )ObjectStoreConfigzE
ObjectStoreConfig is the configurigation of an ObjectStore.
Nr r r rM r rN r r r re rP r r r r; rw c t }| | j |d< |S r r r s r$ rz zObjectStoreConfig.as_dict9 r r# r )r r r r r r r r r r r r rz r r s @r$ r r + s !F !%K%%%% C #I####%)G))))H%)I)))) r# r c N e Zd ZU dZded< dZded< ed
fd Z xZS )
ObjectLinkzI
ObjectLink is used to embed links to other buckets and objects.
r8 r Nr rr r5 r6 c F t | S r )r r? r s r$ r? zObjectLink.from_responseK s ww$$T***r# r ) r r r r r rr r r? r r s @r$ r r ? sq
KKK D + + + + + [+ + + + +r# r c N e Zd ZU dZded< dZded< ed fd Z xZS )
ObjectMetaOptionsNzOptional[ObjectLink]linkrN max_chunk_sizer5 r6 c ~ | |dt t | S )Nr )rG r r r? r s r$ r? z ObjectMetaOptions.from_responseU s1 T6:...ww$$T***r# r ) r r r r r r r r? r r s @r$ r r P sk !%D%%%%$(N((((+ + + + + [+ + + + +r# r c n e Zd ZU dZdZded< dZded< dZded< dZded < e d
fd Z
xZ S )
ObjectMetaz?
ObjectMeta is high level information about an object.
Nr rr r Optional[dict]r Optional[ObjectMetaOptions]optionsr5 r6 c ~ | |dt t | S Nr rG r r r? r s r$ r? zObjectMeta.from_responseg 2 T9&7888ww$$T***r# r ) r r r r rr r r r r r r? r r s @r$ r r [ s D !%K%%%% "G""""+/G////+ + + + + [+ + + + +r# r c e Zd ZU dZded< ded< ded< dZded< dZd ed
< dZded < dZd ed < d
Z ded< dZ
d ed< dZ ded< dZ ded< e
d d Zd dZed fd Z xZS )
ObjectInfoz7
ObjectInfo is meta plus instance information.
r8 rr r nuidNrN sizer mtimechunksdigestFr r r r r r r r; r c P t | j | j | j | j S )N)rr r r r )r rr r r r r7 s r$ metazObjectInfo.meta s. (LL
r# r c 0 | j d uo
| j j d uS r )r r r7 s r$ is_linkzObjectInfo.is_link s |4'IDL,=T,IIr# r5 r6 c ~ | |dt t | S r r r s r$ r? zObjectInfo.from_response r r# )r; r )r; r r )r r r r r r r r r r r r r r r r r r? r r s @r$ r r m s2 IIIKKK
III D E F F #G####!%K%%%% "G""""+/G////
X
J J J J + + + + + [+ + + + +r# r )?
__future__r r\ dataclassesr r r enumr typingr r r
r r r
r rI r8 r DEFAULT_PREFIX INBOX_PREFIXr& r1 r2 r r r r r r r r r r r r r r r r r r& r- r> rD rN rT rn rv r r r r r r r r r r r r r r" r# r$ r s # " " " " " 2 2 2 2 2 2 2 2 2 2 I I I I I I I I I I I I I I I I I I S$ d
WT ` ` ` ` ` ` ` `F % % % % %T % % % % % % % % % % % T 4 0 + + + + +t + + + T
+ + + + +$ + + +" c4 #t C
sD
#t , ( ( ( ( ( ( ( ( t S S S S S4 S S Sl t
+
+
+
+
+$
+
+
+ + + + + + + + +, ( . T * * * * *C * * *" 3 F F F F FT F F FR 4 " $ $ $ $ $4 $ $ $N * * * * *D * * * D "
+
+
+
+
+4
+
+
+ t $ @ + + + + +4 + + +4 T .
&
+
+
+
+
+
+
+
+ + + + + + + + + + + + + + + + +" #+ #+ #+ #+ #+ #+ #+ #+ #+ #+r#