Iis %SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSK J r SSK J r J r Jr SSKJr SSKJrJrJrJrJrJrJr SSKJrJrJr SSKJrJrJrJ r J!r!J"r" S S K#J$r$J%r%J&r&J'r' S S K(J)r) S S K*J+r+J,r, S S K-J.r.J/r/J0r0J1r1J2r2J3r3J4r4J5r5 S SK6J7r7 S SK8J9r9J:r:J;r;Jr>J?r?J@r@ \:(aSSKArASrBSrCSrDSrESrF\G"5rH\\\&\'\%4\IS'\:(a\%rJO\&rJ"SS5rK"SS5rL"SS5rM"SS\M5rN"SS\N5rO"S S!\M5rP"S"S#\O5rQ"S$S%\N5rRS&rSS'rT\U\V\V\T\T\W\U\U\T\VS(. rXS)rY"S*S+5rZ"S,S-\Z5r[g).N)abstractmethod)chain)EmptyFull LifoQueue)time)AnyCallableDictListOptionalTypeUnion)parse_qsunquoteurlparse) CacheEntryCacheEntryStatus CacheFactoryCacheFactoryInterfaceCacheInterfaceCacheKey)Encoder_HiredisParser _RESP2Parser _RESP3Parser) NoBackoff)CredentialProvider"UsernamePasswordCredentialProvider)AuthenticationError$AuthenticationWrongNumberOfArgsErrorChildDeadlockedErrorConnectionError DataError RedisError ResponseError TimeoutError)Retry)CRYPTOGRAPHY_AVAILABLEHIREDIS_AVAILABLE SSL_AVAILABLEcompare_versions ensure_stringformat_error_messageget_lib_version str_if_bytes*$s  DefaultParserc"\rSrSrS\4SjrSrg)HiredisRespSerializerDargsc/n[US[5(a1[USR5R 55USS-nO+SUS;a"[USR 55USS-nUR [ R"U55 U$![a3 [R"5up4n[U5RU5ef=f2Pack a series of arguments into the Redis protocolrrN ) isinstancestrtupleencodesplitappendhiredis pack_command TypeErrorsysexc_infor%with_traceback)selfr:output_value tracebacks 6/venv/lib/python3.13/site-packages/redis/connection.pypackHiredisRespSerializer.packEs d1gs # #a)//12T!"X=D T!W_a)DH4D = MM'..t4 5   ="%,,. AiE"11)< < =s 8%B=CN)__name__ __module__ __qualname____firstlineno__r rQ__static_attributes__rSr4rPr8r8Ds$r4r8c$\rSrSrSSjrSrSrg)PythonRespSerializerVNcXlX lgN_buffer_cutoffrB)rK buffer_cutoffrBs rP__init__PythonRespSerializer.__init__Ws + r4c /n[US[5(a1[USR5R 55USS-nO+SUS;a"[USR 55USS-n[ R [[[U55R5[45nURn[URU5Hn[U5n[U5U:dXd:d[U[5(ab[ R U[[U5R5[45nURU5 URU5 [nM[ R U[[U5R5[U[45nM URU5 U$r<)r?r@rArBrC SYM_EMPTYjoinSYM_STARlenSYM_CRLFr_map memoryview SYM_DOLLARrD)rKr:rLbuffr`arg arg_lengths rPrQPythonRespSerializer.pack[sh d1gs # #a)//12T!"X=D T!W_a)DH4D~~xSY)>)>)@(KL++ t{{D)CSJD M)-c:.. ~~:s:'='='?J d# c" ~~"J..0   !*4  d r4r^returnN)rTrUrVrWrarQrXrSr4rPrZrZVs +r4rZcL\rSrSr\S5r\S5r\S5r\S5r\S5r \S5r \S5r \S 5r \SS j5r \S 5r\SS j5r\SS SS.Sjj5r\S5r\S5r\\S\\\\4\\\444Sj55rSrg)ConnectionInterfacecgr]rSrKs rP repr_piecesConnectionInterface.repr_pieces r4cgr]rSrKcallbacks rPregister_connect_callback-ConnectionInterface.register_connect_callbackryr4cgr]rSr{s rPderegister_connect_callback/ConnectionInterface.deregister_connect_callbackryr4cgr]rSrK parser_classs rP set_parserConnectionInterface.set_parserryr4cgr]rSrvs rPconnectConnectionInterface.connectryr4cgr]rSrvs rP on_connectConnectionInterface.on_connectryr4cgr]rSrKr:s rP disconnectConnectionInterface.disconnectryr4cgr]rSrvs rP check_health ConnectionInterface.check_healthryr4Tcgr]rSrKcommandrs rPsend_packed_command'ConnectionInterface.send_packed_commandryr4cgr]rSrKr:kwargss rP send_command ConnectionInterface.send_commandryr4cgr]rSrKtimeouts rPcan_readConnectionInterface.can_readryr4Fdisconnect_on_error push_requestcgr]rS)rKdisable_decodingrrs rP read_response!ConnectionInterface.read_responses r4cgr]rSrs rPrF ConnectionInterface.pack_commandryr4cgr]rSrKcommandss rP pack_commands!ConnectionInterface.pack_commandsryr4rqcgr]rSrvs rPhandshake_metadata&ConnectionInterface.handshake_metadatas r4rSNTrF)rTrUrVrWrrwr}rrrrrrrrrrrFrpropertyrr bytesr@rrXrSr4rPrsrssh                       !        E$ue|*S2jr%S?S/SS3.S4jjr&S5r'S6r(S7\=(d \ 4S8jr)\*S7\ \+\,\,4\+\ \ 444S9j5r-\-R\S:\ \+\,\,4\+\ \ 444S;j5r-S &9&E+  99;& &#6    , ! )%3 "&<# 0 X %N   ! !, /, N}"9;2 "]]51 JJ . .~ >y{A.DJ%:"!""4x:JK "& !1  %"$" H A 1uA%&FGGDM#==nM %$A A!"?@ @ A1uA%&FGGDMs$; F;;G" G% G""G%% Hc SRUR5VVs/sH upUSU3PM snn5nSURRSURRSUS3$s snnf)N,=<.()>)rerw __class__rUrT)rKkv repr_argss rP__repr__AbstractConnection.__repr__+snHHT5E5E5GH5GTQ1QCj5GHI 4>>,,-Qt~~/F/F.Gq SUVVIsA. cgr]rSrvs rPrwAbstractConnection.repr_pieces/ryr4cFUR5 g![a gf=fr])r Exceptionrvs rP__del__AbstractConnection.__del__3s#  OO    s   cUbU$[(a [5$[URURR 5$r])r+r8rZr_rrB)rKpackers rPr,AbstractConnection._construct_command_packer9s9  M  (* *'(;(;T\\=P=PQ Qr4c[R"U5nX R;aURRU5 gg)a. Register a callback to be called when the connection is established either initially or reconnected. This allows listeners to issue commands that are ephemeral to the connection, for example pub/sub subscription or key tracking. The callback must be a _method_ and will be kept as a weak reference. N)weakref WeakMethodrrD)rKr|wms rPr},AbstractConnection.register_connect_callbackAs9   ) ,, ,  # # * *2 . -r4cURR[R"U55 g![a gf=f)z De-register a previously registered callback. It will no-longer receive notifications on connection events. Calling this is not required when the listener goes away, since the callbacks are kept as weak methods. N)rremoverrrr{s rPr.AbstractConnection.deregister_connect_callbackMs8    # # * *7+=+=h+G H   s /2 ??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 )rN)r_parserrs rPrAbstractConnection.set_parserXs $T5K5KL r4ct^TR(agTRRU4SjU4Sj5nUTlTRcTR5 OTRT5 TRVs/sHo3"5(dMUPM snTl TRHnU"5nU(dMU"T5 M g![Ra [ S5e[ an[TRU55eSnAff=f![a TR5 ef=fs snf)z5Connects to the Redis server if not already connectedNc$>TR5$r])_connectrvsrP,AbstractConnection.connect..fs  r4c&>TRU5$r]r)errorrKs rPr r fstu7Mr4zTimeout connecting to server)rrcall_with_retrysocketrr(OSErrorr$_error_messagerrr&rr)rKsockerefr|s` rPrAbstractConnection.connect`s  ::  :::--')MD  &&.!''-372I2I"S2I3SU32I"S**CuHx+-~~ ?=> > :!$"5"5a"89 9 :  OO   #Ts5$C DD?D5D5 (D4DDD2cgr]rSrvs rPr AbstractConnection._connectryr4cgr]rSrvs rP _host_errorAbstractConnection._host_errorryr4c6[UR5U5$r])r/r)rK exceptions rPr!AbstractConnection._error_messages#D$4$4$6 BBr4cURRU5 URnSnUR(d"UR(dUR(aCUR=(d [ URUR5nUR 5nU(aURS;a[UR[5(aKUR[5 URURl URRU5 [U5S:XaSUS/nUR"SURS/UQ76 UR5UlGORU(aCUR"S/UQ7SS 06 UR5n[%U5S :wa ['S 5eGOURS;a[UR[5(aKUR[5 URURl URRU5 URSUR5 UR5UlUR R)S5UR:wa4UR R)S5UR:wa [+S5eUR,(aEURSSUR,5 [%UR55S :wa [+S5eUR.(a.URSSSUR.5 UR5 UR2(a.URSSSUR25 UR5 UR4(aEURSUR45 [%UR55S :wa [+S5egg!["a( URSUS S S 9 UR5nGNf=f![0a Nf=f![0a Nf=f)z=Initialize the connection, authenticate and select a databaseN)r52rdefaultrHELLOAUTHrFrOKzInvalid Username or PasswordsprotoprotozInvalid RESP versionCLIENTSETNAMEzError setting client nameSETINFOzLIB-NAMEzLIB-VERSELECTzInvalid Database)rrrrrr get_credentialsrr?rrrEXCEPTION_CLASSESrgrrrr"r1r!getr$rrr'rr)rKparser auth_args cred_provider auth_responses rPrAbstractConnection.on_connectsd %  # # ((T5dmmT]]S &557I h6$,, 55 -171I1I . ''-9~"& ! 5   gt}}f Iy I&*&8&8&:D #    f Ey Eu E 5 $ 2 2 4 M*d2)*HII3]]( *$,, 55 -171I1I . ''-   gt}} 5&*&8&8&:D #''++H5F++//8DMMI%&<==      h 43C3C DD..01T9%&ABB }}!!(Iz4==Q""$ !!(Iy$BRBRS""$ 77   h 0D..01T9%&899: a8 5 !!&)B-e!L $ 2 2 4  5J      s6 O,?P!?P1,.PP! P.-P.1 P>=P>cZURR5 URnSUlUcg[R"5UR :Xa UR [R5 UR5 g![[4a N$f=f![a gf=f)z!Disconnects from the Redis serverN) r on_disconnectrrrrshutdownr SHUT_RDWRrrGclose)rKr: conn_socks rPrAbstractConnection.disconnects ""$JJ     99;$(( " ""6#3#34  OO  Y'      s$B6BBB B*)B*ctURSSS9 [UR55S:wa [S5eg)z Send PING, expect PONG in returnPINGFr&PONGz#Bad response from PING health checkN)rr1rr$rvs rP _send_pingAbstractConnection._send_pings< &u5 **, - 7!"GH H 8r4c$UR5 g)z Function to call when PING failsNr)rKrs rP _ping_failedAbstractConnection._ping_failed  r4cUR(aJ[5UR:a1URR UR UR 5 ggg)z3Check the health of the connection with a PING/PONGN)rrrrrr?rBrvs rPrAbstractConnection.check_healthsA  % %$&43I3I*I JJ & &t8I8I J+J %r4TcvUR(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 socketrUNKNOWNrzError z while writing to socket. rN)rrrr?r@sendallrrrr(rrgr:r$ BaseException)rKrritemrerrnoerrmsgs rPr&AbstractConnection.send_packed_command szz LLN      '3''") ""4( ~~ < OO :; ; W OO 166{a )166!9vq !F5'1KF8ST"UV V  OO    s  V ,! ,\0<cjS(E$ue|*Xl[U5UlX0lU=(d 0UlXPl[ TU]"S0UD6 gNrS)hostrportsocket_keepalivesocket_keepalive_options socket_typesuperra)rKrrrsrtrurvrrs rPraConnection.__init__s> I 0(@(FB%& "6"r4cSUR4SUR4SUR4/nUR(aUR SUR45 U$)Nrrrsrr)rrrsrrrDrKr\s rPrwConnection.repr_piecessM499% ':T477OL    MM=$*:*:; < r4c`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 connectionNrz)socket.getaddrinfo returned an empty list)r getaddrinforrrsrv SOCK_STREAM setsockopt IPPROTO_TCP TCP_NODELAYrt SOL_SOCKET SO_KEEPALIVEruitems settimeoutrrrrr9) rKerrresfamilysocktyper( canonnamesocket_addressrrrrMs rPr Connection._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-c8URSUR3$)N:)rrrsrvs rPrConnection._host_errors))Adii[))r4)rrrsrtrurv) localhostiFNr rTrUrVrWrjrarwr rrX __classcell__rs@rProros2: !% #  'CR**r4roc:\rSrSrSrSrSrS\S\S\ R4Sjr S r S r S rS rS rSrSrSrS$SjrSrS%SjrS&SSS.SjjrSrSr\S\\\\4\\\444Sj5rSr Sr!S\SS4Sjr"S r#S!\$\\\%\$\44S"jr&S#r'g)'CacheProxyConnectionisfooz7.4.0redisconncache pool_lockc[R"5UlXlURRUlURR UlURR UlX0lX l[R"5Ul SUl SUl URUR5 gr])rrr_connrrrrs _pool_lock_cache threadingLock _cache_lock_current_command_cache_key_current_optionsr}_enable_tracking_callback)rKrrrs rPraCacheProxyConnection.__init__s 99; ZZ%% JJOO JJOO # $>>+*.' $ &&t'E'EFr4c6URR5$r])rrwrvs rPrw CacheProxyConnection.repr_piecesszz%%''r4c:URRU5 gr])rr}r{s rPr}.CacheProxyConnection.register_connect_callbacks ,,X6r4c:URRU5 gr])rrr{s rPr0CacheProxyConnection.deregister_connect_callbacks ..x8r4c:URRU5 gr])rrrs rPrCacheProxyConnection.set_parsers l+r4c(URR5 URRRSS5nUc&URRRSS5nURRRSS5nUc&URRRSS5nUbUc [ S5e[ U5n[ U5nXR :wd[X R5S:Xa [ S5eg)Nsserverserversversionversionz0Cannot retrieve information about server versionrziTo maximize compatibility with all Redis products, client-side caching is supported by Redis 7.4 or later) rrrr/r$r.DEFAULT_SERVER_NAMEr-MIN_ALLOWED_VERSION)rK server_name server_vers rPrCacheProxyConnection.connects jj3377 4H  **77;;HdKKZZ2266z4H  66::9dKJ  !3!"TU U":. #K0  33 3 ,D,DEJ!{ Kr4c8URR5 gr])rrrvs rPrCacheProxyConnection.on_connects r4cUR URR5 SSS5 URR"U6 g!,(df  N(=fr])rrflushrrrs rPrCacheProxyConnection.disconnects;    KK    t$ s A  Ac8URR5 gr])rrrvs rPr!CacheProxyConnection.check_health#s !r4Tc:URRU5 gr])rrrs rPr(CacheProxyConnection.send_packed_command&s &&w/r4c UR5 UR URR[ USSS95(d-SUlUR R"U0UD6 SSS5 gSSS5 URS5c [S5e[ US[URS55S9UlUR URRUR 5(aURRUR 5nURUR :wanUR URR5(a:URRSS9 URR5(aM:SSS5 SSS5 gURR[!UR UR"[$R&UR S95 SSS5 UR R"U0UD6 g!,(df  GN=f!,(df  N=f!,(df  NN=f) NrrS)r redis_keyskeyszCannot create cache key.Tr) cache_key cache_valuestatusconnection_ref)_process_pending_invalidationsrr is_cachablerrrrr/rrArrrrsetrDUMMY_CACHE_VALUEr IN_PROGRESS)rKr:rentrys rPr!CacheProxyConnection.send_command+s ++-   ;;**8DGPR+STT26/ ''88  U ::f  %78 8+3Gfjj.@(A+ '  {{t>>?? (G(GH''4::5#22;;==!00>>D>Q$22;;==)  KKOO"== $ 6 6+77#'::  !6 00W 0) s9AH*A6I AH<" I 4AI * H9< I I  Ic8URRU5$r])rrrs rPrCacheProxyConnection.can_read[szz""7++r4FrcUR URbURRUR5bURRUR5R[ R :waL[R"URRUR5R5sSSS5 $SSS5 URRUUUS9nUR URc UsSSS5 $Uc1URRUR/5 UsSSS5 $URRUR5nUb6[ RUlXEl URRU5 SSS5 U$!,(df  N=f!,(df  U$=f)N)rrr)rrrr/rrrrrrrrdelete_by_cache_keysVALIDr)rKrrrrW cache_entrys rPr"CacheProxyConnection.read_response^ss  //;KKOOD$C$CDPKKOOD$C$CDKK#//0}}KKOOD$C$CDPP  ::++- 3%,    ..6   00$2Q2Q1RS ++//$*I*IJK&%5%;%; "*2'  ,!$I $ $s%B7F2=G*G AG2 G Gc4URR"U6$r])rrFrs rPrF!CacheProxyConnection.pack_commandszz&&--r4c8URRU5$r])rrrs rPr"CacheProxyConnection.pack_commandsszz''11r4rqc.URR$r])rrrvs rPr'CacheProxyConnection.handshake_metadataszz,,,r4c8URR5 gr])rr rvs rPr CacheProxyConnection._connects r4c8URR5 gr])rrrvs rPr CacheProxyConnection._host_errors  r4NcURSSS5 UR5 URRUR5 g)Nr)TRACKINGON)rrrset_invalidation_push_handler_on_invalidation_callback)rKrs rPr.CacheProxyConnection._enable_tracking_callbacks8 (J5  2243Q3QRr4cUR5(a1URRSS9 UR5(aM0gg)NTr)rrrrvs rPr3CacheProxyConnection._process_pending_invalidationss/mmoo JJ $ $$ $ 7mmoor4datacUR UScURR5 OURRUS5 SSS5 g!,(df  g=f)Nr)rrrdelete_by_redis_keys)rKrs rPr.CacheProxyConnection._on_invalidation_callbacksF   Aw !!# 00a9   s AA A$) rrrrrrrrrrsrrrr)(rTrUrVrWrrrrsrrrrarwr}rrrrrrrrrrrFrrrr rr@rr rrrr r rrXrSr4rPrrs!!G!GG>> G$(79,. % "0 .1`, %'=APU'R.2-E$ue|*S9S3T.U:r4rc^^\rSrSrSrSU4SjjrU4SjrSrSrU=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 [S5eXlX lUc[R nO^[ U[5(aI[R [R[RS.nUU;a[SU35eUUnX0l X@l XPl Xpl X`lXlXlXlXlXlXlXl[,TU]\"S0UD6 g)aqConstructor 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. ssl_min_version: The lowest supported SSL version. It affects the supported SSL versions of the SSLContext. None leaves the default provided by ssl module. ssl_ciphers: A string listing the ciphers that are allowed to be used. Defaults to None, which means that the default ciphers are used. See https://docs.python.org/3/library/ssl.html#ssl.SSLContext.set_ciphers for more information. Raises: RedisError z$Python wasn't built with SSL supportN)noneoptionalrequiredz+Invalid SSL Certificate Requirements Flag: rS)r,r&keyfilecertfilessl CERT_NONEr?r@ CERT_OPTIONAL CERT_REQUIRED cert_reqsca_certsca_dataca_pathcheck_hostnamecertificate_passwordssl_validate_ocspssl_validate_ocsp_stapledssl_ocsp_contextssl_ocsp_expected_certssl_min_version ssl_ciphersrwra)rK ssl_keyfile ssl_certfile ssl_cert_reqs ssl_ca_certs ssl_ca_datassl_check_hostname ssl_ca_path ssl_passwordrrrrrrr CERT_REQSrs rPraSSLConnection.__init__sP}CD D" $  MMM  s + + ----I I- A-Q&m4M&$ " " 0$0!!2)B& 0&<#.& "6"r4c>[TU]5nURU5$![[4a UR 5 ef=f)z> Wrap the socket with SSL support, handling potential errors. )rwr _wrap_socket_with_sslrr&r9)rKrrs rPr SSLConnection._connectsHw! --d3 3$  JJL  s ""Acx[R"5nURUlURUlUR (dUR (a/URUR UR URS9 URcURc URb/URURURURS9 URbURUlUR(aUR!UR5 UR"SLa[$SLa ['S5eUR((aUR"(a ['S5eUR+XR,S9nUR((Ga,S SKnS S KJn UR4cfUR6R9UR6R:5nUR=UR 5 UR?UR 5 O UR4nURAXPRB5 UR6REU[FRF"55nURI5 URKUR,URL45 URO5 URQ5 U$UR"SLa[[$(aPS S KJ)n U"X0R,URLUR5n U RU5(aU$[WS 5eU$)z} Wraps the socket with SSL support. Args: sock: The plain socket to wrap with SSL. Returns: An SSL wrapped socket. )rrrN)cafilecapathcadataTFzcryptography is not installed.zKEither an OCSP staple or pure OCSP connection must be validated - not both.)server_hostnamerr)ocsp_staple_verifier) OCSPVerifierzocsp validation error),rcreate_default_contextrr verify_moderrload_cert_chainrrrrload_verify_locationsrminimum_versionr set_ciphersrr*r&r wrap_socketrrOpenSSLocsprrSSLContext SSLv23_METHODuse_certificate_fileuse_privatekey_fileset_ocsp_client_callbackrror request_ocsprrs do_handshaker7ris_validr$) rKrcontextsslsockrr staple_ctxconros rPr #SSLConnection._wrap_socket_with_sslsw,,.!%!4!4"nn ==DLL  # # 22 $  MM %||'||'  ) )}}T\\$,, *     +&*&:&:G #       0 0 1  ! !T ).D.M=> >  ) )d.D.D  %%dII%F  ) ) )  2$$,$[[001J1JK // >..t||<!22  / /$&A&A  ++((V]]_EC     KKDII. /     LLNN  ! !T ).D.D *WiiDMMJAzz||%&=>>r4)rrrrrrrrrrrrrr)NNrNNFNNFFNNNN) rTrUrVrWrjrar r rXrrs@rPrrsL  "'#F#P MMr4rcB^\rSrSrSrSU4SjjrSrSrSrSr U=r $) UnixDomainSocketConnectioniRz4Manages UDS communication to and from a Redis serverc >>[TU]"S0UD6 XlX lgrq)rwrapathr)rKr1rrrs rPra#UnixDomainSocketConnection.__init__Us "6" ,r4cSUR4SUR4/nUR(aURSUR45 U$)Nr1rr)r1rrrDrzs rPrw&UnixDomainSocketConnection.repr_piecesZsB499%dgg7    MM=$*:*:; < r4cN[R"[R[R5nURUR5 UR UR 5 URUR5 U$![a UR5 ef=f)z&Create a Unix domain socket connection) rAF_UNIXr~rrrr1rr9r)rKrs rPr #UnixDomainSocketConnection._connect`sy}}V^^V-?-?@ 334  LL # ++,   JJL  s BB$cUR$r])r1rvs rPr&UnixDomainSocketConnection._host_errorms yyr4)r1r)Nrrs@rPr/r/Rs:-  r4r/)0FFALSENNOcUbUS:Xag[U[5(aUR5[;ag[ U5$)Nr:F)r?r@upper FALSE_STRINGSrl)rNs rPto_boolrCts7 } %%++-="@ ;r4) rrrrtrrmax_connectionsrrrcURS5(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.rrunixr1connection_classrrrsr/r:rediss) startswithrrrqueryrrgrURL_QUERY_ARGUMENT_PARSERSr/rGrrschemer1r/hostnamersrreplaceAttributeErrorr)urlrnamerNr0s rP parse_urlrSs 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. rGrS)rSupdate)clsrQr url_optionss rPfrom_urlConnectionPool.from_urls?R n  '.45G.HK* + k"}V}r4NrD cache_factoryc *U=(d Sn[U[5(aUS:a [S5eXlX@lX lSUlX0lURS5(dURS5(aURS5S;a [S5eURRS5nUb'[U[5(d [S 5eXPlOdURb URR5UlO7[URRS55R5UlURSS5 URSS5 [R"5UlUR#5 g) Nlrz,"max_connections" must be a positive integer cache_configrr)rrVz4Client caching is only supported with RESP version 3z#Cache must implement CacheInterface)r?rrrGconnection_kwargsrDr_cache_factoryr/r&r get_cacherpoprr _fork_lockreset)rKrGrDr\r_rs rPraConnectionPool.__init__sO*2U/3//?Q3FKL L 0!2. +   0 04E4I4I'4R4R $$Z0@ !WXX**..w7E !%88$%JKK" &&2!%!4!4!>!>!@DJ!-..22>B"ikJ gt,nd3$..* r4rqc S[U5RS[U5RS[UR"S0UR D65S3$)NrrrrrS)typerUrTreprrGr_rvs rPrConnectionPool.__repr__4sST %%&aT (;(;'<T**DT-C-CDEFb J r4c:URRSS5$)z Returns: The RESP protocol version, or ``None`` if the protocol is not specified, in which case the server default will be used. rN)r_r/rvs rPrcConnectionPool.get_protocol:s %%))*d;;r4c[R"5UlSUl/Ul[ 5Ul[R"5Ul g)Nr) rr_lock_created_connections_available_connectionsr_in_use_connectionsrrrrvs rPrdConnectionPool.resetBs9^^% $%!&(##&5 99;r4crUR[R"5:wauURR SS9nU(d[ eUR[R"5:waUR 5 URR5 gg!URR5 f=f)N)r)rrrrcacquirer#rdrelease)rKacquireds rP _checkpidConnectionPool._checkpidSsF 88ryy{ "..q.9H** *88ryy{*JJL'') #'')s 3BB6 command_namerocUR5 UR URR5nUR RU5 SSS5 WR5 UR5(aURc [S5eU$![a UR 5nNf=f!,(df  No=f![[4aD UR5 UR5 UR5(a [S5eU$f=f![a URW5 ef=f)zGet a connection from the poolNConnection has dataConnection not ready)rwrmrorb IndexErrormake_connectionrpaddrrrr$rrrJrurKryroptions connections rPget_connectionConnectionPool.get_connections)  ZZ 4!88<<>   $ $ ( ( 4       B&&((TZZ-?)*?@@3 4!113  4Z"$W- B%%'""$&&(()*@AA) B   LL $   sXB=BB=D%.-CB:7B=9B::B== C AD"D%!D""D%%EcURn[URSS5URSS5URSS5S9$)z,Return an encoder based on encoding settingsrrrrrF)rrr)r_rr/)rKrs rP get_encoderConnectionPool.get_encodersF''ZZ G4"JJ'8(C#ZZ(:EB  r4c>URUR:a [S5eU=RS- slURb;[ UR "S0UR D6URUR5$UR "S0UR D6$)zCreate a new connectionzToo many connectionsrrS)rnrDr$rrrGr_rmrvs rPr~ConnectionPool.make_connections  $ $(<(< <!"89 9 !!Q&! :: !'%%?(>(>?TZZ $$>t'='=>>r4rcUR5 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 poolrN) rwrmrprKeyErrorowns_connectionrorDrnrrKrs rPruConnectionPool.releases  ZZ ((// ; ##J//++22:> ))Q.)%%'!Z?Z  Zs.B5B%AB5% B2/B51B22B55 Cc4URUR:H$r])rrs rPrConnectionPool.owns_connections~~))r4inuse_connectionsc 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)rwrmrrorpr)rKr connectionsrs rPrConnectionPool.disconnects`  ZZ #//1I1I #99 ) %%'*ZZs AA44 Bc$UR5 g)z-Close the pool, disconnecting all connectionsNrrvs rPr9ConnectionPool.closerDr4cURRSU05 URH nXlM URH nXlM g)Nr)r_rWrorrp)rKrrs rP set_retryConnectionPool.set_retrysE %%w&67//DJ0,,DJ-r4) ror`rnrcrprmrrGr_rDrrp)rqrs)rrorqNr)rr)rqN)rTrUrVrWrj classmethodrZror rrrar@rrcrdrwrrrr~rurrlrr9rrXrSr4rPrUrUs ..d$)-9= 0"#0 56 0d 3* <"-*^3\B W  ?**,*3*(D(D((r4rUcV^\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)rGrDrS) queue_classrrwra)rKrDrrGrr_rs rPraBlockingConnectionPool.__init__s2'   -+   r4cURUR5UlURRS5 M![a Of=f/Ul[ R"5Ulgr]) rrDpool put_nowaitr _connectionsrrrrvs rPrdBlockingConnectionPool.reset#sf$$T%9%9:   $$T*   99;sA A  A cURb<[UR"S0URD6URUR5nOUR"S0URD6nUR R U5 U$)zMake a fresh connection.rS)rrrGr_rmrrDrs rPr~&BlockingConnectionPool.make_connection;sn :: !-%%?(>(>?TZZJ..H1G1GHJ   ,r4c 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.r{r|) rwrr/rrr$r~rrrrrJrurs rPr%BlockingConnectionPool.get_connectionFs   >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)rwrrrrrrs rPruBlockingConnectionPool.releasezsm ##J//  ! ! # II  &   II  ,   sA00 A=<A=cjUR5 URHnUR5 M g)z(Disconnects all connections in the pool.N)rwrrrs rPr!BlockingConnectionPool.disconnects( ++J  ! ! #,r4)rrrrr)rTrUrVrWrjrorrardr~rrurrXrrs@rPrrs;F#  0 2h*$$r4r)\rrrrrHrrabcr itertoolsrqueuerrrrtypingr r r r r rr urllib.parserrr redis.cacherrrrrr_parsersrrrrbackoffr credentialsrr exceptionsr!r"r#r$r%r&r'r(rr)utilsr*r+r,r-r.r/r0r1rErfrkrhrdrobjectr__annotations__r6r8rZrsrrorrr/rBrCrrklistrLrSrUrrSr4rPrs ((CCC44JIO            8E, nDEFF"M M$00fB B JJ),J)ZC*#C*LE:.E:PfJfR!3>/  # ! 6rkk\ b$^b$r4