ó O'—^c@sôddlZddlZddlZddlmZddlmZmZddlm Z m Z m Z ddl m Z mZmZde fd„ƒYZde fd „ƒYZd efd „ƒYZd efd „ƒYZdefd„ƒYZdS(iÿÿÿÿN(t StrictRedis(tConnectionPoolt Connection(tConnectionErrort ResponseErrort ReadOnlyError(t iteritemst nativestrtxrangetMasterNotFoundErrorcBseZRS((t__name__t __module__(((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyR stSlaveNotFoundErrorcBseZRS((R R (((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyR stSentinelManagedConnectioncBs5eZd„Zd„Zd„Zd„Zd„ZRS(cKs,|jdƒ|_tt|ƒj|dS(Ntconnection_pool(tpopRtsuperR t__init__(tselftkwargs((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyRscCsU|j}dt|ƒj|jf}|jrQd|j|jf}||}n|S(Ns%ss,host=%s,port=%s(RttypeR t service_namethosttport(Rtpooltst host_info((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyt__repr__s    cCsl|\|_|_tt|ƒjƒ|jjrh|jdƒt|j ƒƒdkrht dƒ‚qhndS(NtPINGtPONGs PING failed( RRRR tconnectRtcheck_connectiont send_commandRt read_responseR(Rtaddress((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyt connect_to s   cCs~|jr dS|jjr2|j|jjƒƒnHx?|jjƒD].}y|j|ƒSWqBtk roqBqBXqBWt‚dS(N(t_sockRt is_masterR#tget_master_addresst rotate_slavesRR (Rtslave((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyR(s    cCsWytt|ƒjƒSWn9tk rR|jjrL|jƒtdƒ‚n‚nXdS(Ns"The previous master is now a slave(RR R!RRR%t disconnectR(R((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyR!5s   (R R RRR#RR!(((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyR s     tSentinelConnectionPoolcBsDeZdZd„Zd„Zd„Zd„Zd„Zd„ZRS(s¸ Sentinel backed connection pool. If ``check_connection`` flag is set to True, SentinelManagedConnection sends a PING command right after establishing the connection. cKs‚|jdtƒ|d<|jdtƒ|_|jdtƒ|_tt|ƒj |t j |ƒ|j d<||_ ||_dS(Ntconnection_classR%RR(tgetR RtTrueR%tFalseRRR*Rtweakreftproxytconnection_kwargsRtsentinel_manager(RRR2R((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyRLs cCs,dt|ƒj|j|jr$dp'dfS(Ns%s>> 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') '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. ic KsŸ|dkrOtgt|ƒD]'\}}|jdƒr||f^qƒ}n||_g|D]!\}}t|||j^q_|_||_||_dS(Ntsocket_( R5tdictRt startswithtsentinel_kwargsRt sentinelstmin_other_sentinelsR1( RRJRKRIR1tktvthostnameR((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyR¨s ' . cCseg}x<|jD]1}|jd|jjd|jjdfƒqWdt|ƒjdj|ƒfS(Ns%s:%sRRs%st,(RJtappendRR1RR tjoin(Rtsentinel_addressestsentinel((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyR¸s   cCs>|d s|ds|dr#tS|d|jkr:tStS(NR%tis_sdowntis_odownsnum-other-sentinels(R.RKR-(RtstateR((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pytcheck_master_stateÃs cCs¹xŸt|jƒD]Ž\}}y|jƒ}Wntk rBqnX|j|ƒ}|r|j||ƒr||jd|jd<|j|<|d|dfSqWtd|fƒ‚dS(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. itipRsNo master found for %rN(t enumerateRJtsentinel_mastersRR,RWR (RRt sentinel_noRStmastersRV((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyR8Ës "cCsPg}xC|D];}|ds |dr-q n|j|d|dfƒq W|S(s1Remove slaves that are in an ODOWN or SDOWN stateRURTRXR(RP(RR=t slaves_aliveR(((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyt filter_slavesàs  cCsaxZ|jD]O}y|j|ƒ}Wnttfk r?q nX|j|ƒ}|r |Sq WgS(s;Returns a list of alive slaves for service ``service_name``(RJtsentinel_slavesRRR^(RRRSR=((s0/tmp/pip-unpacked-wheel-5e_doG/redis/sentinel.pyR9éscKs?t|ds   1G