keJi:4ddlZddlZddlZddlmZmZmZmZmZm Z m Z ddl m Z ddl mZmZmZmZddlmZddlmZmZmZmZGddeZGd d eZGd d eZGd deeZGddeZGddeZdS)N) AsyncIteratorIterableMappingOptionalSequenceTupleType)Redis) ConnectionConnectionPool EncodableT SSLConnection)AsyncSentinelCommands)ConnectionError ReadOnlyError ResponseError TimeoutErrorceZdZdS)MasterNotFoundErrorN__name__ __module__ __qualname__\/var/www/html/movieo_spanner_bot/venv/lib/python3.11/site-packages/redis/asyncio/sentinel.pyrrDrrceZdZdS)SlaveNotFoundErrorNrrrrrrrrrc eZdZfdZdZdZdZdZ dddd d ed e e d e e d e effdZ xZ S)SentinelManagedConnectionc n|d|_tjdi|dS)Nconnection_poolr)popr#super__init__)selfkwargs __class__s rr&z"SentinelManagedConnection.__init__s;%zz*;<<""6"""""rcd|jjd|jj}|jrd|jd|j}||z }|dzS)N<.z,host=z,port=z)>)r)rrhostport)r's host_infos r__repr__z"SentinelManagedConnection.__repr__#sV E) E EDN,C E E 9 ===$)==I NA4xrcvK|\|_|_||jjdd{VdS)NF) check_healthretry_socket_connect)r-r.connect_check_healthr#check_connection)r'addresss r connect_toz$SentinelManagedConnection.connect_to*se& 49''->!&(           rcPK|jrdS|jjr:||jd{Vd{VdS|j23d{V} ||d{VcS#t $rY1wxYw6tN)_readerr# is_masterr8get_master_address rotate_slavesrr)r'slaves r_connect_retryz(SentinelManagedConnection._connect_retry1s <  F   ) %//(<(O(O(Q(Q"Q"Q"Q"Q"Q"QRR R R R R R R R R R#3AACC       e!%!7!7777777777&H D % $s+B 3B BBcTK|j|jdd{VS)Nc*tjdS)Nr)asynciosleep)errors rz3SentinelManagedConnection.connect..As'-**r)retrycall_with_retryr@r's rconnectz!SentinelManagedConnection.connect>sJZ//   * *         rFNT)disconnect_on_error push_requestdisable_decodingtimeoutrKrLcK t||||d{VS#t$r7|jjr)|d{Vt dwxYw)N)rMrNrKrLz"The previous master is now a slave)r% read_responserr#r< disconnectr)r'rMrNrKrLr)s rrPz'SentinelManagedConnection.read_responseDs ..!1$7) /     #- L oo'''''''''%&JKKK  s *0AA1)FN) rrrr&r1r8r@rJboolrfloatrP __classcell__r)s@rr!r!s#####    % % %   "'#' 04', % &e_  tn rr!ceZdZdS)SentinelManagedSSLConnectionNrrrrrWrW_rrrWcTeZdZdZfdZdZfdZdeffd ZdZ de fd Z xZ S) SentinelConnectionPoolz Sentinel backed connection pool. If ``check_connection`` flag is set to True, SentinelManagedConnection sends a PING command right after establishing the connection. c |d|ddrtnt|d<|dd|_|dd|_t jdi|tj ||j d<||_ ||_ d|_ d|_dS) Nconnection_classsslFr<Tr6r#r)getr$rWr!r<r6r%r&weakrefproxyconnection_kwargs service_namesentinel_managermaster_addressslave_rr_counter)r'rarbr(r)s rr&zSentinelConnectionPool.__init__ks%+ZZ ::eU++/,,. & & !" K66 & +=u E E""6"""4;M$4G4G01( 0" $rc dd|jjd|jjd|jd|jrdpdd S)Nr+r,z (service=(masterr?z))>)r)rrrar<rIs rr1zSentinelConnectionPool.__repr__}sf X) X XDN,C X X) X X,0N,Gx,R7 X X X rcdtd|_d|_dSr:)r%resetrcrd)r'r)s rrizSentinelConnectionPool.resets*  " $r connectionc|j p|jo|j|j|jfk}|o t |Sr:)r<rcr-r.r%owns_connection)r'rjcheckr)s rrlz&SentinelConnectionPool.owns_connectionsON" N Xt2z 6XX <00<< ?"n44&4#ooo>>>>>>>>>rreturncK|j|jd{V}|r|j*t jdt |dz |_tt |D]3}|jdzt |z|_||j}|WV4 |d{VWVn#t$rYnwxYwtd|j)zRound-robin slave balancerNrzNo slave found for ) rbdiscover_slavesrardrandomrandintlenranger=rr)r'slaves_r?s rr>z$SentinelConnectionPool.rotate_slavess!,<)Bc&kk(Q%t45  //11111111 1 1 1 1 1"    D  !Lt7H!L!LMMMs,C CC) rrr__doc__r&r1rir rlr=rr>rTrUs@rrYrYcs%%%%%$   %%%%% =*====== N]NNNNNNNNrrYceZdZdZ ddZdZdZdeded e fd Z defd Z d e e d eeeeffd Zded eeeeffdZeefdedeedeefdZeefdedeedeefdZdS)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. rNc |d|D}|_fd|D_|_|_|_dS)NcDi|]\}}|d||S)socket_) startswith).0kvs r z%Sentinel.__init__..s?Aall9>U>U1rc>g|]\}}td||djS))r-r.r)r sentinel_kwargs)rhostnamer.r's r z%Sentinel.__init__..sE   $  Cxd C Cd.B C C   r)itemsr sentinelsmin_other_sentinelsr`_force_master_ip)r'rrrforce_master_ipr`s` rr&zSentinel.__init__s  "!2!8!8!:!:O /    "+   $7 !2 /rczKtdd}tdd}|r5tj|jjid{V}|r|gS|rdndSfd|jD}t j|d{V}|r|St|S)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_responsesNTc Ng|]!}tj|ji"Sr)rCTaskexecute_command)rsentinelargsr(s rrz,Sentinel.execute_command..sF    L114B6BB C C   r) rRr$ruchoicerrrCgatherall)r'rr(rrresponsetasks responsess `` rrzSentinel.execute_commands FJJvu--..  +=u E EFF  3JV]4>::JH  3 z!'2ttU2      N   ".%0000000   9~~rcg}|jD]<}||jjdd|jjd=d|jd|jjdd|dS) Nr-:r.r+r,z (sentinels=[,z])>)rappendr#r`r)rjoin)r'sentinel_addressesrs rr1zSentinel.__repr__s  H  % %+=fEHH+=fEHH      = = =!8 = =88$677 = = = rstaterarqc`|dr|ds|drdS|d|jkrdSdS)Nr<is_sdownis_odownFznum-other-sentinelsT)r)r'rras rcheck_master_statezSentinel.check_master_state sJ[! U:%6 % :K 5 & '$*B B B5trc^Kt}t|jD]\}} |d{V}n8#tt f$r$}||d|Yd}~Qd}~wwxYw||}|rX|||rB||jdc|jd<|j|<|j |j n|d}||dfcSd} t|dkrdd |} td || ) 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 - ripr.z : z, zNo master found for ) list enumeratersentinel_mastersrrrr]rrrwrr) r'racollected_errors sentinel_normasterserr error_infos rrpzSentinel.discover_masters 66%.t~%>%> ) ) !K  ( 9 9 ; ;;;;;;;#\2    ''8(=(=(=(=>>> KK --E )00 EE )N1%?q!4>+#>,8))t 5=((((  1 $ $ >EZ  E*$5    teFm < = = = =rcK|jD]W} ||d{V}n#tttf$rY8wxYw||}|r|cSXgS)z;Returns a list of alive slaves for service ``service_name``N)rsentinel_slavesrrrr)r'rarrys rrtzSentinel.discover_slavesAs  H '77 EEEEEEEE#]LA    ''//F    s)AA redis_classconnection_pool_classc d|d<t|j}|||||fi|}||S)a 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. Tr<dictr`update from_poolr'rarrr(r`r#s r master_forzSentinel.master_forOsb>#{ !788  (((// dXXFWXX$$_555rc d|d<t|j}|||||fi|}||S)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<rrs r slave_forzSentinel.slave_forvsb0${ !788  (((// dXXFWXX$$_555r)rNN)rrrr{r&rr1rstrrRrrprrrrr rrtr rYr rrrrrr}r}s> 00000@    CD!W#!W!W!W!WF w'  % J./ 0       % J./ 0    "$)>T %6%6%6%[%6 $$:; %6%6%6%6T$)>T 666%[6 $$:; 666666rr})rCrur^typingrrrrrrr redis.asyncio.clientr redis.asyncio.connectionr r r rredis.commandsrredis.exceptionsrrrrrrr!rWrYr}rrrrs TTTTTTTTTTTTTTTTTT&&&&&& 100000     /           >>>>> >>>B     #