(ph-SSKrSSKrSSKJr SSKJrJr SSKJrJ r J r J r SSK J r JrJr "SS\5r"SS \5r"S S \5r"S S \5r"SS\5rg)N)Redis)ConnectionPool Connection)ConnectionError ResponseError ReadOnlyError TimeoutError) iteritems nativestrxrangec\rSrSrSrg)MasterNotFoundError N__name__ __module__ __qualname____firstlineno____static_attributes__rA/var/www/html/venv/lib/python3.13/site-packages/redis/sentinel.pyrr rrc\rSrSrSrg)SlaveNotFoundErrorrNrrrrrrrrrcL^\rSrSrU4SjrSrU4SjrSrU4SjrSr U=r $)SentinelManagedConnectionc Z>URS5Ul[[U]"S0UD6 g)Nconnection_poolr)popr!superr__init__)selfkwargs __class__s rr$"SentinelManagedConnection.__init__s(%zz*;< '7A&ArcURn[U5R<SUR<S3nUR(a"SUR<SUR <3nX#-nU$)N z,host=z,port=)r!typer service_namehostport)r%pools host_infos r__repr__"SentinelManagedConnection.__repr__sN###':#6#68I8I J 999.2iiCI Arc>UuUlUl[[U]5 UR R (a:URS5 [UR55S:wa [S5egg)NPINGPONGz PING failed) r-r.r#rconnectr!check_connection send_commandr read_responser)r%addressr's r connect_to$SentinelManagedConnection.connect_to sg& 49 '68    0 0   f %++-.&8%m449 1rcDUR(agURR(a*URURR 55 gURR 5HnURU5s $ [e![ a M,f=fN)_sockr! is_masterr<get_master_address rotate_slavesrr)r%slaves rr7!SentinelManagedConnection.connect(s ::     ) ) OOD00CCE F--;;=??511> % $'s6B BBc>[[U] 5$![a8 URR (aUR 5 [S5eef=f)Nz"The previous master is now a slave)r#rr:rr!rA disconnectrr%r's rr:'SentinelManagedConnection.read_response5sR 2DGI I ##-- !%&JKK  s AA)r!r-r.) rrrrr$r2r<r7r:r __classcell__r's@rrrs"B5 %  rrcV^\rSrSrSrU4SjrSrU4SjrU4SjrSr Sr S r U=r $) SentinelConnectionPoolDz Sentinel backed connection pool. If ``check_connection`` flag is set to True, SentinelManagedConnection sends a PING command right after establishing the connection. c >URS[5US'URSS5UlURSS5Ul[ [ U]"S0UD6 [R"U5URS'Xl X l g)Nconnection_classrATr8Fr!r) getrr"rAr8r#rMr$weakrefproxyconnection_kwargsr,sentinel_manager)r%r,rUr&r's rr$SentinelConnectionPool.__init__Ls|%+ZZ  9&;!"K6 & +=u E $d4>v>4;MM$4G01( 0rc[U5R<SUR<SUR=(a S=(d S<S3$)Nr*(masterrD))r+rr,rA)r%s rr2SentinelConnectionPool.__repr__Vs6 J      NN 'x 27 2  rcF>[[U] 5 SUlSUlgr?)r#rMresetmaster_addressslave_rr_counterrHs rr]SentinelConnectionPool.reset]s! $d13" $rc>UR(+=(d8 UR=(a% URURUR4:Hn[ [ U5nU=(a UR U5$r?)rAr^r-r.r#rMowns_connection)r% connectioncheckparentr's rrb&SentinelConnectionPool.owns_connectionbseNN"LK$$*//(JJ -t4;// ;;rcURRUR5nUR(a%URU:waXlUR SS9 U$)NF)inuse_connections)rUdiscover_masterr,rAr^rG)r%r^s rrB)SentinelConnectionPool.get_master_addressisR..>>    >>""n4&4#%8rc## URRUR5nU(aURc([R "S[ U5S- 5Ul[[ U55H5nURS-[ U5-UlXRnUv M7 UR5v [SUR-5e![a N$f=f7f)zRound-robin slave balancerrzNo slave found for %r) rUdiscover_slavesr,r_randomrandintlenr rBrr)r%slaves_rDs rrC$SentinelConnectionPool.rotate_slavests&&66t7H7HI $$,(.q#f+/(J%CK())A-V)=%445 )  ))+ +!!8D>> 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 Uc7[U5VVs0sHupVURS5(dMXV_M! nnnX0lUVVs/sHupx[Xx40URD6PM snnUlX lX@lgs snnfs snnf)Nsocket_)r startswithsentinel_kwargsr sentinelsmin_other_sentinelsrT) r%r|r}r{rTkvhostnamer.s rr$Sentinel.__init__s  "&&788DA<< *8  /1:;09nh G$2F2FG09;#6 !2;sA>A>"Bc/nURHInURURRS<SURRS<35 MK [ U5R <SSR U5<S3$)Nr-:r.z )r|appendr!rTr+rjoin)r%sentinel_addressessentinels rr2Sentinel.__repr__swH  % %((::6B((::6B' ' J   HH' (* *rcjUS(aUS(d US(agUSUR:agg)NrAis_sdownis_odownFznum-other-sentinelsT)r})r%stater,s rcheck_master_stateSentinel.check_master_states5[!U:%6% :K & '$*B*B Brcz[UR5H}up#UR5nUR U5nU(dM0UR XQ5(dMHX0RSsURS'URU'USUS4s $ [SU<35e![[4a Mf=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. ripr.zNo master found for ) enumerater|sentinel_mastersrr rQrr)r%r, sentinel_normastersrs rriSentinel.discover_masters&/t~~%> !K "335KK -Eu00EEnnQ/?q!4>>+#>T{E&M11&?"l"LMM$\2  sB&&B:9B:cz/nUH2nUS(d US(aMURUSUS45 M4 U$)z1Remove slaves that are in an ODOWN or SDOWN staterrrr.)r)r%rq slaves_aliverDs r filter_slavesSentinel.filter_slavessF EZ E*$5   teFm < =rcURH1nURU5nUR U5nU(dM/Us $ /$![[[4a MOf=f)z;Returns a list of alive slaves for service ``service_name``)r|sentinel_slavesrrr r)r%r,rrqs rrmSentinel.discover_slavesscH !11,?''/Fv ' $]LA  sAAAc rSUS'[UR5nURU5 U"U"X40UD6S9$)a Returns a redis client instance for the ``service_name`` master. A SentinelConnectionPool class is used to retrive 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 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. TrAr!dictrTupdater%r, redis_classconnection_pool_classr&rTs r master_forSentinel.master_forsM,#{ !7!78  (+@ ,5"3,56 6rc rSUS'[UR5nURU5 U"U"X40UD6S9$)at Returns redis client instance for the ``service_name`` slave(s). A SentinelConnectionPool class is used to retrive the slave's address before establishing a new connection. By default clients will be a 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. FrArrrs r slave_forSentinel.slave_forsM&${ !7!78  (+@ ,5"3,56 6r)rTr}r{r|)rN)rrrrrtr$r2rrirrmrrMrrrrrrrvrvs@83" *N* 49)?6838(>6rrv)rnrR redis.clientrredis.connectionrrredis.exceptionsrrrr redis._compatr r r rrrrMobjectrvrrrrse 7,,66 /   . .b@P^@PF^6v^6r