+ hscsaR3t\0t^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIH t ^RI H t ^RI H t HtHt^RIHt^RIHtHtHtHtHtHtHt^RIHtHtHt^RIHtHtH t H!t!H"t"H#t#^R I$H%t%H&t&H't'H(t(^R I)H*t*^R I+H,t,H-t-^R I.H/t/H0t0H1t1H2t2H3t3H4t4H5t5H6t6^R I7H8t8^RI9H:t:H;t;Ht>H?t?H@t@HAtA];'d^RIBtBRtCRtDRtERtF^tG]H!4tI]^k];'d]&tJM]'tJ!RR4tK!RR4tL!RR4tM!RR]M4tN!RR]N4tO!RR]M4tP!RR ]O4tQ!R!R"]N4tRR4tSR#tTR$]UR%]VR&]VR']TR(]TR)]WR*]UR+]UR,]TR-]V/ tXR.tY!R/R04tZ!R1R2]Z4t[R#)5N)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_bytess*s$s cs2a]tRt^DtoV3RlRltRtVtR#)HiredisRespSerializerc <V^8dQhRS[/#)args)r format __classdict__"5/usr/lib/python3.14/site-packages/redis/connection.py __annotate__Z"HiredisRespSerializer.__annotate__Es$r/c s.p\V^,\4'd>\V^,P4P 44VR,,pMC?N)__name__ __module__ __qualname____firstlineno__rK__static_attributes____classdictcell__r6@r8r0r0Dsr/r0cs8a]tRt^VtoV3RlRltRtRtVtR#)PythonRespSerializerc<V^8dQhRR/#r2returnNrLr4r7r8r9Z!PythonRespSerializer.__annotate__Wsr/csWnW nR#N_buffer_cutoffr@)rG buffer_cutoffr@&&&r8__init__ZPythonRespSerializer.__init__Ws + r/c  s.p\V^,\4'd>\V^,P4P 44VR,,pMr?r@rA SYM_EMPTYjoinSYM_STARlenSYM_CRLFr[Zmap memoryview SYM_DOLLARrB)rGr3rHZbuffr\ZargZ arg_lengths&* r8rKZPythonRespSerializer.pack[sd d1gs # #a)//12T"X=D T!W_a)DH4D~~xSY)>)>)@(KL++ t{{D)CSJD M)-c:.. ~~:s:'='='?J d# c" ~~"J..0   !*4  d r/rZN)rMrNrOrPr^rKrQrRrSrTr8rUrUVs++r/rUcs>a]tRt^to]R4t]R4t]R4t]R4t]R4t ]R4t ]R4t ]R4t ]RR l4t ]R 4t]RR l4t]RRR RR /Rll4t]R4t]R4t]]V3RlRl44tRtVtR#)ConnectionInterfacecR#rYrLrG&r8 repr_piecesZConnectionInterface.repr_pieces r/crgrYrLrGcallback&&r8register_connect_callbackZ-ConnectionInterface.register_connect_callbackrkr/crgrYrLrlrnr8deregister_connect_callbackZ/ConnectionInterface.deregister_connect_callbackrkr/crgrYrLrG parser_classrnr8 set_parserZConnectionInterface.set_parserrkr/crgrYrLrhrir8connectZConnectionInterface.connectrkr/crgrYrLrhrir8 on_connectZConnectionInterface.on_connectrkr/crgrYrLrGr3&*r8 disconnectZConnectionInterface.disconnectrkr/crgrYrLrhrir8 check_healthZ ConnectionInterface.check_healthrkr/TcrgrYrLrGcommandryr]r8send_packed_commandZ'ConnectionInterface.send_packed_commandrkr/crgrYrLrGr3kwargs&*,r8 send_commandZ ConnectionInterface.send_commandrkr/crgrYrLrGtimeoutrnr8can_readZConnectionInterface.can_readrkr/Fdisconnect_on_error push_requestcrgrYrL)rGdisable_decodingrrs&&$$r8 read_responseZ!ConnectionInterface.read_responses r/crgrYrLrvrwr8rDZ ConnectionInterface.pack_commandrkr/crgrYrLrGcommandsrnr8 pack_commandsZ!ConnectionInterface.pack_commandsrkr/cb<V^8dQhRS[S[S[S[3,S[S[S[3,3,/#r2rXr r bytesr>r4r7r8r9Z ConnectionInterface.__annotate__s/  E$ue|*floatboolr rrrr4r7r8r9AbstractConnection.__annotate__s>XNXN XN3-XN! XN !) XN  XNXNXNXNXN #XNc]XN3-XN c]!XN"3-#XN$S$Y%XN&%Xb$h%78'XN(&&89)XN*3-+XN,!"d(!34-XNr/c s0V'g V'dVe \R4h\P!4VnWnWnWnWnVVnW n VVn W0n VfTpW@n WPn V\Jd.pV'dVP\ 4W`nV'g V'dVVf\%\'4^4VnM\*P,!V4VnVP(P/V4M\%\'4^4VnWn^VnVVn\7WxV 4VnRVnRVnWnVPAV 4.Vn!RVn"\GV4pT^8gT^8d \OR4hTTn(TPST4Tn*R# \Hd \JpLK\Ld \OR4hi;i X^8gT^8d \OR4hTTn(i;i)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`. Nz'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'ipzprotocol must be an integerzprotocol must be either 2 or 3)+r"osgetpidpidrrrrrrrrrrSENTINELrBr%retry_on_errorr&rrcopydeepcopyZupdate_supported_errorsrnext_health_checkrrencoderr_sock_socket_read_sizers_connect_callbacksr[rrEDEFAULT_RESP_VERSION ValueErrorr!r_construct_command_packer_command_packer)rGrrrrrrrrrrrrrrrrrrrrrrZps&&&&&&&&&&&&&&&&&&&&&& r8r^ZAbstractConnection.__init__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* GG0G3G0# G00G33"Hc sRPVP4UUu.uF wrV RV 2NK upp4pRVPP RVPP RV R2#uuppi)Z,Z=<.()>)r`rj __class__rNrM)rGkvZ repr_argss& r8__repr__ZAbstractConnection.__repr__+snHHT5E5E5GH5GTQ1QCj5GHI 4>>,,-Qt~~/F/F.Gq SUVVIsA- crgrYrLrhrir8rjZAbstractConnection.repr_pieces/rkr/csLVP4R# \dR#i;irY)rxZ Exceptionrhrir8__del__ZAbstractConnection.__del__3s#  OO    s  ##csVeV#\'d \4#\VPVPP 4#rY)r(r0rUr[rr@)rGZpackerrnr8rZ,AbstractConnection._construct_command_packer9s9  M  (* *'(;(;T\\=P=PQ Qr/c s\P!V4pW P9dVPPV4R#R#)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 WeakMethodrrB)rGrmZwm&& r8roZ,AbstractConnection.register_connect_callbackAs9   ) ,, ,  # # * *2 . -r/c sVPP\P!V44R# \dR#i;i)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)rremoverrrrlrnr8rpZ.AbstractConnection.deregister_connect_callbackMs8    # # * *7+=+=h+G H   s/3 AAc s6V!VPR7VnR#)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_parserrqrnr8rsZAbstractConnection.set_parserXs $T5K5KL r/c saSP'dR#SPPV3RlV3Rl4pTSnSPfSP4MSPS4SPUu.uFq3!4'gKTNK upSn SPFpT!4pT'gKT!S4K R# \Pd \ R4h\ d p\SPT44hRp?ii;i \dSP4hi;iuupi)z5Connects to the Redis server if not already connectedNcs$<SP4#rY)_connectrhsr8,AbstractConnection.connect..fs  r/cs&<SPV4#rYrx)errorrGs&r8rrfstu7Mr/zTimeout connecting to server)rrcall_with_retrysocketrr%OSErrorr!_error_messagerrur#rxr)rGsockeZrefrmsf r8rtZAbstractConnection.connect`s :::  :::--')MD  &&.!''-372I2I"S2I3SU332I"S**CuHx+-~~ ?=> > :!$"5"5a"89 9 :  OO   #Ts;$CD"DD=D=(D:D;DDD:crgrYrLrhrir8rZAbstractConnection._connectrkr/crgrYrLrhrir8 _host_errorZAbstractConnection._host_errorrkr/cs6\VP4V4#rY)r,r)rGZ exceptionrnr8rZ!AbstractConnection._error_messages#D$4$4$6 BBr/c sVPPV4VPpRpVP'g%VP'gVP'dEVP;'g!\ VPVP4pVP 4pV'dVPR9d\VP\4'dLVP\4VPVPn VPPV4\V4^8Xd RV^,.pVP!RVPR.VO5!VP4VnEMXV'dEVP!R.VO5RR/VP4p\%V4R8wd \'R 4hEM VPR9d\VP\4'dLVP\4VPVPn VPPV4VPRVP4VP4VnVP P)R 4VP8wd6VP P)R 4VP8wd \+R 4hVP,'dGVPR RVP,4\%VP44R8wd \+R4hVP.'d/VPR RRVP.4VP4TP2'd/TPR RRTP24TP4TP4'dHTPRTP44\%TP44R8wd \+R4hR#R# \"d0TPRTR,RR7TP4pELi;i \0dLi;i \0dLi;i)z=Initialize the connection, authenticate and select a databaseNZdefaultZHELLOZAUTHryFryZOKzInvalid Username or PasswordsprotoprotozInvalid RESP versionCLIENTZSETNAMEzError setting client nameZSETINFOzLIB-NAMEzLIB-VERZSELECTzInvalid Database)r2Z2i)rrurrrrZget_credentialsrr=rrsrZEXCEPTION_CLASSESrbrrrrr.rgetr!rrr$rr)rGparserZ auth_argsZ cred_providerZ auth_response& r8ruZAbstractConnection.on_connects{ %  # # # ((TT5dmmT]]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""$ 777   h 0D..01T9%&899: a8 5 !!&)B-e!L $ 2 2 4  5J      sBP+Q=.Q,Q>.Q6QQ QQ Q#"Q#c shVPP4VPpRVnVfR#\P!4VP 8Xd!VP \P4VP4R# \\3dL&i;i \dR#i;i)z!Disconnects from the Redis serverN) rZ on_disconnectrrrrshutdownrZ SHUT_RDWRrrEclose)rGr3Z conn_socks&* r8rxZAbstractConnection.disconnects ""$JJ     99;$(( " ""6#3#34  OO  Y'      s$B 9B" BB" B10B1c s~VPRRR7\VP44R8wd \R4hR#)z Send PING, expect PONG in returnZPINGFrZPONGz#Bad response from PING health checkN)rr.rr!rhrir8 _send_pingZAbstractConnection._send_pings< &u5 **, - 7!"GH H 8r/c &VP4R#)z Function to call when PING failsNr)rGrrnr8 _ping_failedZAbstractConnection._ping_failed  r/c sVP'dN\4VP8d3VPP VP VP 4R#R#R#)z3Check the health of the connection with a PING/PONGN)rrrrrrrrhrir8ryZAbstractConnection.check_healthsD  % % %$&43I3I*I JJ & &t8I8I J+J %r/Tc sVP'gVP4V'dVP4\V\4'dV.pVFpVPP V4K R# \ PdTP4\R4h\d}pTP4\TP4^8XdRTP^,reM&TP^,pTP^,p\RT RT R24hRp?i\dTP4hi;i)z2Send an already packed command to the Redis serverzTimeout writing to socketZUNKNOWNzError z while writing to socket. rN)rrtryr=r>Zsendallrrrxr%rrbr3r! BaseException)rGr{ryZitemrZerrnoZerrmsgs&&& r8r|Z&AbstractConnection.send_packed_command szzz LLN      '3''") ""4( ~~ < OO :; ; W OO 166{a )166!9vq !F5'1KF8ST"UV V  OO    s$=A;;8E 4E 5A7D,, E 9E c s|VPVPP!V!VPRR4R7R#)z+Pack and send a command to the Redis serverryTrN)r|rrKrr}rr8rZAbstractConnection.send_command*s7    % %t ,ND9 ! r/c sVPpV'gVP4VP4pVPP V4# \ d1pTP 4\RT RTP 24hRp?ii;i)z8Poll the socket to see if there's data that can be read.Error while reading from z: N) rrtrrrrrxr!r3)rGrr host_errorrs&& r8rZAbstractConnection.can_read1syzz LLN%%'  V<<((1 1 V OO !$=j\AFF8"TU U VsA B +BB rrc sVP4pVPR9d*\'gVPP WR7pMVPP VR7pVP'd!\4VP,Vn\!V\"4'dVhV# \ P d(T'dTP4\RT 24h\d9pT'dTP4\RT RTP 24hRp?i\dT'dTP4hi;i ?i;i)z0Read the response from a previously sent command)rr)rzTimeout reading from rz : N)3)rrr(rrrrrxr%rr!r3rrrrr=r$)rGrrrrresponsers&&$$ r8rZ AbstractConnection.read_response?s/%%'  }}(1B1B<<55%56 <<55GW5X&  % % %%)Vd.H.H%HD " h . . 5~~ E"!!6zlCD D "!!+J<3qvvhG  #!   sFB6B6 B62E6E&E:E;3D.. E;EEEc 6VPP!V!#)r;)rrKrvrwr8rDZAbstractConnection.pack_commandms##(($//r/c s .p.p^pVPpVFpVPP!V!Fp\V4pWE8gW8g\ V\ 4'd1V'd%VP \PV44^p.pW8g\ V\ 4'dVP V4KVP V4WH, pK K V'd%VP \PV44V#)z.Pack multiple commands into the Redis protocol) r[rrKrbr=rdrBr_r`) rGrrHpiecesZ buffer_lengthr\ZcmdZchunkZchunklens && r8rZ AbstractConnection.pack_commandsqs ++ C--22C8u:!1/!%44 innV&<=$%MF+z%/L/LMM%(MM%(!-M!9&  MM)..0 1 r/cs6<V^8dQhRS[;'gS[/#r)rr>r4r7r8r9rscjjSr/cVP#rY)rrhrir8 get_protocolZAbstractConnection.get_protocols }}r/crrrr4r7r8r9rs/((E$ue|*  V,! ,  ,\0<(())r/rcLaa]tRtRtoRtRV3RlltRtRtRtRt Vt V;t #) Connectioniz4Manages TCP communication to and from a Redis serverc s<Wn\V4VnW0nT;'g/VnWPn\ SV`!R/VBR#NrL)hostrportsocket_keepalivesocket_keepalive_options socket_typesuperr^)rGrrrrrr~rs&&&&&&,r8r^ZConnection.__init__sA I 0(@(F(FB%& "6"r/csRVP3RVP3RVP3.pVP'dVP RVP34V#)rrrr)rrrrrBrGr& r8rjZConnection.repr_piecessP499% ':T477OL     MM=$*:*:; < r/c shRp\P!VPVPVP\P 4EFpVwr4rVpRp\P!W4V4pVP \P\P^4VP'dsVP \P\P^4VPP4F%wrVP \PW4K' VPVP4VP!V4VPVP"4Vu# VeVh\%R4h \$d*p T pTeTP'4Rp ? EK]Rp ? EKdRp ? ii;i)zCreate a TCP socket connectionNz)socket.getaddrinfo returned an empty list)rZ getaddrinforrr SOCK_STREAMZ setsockoptZ IPPROTO_TCPZ TCP_NODELAYrZ SOL_SOCKETZ SO_KEEPALIVEritems settimeoutrrtrrr) rGZerrZresZfamilyZsocktyperZ canonnameZsocket_addressrrrrIs & r8rZConnection._connects[ %% IItyy$"2"2F4F4F CBE >FeD !}}Vu= 2 2F4F4FJ(((OOF$5$5v7J7JAN $ = = C C E(:(:AA!F ; ;< ^, 3 34 1 > ?IABB !#JJLL$ !sDE== F1F,,F1cs8VP RVP 2#)Z:)rrrhrir8rZConnection._host_errors))Adii[))r/)rrrrr)Z localhostiFNr rMrNrOrPrr^rjrrrQrR __classcell__rr6@@r8rrs#:#  'CR**r/rcsa]tRtRtoRtRtRtV3RlRltRtRt R t R t R t R t R tRtR$RltRtR%RltR&RRRR/RlltRtRt]V3RlRl4tRtRtV3RlRltRtV3R lR!ltR"tVtR##)'CacheProxyConnectionisfooz7.4.0Zrediscs@<V^8dQhRS[RS[RS[P/#)r2conncache pool_lock)rfr threadingLockr4r7r8r9!CacheProxyConnection.__annotate__s2GG!GG>> Gr/cs\P!4VnWnVPPVnVPP VnVPP VnW0nW n\P!4Vn RVn RVn VPVP4R#rY)rrr_connrrr _pool_lock_cacher r  _cache_lock_current_command_cache_key_current_optionsro_enable_tracking_callback)rGrrrs&&&&r8r^ZCacheProxyConnection.__init__s 99; ZZ%% JJOO JJOO # $>>+*.' $ &&t'E'EFr/cs6VPP4#rY)r rjrhrir8rjZ CacheProxyConnection.repr_piecesszz%%''r/c<VPPV4R#rY)r rorlrnr8roZ.CacheProxyConnection.register_connect_callbacks ,,X6r/crrY)r rprlrnr8rpZ0CacheProxyConnection.deregister_connect_callbacks ..x8r/crrY)r rsrqrnr8rsZCacheProxyConnection.set_parsers l+r/cs6VPP4VPPPRR4pVf'VPPPRR4pVPPPRR4pVf'VPPPRR4pVeVf \ R4h\ V4p\ V4pWP 8wg\W P4^8Xd \ R4hR#)sserverNZserversversionZversionz0Cannot retrieve information about server versionziTo maximize compatibility with all Redis products, client-side caching is supported by Redis 7.4 or later) r rtrrr!r+DEFAULT_SERVER_NAMEr*MIN_ALLOWED_VERSION)rGZ server_nameZ server_vers& r8rtZCacheProxyConnection.connects jj3377 4H  **77;;HdKKZZ2266z4H  66::9dKJ  !3!"TU U":. #K0  33 3 ,D,DEJ!{ Kr/c:VPP4R#rY)r rurhrir8ruZCacheProxyConnection.on_connects r/csVP;_uu_4VPP4RRR4VPP!V!R# +'giL,;irY)rrflushr rxrvrwr8rxZCacheProxyConnection.disconnects>     KK    t$ s A A$ crrY)r ryrhrir8ryZ!CacheProxyConnection.check_health#s !r/TcrrY)r r|rzr]r8r|Z(CacheProxyConnection.send_packed_command&s &&w/r/c sVP4VP;_uu_4VPP\ V^,RR74'g/RVnVP P!V/VBRRR4R#RRR4VPR4f \R4h\ V^,\VPR44R7VnVP;_uu_4VPPVP 4'dVPPVP 4pVPVP 8wd]VP;_uu_4VPP4'dVPPRR7K>RRR4RRR4R#VPP\!VP VP"\$P&VP R74RRR4VP P!V/VBR# +'giEL;i +'giL;i +'giLU;i) r)r{Z redis_keysNkeyszCannot create cache key.Tr)Z cache_key cache_valuestatusconnection_refrL)_process_pending_invalidationsrrZ is_cachablerrr rrrr?rr rrsetrDUMMY_CACHE_VALUEr IN_PROGRESS)rGr3r~Zentrys&*, r8rZ!CacheProxyConnection.send_command+s ++-    ;;**8DGPR+STT26/ ''88  U ::f  %78 8+3Gfjj.@(A+ '   {{t>>?? (G(GH''4::5#22;;==!00>>D>Q>)  KKOO"== $ 6 6+77#'::  !6 00W  0) s>AI3BI'3 I I 3 I'AI' I  I$ I'' I7 c8VPPV4#rY)r rrrnr8rZCacheProxyConnection.can_read[szz""7++r/FrrcsVP;_uu_4VPeVPPVP4eVPPVP4P\ P 8wdN\P!VPPVP4P4uuRRR4#RRR4VPPVVVR7pVP;_uu_4VPf VuuRRR4#Vf3VPPVP.4VuuRRR4#VPPVP4pVe7\ PVnWEn VPPV4RRR4V# +'giL;i +'giT#;i)N)rrr)rrrrrrr rrrr rZdelete_by_cache_keysZVALIDr)rGrrrrZ cache_entrys&&$$ r8rZ"CacheProxyConnection.read_response^sy   //;KKOOD$C$CDPKKOOD$C$CDKK#//0}}KKOOD$C$CDPP  ::++- 3%,     ..6   00$2Q2Q1RS ++//$*I*IJK&%5%;%; "*2'  ,!$I $ $s%B:GG!/+G!%AG! G ! G2 crrY)r rDrvrwr8rDZ!CacheProxyConnection.pack_commandszz&&--r/cr!rY)r rrrnr8rZ"CacheProxyConnection.pack_commandsszz''11r/crrrr4r7r8r9r s/--E$ue|*r rr4r7r8r9r s,::d5htE{>S9S3T.U:r/csVP;_uu_4V^,fVPP4M"VPPV^,4RRR4R# +'giR#;i)r<N)rrrZdelete_by_redis_keys)rGr$rnr8r#Z.CacheProxyConnection._on_invalidation_callbacksL    Aw !!# 00a9    s A A(( A9 ) rrr rrr rrrrNrrr)rMrNrOrPrrrr^rjrorprsrtrurxryr|rrrrDrrrrrrrr#rQrRrSrTr8rrs!!GG$(79,. % "0 .1`,'=A'PU'R.2--!SS 8::r/rcsLaa]tRtRtoRtRV3RlltV3RltRtRtVt V;t #) 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 s<\'g \R4hWnW nVf\P pMf\ V\4'dQR\P R\PR\P/pVV9d\RV 24hVV,pW0n W@n WPn Wpn W`nWnWnWnWnWnWnWn\,SV`\!R/VBR#)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 supportNZnoneZoptionalrequiredz+Invalid SSL Certificate Requirements Flag: rL)r)r#keyfilecertfilesslZ CERT_NONEr=r>Z CERT_OPTIONALZ CERT_REQUIRED cert_reqsca_certsca_dataca_pathcheck_hostnamecertificate_passwordssl_validate_ocspssl_validate_ocsp_stapledssl_ocsp_contextssl_ocsp_expected_certssl_min_version ssl_ciphersrr^)rGZ ssl_keyfileZ ssl_certfileZ ssl_cert_reqsZ ssl_ca_certsZ ssl_ca_datassl_check_hostnameZ ssl_ca_pathZ ssl_passwordr0r1r2r3r4r5r~Z CERT_REQSrs&&&&&&&&&&&&&&&, r8r^ZSSLConnection.__init__sP}CD D" $  MMM  s + + C--C--I I- A-Q&m4M&$ " " 0$0!!2)B& 0&<#.& "6"r/c s<\SV`4pVPV4# \\3dTP 4hi;i)z> Wrap the socket with SSL support, handling potential errors. )rr_wrap_socket_with_sslrr#r)rGrrs& r8rZSSLConnection._connectsHw! --d3 3$  JJL  s "#Ac s\P!4pVPVnVPVnVP 'gVP 'd3VPVP VP VPR7VPfVPfVPe3VPVPVPVPR7VPeVPVnVP'dVP!VP4VP"RJd\$RJd \'R4hVP('dVP"'d \'R4hVP+WP,R7pVP('Ed.^RIp^R IHpVP4fgVP6P9VP6P:4pVP=VP 4VP?VP 4M VP4pVPAWPPB4VP6PEV\FPF!44pVPI4VPKVP,VPL34VPO4VPQ4V#VP"RJd^\$'dR^R IH)pV!W0P,VPLVP4p V PU4'dV#\WR 4hV#) z} Wraps the socket with SSL support. Args: sock: The plain socket to wrap with SSL. Returns: An SSL wrapped socket. )r(r'rN)ZcafileZcapathZcadataTFzcryptography is not installed.zKEither an OCSP staple or pure OCSP connection must be validated - not both.)Zserver_hostname)ocsp_staple_verifier) OCSPVerifierzocsp validation error),r)Zcreate_default_contextr.r*Z verify_moder(r'Zload_cert_chainr/r+r-r,Zload_verify_locationsr4Zminimum_versionr5Z set_ciphersr0r'r#r1Z wrap_socketrOpenSSLZocspr8r2ZSSLZContextZ SSLv23_METHODZuse_certificate_fileZuse_privatekey_fileZset_ocsp_client_callbackr3rrZ request_ocsprtrZ do_handshakerr9Zis_validr!) rGrZcontextZsslsockr:r8Z staple_ctxZconr9Zos && r8r7Z#SSLConnection._wrap_socket_with_ssls,,.!%!4!4"nn ===DLLL  # # 22 $  MM %||'||'  ) )}}T\\$,, *     +&*&:&:G #        0 0 1  ! !T ).D.M=> >  ) ) )d.D.D.D  %%dII%F  ) ) )  2$$,$[[001J1JK // >..t||<!22  / /$&A&A  ++((V]]_EC     KKDII. /     LLNN  ! !T ).D.D *WiiDMMJAzz||%&=>>r/)r+r,r-r*r(r/r.r'r5r4r2r3r0r1)NNr&NNFNNFFNNNN) rMrNrOrPrr^rr7rQrRrrrr8r%r%s" F#P MMr/r%cr) UnixDomainSocketConnectioniRz4Manages UDS communication to and from a Redis serverc s@<\SV`!R/VBWnW nR#r)rr^pathr)rGr<rr~rs&&&,r8r^Z#UnixDomainSocketConnection.__init__Us "6" ,r/csRVP3RVP3.pVP'dVPRVP34V#)r<rr)r<rrrBrrr8rjZ&UnixDomainSocketConnection.repr_piecesZsE499%dgg7     MM=$*:*:; < r/c sP\P!\P\P4pVPVP4VP VP 4TPTP4T# \dTP4hi;i)z&Create a Unix domain socket connection) rZAF_UNIXrrrrtr<rrr)rGrrr8rZ#UnixDomainSocketConnection._connect`sy}}V^^V-?-?@ 334  LL # ++,   JJL  s BB%crrY)r<rhrir8rZ&UnixDomainSocketConnection._host_errorms yyr/)r<r)Nrrrr8r;r;Rs!:-  r/r;csVeVR8XdR#\V\4'dVP4\9dR#\ V4#)Nr=F)r=r>Zupper FALSE_STRINGSr)rJrir8to_boolr?ts7 } %%++-="@ ;r/rrrrrrmax_connectionsrr6rcsVPR4'g:VPR4'g#VPR4'g \R4h\V4p/p\VP4P 4Fawr#V'gK\ V4^8gK!\V^,4p\PV4pV'dV!V4W&K]W1V&Kc VP'd\VP4VR&VP'd\VP4VR&VPR8Xd6VP'd\VP4VR &\VR &V#VP 'd\VP 4VR &VP"'d\%VP"4VR &VP'd:R V9d3\%\VP4P'RR44VR &VPR8Xd \*VR &V# \\3d\RT R24hi;i \(\3dLSi;i)zredis://z rediss://zunix://zRRedis URL must specify one of the following schemes (redis://, rediss://, unix://)zInvalid value for 'z' in connection URL.rrZunixr<connection_classrrrZ/r=Zrediss)Z startswithrrrZqueryrrbrURL_QUERY_ARGUMENT_PARSERSrrErrZschemer<r;ZhostnamerrZreplaceZAttributeErrorr%)urlr~ZnamerJrrr8 parse_urlrDs z"" >>+ & & >>) $ $ 5  3-C F *002  5SZ!^E!H%E/33D9FW#)%=FL %t 3 |||$S\\2z |||$S\\2z zzV 888$SXX.F6N%?!"& M! <<<$S\\2F6N 888 ]F6N 888F* "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. rArL)rDupdate)ZclsrCr~Z url_optionss&&, r8from_urlZConnectionPool.from_urls?R n  '.45G.HK* + k"}V}r/NcsF<V^8dQhRS[S[,RS[S[,/#)r2r@ cache_factory)r rrr4r7r8r9ConnectionPool.__annotate__s+00"#0 56 0r/c s>T;'gRp\V\4'dV^8d \R4hWnW@nW nRVnW0nVPR4'gVPR4'dVPR4R 9d \R4hVPPR4pVe)\V\4'g \R4hWPnMeVPe!VPP4VnM7\VPPR44P4VnVPRR4VPRR4\P!4VnVP#4R#) r2z,"max_connections" must be a positive integerNZ cache_configrrz4Client caching is only supported with RESP version 3z#Cache must implement CacheInterfacel)rr)r=rrrAconnection_kwargsr@r_cache_factoryrr#rZ get_cacherpopr r  _fork_lockreset)rGrAr@rHrJrs&&&&, r8r^ZConnectionPool.__init__sR*22U/3//?Q3FKL L 0!2. +   0 04E4I4I'4R4R $$Z0@ !WXX**..w7E !%88$%JKK" &&2!%!4!4!>!>!@DJ!-..22>B"ikJ gt,nd3$..* r/cs&<V^8dQhRS[S[3/#rr>r4r7r8r9rI4s  3* r/c sR\V4P R\V4P R\VP!R/VP B4 R2#)rrrrrL)ZtyperNrMZreprrArJrhrir8rZConnectionPool.__repr__4sST %%&aT (;(;'<T**DT-C-CDEFb J r/c s:VPPRR4#)z Returns: The RESP protocol version, or ``None`` if the protocol is not specified, in which case the server default will be used. rN)rJrrhrir8rZConnectionPool.get_protocol:s %%))*d;;r/crVrWrLr4r7r8r9rIBstr/cs\P!4Vn^Vn.Vn\ 4Vn\P!4Vn R#)rN) r r _lock_created_connections_available_connectionsr_in_use_connectionsrrrrhrir8rNZConnectionPool.resetBs9^^% $%!&(##&5 99;r/crVrWrLr4r7r8r9rISs-*-*4-*r/csVP\P!48wd|VPP ^R7pV'g\ hVP\P!48wdVP 4VPP4R#R# TPP4i;i)i)rN)rrrrMZacquirer rNrelease)rGZacquiredrr8 _checkpidZConnectionPool._checkpidSsF 88ryy{ "..q.9H** *88ryy{*JJL'') #'')s 4B""B>cr")r2 command_namerXrrOr4r7r8r9rIs3\r/c sVP4VP;_uu_4VPP4pVP PV4RRR4XP4VP4'dVPf \R4hV# \dTP 4pLi;i +'giLt;i \\3dFTP4TP4TP4'd \R4hT#i;i \dTPX4hi;i)zGet a connection from the poolNConnection has dataConnection not ready)rUrPrRrLZ IndexErrormake_connectionrSZaddrtrrr!rrxrrTrGrVrZoptions connection&&*, r8get_connectionZConnectionPool.get_connections+  ZZZ 4!88<<>   $ $ ( ( 4       B&&((TZZ-?)*?@@3 4!113  4Z"$W- B%%'""$&&(()*@AA) B   LL $   seCB'C%D46C C'CCCC C AD1" D1-D40D11D44Ecr1r)rr4r7r8r9rIs  W r/c sVPp\VPRR4VPRR4VPRR4R7#)z,Return an encoder based on encoding settingsrrrrrF)rrr)rJrr)rGr~rr8 get_encoderZConnectionPool.get_encodersF''ZZ G4"JJ'8(C#ZZ(:EB  r/crV)r2rXrfrLr4r7r8r9rIs ? ?!6 ?r/c sJVPVP8d \R4hV;P^, unVPe<\ VP !R/VP BVPVP4#VP !R/VP B#)zCreate a new connectionzToo many connectionsrL)rQr@r!rrrArJrPrhrir8rYZConnectionPool.make_connections  $ $(<(< <!"89 9 !!Q&! :: !'%%?(>(>?TZZ $$>t'='=>>r/c"<V^8dQhRRRR/#)r2r[rrXNrLr4r7r8r9rIs,4r/c sVP4VP;_uu_4VPPV4VP V4'dVP PV4M4V;P^,unVP4RRR4R#RRR4R# \dLi;i +'giR#;i)z(Releases the connection back to the poolN) rUrPrSrZKeyErrorowns_connectionrRrBrQrxrGr[rnr8rTZConnectionPool.releases  ZZZ ((// ; ##J//++22:> ))Q.)%%'!Z?Z  ZZs5CB4CAC4 C?CCC C cs$<V^8dQhRRRS[/#)r2r[rrX)rr4r7r8r9rIs**,*3*r/cs4VPVP8H#rY)rrarnr8r`ZConnectionPool.owns_connections~~))r/cr")r2inuse_connectionsrXN)rr4r7r8r9rIs((D(D(r/c s$VP4VP;_uu_4V'd"\VPVP4pM VPpVFpVP 4K RRR4R# +'giR#;i)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)rUrPrrRrSrx)rGrbZ connectionsr[s&& r8rxZConnectionPool.disconnectsd  ZZZ #//1I1I #99 ) %%'*ZZZs AA>> B crVrWrLr4r7r8r9rIstr/c r)z-Close the pool, disconnecting all connectionsNrrhrir8rZConnectionPool.closerr/cr_)r2rr&rXNrLr4r7r8r9rIsw4r/csVPPRV/4VPF pWnK VPF pWnK R#)rN)rJrFrRrrS)rGrrrr8 set_retryZConnectionPool.set_retrysE %%w&67//DJ0,,DJ-r/) rRrKrQrMrSrPrrArJr@rr)rMrNrOrPrZ classmethodrGrr^rrrNrUr]r^rYrTr`rxrrcrQrRrSrTr8rErEs ..d$)-9= 00d  <"-*-*^B   ? ?***(((r/rEcs`aa]tRtRtoRt^2^]]3V3RlltRtRt Rt Rt Rt R t VtV;t#) 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) c sH<W@nW n\SV` !RRVRV/VBR#)rAr@NrL) queue_classrrr^)rGr@rrArerJrs&&&&&,r8r^ZBlockingConnectionPool.__init__s7'   - +   r/csVPVP4VnVPPR4K \dMi;i.Tn\ P!4TnR#)TN) rer@pool put_nowaitr _connectionsrrrrhrir8rNZBlockingConnectionPool.reset#s_$$T%9%9:   $$T*   99;sA A Ac sVPe=\VP!R/VPBVPVP4pMVP!R/VPBpVP P V4V#)zMake a fresh connection.rL)rrrArJrPrhrBrarr8rYZ&BlockingConnectionPool.make_connection;sn :: !-%%?(>(>?TZZJ..H1G1GHJ   ,r/c s2VP4RpVPPRVPR7pTfTP 4pTP4TP4'd \ R4hT# \d \ R4hi;i \ \3dFTP4TP4TP4'd \ R4hT#i;i \dTPT4hi;i)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)ZblockrzNo connection available.rWrX) rUrfrrrr!rYrtrrrxrrTrZr\r8r]Z%BlockingConnectionPool.get_connectionFs   >T4<<HJ  --/J      B&&(()*?@@)= >""<= = >($W- B%%'""$&&(()*@AA) B   LL $  sB'BC8!B7 BBAC5& C51C84C55C88Dc s VP4VPV4'g.VP4VPP R4R#VPP V4R# \ dR#i;i)z)Releases the connection back to the pool.N)rUr`rxrfrgrrarnr8rTZBlockingConnectionPool.releasezsm ##J//  ! ! # II  &   II  ,   sA33 BBc slVP4VPFpVP4K R#)z(Disconnects all connections in the pool.N)rUrhrxrarr8rxZ!BlockingConnectionPool.disconnects( ++J  ! ! #,r/)rhrrfrer)rMrNrOrPrrrr^rNrYr]rTrxrQrRrrrr8rdrds=F#  0 2h*$$r/rdcsV^8dQh/^\9d+\\\\\ 3,,;R&#)r2r)__conditional_annotations__r r rrr)r5s"r8r9r9s, xGFtE, nDEFFy r/)Z0ZFZFALSEZNZNO)]rirrrr)rFr rZabcrZ itertoolsrZqueuerrrrZtypingrrr r r r r Z urllib.parserrrZ redis.cacherrrrrrZ_parsersrrrrZbackoffrZ credentialsrrZ exceptionsrrr r!r"r#r$r%rr&Zutilsr'r(r)r*r+r,r-r.rCrarercr_rZobjectrrr0rUrfrrrr%r;r>r?rrZlistrBrDrErdr9)rirTr8rjs ((CCC44JIO            8F"M M$00fB B JJ),J)ZC*#C*LE:.E:PfJfR!3>/  #eedsS' u 6rkk\ b$^b$r/