U
    dG4                     @   s   d dl Z d dlZd dlZd dlmZmZmZmZmZm	Z	 d dl
mZ d dlmZmZmZmZ d dlmZ d dlmZmZmZmZ d dlmZ G dd	 d	eZG d
d deZG dd deZG dd deeZG dd deZG dd deZdS )    N)AsyncIteratorIterableMappingSequenceTupleType)Redis)
ConnectionConnectionPool
EncodableTSSLConnection)AsyncSentinelCommands)ConnectionErrorReadOnlyErrorResponseErrorTimeoutError)str_if_bytesc                   @   s   e Zd ZdS )MasterNotFoundErrorN__name__
__module____qualname__ r   r   :/tmp/pip-unpacked-wheel-f5h5_hbx/redis/asyncio/sentinel.pyr      s   r   c                   @   s   e Zd ZdS )SlaveNotFoundErrorNr   r   r   r   r   r      s   r   c                       sL   e Zd Z fddZdd Z fddZdd Zded
 fddZ  Z	S )SentinelManagedConnectionc                    s   | d| _t jf | d S )Nconnection_pool)popr   super__init__)selfkwargs	__class__r   r   r      s    z"SentinelManagedConnection.__init__c                 C   sD   | j }| jj d|j }| jr<d| j d| j }||7 }|d S )N	<service=z,host=z,port=>)r   r#   r   service_namehostport)r    poolsZ	host_infor   r   r   __repr__   s    z"SentinelManagedConnection.__repr__c                    sV   |\| _ | _t  I d H  | jjrR| dI d H  t|  I d H dkrRt	dd S )NZPINGZPONGzPING failed)
r'   r(   r   connectr   check_connectionZsend_commandr   read_responser   )r    addressr"   r   r   
connect_to'   s    z$SentinelManagedConnection.connect_toc              	      s   | j r
d S | jjr0| | j I d H I d H  nN| j 2 z<3 d H W }z| |I d H W   S  tk
rt   Y q:Y q:X q:6 td S N)Z_readerr   	is_masterr0   get_master_addressrotate_slavesr   r   )r    slaver   r   r   r,   /   s    z!SentinelManagedConnection.connectFdisable_decodingc                    sP   zt  j|dI d H W S  tk
rJ   | jjrD|  I d H  td Y nX d S )Nr6   z"The previous master is now a slave)r   r.   r   r   r2   
disconnectr   )r    r7   r"   r   r   r.   <   s    z'SentinelManagedConnection.read_response)F)
r   r   r   r   r+   r0   r,   boolr.   __classcell__r   r   r"   r   r      s
   r   c                   @   s   e Zd ZdS )SentinelManagedSSLConnectionNr   r   r   r   r   r;   K   s   r;   c                       s\   e Zd ZdZ fddZdd Z fddZed fd	d
Zdd Z	e
dddZ  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                    sv   | d|ddrtnt|d< |dd| _|dd| _t jf | t	| | j
d< || _|| _d | _d | _d S )NZconnection_classsslFr2   Tr-   r   )getr   r;   r   r2   r-   r   r   weakrefproxyconnection_kwargsr&   sentinel_managermaster_addressslave_rr_counter)r    r&   rB   r!   r"   r   r   r   W   s    
zSentinelConnectionPool.__init__c                 C   s&   | j j d| j d| jrdpd dS )Nr$   (Zmasterr5   z)>)r#   r   r&   r2   r    r   r   r   r+   g   s    $zSentinelConnectionPool.__repr__c                    s   t    d | _d | _d S r1   )r   resetrC   rD   rF   r"   r   r   rG   m   s    
zSentinelConnectionPool.reset)
connectionc                    s0   | j  p| j o| j|j|jfk}|o.t |S r1   )r2   rC   r'   r(   r   owns_connection)r    rH   checkr"   r   r   rI   r   s    z&SentinelConnectionPool.owns_connectionc                    s@   | j | jI d H }| jr<| j|kr<|| _| jddI d H  |S )NF)Zinuse_connections)rB   discover_masterr&   r2   rC   r8   )r    rC   r   r   r   r3   x   s    
z)SentinelConnectionPool.get_master_address)returnc                 C  s   | j | jI dH }|rn| jdkr8tdt|d | _tt|D ](}| jd t| | _|| j }|V  qDz|  I dH V  W n t	k
r   Y nX t
d| jdS )zRound-robin slave balancerNr      zNo slave found for )rB   discover_slavesr&   rD   randomrandintlenranger3   r   r   )r    slaves_r5   r   r   r   r4      s    

