o rPfv7@sddlZddlZddlZddlmZmZmZmZmZm Z m Z ddl m Z ddl mZmZmZmZddlmZddlmZmZmZmZddlmZGdd d eZGd d d eZGd d d eZGdddeeZGdddeZGdddeZ dS)N) AsyncIteratorIterableMappingOptionalSequenceTupleType)Redis) ConnectionConnectionPool EncodableT SSLConnection)AsyncSentinelCommands)ConnectionError ReadOnlyError ResponseError TimeoutError) str_if_bytesc@ eZdZdS)MasterNotFoundErrorN__name__ __module__ __qualname__rrW/var/www/html/humari/django-venv/lib/python3.10/site-packages/redis/asyncio/sentinel.pyrrc@r)SlaveNotFoundErrorNrrrrrrrrc sxeZdZfddZddZfddZddZd d Z dd d ddede e de e de effddZ Z S)SentinelManagedConnectionc s"|d|_tjdi|dS)Nconnection_poolr)poprsuper__init__)selfkwargs __class__rrr"s z"SentinelManagedConnection.__init__cCsD|j}|jjd|j}|jrd|jd|j}||7}|dS)N )rr&r service_namehostport)r#pools host_inforrr__repr__s z"SentinelManagedConnection.__repr__cs\|\|_|_tIdH|jjr*|dIdHt|IdHdkr,t ddSdS)NPINGPONGz PING failed) r*r+r!connectrcheck_connection send_commandr read_responser)r#addressr%rr connect_to's z$SentinelManagedConnection.connect_toc sz|jrdS|jjr||jIdHIdHdS|j2z3dHW}z ||IdHWSty9Yqw6tN)_readerr is_masterr7get_master_address rotate_slavesrr)r#slaverrr_connect_retry/s  z(SentinelManagedConnection._connect_retrycs|j|jddIdHS)NcSs tdS)Nr)asynciosleep)errorrrr?s z3SentinelManagedConnection.connect..)retrycall_with_retryr>r#rrrr2<s  z!SentinelManagedConnection.connectFNT)disconnect_on_error push_requestdisable_decodingtimeoutrFrGcsNztj||||dIdHWSty&|jjr%|IdHtdw)N)rHrIrFrGz"The previous master is now a slave)r!r5rrr: disconnectr)r#rHrIrFrGr%rrr5Bs z'SentinelManagedConnection.read_response)FN) rrrr"r/r7r>r2boolrfloatr5 __classcell__rrr%rrs(   rc@r)SentinelManagedSSLConnectionNrrrrrrN]rrNcs\eZdZdZfddZddZfddZdeffd d Zd d Z d e fddZ Z 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 sz|d|ddr tnt|d<|dd|_|dd|_tjdi|t ||j d<||_ ||_ d|_ d|_dS) Nconnection_classsslFr:Tr3rr)getr rNrr:r3r!r"weakrefproxyconnection_kwargsr)sentinel_managermaster_addressslave_rr_counter)r#r)rVr$r%rrr"is  zSentinelConnectionPool.__init__cCs&|jjd|jd|jrdpddS)Nr'(masterr=z)>)r&rr)r:rErrrr/ys  zSentinelConnectionPool.__repr__cstd|_d|_dSr8)r!resetrWrXrEr%rrr[s  zSentinelConnectionPool.reset connectioncs0|j p|jo|j|j|jfk}|ot|Sr8)r:rWr*r+r!owns_connection)r#r\checkr%rrr]sz&SentinelConnectionPool.owns_connectioncsB|j|jIdH}|jr|j|kr||_|jddIdH|S)NF)inuse_connections)rVdiscover_masterr)r:rWrJ)r#rWrrrr;s z)SentinelConnectionPool.get_master_addressreturncCs|j|jIdH}|r8|jdurtdt|d|_tt|D]}|jdt||_||j}|Vq#z |IdHVWn t yKYnwt d|j)zRound-robin slave balancerNrzNo slave found for ) rVdiscover_slavesr)rXrandomrandintlenranger;rr)r#slaves_r=rrrr<s   z$SentinelConnectionPool.rotate_slaves) rrr__doc__r"r/r[r r]r;rr<rMrrr%rrOas   rOc@seZdZdZ  dddZddZdd Zd ed ed e fd dZ d efddZ de e d eeeeffddZd ed eeeeffddZeefd edeedeefddZeefd edeedeefddZdS)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 sD|dur dd|D}|_fdd|D_|_|_dS)NcSs i|] \}}|dr||qS)socket_) startswith).0kvrrr s z%Sentinel.__init__..cs&g|]\}}td||djqS))r*r+r)r sentinel_kwargs)rnhostnamer+rErr sz%Sentinel.__init__..)itemsrr sentinelsmin_other_sentinelsrU)r#rvrwrrrUrrErr"s   zSentinel.__init__csxtdd}dvrd|r't|jjiIdHdSfdd|jD}tj |IdHdS)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. onceFNcs"g|] }t|jiqSr)r?Taskexecute_command)rnsentinelargsr$rrrtsz,Sentinel.execute_command..T) rKrRkeysr rdchoicervrzr?gather)r#r}r$rxtasksrr|rrzs   zSentinel.execute_commandcCsNg}|jD]}||jjdd|jjdq|jjdd|dS)Nr*:r+z )rvappendrrUr&rjoin)r#sentinel_addressesr{rrrr/s  zSentinel.__repr__stater)racCs2|dr |ds |drdS|d|jkrdSdS)Nr:is_sdownis_odownFznum-other-sentinelsT)rw)r#rr)rrrcheck_master_states zSentinel.check_master_statec st}t|jD]Q\}}z |IdH}Wnttfy4}z||d|WYd}~q d}~ww||}|rZ|||rZ||jd|jd<|j|<|d|dfSq d}t |dkrkdd |}t d ||) 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 enumeratervsentinel_mastersrrrrRrrfrr) r#r)collected_errors sentinel_nor{masterser error_inforrrr`s*   zSentinel.discover_masterrhcCs:g}|D]}|ds|drq||d|dfq|S)z1Remove slaves that are in an ODOWN or SDOWN staterrrr+)r)r#rh slaves_aliver=rrr filter_slavess zSentinel.filter_slavesc sV|jD]$}z ||IdH}Wn tttfyYqw||}|r(|SqgS)z;Returns a list of alive slaves for service ``service_name``N)rvsentinel_slavesrrrr)r#r)r{rhrrrrc&s  zSentinel.discover_slaves redis_classconnection_pool_classcK8d|d<t|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. Tr:dictrUupdate from_poolr#r)rrr$rUrrrr master_for4s    zSentinel.master_forcKr)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:rrrrr slave_forYs    zSentinel.slave_for)rN)rrrrjr"rzr/rstrrKrr`rrrrr rrcr rOrrrrrrrrksJ      (rk)!r?rdrStypingrrrrrrrredis.asyncio.clientr redis.asyncio.connectionr r r r redis.commandsrredis.exceptionsrrrr redis.utilsrrrrrNrOrkrrrrs$   CE