/
opt
/
alt
/
python27
/
lib
/
python2.7
/
site-packages
/
redis
/
up file
home
� { vhc @ s� d d l Z d d l Z d d l m Z d d l m Z m Z d d l m Z m Z m Z m Z d d l m Z m Z m Z d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d S( i����N( t Redis( t ConnectionPoolt Connection( t ConnectionErrort ResponseErrort ReadOnlyErrort TimeoutError( t iteritemst nativestrt xranget MasterNotFoundErrorc B s e Z RS( ( t __name__t __module__( ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR s t SlaveNotFoundErrorc B s e Z RS( ( R R ( ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR s t SentinelManagedConnectionc B s5 e Z d � Z d � Z d � Z d � Z d � Z RS( c K s, | j d � | _ t t | � j | � d S( Nt connection_pool( t popR t superR t __init__( t selft kwargs( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR s c C sU | j } d t | � j | j f } | j rQ d | j | j f } | | } n | S( Ns %s<service=%s%%s>s ,host=%s,port=%s( R t typeR t service_namet hostt port( R t poolt st host_info( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyt __repr__ s c C sl | \ | _ | _ t t | � j � | j j rh | j d � t | j � � d k rh t d � � qh n d S( Nt PINGt PONGs PING failed( R R R R t connectR t check_connectiont send_commandR t read_responseR ( R t address( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyt connect_to s c C s~ | j r d S| j j r2 | j | j j � � nH x? | j j � D]. } y | j | � SWqB t k ro qB qB XqB Wt � d S( N( t _sockR t is_masterR$ t get_master_addresst rotate_slavesR R ( R t slave( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR ( s c C sW y t t | � j � SWn9 t k rR | j j rL | j � t d � � n � n Xd S( Ns" The previous master is now a slave( R R R" R R R& t disconnectR ( R ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR" 5 s ( R R R R R$ R R" ( ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR s t SentinelConnectionPoolc B sD e Z d Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s� Sentinel backed connection pool. If ``check_connection`` flag is set to True, SentinelManagedConnection sends a PING command right after establishing the connection. c K s� | j d t � | d <| j d t � | _ | j d t � | _ t t | � j | � t j | � | j d <| | _ | | _ d S( Nt connection_classR& R R ( t getR R t TrueR& t FalseR R R+ R t weakreft proxyt connection_kwargsR t sentinel_manager( R R R3 R ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR L s c C s, d t | � j | j | j r$ d p' d f S( Ns %s<service=%s(%s)t masterR) ( R R R R& ( R ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR V s c C s) t t | � j � d | _ d | _ d S( N( R R+ t resett Nonet master_addresst slave_rr_counter( R ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR5 ] s c C sP | j p+ | j o+ | j | j | j f k } t t | � } | oO | j | � S( N( R& R7 R R R R+ t owns_connection( R t connectiont checkt parent( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR9 b s c C sP | j j | j � } | j rL | j | k rL | | _ | j d t � qL n | S( Nt inuse_connections( R3 t discover_masterR R& R7 R* R/ ( R R7 ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR' i s c c s� | j j | j � } | r� | j d k rL t j d t | � d � | _ n xI t t | � � D]2 } | j d t | � | _ | | j } | Vq_ Wn y | j � VWn t k r� n Xt d | j � � d S( s Round-robin slave balanceri i s No slave found for %rN( R3 t discover_slavesR R8 R6 t randomt randintt lenR R' R R ( R t slavest _R) ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR( t s " ( R R t __doc__R R R5 R9 R' R( ( ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR+ D s t Sentinelc B sh e Z d Z d d d � Z d � Z d � Z d � Z d � Z d � Z e e d � Z e e d � Z RS( sr 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) >>> master.set('foo', 'bar') >>> slave = sentinel.slave_for('mymaster', socket_timeout=0.1) >>> 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. i c K su | d k r% d � t | � D� } n | | _ g | D]! \ } } t | | | j � ^ q5 | _ | | _ | | _ d S( Nc S s. i | ]$ \ } } | j d � r | | � q S( t socket_( t startswith( t .0t kt v( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pys <dictcomp>� s ( R6 R t sentinel_kwargsR t sentinelst min_other_sentinelsR2 ( R RM RN RL R2 t hostnameR ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR � s . c C se g } x< | j D]1 } | j d | j j d | j j d f � q Wd t | � j d j | � f S( Ns %s:%sR R s %s<sentinels=[%s]>t ,( RM t appendR R2 R R t join( R t sentinel_addressest sentinel( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR � s c C s> | d s | d s | d r# t S| d | j k r: t St S( NR& t is_sdownt is_odowns num-other-sentinels( R/ RN R. ( R t stateR ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyt check_master_state� s c C s� x� t | j � D]� \ } } y | j � } Wn t t f k rH q n X| j | � } | r | j | | � r | | j d | j d <| j | <| d | d f Sq Wt d | f � � d S( s� 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. i t ipR s No master found for %rN( t enumerateRM t sentinel_mastersR R R- RX R ( R R t sentinel_noRT t mastersRW ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR> � s "c C sP g } xC | D]; } | d s | d r- q n | j | d | d f � q W| S( s1 Remove slaves that are in an ODOWN or SDOWN stateRV RU RY R ( RQ ( R RC t slaves_aliveR) ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyt filter_slaves� s c C sd x] | j D]R } y | j | � } Wn t t t f k rB q n X| j | � } | r | Sq Wg S( s; Returns a list of alive slaves for service ``service_name``( RM t sentinel_slavesR R R R_ ( R R RT RC ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR? � s c K s? t | d <t | j � } | j | � | d | | | | � � S( sF Returns a redis client instance for the ``service_name`` master. A SentinelConnectionPool class is used to retrive 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 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. R& R ( R. t dictR2 t update( R R t redis_classt connection_pool_classR R2 ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyt master_for� s c K s? t | d <t | j � } | j | � | d | | | | � � S( s� Returns redis client instance for the ``service_name`` slave(s). A SentinelConnectionPool class is used to retrive the slave's address before establishing a new connection. By default clients will be a 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. R& R ( R/ Ra R2 Rb ( R R Rc Rd R R2 ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyt slave_for s N( R R RE R6 R R RX R> R_ R? R R+ Re Rf ( ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyRF � s ( R@ R0 t redis.clientR t redis.connectionR R t redis.exceptionsR R R R t redis._compatR R R R R R R+ t objectRF ( ( ( s? /opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyt <module> s " 1C