ph:SSKrSSKrSSKrSSKJrJrJrJrJrJ r J r SSK J r SSK JrJrJrJr SSKJr SSKJrJrJrJr "SS\5r"S S \5r"S S \5r"S S\\5r"SS\5r"SS\5rg)N) AsyncIteratorIterableMappingOptionalSequenceTupleType)Redis) ConnectionConnectionPool EncodableT SSLConnection)AsyncSentinelCommands)ConnectionError ReadOnlyError ResponseError TimeoutErrorc\rSrSrSrg)MasterNotFoundErrorN__name__ __module__ __qualname____firstlineno____static_attributes__rP/home/james-whalen/.local/lib/python3.13/site-packages/redis/asyncio/sentinel.pyrrrrc\rSrSrSrg)SlaveNotFoundErrorrNrrrrr"r"r rr"c ^\rSrSrU4SjrSrSrSrSrSSSS .S \ S \ \ S \ \ S \ \ 4U4Sjjjjr Sr U=r$)SentinelManagedConnectionc R>URS5Ul[TU] "S0UD6 g)Nconnection_poolr)popr(super__init__)selfkwargs __class__s rr+"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# UuUlUlURURRSS9IShvN gN7f)NF) check_healthretry_socket_connect)r3r4connect_check_healthr(check_connection)r,addresss r connect_to$SentinelManagedConnection.connect_to*sB& 49''-->>!&(   s7A?Ac# UR(agURR(a:URURR 5IShvN 5IShvN gURR 5ShvN nURU5IShvN s $NPNFN$N ![ a M:f=f [e7fN)_readerr( is_masterr?get_master_address rotate_slavesrr")r,slaves r_connect_retry(SentinelManagedConnection._connect_retry1s <<     ) )//(<(<(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 r3SentinelManagedConnection.connect..As '--*r)retrycall_with_retryrHr,s rconnect!SentinelManagedConnection.connect>s2ZZ//    *    s +424FT)disconnect_on_error push_requestdisable_decodingtimeoutrVrWc># [TU]UUUUS9IShvN $N![aA URR(a$UR 5IShvN [ S5eef=f7f)N)rXrYrVrWz"The previous master is now a slave)r* read_responserr(rD disconnectr)r,rXrYrVrWr.s rr['SentinelManagedConnection.read_responseDsx .!1$7) /   ##-- oo'''%&JKK  s1A-A-8A*AA**A-)r(r3r4)FN)rrrrr+r7r?rHrTboolrfloatr[r __classcell__r.s@rr%r%sm#  % "'#' 04', % &e_  tn rr%c\rSrSrSrg)SentinelManagedSSLConnection_rNrrrrrcrc_r rrccf^\rSrSrSrU4SjrSrU4SjrS\4U4Sjjr Sr S \ 4S jr S r U=r$) SentinelConnectionPoolcz 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_classsslFrDTr=r(r)getr)rcr%rDr=r*r+weakrefproxyconnection_kwargs service_namesentinel_managermaster_addressslave_rr_counter)r,rorpr-r.s rr+SentinelConnectionPool.__init__ks%+ZZ ::eU++-. & !" K6 & +=u E "6"4;MM$4G01( 0" $rc SURRSURRSURSUR=(a S=(d SS3 $)Nr1r2z (service=(masterrGz))>)r.rrrorDrSs rr7SentinelConnectionPool.__repr__}sV))*!DNN,C,C+D))*!DNN,Gx,R7+SSV X rc>>[TU]5 SUlSUlgrB)r*resetrqrr)r,r.s rrySentinelConnectionPool.resets  " $r connectionc>UR(+=(d8 UR=(a% URURUR4:HnU=(a [TU]U5$rB)rDrqr3r4r*owns_connection)r,r{checkr.s rr}&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 ) rpdiscover_slavesrorrrandomrandintlenrangerErr")r,slaves_rGs rrF$SentinelConnectionPool.rotate_slavess,,<)>)Bc&k(Q%445 (  //11 1!#6t7H7H6K!LMMP2"   sF)DC/BD;C3C1C3D1C33 D=D?DD)r=rDrqrprorr)rrrr__doc__r+r7ryr r}rErrFrr`ras@rrfrfcs<%$ % =*= N]NNrrfc\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<UR5VVs0sHupgURS5(dMXg_M! nnnX0lUVV s/sHup[SXS.URD6PM sn nUlX lXPlX@lgs snnfs sn nf)Nsocket_)r3r4r)items startswithsentinel_kwargsr sentinelsmin_other_sentinelsrn_force_master_ip) r,rrrforce_master_iprnkvhostnamer4s rr+Sentinel.__init__s  "!2!8!8!:!:all9>U!:  /#, "+  Cx Cd.B.B C"+ $7 !2 /  sB B  #Bc # [URSS55n[URSS55nU(aM[R"UR5R "U0UD6IShvN nU(aU/$U(aS$S$URVs/sH)n[ R"UR "U0UD65PM+ nn[ R"U6IShvN nU(aU$[U5$Ns snfN7f)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. onceFreturn_responsesNT) r^r)rchoicerexecute_commandrLTaskgatherall) r,argsr-rrresponsesentineltasks responsess rrSentinel.execute_commands FJJvu-.  +=u EF #]]4>>:JJH  z!'t2U2!NN * LL114B6B C*  "..%00  9~# 1s0A1D3C<4'D0C> D#D$D>Dc&/nURHGnURURRSSURRS35 MI SURSURR SSR U5S3$) Nr3:r4r1r2z (sentinels=[,z])>)rappendr(rnr.rjoin)r,sentinel_addressesrs rr7Sentinel.__repr__sH  % %++==fEFa++==fEFH ' q!8!8 9388$678 = rstaterorcjUS(aUS(d US(agUSUR:agg)NrDis_sdownis_odownFznum-other-sentinelsT)r)r,rros rcheck_master_stateSentinel.check_master_state s5[!U:%6% :K & '$*B*B Brcl# [5n[UR5Hup4UR5IShvN nURU5nU(dM8URXq5(dMPUURSsURS'URU'URb UROUSnXS4s $ Sn [U5S:aSSRU53n [S U<U 35eN![[ 4a#nUR USU<35 SnAGM SnAff=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 - ripr4z : z, zNo master found for ) list enumeratersentinel_mastersrrrrkrrrrr) r,rocollected_errors sentinel_normasterserr error_infos rrSentinel.discover_masters9 6%.t~~%> !K  ( 9 9 ;;KK -Eu00EENN1%?q!4>>+#>,,8))t =(('&?*  1 $tyy)9:; sK%D4C>C<C>D4D42B D4<C>>D1D,%D4,D11D4rcz/nUH2nUS(d US(aMURUSUS45 M4 U$)z1Remove slaves that are in an ODOWN or SDOWN staterrrr4)r)r,r slaves_aliverGs r filter_slavesSentinel.filter_slaves6sH 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,rorrs rrSentinel.discover_slavesAsnH '77 EE''/Fv ' F#]LA  s=A,AAAA,A,AA)%A,(A))A, redis_classconnection_pool_classc SUS'[UR5nURU5 U"X40UD6nURU5$)am Returns a redis client instance for the ``service_name`` master. Sentinel client will detect failover and reconnect Redis clients automatically. 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. TrDdictrnupdate from_poolr,rorrr-rnr(s r master_forSentinel.master_forOsN>#{ !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. FrDrrs r slave_forSentinel.slave_forvsN0${ !7!78  (/ XFWX$$_55r)rrnrrr)rNN)rrrrrr+rr7rstrr^rrrrrrr rrr rfr rrrrrrrrs> 00@  CD!W#!WF w'  % J./ 0    % J./ 0 "$)>T %6%6%[%6 $$:; %6T$)>T 66%[6 $$:; 66rr)rLrrltypingrrrrrrr redis.asyncio.clientr redis.asyncio.connectionr r r rredis.commandsrredis.exceptionsrrrrrr"r%rcrfrrrrrs TTT& 1 /   > >B #