Ë
|
|
çúh ã óº d dl mZmZ d dlmZ d dlmZ d dlZdZ G d de« Z G d d e« Z
|
G d
|
d e
|
« Z G d d ej « Z G d de « Zy)é )ÚABCÚabstractmethod)ÚEnum)ÚCallableNé< c ó e Zd ZdZdZdZy)ÚStateÚclosedÚopenz half-openN)Ú__name__Ú
|
__module__Ú __qualname__ÚCLOSEDÚOPENÚ HALF_OPEN© ó õh H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/multidb/circuit.pyr r
|
s Ø FØ DØIr r c ó" e Zd Zeedefd« « Zej edefd« « Zeedefd« « Z e j edefd« « Z eed « « Z
|
e
|
j ed « « Z
|
ed
|
e d eegd f fd « Z y ) ÚCircuitBreakerÚreturnc ó y)z@The grace period in seconds when the circle should be kept open.Nr ©Úselfs r Ú grace_periodzCircuitBreaker.grace_period ó ð r r c ó y)z Set the grace period in seconds.Nr ©r r s r r zCircuitBreaker.grace_period s r c ó y)z!The current state of the circuit.Nr r s r ÚstatezCircuitBreaker.state r r r c ó y)z!Set current state of the circuit.Nr ©r r s r r zCircuitBreaker.state" r r c ó y)z&Database associated with this circuit.Nr r s r ÚdatabasezCircuitBreaker.database( r r c ó y)z*Set database associated with this circuit.Nr ©r r$ s r r$ zCircuitBreaker.database. r r ÚcbNc ó y©z6Callback called when the state of the circuit changes.Nr ©r r' s r Úon_state_changedz CircuitBreaker.on_state_changed4 ó ð r ) r r r Úpropertyr Úfloatr Úsetterr r r$ r r+ r r r r r sÿ Ø Øð eò ó ó ð ð ×ÑØð/¨ò /ó ó ð/ð Øð uò ó ó ð ð \\Øð 5ò ó ó ð ð Øñ ó ó ð ð __Øñ ó ó ð ð ð 8Ð-=¸uÀeÐ,LÈdÐ,RÑ#Sò ó ñ r r c ó
|
e Zd ZdZdej
|
fdZedefd« Z e j defd« Z ede fd« Z e j d e fd
|
« Z ed « Z e j d « Z eded e e gdf fd« Zy)ÚBaseCircuitBreakerz;
|
Base implementation of Circuit Breaker interface.
|
r' c ó || _ t j | j j t j | j j
|
t j | j j i| _ d | _ y ©N)
|
Ú_cbr r Úcloser r r Ú half_openÚ_state_pb_mapperÚ _databaser* s r Ú__init__zBaseCircuitBreaker.__init__? sQ Øä LL$((..Ü JJ Ü OOTXX× /Ñ /ð!
|
Ô ð
|
r r c ó. | j j S r3 ©r4 Ú reset_timeoutr s r r z BaseCircuitBreaker.grace_periodH s àxx×%Ñ%Ð%r r c ó& || j _ y r3 r; r s r r z BaseCircuitBreaker.grace_periodL s à!-Õ r c óV t | j j j ¬« S ©N)Úvalue)r r4 r Únamer s r r zBaseCircuitBreaker.stateP s ä488>>×.Ñ.Ô/Ð/r r c ó, | j | « y r3 )r7 r" s r r zBaseCircuitBreaker.stateT s à$× Ñ eÑ$Õ&r c ó | j S r3 ©r8 r s r r$ zBaseCircuitBreaker.databaseX s à~~Ð r c ó || _ y r3 rD r& s r r$ zBaseCircuitBreaker.database\ s à!r r Nc ó yr) r r* s r r+ z#BaseCircuitBreaker.on_state_changed` r, r )r r r Ú__doc__Ú pybreakerr r9 r- r. r r/ r r r$ r r r+ r r r r1 r1 : sè ñð 9×3Ñ3ó ð ð&eò &ó ð&ð ×Ñð.¨ò .ó ð.ð ð0uò 0ó ð0ð \\ð'5ò 'ó ð'ð ñ ó ð ð __ñ"ó ð"ð ð 8Ð-=¸uÀeÐ,LÈdÐ,RÑ#Sò ó ñ r r1 c ó2 e Zd ZdZdeeeegdf fdZd Zy)Ú
|
PBListenerzDWrapper for callback to be compatible with pybreaker implementation.r' Nc ó || _ || _ y)zî
|
Initialize a PBListener instance.
|
|
Args:
|
cb: Callback function that will be called when the circuit breaker state changes.
|
database: Database instance associated with this circuit breaker.
|
N)r4 r8 )r r' r$ s r r9 zPBListener.__init__i s ð Ø!r c óº t |« }| j |_ t |j ¬« }t |j ¬« }| j |||« y r? )ÚPBCircuitBreakerAdapterr8 r$ r rA r4 )r r' Ú old_stateÚ new_states r Ú state_changezPBListener.state_changey sC Ü $ RÓ (Ønn Ü §¡Ô/ Ü §¡Ô/ Ø Y Õ*r ) r r r rG r r r r9 rP r r r rJ rJ f s( ÙNð"à n e¨UÐ3°TÐ9Ñ :ó"ó +r rJ c óT e Zd Zdej f fd Zdedeegdf fdZ xZ S )rM r' c ó$ t | |« y)a
|
Initialize a PBCircuitBreakerAdapter instance.
|
|
This adapter wraps pybreaker's CircuitBreaker implementation to make it compatible
|
with our CircuitBreaker interface.
|
|
Args:
|
cb: A pybreaker CircuitBreaker instance to be adapted.
|
N)Úsuperr9 )r r' Ú __class__s r r9 z PBCircuitBreakerAdapter.__init__ s ø ô ÑÕ r r Nc óf t || j « }| j j |« y r3 )rJ r$ r4 Ú add_listener)r r' Úlisteners r r+ z(PBCircuitBreakerAdapter.on_state_changed s$ Ü b $§-¡-Ó0Ø × Ñ hÕ'r )
|
r r r rH r r9 r r r+ Ú __classcell__)rT s @r rM rM s3 ø ð
|
9×3Ñ3õ
|
ð( 8Ð-=¸uÀeÐ,LÈdÐ,RÑ#S÷ (r rM )Úabcr r Úenumr Útypingr rH ÚDEFAULT_GRACE_PERIODr r r1 ÚCircuitBreakerListenerrJ rM r r r ú<module>r^ s\ ðß #Ý Ý ã àÐ ô Dô ô ' Sô ' ôT) ô ) ôX+×1Ñ1ô +ô6(Ð 0õ (r
|
