ng\j ;SSKrSSKrSSKJrJr SSKJr SSKJr SSK J r J r J r SSK JrJrJrJr SSKJr "SS \5r"S S \5r"S S \ 5r"SS\\ 5r"SS5r"SS\ 5r"SS\5rg)N)OptionalUnion)Redis)SentinelCommands) ConnectionConnectionPool SSLConnection)ConnectionError ReadOnlyError ResponseError TimeoutError)SENTINELc\rSrSrSrg)MasterNotFoundErrorN__name__ __module__ __qualname____firstlineno____static_attributes__rI/home/edenadmin/noVNC/venv/lib/python3.13/site-packages/redis/sentinel.pyrrrrc\rSrSrSrg)SlaveNotFoundErrorrNrrrrrrrrrc ^\rSrSrU4SjrSrSrSrSrS\ SSS.S \ \ \ 4S \ \S \ \4U4S jjjjrS rU=r$)SentinelManagedConnectionc R>URS5Ul[TU] "S0UD6 g)Nconnection_poolr)popr#super__init__)selfkwargs __class__s rr&"SentinelManagedConnection.__init__s%%zz*;< "6"rcURnS[U5RS[U5RSURS3nUR (a SUR SUR 3nX#-nU$)N<. (service=z%s)>z,host=z,port=)r#typerr service_namehostport)r'pools host_infos r__repr__"SentinelManagedConnection.__repr__sy##T %%&aT (;(;'<))*$ 0  99  6$))=I ArcjUuUlUlURURRSS9 g)NF) check_healthretry_socket_connect)r1r2connect_check_healthr#check_connection)r'addresss r connect_to$SentinelManagedConnection.connect_to)s5& 49 !!-->>!& " rcDUR(agURR(a*URURR 55 gURR 5HnURU5s $ [e![ a M,f=fN)_sockr# is_masterr>get_master_address rotate_slavesr r)r'slaves r_connect_retry(SentinelManagedConnection._connect_retry1s ::     ) ) OOD00CCE F--;;=??511> % $'s6B BBcPURRURS5$)NcgrAr)errors r3SentinelManagedConnection.connect..?sTr)retrycall_with_retryrGr's rconnect!SentinelManagedConnection.connect>s zz))$*=*=?QRRrF)timeoutdisconnect_on_error push_requestrSrTrUc>[TU]UUUUS9$![a8 URR(aUR 5 [ S5eef=f)N)disable_decodingrSrTrUz"The previous master is now a slave)r% read_responser r#rC disconnectr )r'rWrSrTrUr)s rrX'SentinelManagedConnection.read_responseAsf 7(!1$7) )   ##-- !%&JKK  s AA)r#r1r2)F)rrrrr&r6r>rGrQrrfloatobjectrboolrXr __classcell__r)s@rr r sk#   %S )1.3', uf}%  &d^  tn rr c\rSrSrSrg)SentinelManagedSSLConnection\rNrrrrrara\rrrac,\rSrSrSrSrSrSrSrg)SentinelConnectionPoolProxy`c[R"U5UlX lX0lX@lXPlUR5 grA)weakrefrefconnection_pool_refrCr<r0sentinel_managerreset)r'r#rCr<r0rjs rr&$SentinelConnectionPoolProxy.__init__as5$+;;#? " 0( 0 rc SUlSUlgrA)master_addressslave_rr_counterrPs rrk!SentinelConnectionPoolProxy.resetps" $rcURRUR5nUR(a8URU:wa(XlUR 5nUbUR SS9 U$)NF)inuse_connections)rjdiscover_masterr0rCrnrirY)r'rnr#s rrD.SentinelConnectionPoolProxy.get_master_addresstse..>>t?P?PQ >>d11^C"0 #668O***U*Crc## URRUR5nU(aURc([R "S[ U5S- 5Ul[[ U55H5nURS-[ U5-UlXRnUv M7 UR5v [SUR<35e![a N%f=f7f)NrzNo slave found for ) rjdiscover_slavesr0rorandomrandintlenrangerDrr)r'slaves_rFs rrE)SentinelConnectionPoolProxy.rotate_slavess&&66t7H7HI $$,(.q#f+/(J%3v;')-)>)>)Bc&k(Q%445 (  ))+ +!#6t7H7H6K!LMM#   s*B/C-2CC- C*'C-)C**C-)r<rirCrnrjr0roN) rrrrr&rkrDrErrrrrdrd`s % Nrrdcf^\rSrSrSrU4SjrSrU4Sjr\S5r U4Sjr Sr S r S r U=r$) SentinelConnectionPoolz Sentinel backed connection pool. If ``check_connection`` flag is set to True, SentinelManagedConnection sends a PING command right after establishing the connection. c >URSURSS5(a[O[5US'URSS5UlURSS5Ul[ UURUR UUS9Ul[TU]$"S 0UD6 URURS'Xl X l g) Nconnection_classsslFrCTr<)r#rCr<r0rjr#r) getr$rar rCr<rdproxyr%r&connection_kwargsr0rj)r'r0rjr(r)s rr&SentinelConnectionPool.__init__s%+ZZ ::eU++-. & !" K6 & +=u E0 nn!22%-    "6"48JJ01( 0rc UR(aSOSnS[U5RS[U5RSURSUS3 $)NmasterrFr,r-r.(z))>)rCr/rrr0)r'roles rr6SentinelConnectionPool.__repr__sR>>xwT %%&aT (;(;'<))*!D6 6 rcV>[TU]5 URR5 grA)r%rkr)r'r)s rrkSentinelConnectionPool.resets   rc.URR$rA)rrnrPs rrn%SentinelConnectionPool.master_addressszz(((rc>UR(+=(d8 UR=(a% URURUR4:Hn[ 5nU=(a UR U5$rA)rCrnr1r2r%owns_connection)r' connectioncheckparentr)s rr&SentinelConnectionPool.owns_connectionsZNN" NN Xt22z 6XX ;// ;;rc6URR5$rA)rrDrPs rrD)SentinelConnectionPool.get_master_addressszz,,..rc6URR5$)zRound-robin slave balancer)rrErPs rrE$SentinelConnectionPool.rotate_slavesszz''))r)r<rCrrjr0)rrrr__doc__r&r6rkpropertyrnrrDrErr^r_s@rrrs?1. ))</**rrch\rSrSrSrSSjrSrSrSrSr S r S r \ \ 4S jr\ \ 4S jrS rg)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) >>> master.set('foo', 'bar') >>> slave = sentinel.slave_for('mymaster', socket_timeout=0.1) >>> 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[X40URD6PM sn nUlX lXPlX@lgs snnfs sn nf)Nsocket_)items startswithsentinel_kwargsr sentinelsmin_other_sentinelsr_force_master_ip) r'rrrforce_master_iprkvhostnamer2s rr&Sentinel.__init__s  "!2!8!8!:!:all9>U!:  /#, "+ ( 9D$8$8 9"+ $7 !2 /  sB B  "Bc[URSS55n[URSS55nU(aE[R"UR5R "U0UD6nU(aU/$U(aS$S$/nURH$nUR UR "U0UD65 M& U(aU$[U5$)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_responsesT)r]r$rxchoicerexecute_commandappendall)r'argsr(rrresponse responsessentinels rrSentinel.execute_commands FJJvu-.  +=u EF }}T^^4DDdUfUH z!'t2U2 H   X55tFvF G'  9~rc/nURH7nURSRURR55 M9 S[ U5R S[ U5RSSRU5S3$)Nz {host}:{port}r,r-z (sentinels=[,z])>) rr format_mapr#rr/rrjoin)r'sentinel_addressesrs rr6Sentinel.__repr__sH  % %**8+C+C+U+UV ' T %%&aT (;(;'<388$678 = rcjUS(aUS(d US(agUSUR:agg)NrCis_sdownis_odownFznum-other-sentinelsT)r)r'stater0s rcheck_master_stateSentinel.check_master_state)s5[!U:%6% :K & '$*B*B BrcN[5n[UR5Hup4UR5nURU5nU(dM0URXq5(dMHUURSsURS'URU'URb UROUSnXS4s $ Sn [U5S:aSSRU53n [S U<U 35e![[ 4a"nUR USU<35 SnAMSnAff=f) 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. z - Nripr2z : z, zNo master found for ) list enumeratersentinel_mastersr r rrrrrzrr) r'r0collected_errors sentinel_normasterserr error_infos rrsSentinel.discover_master1s1 6%.t~~%> !K "335KK -Eu00EENN1%?q!4>>+#>,,8))t =(('&?*  1 $tyy)9:; sC22D$DD$cz/nUH2nUS(d US(aMURUSUS45 M4 U$)z1Remove slaves that are in an ODOWN or SDOWN staterrrr2)r)r'r| slaves_aliverFs r filter_slavesSentinel.filter_slavesTsF EZ E*$5   teFm < =rcURH1nURU5nUR U5nU(dM/Us $ /$![[[4a MOf=f)z;Returns a list of alive slaves for service ``service_name``)rsentinel_slavesr r r r)r'r0rr|s rrwSentinel.discover_slaves]scH !11,?''/Fv ' $]LA  sAAAc SUS'[UR5nURU5 URU"X40UD65$)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. TrCdictrupdate from_poolr'r0 redis_classconnection_pool_classr(rs r master_forSentinel.master_forisN>#{ !7!78  ($$ !, J8I J  rc SUS'[UR5nURU5 URU"X40UD65$)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. FrCrrs r slave_forSentinel.slave_forsN0${ !7!78  ($$ !, J8I J  r)rrrrr)rNN)rrrrrr&rr6rrsrrwrrrrrrrrrrsR> 008  !WF 4 $ R4  rr)rxrgtypingrr redis.clientrredis.commandsrredis.connectionrrr redis.exceptionsr r r r redis.utilsrrrr rardrrrrrrs "+FF ! /   @ @F #