4t* d dl mZ d dlZd dlZd dlmZ d dlmZmZm Z m
Z
m Z d dl m
Z
mZmZ erd dlmZ dZdZe G d d
ZdS ) ) annotationsN) dataclass)
TYPE_CHECKINGDictListOptionalUnion)ErrorMsgAlreadyAckdErrorNotJSMessageError)NATS c | e Zd ZU dZded< dZded< dZded< dZd ed
< d Zd ed
< d Z ded< dZ
ded< d Z ded< G d d Z e
d2d Ze
d3d Ze
d4d Zd5d Zd6d Zd7d8d#Zd9d:d&Zd6d'Zd6d(Ze
d;d* Zd headerz
Msg.headerI s
|r c | j S )zm
Have we sent a terminal ack message (not in-progress) in response to this original message?
)r rB s r> is_ackedz Msg.is_ackedP s
zr intc < | j t d | j S )zA
sid returns the subscription ID from a message.
Nz sid not set)r r
rB s r> sidzMsg.sidW s"
9
&& &yr Nonec K | j st d | j st d | j | j || j d{V dS )zN
respond replies to the inbox of the message if there is one.
zno reply subject availablezclient not setrA N)r r
r publishr )rC r s r> respondz Msg.respond` ss z 6455 5| *()) )l""4:tT\"JJJJJJJJJJJr c K | | j | j d{V d| _ dS )zD
ack acknowledges a message delivered by JetStream.
NT) _check_replyr rL r r rB s r> ackzMsg.ackk sO
l""4:.........
r ?timeoutfloat'Msg'c K | | j | j | d{V }d| _ |S )zW
ack_sync waits for the acknowledgement to be processed by the server.
)rR NT)rO r requestr r )rC rR resps r> ack_syncz Msg.ack_syncs sT
\))$*g)FFFFFFFF
r delayUnion[int, float, None]c T K | t j j }t }|rt |dz |d< |r,|dt
j | z z
}| j
| j | d{V d| _ dS )z
nak negatively acknowledges a message delivered by JetStream triggering a redelivery.
if `delay` is provided, redelivery is delayed for `delay` seconds
i ʚ;rY NT)
rO r r. r/ dictrG jsondumpsencoder rL r r )rC rY payload json_argss r> nakzMsg.nak| s
'+FF 4!$UU]!3!3Ig = tdj 3 3 : : < << in_progresszMsg.in_progress sY
: r!1!1# #l""4:sw/?@@@@@@@@@@@r c K | | j | j t j j d{V d| _ dS )z]
term terminates a message delivered by JetStream and disables redeliveries.
NT)rO r rL r r r. r1 r rB s r> termzMsg.term sU
l""4:sw|<<<<<<<<<
r Metadatac r | j }||S t j | j }|| _ |S )zG
metadata returns the Metadata of a JetStream message.
)r r rh _from_replyr )rC metadatas r> rk z Msg.metadata s9 > O<++DJ77!r
Optional[str] List[str]c @ t j | S N)r rh _get_metadata_fields)rC r s r> rp zMsg._get_metadata_fields s |00777r c d | j | j dk rt | j rt | d S )Nr )r r r r rB s r> rO zMsg._check_reply s> : r!1!1# # : ,%d++ + , ,r Tfrozenc e Zd ZU dZded< ded< ded< ded< d ed
< d ed < d Zd
ed< ed G d d Zedd Z edd Z
d S ) Msg.Metadataa
Metadata is the metadata from a JetStream message.
- num_pending is the number of available messages in the Stream that have not been
consumed yet.
- num_delivered is the number of times that this message has been delivered.
For example, num_delivered higher than one means that there have been redeliveries.
- timestamp is the time at which the message was delivered.
- stream is the name of the stream.
- consumer is the name of the consumer.
SequencePairsequencerG num_pending
num_deliveredzdatetime.datetime timestampr streamconsumerNrl domainTrr c ( e Zd ZU dZded< ded< dS )Msg.Metadata.SequencePairzY
SequencePair represents a pair of consumer and stream sequence.
rG r| r{ N)r+ r, r- __doc____annotations__r= r r> rv r s.
MMM KKKKKr r r? rm c " |st | d }t | t k st | t dz
k r8|d t
j j k r |d t
j j k r|S t )N. r ) r splitlen_V1_TOKEN_COUNT_V2_TOKEN_COUNTr r. r2 r3 )clsr tokenss r> rp z!Msg.Metadata._get_metadata_fields sy
(''[[%%FV//3v;;/TUBU3U3U1I 001I 00
# #r c | | }t | t k rt j t |d dz t j j } | t j
t |d t |d t |d t |d ||d |d
S t j t |t j j dz t j j }|t j j
}|d k rd } | t j
t |t j j t |t j j t |t j j t |t j j ||t j j |t j j |
S )z,Construct the metadata from the reply stringr( g eAr& r' )r{ r| r% r) r# r$ )rw ry rx rz r{ r| _r )rw ry rx rz r{ r| r} )rp r r datetime
fromtimestamprG timezoneutcr rh rv r. r; r4 r9 r: r8 r< r6 r7 )r r r tr} s r> rj zMsg.Metadata._from_reply s --e44F6{{o-- %33Cq NN_4TV^VgVklls \ 6 6 "6!9~~!$VAY 7 #&fQi.. #F1I !!9 #AY
%33sw 0122_DhFWF[ /S== Fs \ 6 6 "6#'*;#< = =!$VCG,?%@!A!A 7 #&fSW-A&B"C"C #F37+=$> ? ? !#'.1 #CG$4 5! r r rl r? rm )r r r? ru ) r+ r, r- r r r} r rv classmethodrp rj r= r r> rh ru s $$$$
$$$$$ $
$
$
$
$
& & &
& & & r )r? r )r? r )r? rG )r r r? rJ )r? rJ )rQ )rR rS r? rT ro )rY rZ r? rJ )r? rh r ) r+ r, r- r r r r r r r r r r. propertyrD rF rI rM rP rX rc re rg rk rp rO r rh r= r r> r r & sD MMMGEOOOOD(,G,,,,$(I((((E D & X X X K K K K
A A A A
X
8 8 8 8, , , , YdS S S S S S S S S Sr r )
__future__r r r^ dataclassesr typingr r r r r nats.errorsr
r r natsr
r r r r= r r> r s # " " " " " ! ! ! ! ! ! = = = = = = = = = = = = = = E E E E E E E E E E
b b b b b b b b b br