o )r%rrhostport)r"s host_inforrr__repr__#s z"SentinelManagedConnection.__repr__cs*|\|_|_|j|jjddIdHdS)NF) check_healthretry_socket_connect)r(r)connect_check_healthrcheck_connection)r"addressrrr connect_to*s  z$SentinelManagedConnection.connect_toc sz|jrdS|jjr||jIdHIdHdS|j2z3dHW}z ||IdHWSty9Yqw6tN)_readerr is_masterr2get_master_address rotate_slavesrr)r"slaverrr_connect_retry1s  z(SentinelManagedConnection._connect_retrycs|j|jddIdHS)NcSs tdS)Nr)asynciosleep)errorrrrAs z3SentinelManagedConnection.connect..)retrycall_with_retryr9r"rrrconnect>s  z!SentinelManagedConnection.connectFNT)disconnect_on_error push_requestdisable_decodingtimeoutrBrCcsNztj||||dIdHWSty&|jjr%|IdHtdw)N)rDrErBrCz"The previous master is now a slave)r read_responserrr5 disconnectr)r"rDrErBrCr$rrrFDs z'SentinelManagedConnection.read_response)FN) rrrr!r,r2r9rAboolrfloatrF __classcell__rrr$rrs(  rc@r)SentinelManagedSSLConnectionNrrrrrrK_rrKcs\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_classsslFr5Tr0rr)getrrKrr5r0r r!weakrefproxyconnection_kwargs service_namesentinel_managermaster_addressslave_rr_counter)r"rSrTr#r$rrr!ks  zSentinelConnectionPool.__init__c Cs2d|jjd|jjd|jd|jrdpdd S)Nr&r'z (service=(masterr8z))>)r%rrrSr5r@rrrr,}s  zSentinelConnectionPool.__repr__cstd|_d|_dSr3)r resetrUrVr@r$rrrYs  zSentinelConnectionPool.reset connectioncs0|j p|jo|j|j|jfk}|ot|Sr3)r5rUr(r)r owns_connection)r"rZcheckr$rrr[sz&SentinelConnectionPool.owns_connectioncsB|j|jIdH}|jr|j|kr||_|jddIdH|S)NF)inuse_connections)rTdiscover_masterrSr5rUrG)r"rUrrrr6s 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 ) rTdiscover_slavesrSrVrandomrandintlenranger6rr)r"slaves_r8rrrr7s   z$SentinelConnectionPool.rotate_slaves) rrr__doc__r!r,rYr r[r6rr7rJrrr$rrLcs   rLc@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 sJ|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)rlhostnamer)r@rr sz%Sentinel.__init__..)itemsrp sentinelsmin_other_sentinelsrR_force_master_ip)r"rtrurpforce_master_iprRrr@rr!s   zSentinel.__init__cstdd}tdd}|r-t|jjiIdH}|r'|gS|r+dSdSfdd|jD}tj|IdH}|rD|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_responsesNTcs"g|] }t|jiqSr)r:Taskexecute_command)rlsentinelargsr#rrrrsz,Sentinel.execute_command..) rHrrbchoicertr{r:gatherall)r"r~r#rxryresponsetasks responsesrr}rr{s&    zSentinel.execute_commandcCsXg}|jD]}||jjdd|jjdqd|jd|jjdd|dS) Nr(:r)r&r'z (sentinels=[,z])>)rtappendrrRr%rjoin)r"sentinel_addressesr|rrrr,s  zSentinel.__repr__staterSr_cCs2|dr |ds |drdS|d|jkrdSdS)Nr5is_sdownis_odownFznum-other-sentinelsT)ru)r"rrSrrrcheck_master_state s zSentinel.check_master_statec st}t|jD][\}}z |IdH}Wnttfy4}z||d|WYd}~q d}~ww||}|rd|||rd||jd|jd<|j|<|j durX|j n|d}||dfSq d} t |dkrudd |} 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 enumeratertsentinel_mastersrrrrOrrvrdrr) r"rScollected_errors sentinel_nor|masterserr error_inforrrr^s2    zSentinel.discover_masterrfcCs:g}|D]}|ds|drq||d|dfq|S)z1Remove slaves that are in an ODOWN or SDOWN staterrrr))r)r"rf slaves_aliver8rrr filter_slaves6s zSentinel.filter_slavesc sV|jD]$}z ||IdH}Wn tttfyYqw||}|r(|SqgS)z;Returns a list of alive slaves for service ``service_name``N)rtsentinel_slavesrrrr)r"rSr|rfrrrraAs  zSentinel.discover_slaves redis_classconnection_pool_classcK8d|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. Tr5dictrRupdate from_poolr"rSrrr#rRrrrr master_forOs    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. Fr5rrrrr slave_forvs    zSentinel.slave_for)rNN)rrrrhr!r{r,rstrrHrr^rrrrr rrar rLrrrrrrrrisL   #    *ri)r:rbrPtypingrrrrrrrredis.asyncio.clientr redis.asyncio.connectionr r r r redis.commandsrredis.exceptionsrrrrrrrrKrLrirrrrs$  AG