+ h7cs^RIt^RIt^RIt^RIHtHtHtHtHtH t H t ^RI H t ^RI HtHtHtHt^RIHt^RIHtHtHtHt^RIHt!RR ]4t!R R ]4t!R R ]4t!RR]]4t!RR]4t!RR]4t R#)N) AsyncIteratorIterableMappingOptionalSequenceTupleType)Redis) ConnectionConnectionPool EncodableT SSLConnection)AsyncSentinelCommands)ConnectionError ReadOnlyError ResponseError TimeoutError) str_if_bytescs]tRt^tRtR#)MasterNotFoundErrorN__name__ __module__ __qualname____firstlineno____static_attributes__r;/usr/lib/python3.14/site-packages/redis/asyncio/sentinel.pyrrrrcs]tRt^tRtR#)SlaveNotFoundErrorrNrrrrrrrrrcsxaa]tRt^toV3RltRtV3RltRtRtR RRR R/V3R lV3R llllt R t Vt V;t #)SentinelManagedConnectionc sT<VPR4Vn\SV` !R/VBR#)connection_poolNr)popr super__init__)selfkwargs __class__s&,rr#Z"SentinelManagedConnection.__init__s%%zz*;< "6"rcsRVPP RVPP 2pVP'd%RVP RVP 2pW, pVR,#)<.z,host=z,port=z)>)r&rrhostport)r$ZsZ host_info& r__repr__Z"SentinelManagedConnection.__repr__s]))*!DNN,C,C+D E 999  6$))=I NA4xrcs6<"VwVnVn\SV` 4GRjxL VPP 'dMVP R4GRjxL \VP4GRjxL 4R8wd \R4hR#R#LnL;L 5i)NZPINGZPONGz PING failed) r)r*r"connectr check_connectionZ send_commandr read_responser)r$Zaddressr&s&&r connect_toZ$SentinelManagedConnection.connect_to&s& 49go    0 0 0##F+ + +$"4"4"6676A%m44B 1 +6s9!BBBBBB6B7BBBcs"VP'dR#VPP'd<TPVPP 4GRjxL 4GRjxL R#VPP 4RjxL pVPV4GRjxL u#LRLHL%L \ dK<i;iD:\h5iN)Z_readerr is_masterr0get_master_address rotate_slavesrr)r$slave& r_connect_retryZ(SentinelManagedConnection._connect_retry.s <<<     ) ) )//(<(<(O(O(Q"QR R R#33AAC  e!%!777 #R R 7& D % $s|0C(CB. C'B0( CC B2 CCB6'B4(B6+C0C2C4B66 CCC Ccsl"VPPVPR4GRjxL #L5i)cs.\P!^4#)r)asyncioZsleep)Zerror&rZZ3SentinelManagedConnection.connect..>s '--*rN)ZretryZcall_with_retryr7r$r9rr-Z!SentinelManagedConnection.connect;s2ZZ//    *    s +424Fdisconnect_on_errorT push_requestc sb<V^8dQhRS[RS[S[,RS[S[,RS[S[,/#)disable_decodingtimeoutr;r<)boolrZfloatZformat __classdict__"r __annotate__Z&SentinelManagedConnection.__annotate__As?% &e_  tn rcs<"\SV`VVVVR7GRjxL #L \dCTPP'd%TP 4GRjxL \ R4hhi;i5i))r>r?r;r<Nz"The previous master is now a slave)r"r/rr r2 disconnectr)r$r>r?r;r<r&s&&&$$rr/Z'SentinelManagedConnection.read_responseAs{ .!1$7) /   ##--- oo'''%&JKK  s7A2" "A2"&A/ A/AA//A2)r r)r*)FN) rrrrr#r,r0r7r-r/r__classdictcell__ __classcell__r&rB@@rrrsA#5 %  04  (- rrcs]tRt^\tRtR#)SentinelManagedSSLConnectionrNrrrrrJrJ\rrrJcsxaa]tRt^`toRtV3RltRtV3RltV3RlV3RlltRt V3RlR lt R t Vt V;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 sl<TPRVPRR4'd\M\4VR&VPRR4VnVPRR4Vn\ SV`!R/VB\P!V4VPR&Wn W n RVn RVnR#) Zconnection_classZsslFr2Tr.r Nr)getr!rJrr2r.r"r#weakrefZproxyconnection_kwargs service_namesentinel_managermaster_addressslave_rr_counter)r$rOrPr%r&s&&&,rr#ZSentinelConnectionPool.__init__hs%+ZZ ::eU++-. & !" K6 & +=u E "6"4;MM$4G01( 0" $rc sRVPP RVPP RVP RVP;'d R;'gR R2 #)r'r(z (service=Z(Zmasterr5z))>)r&rrrOr2r:r9rr,ZSentinelConnectionPool.__repr__zs\))*!DNN,C,C+D))*!DNN,G,Gx,R,R7+SSV X rcs@<\SV`4RVnRVnR#r1)r"resetrQrR)r$r&s&rrSZSentinelConnectionPool.resets  " $rc <V^8dQhRS[/#)r= connection)r rArCrrD#SentinelConnectionPool.__annotate__s==*=rcs<VP'*;'g:VP;'d&VPVPVP38HpT;'d\SV`V4#r1)r2rQr)r*r"owns_connection)r$rUZcheckr&s&& rrWZ&SentinelConnectionPool.owns_connections]NN"  NN X Xt22z 6XX <<0<>>""n4&4#ooo>>>X ?s')A9A5A9,A9.A7/A97A9crT)r=return)rrArCrrDrVsNN]Nrc s0"VPPVP4GRjxL pV'dVPf-\P !^\ V4^, 4Vn\\ V44FBpVP^,\ V4,VnWP,pV5xKD VP4GRjxL 5x\RVP: 24hLL" \dL*i;i5i)zRound-robin slave balancerNzNo slave found for ) rPdiscover_slavesrOrRrandomZrandintlenZranger3rr)r$slavesZ_r5s& rr4Z$SentinelConnectionPool.rotate_slavess,,<)>)Bc&k(Q%445 (  //11 1!#6t7H7H6K!LMMP2"   sK)DD DBD D D!D(DD DDDD)r.r2rQrPrOrR)rrrr__doc__r#r,rSrWr3r4rrFrGrHrIrrKrK`s:%$ % == NNNrrKcsa]tRt^toRtRRltRtRtV3RlRltV3RlR lt V3R lR lt V3R lR lt ] ] 3V3RlRllt] ] 3V3RlRlltRtVtR#)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 s&Vf=VP4UUu/uF wrVVPR4'gKWVbK" pppW0nVUUu.uFwrx\RRVRV/VPBNK uppVnW nW@nR#uuppiuuppi)NZsocket_r)r*r)ZitemsZ startswithsentinel_kwargsr sentinelsmin_other_sentinelsrN) r$rarbr`rNZkZvZhostnamer*s &&&&, rr#ZSentinel.__init__s  "!2!8!8!:!:all9>U!:  /#, "+  Cx Cd Cd.B.B C"+ $7 !2  sBB $B c s"\VPRR44pRVP49dVPR4V'd;\P !VP 4P!V/VBGRjxL R#VP Uu.uF)p\P!VP!V/VB4NK+ pp\P!V!GRjxL R#LcuupiL 5i)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@rLZkeysr!r[Zchoiceraexecute_commandr8ZTaskZgather)r$Zargsr%rcsentinelZtaskss&*, rrdZSentinel.execute_commands FJJvu-. V[[] " JJv  --/??PP P P!% .H X55tFvFG . ..%( ( ( Q )s6A C, 3C,?C#C,/C%C,C*C,%C,cs6.pVPFOpVPVPPR, RVPPR, 24KQ RVP RVPP RRP V4 R2#)r)Z:r*r'r(z (sentinels=[Z,z])>)raappendr rNr&rjoin)r$Zsentinel_addressesrer+rr,ZSentinel.__repr__sH  % %++==fEFa++==fEFH ' q!8!8 9388$678 = rcs,<V^8dQhRS[RS[RS[/#)r=staterOrY)dictstrr@rArCrrDSentinel.__annotate__s"CDrcsVR,'dVR,'gVR,'dR#VR,VP8dR#R#)r2is_sdownis_odownFznum-other-sentinelsT)rb)r$rhrOs&&&rcheck_master_stateZSentinel.check_master_states>[!!U:%6%6% :K:K & '$*B*B BrcrT)r=rO)rjrArCrrDrksWW#Wrc sV"\4p\VP4Fwr4VP4GRjxL pTPT4pT'gK9TPYq4'gKRTTP^,uTP^&TPT&TR,TR,3u# Rp\V4^8dRRPV4 2p\RV: V 24hL \\ 3d#pTP T RT: 24Rp?KRp?ii;i5i) 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 - ipr*Zz : z, zNo master found for ) ZlistZ enumerateraZsentinel_mastersrrrfrLrnr\rgr) r$rOZcollected_errorsZ sentinel_noreZmastersZerhZ error_infos && rrXZSentinel.discover_masters 6%.t~~%> !K  ( 9 9 ;;KK -Eu00EENN1%?q!4>>+#>T{E&M11&?  1 $tyy)9:; sK%D)C3C1C3D)D)4A=D)1C33D&D!D)!D&&D)cs\<V^8dQhRS[S[,RS[S[S[S[3,,/#)r=r]rY)rrrrr rArCrrDrks1  w'  % J./ 0 rc s.pVFDpVR,'gVR,'dK#VPVR,VR,34KF V#)z1Remove slaves that are in an ODOWN or SDOWN statermrlror*)rf)r$r]Z slaves_aliver5&& r filter_slavesZSentinel.filter_slavessN EZ  E*$5$5   teFm < =rcsL<V^8dQhRS[RS[S[S[S[3,,/#)r=rOrY)rjrrr rArCrrDrk*s,    % J./ 0 rc s"VPF:pVPV4GRjxL pTP T4pT'gK8Tu# .#L' \\\3dK[i;i5i)z;Returns a list of alive slaves for service ``service_name``N)raZsentinel_slavesrrrrq)r$rOrer]rprrZZSentinel.discover_slaves*snH '77 EE''/Fv ' F#]LA  s=A.AAAA.A.AA+'A.*A++A.cL<V^8dQhRS[RS[S[,RS[S[,/#r=rO redis_classconnection_pool_classrjrrrKrArCrrDrk8s3#6#6#6%[#6 $$:; #6rc RVR&\VP4pVPV4V!W3/VBpVPV4#)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. Tr2rirNZupdateZ from_poolr$rOrtrur%rNr &&&&, r master_forZSentinel.master_for8sN:#{ !7!78  (/ XFWX$$_55rcrrrsrvrArCrrDrk]s3666%[6 $$:; 6rc rw)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. Fr2rxryrzr slave_forZSentinel.slave_for]sN0${ !7!78  (/ XFWX$$_55r)rNrbr`ra)rN)rrrrr^r#rdr,rnrXrqrZrrKr{r|rrF)rBs@rr_r_sm83,(  WW:    "$)>T #6#6P$)>T 666rr_)!r8r[rMZtypingrrrrrrrZredis.asyncio.clientrZredis.asyncio.connectionr r r r Zredis.commandsr Zredis.exceptionsrrrrZ redis.utilsrrrrrJrKr_rrrr}s TTT& 1XX$ /   ? ?D #