Ri fSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSK J r J r J r SSK J r SSKJr SSKJrJrJr SSKJr SSKJrJr SS KJrJrJrJrJrJrJ r J!r!J"r"J#r#J$r$J%r%J&r&J'r'J(r( SS K)J*r* SS K+J,r,J-r-J.r. SSK/r/S r0\2\Rf0r4\0(a<\5"\/S5(aS\4\/Rl'S\4\/Rn'OS\4\/Rp'\9"\4Ru55r;\-(aSSKSr?Sr@SrA\B"5rCSrDSrESrFSrG\\S.rH"SS5rI"SS5rJ"SS5rK"S S!\J5rL"S"S#\J5rM\-(a\MrNO\LrN"S$S%5rO"S&S'\O5rP"S(S)\O5rQS*rRS+rS\T\U\U\S\S\V\T\T\SS,. rWS-rX"S.S/5rY"S0S1\Y5rZg!\1a S r0GN%f=f)2N)chain)EmptyFull LifoQueue)time)Optional)parse_qsunquoteurlparse) NoBackoff)CredentialProvider"UsernamePasswordCredentialProvider)AuthenticationError$AuthenticationWrongNumberOfArgsErrorBusyLoadingErrorChildDeadlockedErrorConnectionError DataErrorExecAbortErrorInvalidResponse ModuleErrorNoPermissionError NoScriptError ReadOnlyError RedisError ResponseError TimeoutError)Retry)CRYPTOGRAPHY_AVAILABLEHIREDIS_AVAILABLE str_if_bytesTFSSLWantReadError*$s zConnection closed by server.z:Error loading the extension. Please check the server logs.z5Error unloading module: no such module with that namez/Error unloading module: operation not possible.z[Error unloading module: the module exports one or more module-side data types, can't unload)zxAUTH called without any password configured for the default user. Are you sure your configuration is correct?z(Client sent AUTH, but no password is setc.\rSrSrSrSrSrSSjrSrg) EncoderTz=Encode strings to bytes-like and decode bytes-like to stringsc(XlX lX0lgNencodingencoding_errorsdecode_responses)selfr-r.r/s b/var/www/html/backend/Backoffice_Marketplace/venv/lib/python3.13/site-packages/redis/connection.py__init__Encoder.__init__Ws . 0r&c[U[[45(aU$[U[5(a [ S5e[U[ [ 45(a[U5R5nO9[U[5(d$[U5Rn[ SUS35e[U[5(a&URURUR5nU$)z=Return a bytestring or bytes-like representation of the valuezNInvalid input of type: 'bool'. Convert to a bytes, string, int or float first.zInvalid input of type: 'z2'. Convert to a bytes, string, int or float first.) isinstancebytes memoryviewboolrintfloatreprencodestrtype__name__r-r.)r0valuetypenames r1r<Encoder.encode\s eeZ0 1 1L t $ $5 U| , ,K&&(EE3''E{++H*8*5BC  eS ! !LL0D0DEE r&cUR(dU(a`[U[5(aUR5n[U[5(a&UR UR UR5nU$)z:Return a unicode string from the bytes-like representation)r/r5r7tobytesr6decoder-r.)r0r@forces r1rEEncoder.decodessQ  E%,, %'' T]]D4H4HI r&)r/r-r.NF) r? __module__ __qualname____firstlineno____doc__r2r<rE__static_attributes__r&r1r(r(TsC1 .r&r(cT\rSrSrS\S\S\S\\\\ \\ \\ \0\ E\\ \\\\\S.rSrSrg ) BaseParser}zmax number of clients reachedzinvalid passwordz,wrong number of arguments for 'auth' commandz,wrong number of arguments for 'AUTH' command)ERR WRONGPASS EXECABORTLOADINGNOSCRIPTREADONLYNOAUTHNOPERMcURS5SnX R;aSU[U5S-SnURUn[U[5(aUR U[ 5nU"U5$[ U5$)zParse an error response rN)splitEXCEPTION_CLASSESlenr5dictgetr)r0response error_codeexception_classs r1 parse_errorBaseParser.parse_errors|^^C(+ // /J! 3 56H"44Z@O/400"1"5"5h "N"8, ,X&&r&rNN)r?rIrJrKrrrMODULE_LOAD_ERRORrMODULE_EXPORTS_DATA_TYPES_ERRORNO_SUCH_MODULE_ERROR MODULE_UNLOAD_NOT_POSSIBLE_ERRORNO_AUTH_SET_ERRORrrrrrr^rerMrNr&r1rPrP}sf ,_  3 !"F !"F { +[ + ,k   ")##!!%#16 'r&rPcd\rSrSrSr\S5rS\S4SjrSr Sr S r S r S r S rS rSrg) SocketBuffercxXlX lX0l[R"5UlSUlSUlgNr)_socksocket_read_sizesocket_timeoutioBytesIO_buffer bytes_written bytes_read)r0socketrrrss r1r2SocketBuffer.__init__s/ 0,zz| r&c4URUR- $r+)rwrxr0s r1lengthSocketBuffer.lengths!!DOO33r&NTc"URnURnURnURUR5 SnU[ LnU(aUR U5 URRU5n [U [5(a[U 5S:Xa[[5eURU 5 [U 5n U=RU - slXz- nUbX:aMU(aUR UR5 gg![R a8 U(a [#S5eU(aUR UR5 gg[$a|n [&R)U R*S5n U(d8U R,U :Xa(Sn A U(aUR UR5 gg[SU R.35eSn A ff=f!U(aUR UR5 ff=fNrTzTimeout reading from socketFz!Error while reading from socket: )rqrrrvseekrwSENTINEL settimeoutrecvr5r6r_rSERVER_CLOSED_CONNECTION_ERRORwritersrytimeoutrNONBLOCKING_EXCEPTIONS#NONBLOCKING_EXCEPTION_ERROR_NUMBERSra __class__errnoargs) r0r}rraise_on_timeoutsockrrbufmarkercustom_timeoutdata data_lengthexalloweds r1_read_from_socketSocketBuffer._read_from_socketszz00ll ##$ 0 5(zz'78dE**s4yA~)*HII $!$i ""k1"%%&/ 3 34~~ "#@AA 3 34& Q :==bllBOG#G(; 3 34"$EbggY"OP P Q 3 34s= B&D&G&<G)! G&*7G!!G) G!!G&&G))%HcZ[UR5=(d URUSS9$)NFrr)r8r}rr0rs r1can_readSocketBuffer.can_reads/DKK  D$:$:e%;%  r&c*US-nXR:aURXR- 5 URRUR5 URR U5nU=R[ U5- slUSS$)Nr#)r}rrvrrxreadr_)r0r}rs r1rSocketBuffer.readsr! KK   " "6KK#7 8 $//*||  ( 3t9$CRyr&cURnURUR5 UR5nUR [ 5(dWUR 5 URUR5 UR5nUR [ 5(dMWU=R[U5- slUSS$)Nr)rvrrxreadlineendswithSYM_CRLFrr_)r0rrs r1rSocketBuffer.readlinesll !||~--))  " " $ HHT__ %<<>D --)) 3t9$CRyr&cUR$)z Get current read position rxr|s r1get_posSocketBuffer.get_possr&cXlg)z? Rewind the buffer to a specific position, to re-start reading Nr)r0poss r1rewindSocketBuffer.rewinds r&cURUR- nUS:agUS:a"URR5nX!*SUSU&URR U5 XlSUlURR S5 g)z8 After a successful read, purge the read part of buffer rN)rwrxrv getbuffertruncater)r0unreadviews r1purgeSocketBuffer.purges##doo5 A:  A:<<))+D ND&M f%# !r&cS=UlUlURR5 SUlSUlg![a Nf=frp)rwrxrvclose Exceptionrqr|s r1rSocketBuffer.closesL 34 4D  LL         s(9 AA)rvrqrxrwrrrs)r?rIrJrKr2propertyr}rrrrrrrrrrMrNr&r1rmrmsN44(,XPT'5R    * r&rmcJ\rSrSrSrSrSrSrSrSr S Sjr S S jr S r g ) PythonParseri*zPlain Python parsing classc:XlSUlSUlSUlgr+)rrencoderrqrvr0rrs r1r2PythonParser.__init__-s 0   r&cFUR5 g![a gf=fr+ on_disconnectrr|s r1__del__PythonParser.__del__3%           cURUl[URURUR5UlUR Ulg)zCalled when the socket connectsN)rqrmrrrsrvrr0 connections r1 on_connectPythonParser.on_connect9sA%% # JJ--z/H/H  ")) r&c|SUlURb!URR5 SUlSUlg)z"Called when the socket disconnectsN)rqrvrrr|s r1rPythonParser.on_disconnectAs1 << # LL   DL r&c^UR=(a URRU5$r+)rvrrs r1rPythonParser.can_readIs ||> 5 5g >>r&cURR5nURUS9nURR5 U$![a URR U5 ef=f)Ndisable_decoding)rvr_read_responser BaseExceptionr)r0rrresults r1 read_responsePythonParser.read_responseLsjll""$ ((:J(KF LL   M   LL   $  s A'A.cURR5nU(d[[5eUSSUSSpCUS;a[ SU<35eUS:Xa:UR SSS9nUR U5n[U[5(aUeU$US:XaOUS :Xa [U5nOtUS :Xa.[U5nUS :XagURRU5nO@US :Xa:[U5nUS :Xag[U5Vs/sHnURUS 9PM nn[U[5(a USLaURR U5nU$s snf)Nr\)-+:r%r$zProtocol Error: rutf-8replace)errorsrrr%rr$rF)rvrrrrrErer5r9rrangerr6r)r0rrawbyterberrorr}is r1rPythonParser._read_responseWsdll##%!"@A ARa#ab'h 5 5!$4SG"<= = 4<wyAH$$X.E%11 L T\  T\8}H T\]F|||((0H T\]F|v&A##5E#F&  h & &+;u+D||**84H sE)rvrqrrrNrH) r?rIrJrKrLr2rrrrrrrMrNr&r1rr*s(   *? .r&rcN\rSrSrSrSrSrSrSrSr \ S4S jr S S jr S r g ) HiredisParseriz*Parser class for connections using Hiredisc\[(d [S5eXl[U5Ulg)NzHiredis is not installed)r rrr bytearrayrvrs r1r2HiredisParser.__init__s'  78 8 0 !12 r&cFUR5 g![a gf=fr+rr|s r1rHiredisParser.__del__rrc DURUlURUl[URUR R S.nUR R(aUR RUS'[R"S0UD6Ul SUl g)N) protocolError replyErrorrr-FrN) rqrs_socket_timeoutrrerr.r/r-hiredisReader_reader_next_response)r0rkwargss r1rHiredisParser.on_connects%% )88,** ((88     . .!+!3!3!URR 5UlURSLaUR USS9$g)NFrT)rrrrgetsread_from_socketrs r1rHiredisParser.can_reads_||!"@A A   % '"&,,"3"3"5D ""e+,,Wu,UUr&Tc^URnU[LnU(aURU5 URRUR5nUS:Xa[ [ 5eURRURSU5 U(aURUR5 gg![Ra8 U(a [S5eU(aURUR5 gg[a|n[RUR S5nU(d8UR"U:Xa(SnAU(aURUR5 gg[ SUR$35eSnAff=f!U(aURUR5 ff=fr)rqrr recv_intorvrrrfeedrryrrrrrarrr)r0rrrrbufflenrrs r1rHiredisParser.read_from_socketsZzz 0 6(jj**4<<8G!|%&DEE LL  dllAw 7 4 45~~ "#@AA 4 45& Q :==bllBOG#G(; 4 45"$EbggY"OP P Q 4 45s<A9B44&FF? F7E??F'E??FF%F,cZUR(d[[5eURSLaURnSUlU$U(aURR S5nOURR 5nUSLaTUR 5 U(aURR S5nOURR 5nUSLaMT[ U[5(aUe[ U[5(a$U(a[ US[5(aUSeU$)NFr)rrrrrrr5list)r0rrbs r1rHiredisParser.read_responses||!"@A A   e +**H"'D O ||((/H||((*H%  ! ! #<<,,U3<<,,. % h 0 0N x & &8A;881+ r&)rvrrrqrrrNrH)r?rIrJrKrLr2rrrrrrrrMrNr&r1rrs/03  $$ (0$6< r&rc\rSrSrSrSSSSSSSSSS\SS S\S SSSSSS4S \\4S jjr S r Sr Sr Sr SrSrSrSrSrSrSrSrSrSrSrS#SjrSrS$SjrS%SjrS rS!rS"rg)& Connectioniz4Manages TCP communication to and from a Redis server localhostirNFrstrictcredential_providercDU(dU(aUb [S5e[R"5UlXl[ U5UlX0lUUlUUl X@l UUl XPl U=(d UUl XplU=(d 0UlXlXlU [$La/n U (aU R'[(5 XlU(dU (aTUc[-[/5S5UlO4"U5UlUR0R7U 5 O[-[/5S5UlUUlSUlUUl[?XU5Ul SUl!UUl"URGU5 /Ul$SUl%g)a Initialize a new Connection. To specify a retry policy for specific errors, first set `retry_on_error` to a list of the error/s to retry on, then set `retry` to a valid `Retry` object. To retry on TimeoutError, `retry_on_timeout` can also be set to `True`. N'username' and 'password' cannot be passed along with 'credential_provider'. Please provide only one of the following arguments: 1. 'password' and (optional) 'username' 2. 'credential_provider'r\rp)&rosgetpidpidhostr9portdb client_namer passwordusernamerssocket_connect_timeoutsocket_keepalivesocket_keepalive_options socket_typeretry_on_timeoutrappendrretry_on_errorrr retrycopydeepcopyupdate_supported_errorshealth_check_intervalnext_health_checkredis_connect_funcr(rrq_socket_read_size set_parser_connect_callbacks_buffer_cutoff)r0rrrrrsrrrrrrr-r.r/ parser_classrrr"rrrr$r s r1r2Connection.__init__sX@ &9&E+  99; I &#6    ,&<&N# 0(@(FB%& 0 X %N   ! !, /, N}"9;2 "]]51 JJ . .~ >y{A.DJ%:"!""4x:JK  !1  %"$"r&c SRUR5VVs/sH upUSU3PM snn5nURRSUS3$s snnf)N,=<>)join repr_piecesrr?)r0kv repr_argss r1__repr__Connection.__repr__MsZHHT5E5E5GH5GTQ1QCj5GHI ..))*!I;a88IsA cSUR4SUR4SUR4/nUR(aUR SUR45 U$)Nrrrr)rrrrrr0piecess r1r1Connection.repr_piecesQsM499% ':T477OL    MM=$*:*:; < r&cFUR5 g![a gf=fr+) disconnectrr|s r1rConnection.__del__Ws#  OO    rcbURR[R"U55 gr+)r'rweakref WeakMethod)r0callbacks r1register_connect_callback$Connection.register_connect_callback]s! &&w'9'9('CDr&c/Ulgr+)r'r|s r1clear_connect_callbacks"Connection.clear_connect_callbacks`s "$r&c.U"URS9Ulg)z Creates a new instance of parser_class with socket size: _socket_read_size and assigns it to the parser for the connection :param parser_class: The required parser class )rrN)r%_parser)r0r)s r1r&Connection.set_parsercs $T5K5KL r&c ^TR(agTRRU4SjU4Sj5nUTlTRcTR5 OTRT5 TRHnU"5nU(dMU"T5 M g![Ra [ S5e[ an[TRU55eSnAff=f![a TR5 ef=f)z5Connects to the Redis server if not already connectedNc$>TR5$r+)_connectr|sr1$Connection.connect..qs  r&c&>TRU5$r+r<)rr0s r1rMrNqstu7Mr&zTimeout connecting to server)rqrcall_with_retryryrrOSErrorr_error_messager$rrr<r')r0rerefrAs` r1connectConnection.connectks ::  :::--')MD  &&.!''-**CuHx+)~~ ?=> > :!$"5"5a"89 9 :  OO   s)$BC'C'(C$CC$'Dc`Sn[R"URURUR[R 5GHnUup4pVnSn[R"X4U5nUR [R[RS5 UR(arUR [R[RS5 URR5H%upUR [RX5 M' URUR5 UR!U5 URUR"5 Us $ UbUe[%S5e![$a(n U nUbUR'5 Sn A GMYSn A GM`Sn A ff=f)zCreate a TCP socket connectionNr\z)socket.getaddrinfo returned an empty list)ry getaddrinforrr SOCK_STREAM setsockopt IPPROTO_TCP TCP_NODELAYr SOL_SOCKET SO_KEEPALIVEritemsrrrVrsrRr) r0errresfamilysocktypeproto canonnamesocket_addressrr2r3_s r1rLConnection._connectsX %% IItyy$"2"2F4F4F CBE >FeD !}}Vu= 2 2F4F4FJ((OOF$5$5v7J7JAN $ = = C C E(:(:AA!F ; ;< ^, 3 34 1 > ?IABB !#JJLL$ !sDE;; F-F((F-cdURSUR3nU$![a SnU$f=f)N:r)rrAttributeError)r0 host_errors r1 _host_errorConnection._host_errorsC & II;a {3J &%J &s  //cXUR5n[UR5S:XaSUSURSS3$SURSSUS URSS3$![a SURS3s$f=f![a SURS3s$f=f) Nr\zError connecting to z. r.zConnection Error: Error z connecting to . )rnr_rrl)r0 exceptionrms r1rSConnection._error_messages%%' y~~ ! # @-j\:"*+1..  @Y^^A./!l"Y^^A%6$7q: " @+INN1,=+>?? @" @+INN1,=+>?? @s#A(%B (BB B)(B)chURRU5 UR(d"UR(dUR(aUR=(d [ URUR5nUR 5nUR"S/UQ7SS06 UR5n[U5S:wa [S5eUR(aEURSS UR5 [UR55S:wa [S 5eUR(aEURS UR5 [UR55S:wa [S 5eg g ![a' URSUSSS9 UR5nNf=f)z=Initialize the connection, authenticate and select a databaseAUTH check_healthFrrxOKzInvalid Username or PasswordCLIENTSETNAMEzError setting client nameSELECTzInvalid DatabaseN)rHrr rrrget_credentials send_commandrrr!rrrr)r0 cred_provider auth_args auth_responses r1rConnection.on_connectsq %  # # ((T5dmmT]]S &557I   f Ey Eu E 5 $ 2 2 4 M*d2)*HII      h 43C3C DD..01T9%&ABB 77   h 0D..01T9%&899: %8 5 !!&)B-e!L $ 2 2 4  5s)F.F10F1crURR5 URcg[R"5UR :Xa*URR [R5 URR5 SUlg![a N/f=f![a N$f=f)z!Disconnects from the Redis serverN) rHrrqrrrshutdownry SHUT_RDWRrRr)r0rs r1r<Connection.disconnects ""$ ::   99;$(( "  ##F$4$45  JJ          s$ )B7B) B&%B&) B65B6ctURSSS9 [UR55S:wa [S5eg)z Send PING, expect PONG in returnPINGFryPONGz#Bad response from PING health checkN)rr!rrr|s r1 _send_pingConnection._send_ping s< &u5 **, - 7!"GH H 8r&c$UR5 g)z Function to call when PING failsNrP)r0rs r1 _ping_failedConnection._ping_faileds  r&cUR(aJ[5UR:a1URR UR UR 5 ggg)z3Check the health of the connection with a PING/PONGN)r"rr#rrQrrr|s r1rxConnection.check_healthsA  % %$&43I3I*I JJ & &t8I8I J+J %r&cvUR(dUR5 U(aUR5 [U[5(aU/nUHnURR U5 M g![ Ra UR5 [S5e[aonUR5 [UR5S:XaSURSpeOURSnURSn[SUSUS35eSnAf[a UR5 ef=f) z2Send an already packed command to the Redis serverzTimeout writing to socketr\UNKNOWNrrrz while writing to socket. rqN)rqrVrxr5r=sendallryrr<rrRr_rrr)r0commandrxitemrTrerrmsgs r1send_packed_commandConnection.send_packed_commandszz LLN      '3''") ""4( ~~ < OO :; ; W OO 166{a )166!9vq !F5'1KF8ST"UV V  OO   s)>)@(KL++ t||**D1CSJD M)-c:.. ~~:s:'='='?J d# c" ~~"J..0   !24  d r&c/n/nSnURnUHnUR"U6Hn[U5nXE:dX:d[U[5(a(UR [ RU55 Sn/nX:d[U[5(aUR U5 MUR U5 XH- nM M U(a$UR [ RU55 U$)z.Pack multiple commands into the Redis protocolr)r(rr_r5r7rrr0) r0commandsrr9 buffer_lengthrcmdchunkchunklens r1 pack_commandsConnection.pack_commandss ++ C**C0u:!1/!%44MM).."89$%MF+z%/L/LMM%(MM%(!-M1$  MM)..0 1 r&)r(r'rHrqr%rr rrr"rr#rrrr$rrrrrrrsrrT)rrH) r?rIrJrKrLr DefaultParserrr r2r5r1rrBrEr&rVrLrnrSrr<rrrxrrrrrrrMrNr&r1rrs:  #!% "<@/M#.&&89/M#^9  E%MB'CR@*&:P$I K 6 V4+Zr&rcT^\rSrSrSrSU4SjjrU4SjrSrU=r$) SSLConnectionizManages SSL connections to and from the Redis server(s). This class extends the Connection class, adding SSL functionality, and making use of ssl.SSLContext (https://docs.python.org/3/library/ssl.html#ssl.SSLContext) c  >[(d [S5e[TU] "S0U D6 XlX lUc[ RnO\[U[5(aG[ R[ R[ RS.nX>;a[SU35eXnX0l X@l XPlXplX`lXlXlXlXlXlg)aConstructor Args: ssl_keyfile: Path to an ssl private key. Defaults to None. ssl_certfile: Path to an ssl certificate. Defaults to None. ssl_cert_reqs: The string value for the SSLContext.verify_mode (none, optional, required). Defaults to "required". ssl_ca_certs: The path to a file of concatenated CA certificates in PEM format. Defaults to None. ssl_ca_data: Either an ASCII string of one or more PEM-encoded certificates or a bytes-like object of DER-encoded certificates. ssl_check_hostname: If set, match the hostname during the SSL handshake. Defaults to False. ssl_ca_path: The path to a directory containing several CA certificates in PEM format. Defaults to None. ssl_password: Password for unlocking an encrypted private key. Defaults to None. ssl_validate_ocsp: If set, perform a full ocsp validation (i.e not a stapled verification) ssl_validate_ocsp_stapled: If set, perform a validation on a stapled ocsp response ssl_ocsp_context: A fully initialized OpenSSL.SSL.Context object to be used in verifying the ssl_ocsp_expected_cert ssl_ocsp_expected_cert: A PEM armoured string containing the expected certificate to be returned from the ocsp verification service. Raises: RedisError z$Python wasn't built with SSL supportN)noneoptionalrequiredz+Invalid SSL Certificate Requirements Flag: rN) ssl_availablersuperr2keyfilecertfilessl CERT_NONEr5r= CERT_OPTIONAL CERT_REQUIRED cert_reqsca_certsca_dataca_pathcheck_hostnamecertificate_passwordssl_validate_ocspssl_validate_ocsp_stapledssl_ocsp_contextssl_ocsp_expected_cert)r0 ssl_keyfile ssl_certfile ssl_cert_reqs ssl_ca_certs ssl_ca_datassl_check_hostname ssl_ca_path ssl_passwordrrrrr CERT_REQSrs r1r2SSLConnection.__init__sH}CD D "6"" $  MMM  s + + ----I - A-Q&4M&$ " " 0$0!!2)B& 0&<#r&c>[T U]5n[R"5nURUlUR UlUR(dUR(a/URURURURS9 URcURc URb/URURURURS9 URXR S9nUR"SLa[$SLa ['S5eUR((aUR"(a ['S5eUR((Ga,S SKnS S KJn UR0cfUR2R5UR2R65nUR9UR5 UR;UR5 O UR0nUR=XPR>5 UR2RAU[BRB"55nURE5 URGUR URH45 URK5 URM5 U$UR"SLa[[$(aPS S KJ'n U"X0R URHUR5n U RQ5(aU$[SS 5eU$)z Wrap the socket with SSL support)rrrN)cafilecapathcadata)server_hostnameTFzcryptography is not installed.zKEither an OCSP staple or pure OCSP connection must be validated - not both.rr\)ocsp_staple_verifier) OCSPVerifierzocsp validation error)*rrLrcreate_default_contextrr verify_moderrload_cert_chainrrrrload_verify_locations wrap_socketrrrrrOpenSSLocsprrSSLContext SSLv23_METHODuse_certificate_fileuse_privatekey_fileset_ocsp_client_callbackrrry request_ocsprVr do_handshakerris_validr) r0rcontextsslsockrr staple_ctxconrors r1rLSSLConnection._connectsJw!,,.!%!4!4"nn ==DLL  # # 22 $  MM %||'||'  ) )}}T\\$,, * %%dII%F  ! !T ).D.M=> >  ) )d.D.D   ) ) )  2$$,$[[001J1JK // >..t||<!22  / /$&A&A  ++((V]]_EC     KKDII. /     LLNN  ! !T ).D.D *WiiDMMJAzz||%&=>>r&) rrrrrrrrrrrr) NNrNNFNNFFNN) r?rIrJrKrLr2rLrM __classcell__rs@r1rrsA  "'#A=FAAr&rc`\rSrSrSSSSSSSSS\\SSSSSS4S \\4S jjrS r S r S r Sr g)UnixDomainSocketConnectioni<rNrrFr r cU(dU(aUb [S5e[R"5UlXlX lXlUUlX@lX0l XPl Xl U [La/n U (aU R[5 XlUR(aTUc[![#5S5UlO[&R("U5UlUR$R+U 5 O[![#5S5UlXlSUlUUl[3XgU5UlSUlXlUR;U 5 /UlSUlg)a Initialize a new UnixDomainSocketConnection. To specify a retry policy for specific errors, first set `retry_on_error` to a list of the error/s to retry on, then set `retry` to a valid `Retry` object. To retry on TimeoutError, `retry_on_timeout` can also be set to `True`. Nr r\rr ) rrrrpathrrr rrrsrrrrrrr rrr r!r"r#r$r(rrqr%r&r'r()r0rrrrrsr-r.r/rrr)rrr"rrr$r s r1r2#UnixDomainSocketConnection.__init__=s"6 &9&E+  99; &#6   , 0 X %N   ! !, /,   }"9;2 "]]51 JJ . .~ >y{A.DJ%:"!""4x:JK  !1  %"$"r&cSUR4SUR4/nUR(aURSUR45 U$)Nrrr)rrrrr8s r1r1&UnixDomainSocketConnection.repr_piecessB499%dgg7    MM=$*:*:; < r&c[R"[R[R5nURUR5 UR UR 5 U$)z&Create a Unix domain socket connection)ryAF_UNIXrZrrsrVr)r0rs r1rL#UnixDomainSocketConnection._connectsC}}V^^V-?-?@ ++, TYY r&c[UR5S:Xa SURSURSS3$SURSSURSURSS3$)Nr\z!Error connecting to unix socket: rsrrqrrz connecting to unix socket: )r_rr)r0rts r1rS)UnixDomainSocketConnection._error_messagesu y~~ ! #6tyykINNSTDUCVVWX X*++G99+R q 12!5 r&)r(r'rqr%rr rrr"r#rrrr$rrrrsr) r?rIrJrKrrrr r2r1rLrSrMrNr&r1rr<s^  "<@%C#$&&89%C#J  r&r)0FFALSENNOcUbUS:Xag[U[5(aUR5[;ag[ U5$)NrF)r5r=upper FALSE_STRINGSr8)r@s r1to_boolrs7 } %%++-="@ ;r&) rrsrrrrmax_connectionsr"rcURS5(d7URS5(d!URS5(d [S5e[U5n0n[UR5R 5HZup#U(dM[ U5S:dM[US5n[RU5nU(a U"U5X'MVX1U'M\ UR(a[UR5US'UR(a[UR5US 'URS :Xa4UR(a[UR5US '[US 'U$UR (a[UR 5US 'UR"(a[%UR"5US'UR(a8SU;a2[%[UR5R'SS55US'URS:Xa [*US 'U$![[4a [SUS35ef=f![([4a NPf=f)Nzredis://z rediss://zunix://zRRedis URL must specify one of the following schemes (redis://, rediss://, unix://)rzInvalid value for `z` in connection URL.rrunixrconnection_classrrr/rrediss) startswith ValueErrorr r queryr`r_r URL_QUERY_ARGUMENT_PARSERSra TypeErrorrrschemerrhostnamerr9rrlr)urlrnamer@parsers r1 parse_urlr s z"" >>+ & & >>) $ $ 5  3-C F *002  5SZ!^E!H%E/33D9FW#)%=FL %t 3 ||$S\\2z ||$S\\2z zzV 88$SXX.F6N%?!"& M! <<$S\\2F6N 88 ]F6N 88F* "7388#4#<# - `rediss://` creates a SSL wrapped TCP socket connection. See more at: - ``unix://``: creates a Unix Domain Socket connection. The username, password, hostname, path and all querystring values are passed through urllib.parse.unquote in order to replace any percent-encoded values with their corresponding characters. There are several ways to specify a database number. The first value found will be used: 1. A ``db`` querystring option, e.g. redis://localhost?db=0 2. If using the redis:// or rediss:// schemes, the path argument of the url, e.g. redis://localhost/0 3. A ``db`` keyword argument to this function. If none of these options are specified, the default db=0 is used. All querystring options are cast to their appropriate Python types. Boolean arguments can be specified with string values "True"/"False" or "Yes"/"No". Values that cannot be properly cast cause a ``ValueError`` to be raised. Once parsed, the querystring arguments and keyword arguments are passed to the ``ConnectionPool``'s class initializer. In the case of conflicting arguments, querystring arguments always win. rrN)r update)clsrr url_optionss r1from_urlConnectionPool.from_urls?R n  '.45G.HK* + k"}V}r&Nc U=(d Sn[U[5(aUS:a [S5eXlX0lX l[ R"5UlUR5 g)Nlrz,"max_connections" must be a positive integer) r5r9rrconnection_kwargsr threadingLock _fork_lockreset)r0rrr*s r1r2ConnectionPool.__init__+sY*2U/3//?Q3FKL L 0!2.$..* r&c ~[U5RS[UR"S0URD65S3$)Nr.r/rN)r>r?r;rr*r|s r1r5ConnectionPool.__repr__As@Dz""#T**DT-C-CDEFa I r&c[R"5UlSUl/Ul[ 5Ul[R"5Ul grp) r+r,_lock_created_connections_available_connectionsset_in_use_connectionsrrrr|s r1r.ConnectionPool.resetGs9^^% $%!&(##&5 99;r&crUR[R"5:wauURR SS9nU(d[ eUR[R"5:waUR 5 URR5 gg!URR5 f=f)N)r)rrrr-acquirerr.release)r0acquireds r1 _checkpidConnectionPool._checkpidXsF 88ryy{ "..q.9H** *88ryy{*JJL'') #'')s 3BB6crUR5 UR URR5nUR RU5 SSS5 WR5 UR5(a [S5eU$![a UR 5nNtf=f!,(df  Nc=f![[4aD UR5 UR5 UR5(a [S5eU$f=f![a URW5 ef=f)zGet a connection from the poolNConnection has dataConnection not ready)r>r3r5pop IndexErrormake_connectionr7addrVrrrRr<rr<r0 command_namekeysoptionsrs r1get_connectionConnectionPool.get_connections%  ZZ 4!88<<>   $ $ ( ( 4       B&&(()*?@@)3 4!113  4Z"$W- B%%'""$&&(()*@AA) B   LL $   sXB1BB1D. CB.+B1-B..B11 B?ADDDDD6cURn[URSS5URSS5URSS5S9$)z,Return an encoder based on encoding settingsr-rr.rr/Fr,)r*r(ra)r0rs r1 get_encoderConnectionPool.get_encodersF''ZZ G4"JJ'8(C#ZZ(:EB  r&cURUR:a [S5eU=RS- slUR"S0URD6$)zCreate a new connectionzToo many connectionsr\rN)r4rrrr*r|s r1rEConnectionPool.make_connectionsM  $ $(<(< <!"89 9 !!Q&!$$>t'='=>>r&cUR5 UR URRU5 UR U5(aUR RU5 O/U=RS-slUR5 SSS5 gSSS5 g![a Nwf=f!,(df  g=f)z(Releases the connection back to the poolr\N) r>r3r7removeKeyErrorowns_connectionr5rr4r<rs r1r<ConnectionPool.releases  ZZ ((// ; ##J//++22:> ))Q.)%%'!Z?Z  Zs.B5B%AB5% B2/B51B22B55 Cc4URUR:H$r+)rrs r1rUConnectionPool.owns_connections~~))r&c UR5 UR U(a![URUR5nO URnUHnUR 5 M SSS5 g!,(df  g=f)z Disconnects connections in the pool If ``inuse_connections`` is True, disconnect connections that are current in use, potentially by other threads. Otherwise only disconnect connections that are idle in the pool. N)r>r3rr5r7r<)r0inuse_connections connectionsrs r1r<ConnectionPool.disconnects`  ZZ #//1I1I #99 ) %%'*ZZs AA44 BcURRSU05 URH nXlM URH nXlM g)Nr)r*r$r5rr7)r0rconns r1 set_retryConnectionPool.set_retrysE %%w&67//DJ0,,DJ-r&) r5r4r-r7r3rr*rrr)rrreturnN)r?rIrJrKrL classmethodr'rr2r5r.r>rKrNrEr<rUr<r_rMrNr&r1r"r"s\ ..b *4, "-*^B ?**((r&r"cV^\rSrSrSrSS\\4U4SjjrSrSr Sr S r S r S r U=r$) BlockingConnectionPoolia Thread-safe blocking connection pool:: >>> from redis.client import Redis >>> client = Redis(connection_pool=BlockingConnectionPool()) It performs the same function as the default :py:class:`~redis.ConnectionPool` implementation, in that, it maintains a pool of reusable connections that can be shared by multiple redis clients (safely across threads if required). The difference is that, in the event that a client tries to get a connection from the pool when all of connections are in use, rather than raising a :py:class:`~redis.ConnectionError` (as the default :py:class:`~redis.ConnectionPool` implementation does), it makes the client wait ("blocks") for a specified number of seconds until a connection becomes available. Use ``max_connections`` to increase / decrease the pool size:: >>> pool = BlockingConnectionPool(max_connections=10) Use ``timeout`` to tell it either how many seconds to wait for a connection to become available, or to block forever: >>> # Block forever. >>> pool = BlockingConnectionPool(timeout=None) >>> # Raise a ``ConnectionError`` after five seconds if a connection is >>> # not available. >>> pool = BlockingConnectionPool(timeout=5) 2c D>X@lX l[TU] "SUUS.UD6 g)N)rrrN) queue_classrrr2)r0rrrrhr*rs r1r2BlockingConnectionPool.__init__s2'   -+   r&cURUR5UlURRS5 M![a Of=f/Ul[ R"5Ulgr+) rhrpool put_nowaitr _connectionsrrrr|s r1r.BlockingConnectionPool.resetsf$$T%9%9:   $$T*   99;sA A  A ctUR"S0URD6nURRU5 U$)zMake a fresh connection.rN)rr*rmrrs r1rE&BlockingConnectionPool.make_connection7s5**DT-C-CD    ,r&c UR5 SnURRSURS9nUcUR 5nUR5 UR5(a [ S5eU$![a [ S5ef=f![ [4aD UR5 UR5 UR5(a [ S5eU$f=f![a URU5 ef=f)a Get a connection, blocking for ``self.timeout`` until a connection is available from the pool. If the connection returned is ``None`` then creates a new connection. Because we use a last-in first-out queue, the existing connections (having been returned to the pool after the initial ``None`` values were added) will be returned before ``None`` values. This means we only create new connections when we need to, i.e.: the actual number of connections will only increase in response to demand. NT)blockrzNo connection available.rArB) r>rkrarrrrErVrrRr<rr<rGs r1rK%BlockingConnectionPool.get_connection=s   >T4<<HJ  --/J      B&&(()*?@@)= >""<= = >($W- B%%'""$&&(()*@AA) B   LL $  s6$B C0 BBAC-)C0,C--C00D cUR5 URU5(d,UR5 URR S5 gURR U5 g![ a gf=f)z)Releases the connection back to the pool.N)r>rUr<rkrlrrs r1r<BlockingConnectionPool.releaseqsm ##J//  ! ! # II  &   II  ,   sA00 A=<A=cjUR5 URHnUR5 M g)z(Disconnects all connections in the pool.N)r>rmr<rs r1r<!BlockingConnectionPool.disconnects( ++J  ! ! #,r&)rmrrkrhr)r?rIrJrKrLrrr2r.rErKr<r<rMrrs@r1rdrds;F#  "0 2h*$$r&rd)[rrrtrryr+r? itertoolsrqueuerrrrtypingr urllib.parser r r redis.backoffr redis.credentialsr rredis.exceptionsrrrrrrrrrrrrrrr redis.retryr redis.utilsrr r!rr ImportErrorBlockingIOError EWOULDBLOCKrhasattrr"SSLWantWriteErrorSSLErrorrrIrrrrrrrobjectrrgrirjrhrkr(rPrmrrrrrrrrr9r:rrr r"rdrNr&r1rs ((44#T"OOM(78I8I&J#s&''DE+C,@,@AEF+C,A,AB<=+CLL9BGGIJ     !? 8PN#T  ':0C &&R%'%'PBBJ[:[|jJjZ!M Mqqh JJJZ\\~/  # ! 6r}}@^$^^$I.MsF$$F0/F0