Ii7SSKrSSKrSSKrSSKJrJrJrJrJrJ r J r SSK J r SSK JrJrJrJr SSKJr SSKJrJrJrJr SSKJr "SS \5r"S S \5r"S S \5r"SS\\5r"SS\5r"SS\5r g)N) AsyncIteratorIterableMappingOptionalSequenceTupleType)Redis) ConnectionConnectionPool EncodableT SSLConnection)AsyncSentinelCommands)ConnectionError ReadOnlyError ResponseError TimeoutError) str_if_bytesc\rSrSrSrg)MasterNotFoundErrorN__name__ __module__ __qualname____firstlineno____static_attributes__rURS5Ul[TU] "S0UD6 g)Nconnection_poolr)popr)super__init__)selfkwargs __class__s r r,"SentinelManagedConnection.__init__s%%zz*;< "6"rcSURRSURR3nUR(a SURSUR3nX- nUS-$)N<.z,host=z,port=z)>)r/rrhostport)r-s host_infos r __repr__"SentinelManagedConnection.__repr__s[))*!DNN,C,C+D E 99  6$))=I NA4xrc.># UuUlUl[TU] 5IShvN URR (aJUR S5IShvN [UR5IShvN 5S:wa [S5eggNjN8N7f)NPINGPONGz PING failed) r4r5r+connectr)check_connection send_commandr read_responser)r-addressr/s r connect_to$SentinelManagedConnection.connect_to&s& 49go    0 0##F+ + +$"4"4"6676A%m44B 1 +6s3!BB3BBB5B6BBBc# UR(agURR(a:URURR 5IShvN 5IShvN gURR 5ShvN nURU5IShvN s $NPNFN$N ![ a M:f=f [e7fN)_readerr) is_masterrBget_master_address rotate_slavesrr#)r-slaves r _connect_retry(SentinelManagedConnection._connect_retry.s <<     ) )//(<(<(O(O(Q"QR R R#33AAC e!%!777 #R R 7& D % $sxAC B) C $B+%C CB- C C B1"B/#B1&C +C -C/B11 B?;C >B?? C cl# URRURS5IShvN $N7f)Nc.[R"S5$)Nr)asynciosleep)errors r 3SentinelManagedConnection.connect..>s '--*r)retrycall_with_retryrKr-s r r=!SentinelManagedConnection.connect;s2ZZ//    *    s +424FT)disconnect_on_error push_requestdisable_decodingtimeoutrXrYc># [TU]UUUUS9IShvN $N![aA URR(a$UR 5IShvN [ S5eef=f7f)N)rZr[rXrYz"The previous master is now a slave)r+r@rr)rG disconnectr)r-rZr[rXrYr/s r r@'SentinelManagedConnection.read_responseAsx .!1$7) /   ##-- oo'''%&JKK  s1A-A-8A*AA**A-)r)r4r5)FN)rrrrr,r8rBrKr=boolrfloatr@r __classcell__r/s@r r&r&sm#5 % "'#' 04', % &e_  tn rr&c\rSrSrSrg)SentinelManagedSSLConnection\rNrrrr rdrd\r!rrdcf^\rSrSrSrU4SjrSrU4SjrS\4U4Sjjr Sr S \ 4S jr S r U=r$) SentinelConnectionPool`z Sentinel backed connection pool. If ``check_connection`` flag is set to True, SentinelManagedConnection sends a PING command right after establishing the connection. c h>URSURSS5(a[O[5US'URSS5UlURSS5Ul[ TU]"S0UD6 [R"U5URS'Xl X l SUl SUlg) Nconnection_classsslFrGTr>r)r)getr*rdr&rGr>r+r,weakrefproxyconnection_kwargs service_namesentinel_managermaster_addressslave_rr_counter)r-rprqr.r/s r r,SentinelConnectionPool.__init__hs%+ZZ ::eU++-. & !" K6 & +=u E "6"4;MM$4G01( 0" $rc SURRSURRSURSUR=(a S=(d SS3 $)Nr2r3z (service=(masterrJz))>)r/rrrprGrVs r r8SentinelConnectionPool.__repr__zsV))*!DNN,C,C+D))*!DNN,Gx,R7+SSV X rc>>[TU]5 SUlSUlgrE)r+resetrrrs)r-r/s r rzSentinelConnectionPool.resets  " $r connectionc>UR(+=(d8 UR=(a% URURUR4:HnU=(a [TU]U5$rE)rGrrr4r5r+owns_connection)r-r|checkr/s r r~&SentinelConnectionPool.owns_connectionsRNN" NN Xt22z 6XX <0<>""n4&4#ooo>>>X ?s!)A4A0=A4)A2*A42A4returnc # URRUR5IShvN nU(aURc([R "S[ U5S- 5Ul[[ U55H6nURS-[ U5-UlXRnU7v M8 UR5IShvN 7v [SUR<35eNN"![a N)f=f7f)zRound-robin slave balancerNrzNo slave found for ) rqdiscover_slavesrprsrandomrandintlenrangerHrr#)r-slaves_rJs r rI$SentinelConnectionPool.rotate_slavess,,<)>)Bc&k(Q%445 (  //11 1!#6t7H7H6K!LMMP2"   sF)DC/BD;C3C1C3D1C33 D=D?DD)r>rGrrrqrprs)rrrr__doc__r,r8rzr r~rHrrIrrarbs@r rgrg`s<%$ % =*= N]NNrrgc\rSrSrSrSSjrSrSrS\S\ S \ 4S jr S\ 4S jr S \ \S \\\\44S jrS\ S \\\\44Sjr\\4S\ S\\S\\4Sjjr\\4S\ S\\S\\4SjjrSrg)Sentinela* Redis Sentinel cluster client >>> from redis.sentinel import Sentinel >>> sentinel = Sentinel([('localhost', 26379)], socket_timeout=0.1) >>> master = sentinel.master_for('mymaster', socket_timeout=0.1) >>> await master.set('foo', 'bar') >>> slave = sentinel.slave_for('mymaster', socket_timeout=0.1) >>> await slave.get('foo') b'bar' ``sentinels`` is a list of sentinel nodes. Each node is represented by a pair (hostname, port). ``min_other_sentinels`` defined a minimum number of peers for a sentinel. When querying a sentinel, if it doesn't meet this threshold, responses from that sentinel won't be considered valid. ``sentinel_kwargs`` is a dictionary of connection arguments used when connecting to sentinel instances. Any argument that can be passed to a normal Redis connection can be specified here. If ``sentinel_kwargs`` is not specified, any socket_timeout and socket_keepalive options specified in ``connection_kwargs`` will be used. ``connection_kwargs`` are keyword arguments that will be used when establishing a connection to a Redis server. Nc Uc<UR5VVs0sHupVURS5(dMXV_M! nnnX0lUVVs/sHupx[SXxS.URD6PM snnUlX lX@lgs snnfs snnf)Nsocket_)r4r5r)items startswithsentinel_kwargsr sentinelsmin_other_sentinelsro) r-rrrrokvhostnamer5s r r,Sentinel.__init__s  "!2!8!8!:!:all9>U!:  /#, "+  Cx Cd.B.B C"+ $7 !2  sBB #B c # [URSS55nSUR5;aURS5 U(a9[R "UR 5R"U0UD6IShvN gUR Vs/sH)n[R"UR"U0UD65PM+ nn[R"U6IShvN gNas snfN 7f)z Execute Sentinel command in sentinel nodes. once - If set to True, then execute the resulting command on a single node at random, rather than across the entire sentinel cluster. onceFNT) r_rlkeysr*rchoicerexecute_commandrOTaskgather)r-argsr.rsentineltaskss r rSentinel.execute_commands FJJvu-. V[[] " JJv  --/??PP P P!% .H X55tFvFG . ..%( ( ( Q )s0A;C(=C>C(0C!C(C&C(!C(c&/nURHGnURURRSSURRS35 MI SURSURR SSR U5S3$) Nr4:r5r2r3z (sentinels=[,z])>)rappendr)ror/rjoin)r-sentinel_addressesrs r r8Sentinel.__repr__sH  % %++==fEFa++==fEFH ' q!8!8 9388$678 = rstaterprcjUS(aUS(d US(agUSUR:agg)NrGis_sdownis_odownFznum-other-sentinelsT)r)r-rrps r check_master_stateSentinel.check_master_states5[!U:%6% :K & '$*B*B Brc6# [5n[UR5Hup4UR5IShvN nURU5nU(dM8URXq5(dMPUURSsURS'URU'USUS4s $ Sn[U5S:aSSRU53n[S U<U35eN![[ 4a"nUR USU<35 SnAMSnAff=f7f) z Asks sentinel servers for the Redis master's address corresponding to the service labeled ``service_name``. Returns a pair (address, port) or raises MasterNotFoundError if no master is found. Nz - ripr5z : z, zNo master found for ) list enumeratersentinel_mastersrrrrlrrrr) r-rpcollected_errors sentinel_normasterser error_infos r rSentinel.discover_masters 6%.t~~%> !K  ( 9 9 ;;KK -Eu00EENN1%?q!4>>+#>T{E&M11&?  1 $tyy)9:; sK%DC$C"C$DD2A0D"C$$D4D DDDrcz/nUH2nUS(d US(aMURUSUS45 M4 U$)z1Remove slaves that are in an ODOWN or SDOWN staterrrr5)r)r-r slaves_aliverJs r filter_slavesSentinel.filter_slavessH EZ E*$5   teFm < =rc# URH9nURU5IShvN nUR U5nU(dM7Us $ /$N&![[[4a MYf=f7f)z;Returns a list of alive slaves for service ``service_name``N)rsentinel_slavesrrrr)r-rprrs r rSentinel.discover_slaves*snH '77 EE''/Fv ' F#]LA  s=A,AAAA,A,AA)%A,(A))A, redis_classconnection_pool_classc SUS'[UR5nURU5 U"X40UD6nURU5$)a Returns a redis client instance for the ``service_name`` master. A :py:class:`~redis.sentinel.SentinelConnectionPool` class is used to retrieve the master's address before establishing a new connection. NOTE: If the master's address has changed, any cached connections to the old master are closed. By default clients will be a :py:class:`~redis.Redis` instance. Specify a different class to the ``redis_class`` argument if you desire something different. The ``connection_pool_class`` specifies the connection pool to use. The :py:class:`~redis.sentinel.SentinelConnectionPool` will be used by default. All other keyword arguments are merged with any connection_kwargs passed to this class and passed to the connection pool as keyword arguments to be used to initialize Redis connections. TrGdictroupdate from_poolr-rprrr.ror)s r master_forSentinel.master_for8sN:#{ !7!78  (/ XFWX$$_55rc SUS'[UR5nURU5 U"X40UD6nURU5$)a Returns redis client instance for the ``service_name`` slave(s). A SentinelConnectionPool class is used to retrieve the slave's address before establishing a new connection. By default clients will be a :py:class:`~redis.Redis` instance. Specify a different class to the ``redis_class`` argument if you desire something different. The ``connection_pool_class`` specifies the connection pool to use. The SentinelConnectionPool will be used by default. All other keyword arguments are merged with any connection_kwargs passed to this class and passed to the connection pool as keyword arguments to be used to initialize Redis connections. FrGrrs r slave_forSentinel.slave_for]sN0${ !7!78  (/ XFWX$$_55r)rorrr)rN)rrrrrr,rr8rstrr_rrrrrrr rrr rgr rrrrrr rrs> 3,(  CDW#W: w'  % J./ 0    % J./ 0 "$)>T #6#6%[#6 $$:; #6P$)>T 66%[6 $$:; 66rr)!rOrrmtypingrrrrrrr redis.asyncio.clientr redis.asyncio.connectionr r r rredis.commandsrredis.exceptionsrrrr redis.utilsrrr#r&rdrgrrrr rs TTT& 1XX$ /   ? ?D #