Ë
|
|
çúh3 ã ó´ d dl Z d dlmZmZ d dlmZmZ d dlmZ d dl 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)Ú AsyncDatabaseÚ Databases)Ú WeightedList)ÚState)ÚNoValidDatabaseExceptionÚ TemporaryUnavailableExceptioné
|
é c ó< e Zd Zedefd« Zededdfd« Zy)ÚAsyncFailoverStrategyÚreturnc ó K yw)z.Select the database according to the strategy.N© ©Úselfs õq H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/asyncio/multidb/failover.pyÚdatabasez AsyncFailoverStrategy.database ó è ø ð ùó Ú databasesNc ó y)z&Set the database strategy operates on.Nr ©r r s r Ú set_databasesz#AsyncFailoverStrategy.set_databases s ð ó )Ú__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 ó K yw)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 ó2 e Zd ZdZd ZdefdZdeddfdZy)ÚWeightBasedFailoverStrategyz6
|
Failover strategy based on database weights.
|
c ó" t « | _ y ©N)r Ú
|
_databasesr s r Ú__init__z$WeightBasedFailoverStrategy.__init__: s Ü&.r r c ó K | j D ]0 \ }}|j j t j k( s.|c S t d« w)Nz-No valid database available for communication)r2 ÚcircuitÚstateÚCBStateÚCLOSEDr )r r Ú_s r r z$WeightBasedFailoverStrategy.database= sH è ø Ø ??ò KHaØ× Ñ ×%Ñ%¬¯ © Ó7Ø ð ô 'Ð'VÓWÐWùs
|
:A ½A r Nc ó || _ y r1 )r2 r s r r z)WeightBasedFailoverStrategy.set_databasesD s Ø#r ) r r r Ú__doc__r3 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 r3 z(DefaultFailoverStrategyExecutor.__init__M s+ ð "Ø"3Ô Ø -Ô Ø%&Ô Ø&'Õ r r c ó | j S r1 )rA r s r r# z1DefaultFailoverStrategyExecutor.failover_attemptsY s à×&Ñ&Ð&r c ó | j S r1 )rB r s r r& z.DefaultFailoverStrategyExecutor.failover_delay] s à×#Ñ#Ð#r c ó | j S r1 )r@ r s r r( z(DefaultFailoverStrategyExecutor.strategya s à~~Ð r c óF K | j j « d { }| j « |S 7 # 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 ww)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í è ø ð Ø !^^× 4Ñ 4Ó 6×6HØ KKMØOð 7ùô (ò Ø×$Ñ$¨Ò)Ü(,¯ © « °d×6JÑ6JÑ(JÔ%Ø×&Ò&¨!Ñ+Ö&Ü × 5Ñ 5Ò5Ø×%Ò%¨×)=Ñ)=Ñ=Õ%Ø×&Ò&¨!Ñ+Õ&à×%Ñ%¨×(?Ñ(?Ò?Ø Øä3ðRóð ûð üs2 D! : ¡8¢: ·D!¸: º D ÁCDÄD Ä D!Nc ó d| _ d| _ y r? )rC rD r s r rJ z&DefaultFailoverStrategyExecutor._reset{ s Ø !Ô Ø!"Õ r )r N)r r r r; ÚDEFAULT_FAILOVER_ATTEMPTSÚDEFAULT_FAILOVER_DELAYr r, r- r3 r+ r# r& r( r r* rJ r r r r= r= H s ñð ";Ø 6ñ
|
(à'ð
|
(ð ð
|
(ð ó
|
(ð ð' 3ò 'ó ð'ð ð$ ò $ó ð$ð ð Ð/ò ó ð ð}ó ô,#r r= )rK Úabcr r Ú redis.asyncio.multidb.databaser r Úredis.data_structurer Úredis.multidb.circuitr r7 Úredis.multidb.exceptionr r
|
rN rO r r! r/ r= r r r ú<module>rU sY ðÛ ß #ç CÝ -Ý 2÷ð
|
Ð ØÐ ô Cô ô sô ô2$Ð"7ô $ô&5#Ð&>õ 5#r
|