z$SentinelConnectionPool.rotate_slaves)r   r   r   __doc__r   r+   rG   r	   rI   r3   r   r4   r:   r   r   r"   r   r<   O   s   
r<   c                   @   s   e Zd ZdZdddZdd Zdd	 Zeee	d
ddZ
edddZee eeeef  dddZeeeeef  dddZeefeee ee dddZeefeee ee dddZdS )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.
    r   Nc                    sD   |d krdd |  D }| _ fdd|D  _| _| _d S )Nc                 S   s    i | ]\}}| d r||qS )Zsocket_)
startswith).0kvr   r   r   
<dictcomp>   s    
  z%Sentinel.__init__.<locals>.<dictcomp>c                    s&   g | ]\}}t f ||d  jqS ))r'   r(   )r   sentinel_kwargs)rX   hostnamer(   rF   r   r   
<listcomp>   s   z%Sentinel.__init__.<locals>.<listcomp>)itemsr\   	sentinelsmin_other_sentinelsrA   )r    r`   ra   r\   rA   r   rF   r   r      s    	
zSentinel.__init__c                    sp   t dd}d kr&d |rR fdd| jD }tj| I dH  nt| jj	 I dH  d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.
        onceFc                    s   g | ]}t |j qS r   )asyncioZTaskexecute_command)rX   sentinelargsr!   r   r   r^      s   z,Sentinel.execute_command.<locals>.<listcomp>NT)
r9   r>   keysr   r`   rc   ZgatherrO   choicerd   )r    rg   r!   rb   Ztasksr   rf   r   rd      s    
zSentinel.execute_commandc                 C   sN   g }| j D ](}||jjd  d|jjd   q
| jj dd| dS )Nr'   :r(   z<sentinels=[,z]>)r`   appendr   rA   r#   r   join)r    Zsentinel_addressesre   r   r   r   r+      s    
zSentinel.__repr__)stater&   rL   c                 C   s2   |d r|d s|d rdS |d | j k r.dS dS )Nr2   is_sdownis_odownFznum-other-sentinelsT)ra   )r    rn   r&   r   r   r   check_master_state   s
    zSentinel.check_master_state)r&   c              
      s   t | jD ]\}}z| I dH }W n ttfk
r@   Y q
Y nX ||}|r
| ||r
|| jd  | jd< | j|< |d |d f  S q
td|dS )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.
        Nr   ipr(   zNo master found for )	enumerater`   Zsentinel_mastersr   r   r>   rq   r   )r    r&   Zsentinel_nore   Zmastersrn   r   r   r   rK      s    

zSentinel.discover_master)rS   rL   c                 C   s:   g }|D ],}|d s|d rq| |d |d f q|S )z1Remove slaves that are in an ODOWN or SDOWN staterp   ro   rr   r(   )rl   )r    rS   Zslaves_aliver5   r   r   r   filter_slaves  s    zSentinel.filter_slaves)r&   rL   c                    sZ   | j D ]N}z||I dH }W n tttfk
r<   Y qY nX | |}|r|  S qg S )z;Returns a list of alive slaves for service ``service_name``N)r`   Zsentinel_slavesr   r   r   rt   )r    r&   re   rS   r   r   r   rN     s    



zSentinel.discover_slaves)r&   redis_classconnection_pool_classc                 K   s0   d|d< t | j}|| |||| f|d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.
        Tr2   r   dictrA   updater    r&   ru   rv   r!   rA   r   r   r   
master_for  s    

 zSentinel.master_forc                 K   s0   d|d< t | j}|| |||| f|d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.
        Fr2   rw   rx   r{   r   r   r   	slave_forB  s    

 zSentinel.slave_for)r   N)r   r   r   rU   r   rd   r+   ry   strr9   rq   rK   r   r   r   r   r   rt   rN   r   r<   r   r|   r}   r   r   r   r   rV      s8     
	)rV   ) rc   rO   r?   typingr   r   r   r   r   r   Zredis.asyncio.clientr   Zredis.asyncio.connectionr	   r
   r   r   Zredis.commandsr   Zredis.exceptionsr   r   r   r   Zredis.utilsr   r   r   r   r;   r<   rV   r   r   r   r   <module>   s    1E