Ë
|
|
çúh÷ ã ó´ d dl Z d dlmZmZ d dlmZ d dlmZ d dl m
|
Z
|
m Z d dl m Z mZ dZdZ G d d
|
e« Z G d d e« Z G d de« Z G d de« Zy)é N)ÚABCÚabstractmethod)Ú WeightedList)ÚState)Ú DatabasesÚ SyncDatabase)ÚNoValidDatabaseExceptionÚ TemporaryUnavailableExceptioné
|
é c ó< e Zd Zedefd« Zededdfd« Zy)ÚFailoverStrategyÚreturnc ó y)z.Select the database according to the strategy.N© ©Úselfs õi H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/multidb/failover.pyÚdatabasezFailoverStrategy.database ó ð ó Ú databasesNc ó y)z&Set the database strategy operates on.Nr ©r r s r Ú set_databasesz FailoverStrategy.set_databases r r )Ú__name__Ú
|
__module__Ú __qualname__r r r r r r r r r r s= Øð ,ò ó ð ð ð yð °Tò ó ñ r r c ó e Zd Zeedefd« « Zeedefd« « Zeede fd« « Z
|
ede fd« Z y)ÚFailoverStrategyExecutorr c ó y)z The number of failover attempts.Nr r s r Úfailover_attemptsz*FailoverStrategyExecutor.failover_attempts ó ð r c ó y)z$The delay between failover attempts.Nr r s r Úfailover_delayz'FailoverStrategyExecutor.failover_delay# r# r c ó y)zThe strategy to execute.Nr r s r Ústrategyz!FailoverStrategyExecutor.strategy) r# r c ó y)z Execute the failover strategy.Nr r s r Úexecutez FailoverStrategyExecutor.execute/ r r N) r r r Úpropertyr Úintr" Úfloatr% r r' r r) r r r r r s
Ø Øð 3ò ó ó ð ð Øð ò ó ó ð ð Øð Ð*ò ó ó ð ð ð ò ó ñ r r c ó4 e Zd ZdZddZdefdZdeddfdZy) ÚWeightBasedFailoverStrategyz6
|
Failover strategy based on database weights.
|
r Nc ó" t « | _ y ©N)r Ú
|
_databasesr s r Ú__init__z$WeightBasedFailoverStrategy.__init__: s Ü&.r c ó | j D ]0 \ }}|j j t j k( s.|c S t d« )Nz-No valid database available for communication)r1 ÚcircuitÚstateÚCBStateÚCLOSEDr )r r Ú_s r r z$WeightBasedFailoverStrategy.database= sD Ø ??ò KHaØ× Ñ ×%Ñ%¬¯ © Ó7Ø ð ô 'Ð'VÓWÐWr r c ó || _ y r0 )r1 r s r r z)WeightBasedFailoverStrategy.set_databasesD s Ø#r ©r N) r r r Ú__doc__r2 r r r r r r r r. r. 5 s- ñó)ðX,ó Xð$ yð $°Tô $r r. c ó e Zd ZdZeefdededefdZ e
|
defd« Z e
|
defd« Z e
|
defd « Z defd
|
Zd d Zy )Ú DefaultFailoverStrategyExecutorz+
|
Executes given failover strategy.
|
r' r" r% c óJ || _ || _ || _ d| _ d| _ y ©Nr )Ú _strategyÚ_failover_attemptsÚ_failover_delayÚ_next_attempt_tsÚ_failover_counter)r r' r" r% s r r2 z(DefaultFailoverStrategyExecutor.__init__M s+ ð "Ø"3Ô Ø -Ô Ø%&Ô Ø&'Õ r r c ó | j S r0 )rA r s r r" z1DefaultFailoverStrategyExecutor.failover_attemptsY s à×&Ñ&Ð&r c ó | j S r0 )rB r s r r% z.DefaultFailoverStrategyExecutor.failover_delay] s à×#Ñ#Ð#r c ó | j S r0 )r@ r s r r' z(DefaultFailoverStrategyExecutor.strategya s à~~Ð r c ó* | j j « }| j « |S # t $ rÛ}| j dk( r<t j
|
« | j z | _ | xj dz c_ nUt j
|
« | j k\ r4| xj | j z c_ | xj dz c_ | j | j kD r| j « |t d« d }~ww xY w)Nr é zhNo database connections currently available. This is a temporary condition - please retry the operation.)
|
r@ r Ú_resetr rC ÚtimerB rD rA r
|
)r r Úes r r) z'DefaultFailoverStrategyExecutor.executee sà ð Ø~~×.Ñ.Ó0HØ KKMØOøÜ'ò Ø×$Ñ$¨Ò)Ü(,¯ © « °d×6JÑ6JÑ(JÔ%Ø×&Ò&¨!Ñ+Ö&Ü × 5Ñ 5Ò5Ø×%Ò%¨×)=Ñ)=Ñ=Õ%Ø×&Ò&¨!Ñ+Õ&à×%Ñ%¨×(?Ñ(?Ò?Ø Øä3ðRóð ûð ús +. ® D·CD Ä DNc ó d| _ d| _ y r? )rC rD r s r rJ z&DefaultFailoverStrategyExecutor._reset{ s Ø !Ô Ø!"Õ r r: )r r r r; ÚDEFAULT_FAILOVER_ATTEMPTSÚDEFAULT_FAILOVER_DELAYr r+ r, r2 r* r" r% r' r r) rJ r r r r= r= H s ñð ";Ø 6ñ
|
(à"ð
|
(ð ð
|
(ð ó
|
(ð ð' 3ò 'ó ð'ð ð$ ò $ó ð$ð ð Ð*ò ó ð ð ó ô,#r r= )rK Úabcr r Úredis.data_structurer Úredis.multidb.circuitr r6 Úredis.multidb.databaser r Úredis.multidb.exceptionr r
|
rN rO r r r. r= r r r ú<module>rU sY ðÛ ß #å -Ý 2ß :÷ð
|
Ð ØÐ ô sô ô sô ô2$Ð"2ô $ô&5#Ð&>õ 5#r
|
