/opt/imunify360/venv/lib/python3.11/site-packages/nats/js/__pycache__
Edit: /opt/imunify360/venv/lib/python3.11/site-packages/nats/js/__pycache__/errors.cpython-311.pyc (14016B)
\R 1 d dl mZ d dlmZ d dlmZmZmZmZm Z d dl
Z d dl m
Z
erd dlmZ G d de j j Z ed d
G d d e Z G d
de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d de j j Z G d d e Z G d d e Z G d d e Z G d! d"e Z G d# d$e e Z G d% d&e e Z G d' d(e e Z! G d) d*e Z" G d+ d,e Z# G d- d.e Z$ G d/ d0e Z% G d1 d2e Z& G d3 d4e Z' G d5 d6e Z( G d7 d8e Z) G d9 d:e Z* G d; d
e Z,dS )? ) annotations) dataclass)
TYPE_CHECKINGAnyDictNoReturnOptionalN)api)Msgc $ e Zd ZdZd
d dZd d ZdS )
ErrorzB
An Error raised by the NATS client when using JetStream.
N description
Optional[str]returnNonec || _ d S Nr selfr s n/builddir/build/BUILD/imunify360-venv-2.6.3/opt/imunify360/venv/lib/python3.11/site-packages/nats/js/errors.py__init__zError.__init__ & strc F d}| j r| j }d| j j d| S )N znats: JetStream. )r __class____name__)r descs r __str__z
Error.__str__# s5 $#DB$."9BBDBBBr r )r r r r r r r
__module__ __qualname____doc__r r" r r r
r
sQ ' ' ' ' 'C C C C C Cr r
F)reprinitc e Zd ZU dZded< ded< ded< ded< ded< ddd Zedd Zedd ZddZ d S )APIErrorzI
An Error that is the result of interacting with NATS JetStream.
Optional[int]codeerr_coder r streamseqNr r c L || _ || _ || _ || _ || _ d S r )r. r/ r r0 r1 )r r. r r/ r0 r1 s r r zAPIError.__init__6 s,
& r msgr r c |j t |j t j j }|t j j k rt |j t j j }t t | | )N)r. r )
headerr, r
HeaderSTATUS
StatusCodeSERVICE_UNAVAILABLEServiceUnavailableError DESCRIPTIONint)clsr3 r. r! s r from_msgzAPIError.from_msgD s` : Nz#*+, 3>5 5 5) ):cj 45DD t<<< vT$ZZ( v v v vdm v vcgcs v v v
r )NNNNN) r. r- r r r/ r- r0 r r1 r- r r )r3 r r r )r? r@ r# )
r r% r& r' __annotations__r classmethodr> rE r" r( r r r, r, * s #%)"& $ !
= = = [= " " " [ "
r r, c e Zd ZdZdS )r: z
A 503 error
Nr r% r& r' r( r r r: r: c Dr r: c e Zd ZdZdS )rB z
A 500 error
NrN r( r r rB rB k rO r rB c e Zd ZdZdS )rC z
A 404 error
NrN r( r r rC rC s rO r rC c e Zd ZdZdS )rD z
A 400 error.
NrN r( r r rD rD { rO r rD c e Zd ZdZddZdS )NoStreamResponseErrorzD
Raised if the client gets a 503 when publishing a message.
r r c dS )Nz nats: no response from streamr( rJ s r r" z NoStreamResponseError.__str__ s ..r Nr# r r% r& r' r" r( r r rT rT s2 / / / / / /r rT c e Zd ZdZddZdS )TooManyStalledMsgsErrorzX
Raised when too many outstanding async published messages are waiting for ack.
r r c dS )Nz@nats: stalled with too many outstanding async published messagesr( rJ s r r" z TooManyStalledMsgsError.__str__ s QQr Nr# rV r( r r rX rX s8 R R R R R Rr rX c e Zd ZdZddZdS )FetchTimeoutErrorz@
Raised if the consumer timed out waiting for messages.
r r c dS )Nznats: fetch timeoutr( rJ s r r" zFetchTimeoutError.__str__ $$r Nr# rV r( r r r[ r[ s2 % % % % % %r r[ c * e Zd ZdZ dd dZd
dZdS ) ConsumerSequenceMismatchErrorz
Async error raised by the client with idle_heartbeat mode enabled
when one of the message sequences is not the expected one.
Nr r c 0 || _ || _ || _ d S r )stream_resume_sequenceconsumer_sequencelast_consumer_sequence)r ra rb rc s r r z&ConsumerSequenceMismatchError.__init__ s" '=#!2 &<###r r c J | j | j z
}d| j d| d| j S )Nz1nats: sequence mismatch for consumer at sequence z (zA sequences behind), should restart consumer from stream sequence )rc rb ra )r gaps r r" z%ConsumerSequenceMismatchError.__str__ sO )D,BB
t@V
t
t
t
tVZVq
t
t
r NNNr r r# r$ r( r r r_ r_ sV $ # = = = = =
r r_ c e Zd ZdZdS )BucketNotFoundErrorzM
When attempted to bind to a JetStream KeyValue that does not exist.
NrN r( r r ri ri rO r ri c e Zd ZdS )BadBucketErrorN)r r% r& r( r r rk rk s Dr rk c e Zd ZdZdS )
KeyValueErrorzL
Raised when there is an issue interacting with the KeyValue store.
NrN r( r r rm rm rO r rm c $ e Zd ZdZdd dZd
dZdS ) KeyDeletedErrorz[
Raised when trying to get a key that was deleted from a JetStream KeyValue store.
Nr r c " || _ || _ d S r )entryop)r rq rr s r r zKeyDeletedError.__init__ s
r r c dS )Nznats: key was deletedr( rJ s r r" zKeyDeletedError.__str__ s &&r )NNrg r# r$ r( r r ro ro sK ' ' ' ' ' 'r ro c $ e Zd ZdZdd dZd
dZdS ) KeyNotFoundErrorz_
Raised when trying to get a key that does not exists from a JetStream KeyValue store.
Nr r c 0 || _ || _ || _ d S r )rq rr message)r rq rr rw s r r zKeyNotFoundError.__init__ s
r r c 2 d}| j r
|d| j z
}|S )Nznats: key not foundz: )rw )r ss r r" zKeyNotFoundError.__str__ s+ ! < %
$dl$$ $Ar rf rg r# r$ r( r r ru ru sK
r ru c $ e Zd ZdZdd dZd
dZdS ) KeyWrongLastSequenceErrorzJ
Raised when trying to update a key with the wrong last sequence.
Nr r c || _ d S r r r s r r z"KeyWrongLastSequenceError.__init__ r r r c d| j S )NrG r rJ s r r" z!KeyWrongLastSequenceError.__str__ s *(***r r rg r# r$ r( r r r{ r{ sK ' ' ' ' '+ + + + + +r r{ c e Zd ZddZdS ) NoKeysErrorr r c dS )Nznats: no keys foundr( rJ s r r" zNoKeysError.__str__ r] r Nr# r r% r& r" r( r r r r s( % % % % % %r r c e Zd ZddZdS )KeyHistoryTooLargeErrorr r c dS )Nz$nats: history limited to a max of 64r( rJ s r r" z KeyHistoryTooLargeError.__str__ s 55r Nr# r r( r r r r s( 6 6 6 6 6 6r r c e Zd ZdZdS )InvalidKeyErrorzO
Raised when trying to put an object in Key Value with an invalid key.
NrN r( r r r r rO r r c e Zd ZdZdS )InvalidBucketNameErrorzL
Raised when trying to create a KV or OBJ bucket with invalid name.
NrN r( r r r r rO r r c e Zd ZdZdS )InvalidObjectNameErrorzO
Raised when trying to put an object in Object Store with invalid key.
NrN r( r r r r rO r r c e Zd ZdZdS )BadObjectMetaErrorzJ
Raised when trying to read corrupted metadata from Object Store.
NrN r( r r r r rO r r c e Zd ZdZdS )LinkIsABucketErrorzN
Raised when trying to get object from Object Store that is a bucket.
NrN r( r r r r rO r r c e Zd ZdZdS )DigestMismatchErrorzd
Raised when getting an object from Object Store that has a different digest than expected.
NrN r( r r r r & rO r r c e Zd ZdZdS )ObjectNotFoundErrorzA
When attempted to lookup an Object that does not exist.
NrN r( r r r r . rO r r c e Zd ZdZdS )ObjectDeletedErrorzM
When attempted to do an operation to an Object that does not exist.
NrN r( r r r r 6 rO r r c e Zd ZdZdS )ObjectAlreadyExistszL
When attempted to do an operation to an Object that already exist.
NrN r( r r r r > rO r r )-
__future__r dataclassesr typingr r r r r nats.errorsnatsnats.jsr
nats.aio.msgr errorsr
r, r: rB rC rD rT rX TimeoutErrorr[ r_ ri rk rm ro ru r{ r r r r r r r r r r r r( r r r sB # " " " " " ! ! ! ! ! ! ? ? ? ? ? ? ? ? ? ? ? ? ? ? ! C C C C CDK C C C E"""5
5
5
5
5
u 5
5
#"5
p h ( H h / / / / /E / / /R R R R Re R R R% % % % % 0 % % %
E
0 - X H
'
'
'
'
'm]
'
'
' }m " + + + + +
+ + +% % % % %- % % %
6 6 6 6 6m 6 6 6
e U U % - % r