ޠj %SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSK J r SSK J r J r Jr SSKJr SSKJrJrJrJrJrJrJrJr SSKJrJrJr SSKJrJrJ r J!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, S S K-J.r.J/r/ S SK0J1r1J2r2 S SK3J4r4J5r5J6r6J7r7J8r8J9r9J:r:J;r; S SKJ?r?J@r@JArAJBrBJCrCJDrDJErEJFrFJGrG \@(aSSKHrHSrISrJSrKSrLSrM\N"5rO\\\'\(\&4\PS'\@(a\&rQO\'rQ"SS5rR"SS5rS"SS5rT"SS\T5rU"S S!\U5rV"S"S#\T5rW"S$S%\V5rX"S&S'\U5rYS(rZS)r[\\\]\]\[\[\^\\\\\[\]S*. r_S+r`\"S,S-S.9ra"S/S-5rb"S0S1\b5rcg)2N)abstractmethod)chain)EmptyFull LifoQueue)time)AnyCallableDictListOptionalTypeTypeVarUnion)parse_qsunquoteurlparse) CacheEntryCacheEntryStatus CacheFactoryCacheFactoryInterfaceCacheInterfaceCacheKey)Encoder_HiredisParser _RESP2Parser _RESP3Parser)TokenInterface) NoBackoff)CredentialProvider"UsernamePasswordCredentialProvider)AfterConnectionReleasedEventEventDispatcher)AuthenticationError$AuthenticationWrongNumberOfArgsErrorChildDeadlockedErrorConnectionError DataError RedisError ResponseError TimeoutError)Retry) CRYPTOGRAPHY_AVAILABLEHIREDIS_AVAILABLE SSL_AVAILABLEcompare_versionsdeprecated_args ensure_stringformat_error_messageget_lib_version str_if_bytes*$s  DefaultParserc"\rSrSrS\4SjrSrg)HiredisRespSerializerGargsc/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 J/var/www/html/gaurav/venv/lib/python3.13/site-packages/redis/connection.pypackHiredisRespSerializer.packHs d1gs # #a)//12T!"X=D T!W_a)DH4D = MM'..t4 5   ="%,,. AiE"11)< < =s 8%B=CN)__name__ __module__ __qualname____firstlineno__r rV__static_attributes__rXr9rUr=r=Gs$r9r=c$\rSrSrSSjrSrSrg)PythonRespSerializerYNcXlX lgN_buffer_cutoffrG)rP buffer_cutoffrGs rU__init__PythonRespSerializer.__init__Zs + r9c /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$rA)rDrErFrGrH SYM_EMPTYjoinSYM_STARlenSYM_CRLFrdmap memoryview SYM_DOLLARrI)rPr?rQbuffrearg arg_lengths rUrVPythonRespSerializer.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 r9rcreturnN)rYrZr[r\rfrVr]rXr9rUr_r_Ys +r9r_c\rSrSr\S5r\S5r\S5r\S5r\S5r \S5r \S5r \S 5r \S 5r \SS j5r\S 5r\SSj5r\SS SS.Sjj5r\S5r\S5r\\S\\\\4\\\444Sj55r\S\4Sj5r\S5rSrg)ConnectionInterfacecgrbrXrPs rU repr_piecesConnectionInterface.repr_pieces r9cgrbrXrPcallbacks rUregister_connect_callback-ConnectionInterface.register_connect_callbackr~r9cgrbrXrs rUderegister_connect_callback/ConnectionInterface.deregister_connect_callbackr~r9cgrbrXrP parser_classs rU set_parserConnectionInterface.set_parserr~r9cgrbrXr{s rU get_protocol ConnectionInterface.get_protocolr~r9cgrbrXr{s rUconnectConnectionInterface.connectr~r9cgrbrXr{s rU on_connectConnectionInterface.on_connectr~r9cgrbrXrPr?s rU disconnectConnectionInterface.disconnectr~r9cgrbrXr{s rU check_health ConnectionInterface.check_healthr~r9TcgrbrXrPcommandrs rUsend_packed_command'ConnectionInterface.send_packed_commandr~r9cgrbrXrPr?kwargss rU send_command ConnectionInterface.send_commandr~r9cgrbrXrPtimeouts rUcan_readConnectionInterface.can_readr~r9Fdisconnect_on_error push_requestcgrbrX)rPdisable_decodingrrs rU read_response!ConnectionInterface.read_responses r9cgrbrXrs rUrK ConnectionInterface.pack_commandr~r9cgrbrXrPcommandss rU pack_commands!ConnectionInterface.pack_commandsr~r9rvcgrbrXr{s rUhandshake_metadata&ConnectionInterface.handshake_metadatas r9tokencgrbrXrPrs rUset_re_auth_token%ConnectionInterface.set_re_auth_tokenr~r9cgrbrXr{s rUre_authConnectionInterface.re_authr~r9rXNTrF)rYrZr[r\rr|rrrrrrrrrrrrrKrpropertyrr bytesrErrrrr]rXr9rUrxrxs                         !        E$ue|*jr1S?r2S@r3g)DAbstractConnectionz0Manages communication to and from a Redis serverrNFutf-8strictizredis-pyr:dbpasswordsocket_timeoutsocket_connect_timeoutretry_on_timeoutencodingencoding_errorsdecode_responsessocket_read_sizehealth_check_interval client_namelib_name lib_versionusernameretryredis_connect_funccredential_providerprotocolcommand_packerevent_dispatchercRU(dU(aUb [S5eUc[5UlOUUl[R"5UlXlXlXlXl UUl X l UUl X0l UcUnX@lXPlU[ La/nU(aUR#[$5 X`lU(dU(aTUc[)[+5S5UlO[.R0"U5UlUR,R3U5 O[)[+5S5UlXlSUlUUl[;XxU 5UlSUlSUl Xl!UREU 5 /Ul#SUl$SUl%[MU5nUS:dUS:a [US 5eUUl+URYU5Ul-g![Na [PnNG[Ra [US5ef=f!WS:dUS:a [US 5eUUl+f=f) 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'rripzprotocol must be an integerr:zprotocol must be either 2 or 3).r)r$_event_dispatcherosgetpidpidrrrrrrrrrrSENTINELrIr,retry_on_errorr-r rcopydeepcopyupdate_supported_errorsrnext_health_checkrrencoderr_sock_socket_read_sizer_connect_callbacksrd_re_auth_tokenintrLDEFAULT_RESP_VERSION ValueErrorr(r_construct_command_packer_command_packer)rPrrrrrrrrrrrrrrrrrrrrrrps rUrfAbstractConnection.__init__s@ &9&E+   #%4%6D "%5D "99;& &#6    , ! )%3 "&<# 0 X %N   ! !, /, N}"9;2 "]]51 JJ . .~ >y{A.DJ%:"!""4x:JK "& !1  %"$"8< H A 1uA%&FGGDM#==nM %$A A!"?@ @ A1uA%&FGGDMs$ GH,H.HH H&c SRUR5VVs/sH upUSU3PM snn5nSURRSURRSUS3$s snnf)N,=<.()>)rjr| __class__rZrY)rPkv repr_argss rU__repr__AbstractConnection.__repr__@snHHT5E5E5GH5GTQ1QCj5GHI 4>>,,-Qt~~/F/F.Gq SUVVIsA- cgrbrXr{s rUr|AbstractConnection.repr_piecesDr~r9cFUR5 g![a gf=frb)r Exceptionr{s rU__del__AbstractConnection.__del__Hs#  OO    s   cUbU$[(a [5$[URURR 5$rb)r/r=r_rdrrG)rPpackers rUr,AbstractConnection._construct_command_packerNs9  M  (* *'(;(;T\\=P=PQ Qr9c[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 WeakMethodrrI)rPrwms rUr,AbstractConnection.register_connect_callbackVs9   ) ,, ,  # # * *2 . -r9cURR[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)rremoverrrrs rUr.AbstractConnection.deregister_connect_callbackbs8    # # * *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 rUrAbstractConnection.set_parserms $T5K5KL r9cr^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$rb)_connectr{srU,AbstractConnection.connect..{s  r9c&>TRU5$rbrerrorrPs rUrr{stu7Mr9zTimeout connecting to server)rrcall_with_retrysocketrr,OSErrorr(_error_messagerrr*rr)rPsockerefrs` rUrAbstractConnection.connectus  ::  :::--')MD  &&.!''-372I2I"S2I3SU32I"S**CuHx+-~~ ?=> > :!$"5"5a"89 9 :  OO   #Ts5$C DD?D4D4 (D3D  DD1cgrbrXr{s rUrAbstractConnection._connectr~r9cgrbrXr{s rU _host_errorAbstractConnection._host_errorr~r9c6[UR5U5$rb)r4r/)rP exceptions rUr'!AbstractConnection._error_messages#D$4$4$6 BBr9cURRU5 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)r:2rdefaultrHELLOAUTHrFrOKzInvalid Username or PasswordsprotoprotozInvalid RESP versionCLIENTSETNAMEzError setting client nameSETINFOzLIB-NAMEzLIB-VERSELECTzInvalid Database)rrrrrr"get_credentialsrrDrrrEXCEPTION_CLASSESrlrrrr&r6r%getr(rrr+rr)rPparser auth_args cred_provider auth_responses rUrAbstractConnection.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_RDWRr&rLclose)rPr? conn_socks rUrAbstractConnection.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)rr6rr(r{s rU _send_pingAbstractConnection._send_pings< &u5 **, - 7!"GH H 8r9c$UR5 g)z Function to call when PING failsNr!rPr#s rU _ping_failedAbstractConnection._ping_failed  r9cUR(aJ[5UR:a1URR UR UR 5 ggg)z3Check the health of the connection with a PING/PONGN)rrrrr$rSrWr{s rUrAbstractConnection.check_healthsA  % %$&43I3I*I JJ & &t8I8I J+J %r9TcvUR(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)rrrrDrEsendallr%rrr,r&rlr?r( BaseException)rPrritemr)errnoerrmsgs rUr&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 gNrX)hostrportsocket_keepalivesocket_keepalive_options socket_typesuperrf)rPrrrrrrrs rUrfConnection.__init__s> I 0(@(FB%& "6"r9cSUR4SUR4SUR4/nUR(aUR SUR45 U$)Nrrrr)rrrrrIrPrqs rUr|Connection.repr_piecessM499% ':T477OL    MM=$*:*:; < r9c`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% getaddrinforrr SOCK_STREAM setsockopt IPPROTO_TCP TCP_NODELAYr SOL_SOCKET SO_KEEPALIVEritems settimeoutrrrr&rM) rPerrresfamilysocktyper< canonnamesocket_addressr(rrrRs rUrConnection._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:)rrr{s rUr/Connection._host_errors))Adii[))r9)rrrrr) localhostiFNr rYrZr[r\rrfr|rr/r] __classcell__rs@rUrrs2: !% #  'CR**r9rcT\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'S$\(4S%jr)S&r*S'r+g)+CacheProxyConnectionisfooz7.4.0redisconncache pool_lockc[R"5UlXlURRUlURR UlURR UlURUlX0lX l [R"5Ul SUl SUlURUR 5 grb)rrr_connrrrr _pool_lock_cache threadingLock _cache_lock_current_command_cache_key_current_optionsr_enable_tracking_callback)rPrrrs rUrfCacheProxyConnection.__init__s 99; ZZ%% JJOO JJOO #'#;#; # $>>+*.' $ &&t'E'EFr9c6URR5$rb)rr|r{s rUr| CacheProxyConnection.repr_piecesszz%%''r9c:URRU5 grb)rrrs rUr.CacheProxyConnection.register_connect_callbacks ,,X6r9c:URRU5 grb)rrrs rUr0CacheProxyConnection.deregister_connect_callback!s ..x8r9c:URRU5 grb)rrrs rUrCacheProxyConnection.set_parser$s l+r9c(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) rrrrCr(r3DEFAULT_SERVER_NAMEr1MIN_ALLOWED_VERSION)rP server_name server_vers rUrCacheProxyConnection.connect's jj3377 4H  **77;;HdKKZZ2266z4H  66::9dKJ  !3!"TU U":. #K0  33 3 ,D,DEJ!{ Kr9c8URR5 grb)rrr{s rUrCacheProxyConnection.on_connect>s r9cUR URR5 SSS5 URR"U6 g!,(df  N(=frb)rrflushrrrs rUrCacheProxyConnection.disconnectAs;    KK    t$ s A  Ac8URR5 grb)rrr{s rUr!CacheProxyConnection.check_healthFs !r9Tc:URRU5 grb)rrrs rUr(CacheProxyConnection.send_packed_commandIs &&w/r9c 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) NrrX)r redis_keyskeyszCannot create cache key.Tr) cache_key cache_valuestatusconnection_ref)_process_pending_invalidationsrr is_cachablerrrrrCrrFrrrrsetrDUMMY_CACHE_VALUEr IN_PROGRESS)rPr?rentrys rUr!CacheProxyConnection.send_commandNs ++-   ;;**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$rb)rrrs rUrCacheProxyConnection.can_read~szz""7++r9FrcUR URbURRUR5bURRUR5R[ R :waU[R"URRUR5R5nSUlUsSSS5 $SSS5 URRUUUS9nUR URc UsSSS5 $Uc1URRUR/5 UsSSS5 $URRUR5nUb6[ RUlXVl URRU5 SUlSSS5 U$!,(df  N=f!,(df  U$=f)N)rrr)rrrrCrrrrrrrrdelete_by_cache_keysVALIDr)rPrrrrrl cache_entrys rUr"CacheProxyConnection.read_responses  //;KKOOD$C$CDPKKOOD$C$CDKK#//0mmKKOOD$C$CDPP37/  ::++- 3%,    ..6   00$2Q2Q1RS ++//$*I*IJK&%5%;%; "*2'  ,.2D +%(Q ( (s%CGG*GA%G G G"c4URR"U6$rb)rrKrs rUrK!CacheProxyConnection.pack_commandszz&&--r9c8URRU5$rb)rrrs rUr"CacheProxyConnection.pack_commandsszz''11r9rvc.URR$rb)rrr{s rUr'CacheProxyConnection.handshake_metadataszz,,,r9c8URR5 grb)rrr{s rUrCacheProxyConnection._connects r9c8URR5 grb)rr/r{s rUr/ CacheProxyConnection._host_errors  r9NcURSSS5 UR5 URRUR5 g)Nr=TRACKINGON)rrrset_invalidation_push_handler_on_invalidation_callback)rPrs rUr.CacheProxyConnection._enable_tracking_callbacks8 (J5  2243Q3QRr9cUR5(a1URRSS9 UR5(aM0gg)NTr)rrrr{s rUr3CacheProxyConnection._process_pending_invalidationss/mmoo JJ $ $$ $ 7mmoor9datacUR UScURR5 OURRUS5 SSS5 g!,(df  g=f)Nr)rrrdelete_by_redis_keys)rPrs rUr.CacheProxyConnection._on_invalidation_callbacksF   Aw !!# 00a9   s AA A$c6URR5$rb)rrr{s rUr!CacheProxyConnection.get_protocolszz&&((r9rc:URRU5 grb)rrrs rUr&CacheProxyConnection.set_re_auth_tokens $$U+r9c8URR5 grb)rrr{s rUrCacheProxyConnection.re_auths r9) rrrrrrrrrrrrrr),rYrZr[r\rrrrxrrrrfr|rrrrrrrrrrrrKrrrr rrErrr/rrr r rrrrrr]rXr9rUrrs+!!G!GG>> G&(79,. % "0 .1`, %+=APU+Z.2-E$ue|*S9S3T.U:),~,r9rc^^\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: rX)r0r*keyfilecertfilessl CERT_NONErDrE CERT_OPTIONAL CERT_REQUIRED cert_reqsca_certsca_dataca_pathcheck_hostnamecertificate_passwordssl_validate_ocspssl_validate_ocsp_stapledssl_ocsp_contextssl_ocsp_expected_certssl_min_version ssl_ciphersrrf)rP ssl_keyfile ssl_certfile ssl_cert_reqs ssl_ca_certs ssl_ca_datassl_check_hostname ssl_ca_path ssl_passwordrrr r!r"r#r CERT_REQSrs rUrfSSLConnection.__init__sP}CD D" $  MMM  s + + ----I I- A-Q&m4M&$ " " 0$0!!2)B& 0&<#.& "6"r9c>[TU]5nURU5$![[4a UR 5 ef=f)z> Wrap the socket with SSL support, handling potential errors. )rr_wrap_socket_with_sslr&r*rM)rPr(rs rUrSSLConnection._connect'sHw! --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_locationsr"minimum_versionr# set_ciphersrr.r*r wrap_socketrOpenSSLocspr6r SSLContext SSLv23_METHODuse_certificate_fileuse_privatekey_fileset_ocsp_client_callbackr!rr% request_ocsprr do_handshakerKr7is_validr() rPr(contextsslsockr?r6 staple_ctxconr7os rUr/#SSLConnection._wrap_socket_with_ssl2sw,,.!%!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||%&=>>r9)rrrrrrrrr#r"r r!rr)NNrNNFNNFFNNNN) rYrZr[r\rrfrr/r]rrs@rUr r sL  "'#F#P MMr9r cB^\rSrSrSrSU4SjjrSrSrSrSr U=r $) UnixDomainSocketConnectioniz4Manages UDS communication to and from a Redis serverc >>[TU]"S0UD6 XlX lgr)rrfpathr)rPrSrrrs rUrf#UnixDomainSocketConnection.__init__s "6" ,r9cSUR4SUR4/nUR(aURSUR45 U$)NrSrr)rSrrrIrs rUr|&UnixDomainSocketConnection.repr_piecessB499%dgg7    MM=$*:*:; < r9cN[R"[R[R5nURUR5 UR UR 5 URUR5 U$![a UR5 ef=f)z&Create a Unix domain socket connection) r%AF_UNIXrrrrrSr&rMr)rPr(s rUr#UnixDomainSocketConnection._connectsy}}V^^V-?-?@ 334  LL # ++,   JJL  s BB$cUR$rb)rSr{s rUr/&UnixDomainSocketConnection._host_errors yyr9)rSr)Nrrs@rUrQrQs:-  r9rQ)0FFALSENNOcUbUS:Xag[U[5(aUR5[;ag[ U5$)Nr\F)rDrEupper FALSE_STRINGSr)rSs rUto_boolres7 } %%++-="@ ;r9) rrrrrrmax_connectionsrr)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.rrunixrSconnection_classrrr/r\rediss) startswithrrrqueryrrlrURL_QUERY_ARGUMENT_PARSERSrCrLrrschemerSrQhostnamerrreplaceAttributeErrorr )urlrnamerSrDs rU parse_urlrus 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. rirX)ruupdate)rzrsr url_optionss rUfrom_urlConnectionPool.from_urls?R n  '.45G.HK* + k"}V}r9Nrf cache_factoryc U=(d Sn[U[5(aUS:a [S5eXlX@lX lSUlX0lURS5(dURS5(aURS5S;a [S5eURRS5nUb'[U[5(d [S 5eXPlOdURb URR5UlO7[URRS55R5UlURSS5 URSS5 URRS S5UlURc[5Ul[ R""5Ul[ R""5UlUR)5 g) Nlrz,"max_connections" must be a positive integer cache_configrr)rrkz4Client caching is only supported with RESP version 3z#Cache must implement CacheInterfacer)rDrrriconnection_kwargsrfr_cache_factoryrCr*r get_cacherpoprr$rr _fork_lock_lockreset)rPrirfrrrs rUrfConnectionPool.__init__5s*2U/3//?Q3FKL L 0!2. +   0 04E4I4I'4R4R $$Z0@ !WXX**..w7E !%88$%JKK" &&2!%!4!4!>!>!@DJ!-..22>B"ikJ gt,nd3!%!7!7!;!;   $ $ ( ( 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)rrrC)rPrs rU get_encoderConnectionPool.get_encodersF''ZZ G4"JJ'8(C#ZZ(:EB  r9c>URUR:a [S5eU=RS- slURb;[ UR "S0UR D6URUR5$UR "S0UR D6$)zCreate a new connectionzToo many connectionsrrX)rrfr(rrrirrr{s rUrConnectionPool.make_connections  $ $(<(< <!"89 9 !!Q&! :: !'%%?(>(>?TZZ $$>t'='=>>r9rcUR5 UR URRU5 UR U5(a@UR RU5 URR[U55 OUR5 SSS5 gSSS5 g![a SSS5 gf=f!,(df  g=f)z(Releases the connection back to the poolN) rrrrKeyErrorowns_connectionrrIrdispatchr#rrPrs rUrConnectionPool.releases  ZZ ((// ; ##J//++22:>&&//0<%%''ZZ  Z Zs.C B4A'C 4 C >C C  C  Cc4URUR:H$rb)rrs rUrConnectionPool.owns_connections~~))r9inuse_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)rrrrrr)rPr connectionsrs rUrConnectionPool.disconnects`  ZZ #//1I1I #99 ) %%'*ZZs AA44 Bc$UR5 g)z-Close the pool, disconnecting all connectionsNr!r{s rUrMConnectionPool.close%rYr9cURRSU05 URH nXlM URH nXlM g)Nr)rr|rrr)rPrrs rU set_retryConnectionPool.set_retry)sE %%w&67//DJ0,,DJ-r9rcV^^^TR TRHLmTRRUU4SjU4Sj5 TRRU4SjU4Sj5 MN TRHmTR T5 M SSS5 g!,(df  g=f)Ncd>TRSTRS5TR55$r)rrr)rrsrUr1ConnectionPool.re_auth_callback..4s'D-- e 4eoo6Gr9c&>TRU5$rb_mockr"s rUrr7s$**U"3r9c$>TR5$rb)r)rsrUrr:sD..0r9c&>TRU5$rbrr"s rUrr:s 5@Qr9)rrrr$rr)rPrrs``@rUre_auth_callbackConnectionPool.re_auth_callback0sz ZZ33 **4   **02Q400&&u-1ZZs BB B(r#c # g7f)z_ Dummy functions, needs to be passed as error callback to retry object. :param error: :return: NrXrVs rUrConnectionPool._mock?s s) rrrrrrrrrirrfrrurb)rvr)rvrx)rrrvNr)rr-rvN)#rYrZr[r\r classmethodrrvrEr~rr rrrfrrrrr2rrrrrrrrrMrrrr*rr]rXr9rUrwrws .d3i.c...d$)-9= 5"#5 56 5n 3* < -*^U:   D W  ?0*,*3*(D(D(( .n .  r9cr^\rSrSrSrSS\\4U4SjjrSrSr \ "S/S S S 9SS j5r S r Sr SrU=r$)BlockingConnectionPooliHa 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)rirfrX) queue_classrrrf)rPrfrrirrrs rUrfBlockingConnectionPool.__init__js2'   -+   r9cURUR5UlURRS5 M![a Of=f/Ul[ R"5Ulgrb) rrfpool put_nowaitr _connectionsrrrr{s rUrBlockingConnectionPool.resetzsf$$T%9%9:   $$T*   99;sA A  A cURb<[UR"S0URD6URUR5nOUR"S0URD6nUR R U5 U$)zMake a fresh connection.rX)rrrirrrrIrs rUr&BlockingConnectionPool.make_connectionsn :: !-%%?(>(>?TZZJ..H1G1GHJ   ,r9rrrrc 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.rr) rrrCrrr(rrrr&rr_rrs rUr%BlockingConnectionPool.get_connections$   >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)rrrrrrrs rUrBlockingConnectionPool.releasesm ##J//  ! ! # II  &   II  ,   sA00 A=<A=cjUR5 URHnUR5 M g)z(Disconnects all connections in the pool.N)rrrrs rUr!BlockingConnectionPool.disconnects( ++J  ! ! #,r9)rrrrrrb)rYrZr[r\rrrrfrrr2rrrr]rrs@rUrrHsZF#  0 U: 2  2h*$$r9r)drrr%rrMrrabcr itertoolsrqueuerrrrtypingr r r r r rrr urllib.parserrr redis.cacherrrrrr_parsersrrrr auth.tokenrbackoffr credentialsr!r"eventr#r$ exceptionsr%r&r'r(r)r*r+r,rr-utilsr.r/r0r1r2r3r4r5r6rJrkrprmrirobjectr__annotations__r;r=r_rxrrrr rQrdrerrlistrnrurvrwrrXr9rUrs ((LLL44JI&O@            8E, nDEFF"M M$00fN N b]',]'@C*#C*LS.SlfJfR!3>/  # ! 6re+,O O d g$^g$r9