+ hE9cs ^RIt^RIt^RIHt^RIHt^RIHt^RIH t H t H t ^RI H t HtHtHt^RIHt!RR ] 4t!R R ] 4t!R R ] 4t!RR]] 4t!RR4t!RR] 4t!RR]4tR#)N)Optional)Redis)SentinelCommands) ConnectionConnectionPool SSLConnection)ConnectionError ReadOnlyError ResponseError TimeoutError) str_if_bytescs]tRt^ tRtR#)MasterNotFoundErrorN__name__ __module__ __qualname____firstlineno____static_attributes__r 3/usr/lib/python3.14/site-packages/redis/sentinel.pyr r rr cs]tRt^tRtR#)SlaveNotFoundErrorr Nrr rrrrrrrcsxaa]tRt^toV3RltRtV3RltRtRtR RRRR/V3R lV3R llllt R t Vt V;t #) SentinelManagedConnectionc sT<VPR4Vn\SV` !R/VBR#)connection_poolNr )poprsuper__init__)selfkwargs __class__s&,rrZ"SentinelManagedConnection.__init__s%%zz*;< "6"rcsVPpR\V4P R\V4P RVP R2pVP 'd%RVP RVP 2pW#,pV#)<. (service=z%s)>z,host=z,port=)rtyperr service_namehostport)rZpoolZsZ host_info& r__repr__Z"SentinelManagedConnection.__repr__s{##T %%&aT (;(;'<))*$ 0  999  6$))=I Arcs<VwVnVn\SV` 4VPP 'd=VP R4\VP44R8wd \R4hR#R#)ZPINGZPONGz PING failedN) r%r&rconnectrcheck_connectionZ send_commandr read_responser)rZaddressrs&&r connect_toZ$SentinelManagedConnection.connect_to$sf& 49     0 0 0   f %D..01V;%m44< 1rcsNVP'dR#VPP'd,VPVPP 44R#VPP 4FpVPV4u# \h \ dK-i;iN)Z_sockr is_masterr,get_master_address rotate_slavesrr)rslave& r_connect_retryZ(SentinelManagedConnection._connect_retry,s :::     ) ) ) OOD00CCE F--;;=??511> % $'s:B B$#B$csPVPPVPR4#)csR#r-r )Zerror&rZZ3SentinelManagedConnection.connect..:sTr)ZretryZcall_with_retryr3rr4rr)Z!SentinelManagedConnection.connect9s zz))$*=*=?QRRrFdisconnect_on_error push_requestcsF<V^8dQhRS[S[,RS[S[,/#)ir6r7)rbool)Zformat __classdict__s"rZ __annotate__Z&SentinelManagedConnection.__annotate__<s)&d^  tn rcs<\SV`VVVR7# \d:TPP'dTP 4\ R4hhi;i))disable_decodingr6r7z"The previous master is now a slave)rr+rrr. disconnectr)rr:r6r7rs&&$$rr+Z'SentinelManagedConnection.read_response<sf 7(!1$7))   ##--- !%&JKK  s&AA)rr%r&)F) rrrrrr(r,r3r)r+r__classdictcell__ __classcell__rr9@@rrrsB# 5 %S/4  (- rrcs]tRt^UtRtR#)SentinelManagedSSLConnectionr Nrr rrr@r@Urrr@cs8a]tRt^YtoRtRtRtRtRtVt R#)SentinelConnectionPoolProxycs\P!V4VnW nW0nW@nWPnVP4R#r-)weakrefZrefconnection_pool_refr.r*r$sentinel_managerreset)rrr.r*r$rDs&&&&&&rrZ$SentinelConnectionPoolProxy.__init__Zs5$+;;#? " 0( 0 rcs"RVnRVnR#r-)master_addressslave_rr_counterr5r4rrEZ!SentinelConnectionPoolProxy.resetis" $rcsVPPVP4pVP'd>VPV8wd-WnVP 4pVeVP RR7V#)NF)Zinuse_connections)rDdiscover_masterr$r.rFrCr;)rrFr& rr/Z.SentinelConnectionPoolProxy.get_master_addressmsg..>>t?P?PQ >>>d11^C"0 #668O***U*Crc#s"VPPVP4pV'dVPf-\P !^\ V4^, 4Vn\\ V44FApVP^,\ V4,VnWP,pVxKC VP4x\RVP: 24h \dL&i;i5i)NzNo slave found for ) rDdiscover_slavesr$rGrandomZrandintlenZranger/r r)rslavesZ_r1r'rr0Z)SentinelConnectionPoolProxy.rotate_slavesxs&&66t7H7HI $$,(.q#f+/(J%3v;')-)>)>)Bc&k(Q%445 (  ))+ +!#6t7H7H6K!LMM#   s*CDC/D/ C=:D<C==D)r*rCr.rFrDr$rGN) rrrrrrEr/r0rr<r9@rrArAYs  % NNrrAcspaa]tRt^toRtV3RltRtV3Rlt]R4t V3Rlt Rt Rt R t VtV;t#) SentinelConnectionPoolz Sentinel backed connection pool. If ``check_connection`` flag is set to True, SentinelManagedConnection sends a PING command right after establishing the connection. c s<TPRVPRR4'd\M\4VR&VPRR4VnVPRR4Vn\ VVPVP VVR7Vn\SV`$!R /VBVPVPR&Wn W n R#) Zconnection_classZsslFr.Tr*)rr.r*r$rDrNr ) getrr@rr.r*rAproxyrrconnection_kwargsr$rD)rr$rDrrs&&&,rrZSentinelConnectionPool.__init__s%+ZZ ::eU++-. & !" K6 & +=u E0 nn!22%-    "6"48JJ01( 0rc sVP'dRMRpR\V4P R\V4P RVP RV R2 #)Zmasterr1r r!r"Z(z))>)r.r#rrr$)rZroler2rr(ZSentinelConnectionPool.__repr__sT>>>xwT %%&aT (;(;'<))*!D6 6 rcsX<\SV`4VPP4R#r-)rrErR)rrs&rrEZSentinelConnectionPool.resets   rcs.VPP#r-)rRrFr5r4rrFZ%SentinelConnectionPool.master_addressszz(((rcs<VP'*;'g:VP;'d&VPVPVP38Hp\ 4pT;'dVP V4#r-)r.rFr%r&rowns_connection)rZ connectionZcheckZparentrs&& rrTZ&SentinelConnectionPool.owns_connectionseNN"  NN X Xt22z 6XX ;;// ;;rc6VPP4#r-)rRr/r5r4rr/Z)SentinelConnectionPool.get_master_addressszz,,..rc rU)zRound-robin slave balancer)rRr0r5r4rr0Z$SentinelConnectionPool.rotate_slavesszz''))r)r*r.rRrDr$)rrrr__doc__rr(rEZpropertyrFrTr/r0rr<r=r>r?rrPrPsA1. ))</**rrPcsna]tRt^toRtR RltRtRtRtRt Rt R t ] ] 3R lt] ] 3R ltR tVtR#)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 s,Vf=VP4UUu/uF wrgVPR4'gKWgbK" pppW0nVUU u.uFwr\W3/VPBNK up pVnW nWPnW@nR#uuppiuup pi)NZsocket_)ZitemsZ startswithsentinel_kwargsr sentinelsmin_other_sentinelsrS_force_master_ip) rrYrZrXZforce_master_iprSZkZvZhostnamer&s &&&&&, rrZSentinel.__init__s  "!2!8!8!:!:all9>U!:  /#, "+ ( 9D$8$8 9"+ $7 !2 /  sB B  !Bc sF\VPRR44pRVP49dVPR4V'd3\P !VP 4P!V/VBR#VP FpVP!V/VBK R#)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. onceFT)r8rQZkeysrrKZchoicerYexecute_command)rZargsrr\sentinels&*, rr]ZSentinel.execute_commands FJJvu-. V[[] " JJv   MM$.. ) 9 94 J6 J!NN(($9&9+rcs.pVPF7pVPRPVPP44K9 R\ V4P R\ V4P RRPV4 R2#)z {host}:{port}r r!z (sentinels=[Z,z])>) rYappendZ format_maprrSr#rrjoin)rZsentinel_addressesr^rIrr(ZSentinel.__repr__ sH  % %**8+C+C+U+UV ' T %%&aT (;(;'<388$678 = rcsVR,'dVR,'gVR,'dR#VR,VP8dR#R#)r.is_sdownis_odownFznum-other-sentinelsT)rZ)rstater$s&&&rcheck_master_stateZSentinel.check_master_states>[!!U:%6%6% :K:K & '$*B*B Brc sr\4p\VP4Fwr4VP4pTPT4pT'gK1TPYq4'gKJTTP^,uTP^&TPT&TPe TPMTR,pYR,3u# Rp \V4^8dRRPV4 2p \RV: V 24h \\ 3d$pTP T RT: 24Rp?EKRp?ii;i) 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 - Nipr&Zz : z, zNo master found for ) ZlistZ enumeraterYZsentinel_mastersrr r_rQrdr[rLr`r ) rr$Zcollected_errorsZ sentinel_nor^ZmastersZercreZ error_infos && rrHZSentinel.discover_masters1 6%.t~~%> !K "335KK -Eu00EENN1%?q!4>>+#>,,8))t =(('&?*  1 $tyy)9:; sDD6D11D6c s.pVFDpVR,'gVR,'dK#VPVR,VR,34KF V#)z1Remove slaves that are in an ODOWN or SDOWN staterbrarer&)r_)rrMZ slaves_aliver1&& r filter_slavesZSentinel.filter_slavesBsL EZ  E*$5$5   teFm < =rc sVPF2pVPV4pTP T4pT'gK0Tu# .# \\\3dKQi;i)z;Returns a list of alive slaves for service ``service_name``)rYZsentinel_slavesrr r rg)rr$r^rMrfrrJZSentinel.discover_slavesKscH !11,?''/Fv ' $]LA  sAAAc RVR&\VP4pVPV4VPV!W3/VB4#)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. Tr.ZdictrSZupdateZ from_poolrr$Z redis_classZconnection_pool_classrrS&&&&, r master_forZSentinel.master_forWsN:#{ !7!78  ($$ !, J8I J  rc rh)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. Fr.rirjrkr slave_forZSentinel.slave_for{sN0${ !7!78  ($$ !, J8I J  r)r[rSrZrXrY)rNN)rrrrrVrr]r(rdrHrgrJrrPrlrmrr<rNrOrrWrWsO800"  !WF 4 " N4   rrW)rKrBZtypingrZ redis.clientrZredis.commandsrZredis.connectionrrrZredis.exceptionsrrr r Z redis.utilsr r rrr@rArPrWr rrrns +FFXX$ /   > >B #