> i6ddlZddlZddlZddlmZmZmZmZmZm Z m Z ddl m Z ddl mZmZmZmZddlmZddlmZmZmZmZddlmZGdd eZGd d eZGd d eZGddeeZGddeZGddeZ y)N) AsyncIteratorIterableMappingOptionalSequenceTupleType)Redis) ConnectionConnectionPool EncodableT SSLConnection)AsyncSentinelCommands)ConnectionError ReadOnlyError ResponseError TimeoutError) str_if_bytesc eZdZy)MasterNotFoundErrorN__name__ __module__ __qualname__r/var/www/html/wine-match-dev/backend/winematch-backend/venv/lib/python3.12/site-packages/redis/asyncio/sentinel.pyrrrrc eZdZy)SlaveNotFoundErrorNrrrrr r rrr c jeZdZfdZdZfdZdZdZ d ddded e e d e e ffd Z xZ S) SentinelManagedConnectionc P|jd|_t| di|y)Nconnection_poolr)popr$super__init__)selfkwargs __class__s rr'z"SentinelManagedConnection.__init__s%%zz*;< "6"rc|j}|jjd|j}|jr!d|jd|j }||z }|dzS)N )r$r*r service_namehostport)r(pools host_infos r__repr__z"SentinelManagedConnection.__repr__sb##~~&&'y1B1B0C D 99  6$))=I NA3wrc"K|\|_|_t| d{|jj rI|j dd{t|jd{dk7r tdyy7d777w)NPINGPONGz PING failed) r/r0r&connectr$check_connection send_commandr read_responser)r(addressr*s r connect_toz$SentinelManagedConnection.connect_to's& 49go    0 0##F+ + +$"4"4"6676A%m44B 1 +6s3!BB .BB B0B 1B B Bc~K|jry|jjr:|j|jj d{d{y|jj 23d{} |j|d{cS7P7F7$7 #t $rY8wxYw6twN)_readerr$ is_masterr=get_master_address rotate_slavesrr )r(slaves r_connect_retryz(SentinelManagedConnection._connect_retry/s <<     ) )//(<(<(O(O(Q"QR R R#33AAC  e!%!777 #R R 7& D % $sxA B=B B=B!B=:B6>B#?B6B=B'B%B'B=!B=#B6%B'' B30B=2B33 B=clK|jj|jdd{S7w)Nc,tjdS)Nr)asynciosleep)errors rz3SentinelManagedConnection.connect..?s'--*r)retrycall_with_retryrEr(s rr8z!SentinelManagedConnection.connect<s3ZZ//    *    s +424T)disconnect_on_errordisable_decodingtimeoutrOcK t||||d{S7#t$r<|jjr$|j d{7t dwxYww)N)rPrQrOz"The previous master is now a slave)r&r;rr$rA disconnectr)r(rPrQrOr*s rr;z'SentinelManagedConnection.read_responseBsv .!1$7/   ##-- oo'''%&JKK  s1A)!!A)!2A&AA&&A))FN) rrrr'r4r=rEr8boolrfloatr; __classcell__r*s@rr"r"s\#5 % "'#' 04 % &e_ rr"c eZdZy)SentinelManagedSSLConnectionNrrrrrYrY[rrrYcTeZdZdZfdZdZfdZdeffd 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 ^|jd|jddrtnt|d<|jdd|_|jdd|_t |di|tj||jd<||_ ||_ d|_ d|_y) Nconnection_classsslFrATr9r$r)getr%rYr"rAr9r&r'weakrefproxyconnection_kwargsr.sentinel_managermaster_addressslave_rr_counter)r(r.rcr)r*s rr'zSentinelConnectionPool.__init__gs%+ZZ zz%' )* & !"  K6 & +=u E "6"4;MM$4G01( 0" $rcx|jjd|jd|jxrdxsddS)Nr,(masterrDz)>)r*rr.rArNs rr4zSentinelConnectionPool.__repr__wsC~~&&'))*!DNN,Gx,R7+SSU W rc>t|d|_d|_yr?)r&resetrdre)r(r*s rrjzSentinelConnectionPool.reset}s  " $r connectionc|j xs3|jxr%|j|j|jfk(}|xrt||Sr?)rArdr/r0r&owns_connection)r(rkcheckr*s rrmz&SentinelConnectionPool.owns_connectionsRNN" NN Xt22z 6XX <0<>""n4&4#ooo>>>X ?s!)A2A.;A2'A0(A20A2returncK|jj|jd{}|r|j't j dt |dz |_tt |D]6}|jdzt |z|_||j}|8 |jd{td|j77!#t$rY'wxYww)zRound-robin slave balancerNrzNo slave found for ) rcdiscover_slavesr.rerandomrandintlenrangerBrr )r(slaves_rDs rrCz$SentinelConnectionPool.rotate_slavess,,<)>)Bc&k(Q%t445    //11 1!#6t7H7H6K!LMMP2"   sF)C9C&BC93C*C(C*C9(C** C63C95C66C9) rrr__doc__r'r4rjr rmrBrrCrVrWs@rr[r[_s6%  % =*= N]Nrr[ceZdZdZ ddZdZdZdedede fd Z defd Z d e e deeeeffd Zdedeeeeffd ZeefdedeedeefdZeefdedeedeefdZy)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 |5|jDcic]\}}|jds||}}}||_|Dcgc]\}}td||d|jc}}|_||_||_ycc}}wcc}}w)Nsocket_)r/r0r)items startswithsentinel_kwargsr sentinelsmin_other_sentinelsrb) r(rrrrbkvhostnamer0s rr'zSentinel.__init__s  "!2!8!8!:Aall9>U1O /#, $  Cxd Cd.B.B C $7 !2  sA>A>"Bc Kt|jdd}d|jvr|jd|r8t j |j j|i|d{y|j Dcgc]'}tj|j|i|)}}tj|d{y7\cc}w7 w)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) rTr_keysr%rvchoicerexecute_commandrHTaskgather)r(argsr)rsentineltaskss rrzSentinel.execute_commands FJJvu-. V[[] " JJv  ?&--/??PP P P!% 5X55tFvFGE..%( ( ( Q )s0A3C5C6C ,C5C C CCcg}|jD]F}|j|jjdd|jjdH|jj ddj |dS)Nr/:r0z )rappendr$rbr*rjoin)r(sentinel_addressesrs rr4zSentinel.__repr__s H  % %++==fEFa++==fEFH   ..))*,sxx@R7S6TTVWWrstater.rrcJ|dr |ds|dry|d|jkryy)NrAis_sdownis_odownFznum-other-sentinelsT)r)r(rr.s rcheck_master_statezSentinel.check_master_states5[!U:%6% :K & '$*B*B BrcKt}t|jD]|\}} |jd{}|j|}|s3|j||sF||jdc|jd<|j|<|d|dfcSd}t|dkDrddj|}td ||7#tt f$r }|j |d|Yd}~d}~wwxYww) 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 - ripr0z : z, zNo master found for ) list enumeratersentinel_mastersrrrr_rrxrr) r(r.collected_errors sentinel_normasterser error_infos rrqzSentinel.discover_masters 6%.t~~%> 2 !K  ( 9 9 ;;KK -E00 ENN1%?q!4>>+#>T{E&M11 2  1 $tyy)9:; sK&D CCCD D (A-D CD&D<D DD rzc`g}|D]&}|ds|dr|j|d|df(|S)z1Remove slaves that are in an ODOWN or SDOWN staterrrr0)r)r(rz slaves_aliverDs r filter_slaveszSentinel.filter_slavessM  >EZ E*$5   teFm < = >rcK|jD]3} |j|d{}|j |}|s1|cSgS7#tttf$rYPwxYww)z;Returns a list of alive slaves for service ``service_name``N)rsentinel_slavesrrrr)r(r.rrzs rruzSentinel.discover_slaves$sr H '77 EE''/F   F#]LA  s=A#A AA A#A#A  A A#A  A# redis_classconnection_pool_classc zd|d<t|j}|j|||||fi|S)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. TrAr$dictrbupdater(r.rrr)rbs r master_forzSentinel.master_for2sO:#{ !7!78  (1d&7  rc zd|d<t|j}|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. FrArrrs r slave_forzSentinel.slave_forXsO0${ !7!78  (1d&7  r)rN)rrrr|r'rr4rstrrTrrqrrrrr rrur r[r rrrrrr~r~s> 3,(XCDW#W: w'  % J./ 0    % J./ 0 "$)>T $ $ %[$  $$:; $ R$)>T   %[  $$:;  rr~)!rHrvr`typingrrrrrrr redis.asyncio.clientr redis.asyncio.connectionr r r rredis.commandsrredis.exceptionsrrrr redis.utilsrrr r"rYr[r~rrrrs TTT& 1XX$ /   > >B #