Ë
|
|
çúhê ã ó d dl Z d dlZd dlmZmZ d dlmZmZ d dlmZm Z d dl
|
m Z d dl m Z dZdZd Z G d
|
d e« Z G d d e« Zy)é N)ÚABCÚabstractmethod)ÚdatetimeÚ timedelta)ÚListÚType)ÚOptional)ÚStateiè g¹?é c óV e Zd Zedededdfd« Zededdfd« Zedd« Zy) ÚFailureDetectorÚ exceptionÚcmdÚreturnNc ó y)z:Register a failure that occurred during command execution.N© ©Úselfr r s õq H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/multidb/failure_detector.pyÚregister_failurez FailureDetector.register_failure ó ð ó c ó y)z Register a command execution.Nr ©r r s r Úregister_command_executionz*FailureDetector.register_command_execution r r c ó y)z*Set the command executor for this failure.Nr ©r Úcommand_executors r Úset_command_executorz$FailureDetector.set_command_executor r r ©r N) Ú__name__Ú
|
__module__Ú __qualname__r Ú ExceptionÚtupler r r r r r r r s_ Øð ¨)ð ¸%ð ÀDò ó ð ð ð ¨eð ¸ò ó ð ð ò ó ñ r r c ó e Zd ZdZeeedfdededede e
|
e e ddf
|
dZ d e d
|
eddfd Zdd Zd
|
eddfd Zd ZddZy)ÚCommandFailureDetectorze
|
Detects a failure based on a threshold of failed commands during a specific period of time.
|
NÚmin_num_failuresÚfailure_rate_thresholdÚfailure_detection_windowÚ error_typesr c ó d| _ || _ || _ || _ || _ d| _ t j « | _ | j t | j ¬« z | _
|
d| _ t j « | _ y)az
|
Initialize a new CommandFailureDetector instance.
|
|
Args:
|
min_num_failures: Minimal count of failures required for failover
|
failure_rate_threshold: Percentage of failures required for failover
|
failure_detection_window: Time interval for executing health checks.
|
error_types: Optional list of exception types to trigger failover. If None, all exceptions are counted.
|
|
The detector tracks command failures within a sliding time window. When the number of failures
|
exceeds the threshold within the specified duration, it triggers failure detection.
|
Nr ©Úseconds)Ú_command_executorÚ_min_num_failuresÚ_failure_rate_thresholdÚ_failure_detection_windowÚ _error_typesÚ_commands_executedr ÚnowÚ _start_timer Ú _end_timeÚ_failures_countÚ threadingÚRLockÚ_lock)r r( r) r* r+ s r Ú__init__z CommandFailureDetector.__init__& s| ð& "&Ô Ø!1Ô Ø'=Ô$Ø)AÔ&Ø 'ÔØ'(Ô Ü%-§\¡\£^ÔØ#'×#3Ñ#3´iØ×2Ñ2ô7
|
ñ $
|
ð %&Ô Ü __Ó&
|
r r r c ó | j 5 | j r-t |« | j v r+| xj dz c_ n| xj dz c_ | j « d d d « y # 1 sw Y y xY w©Né )r; r3 Útyper8 Ú_check_thresholdr s r r z'CommandFailureDetector.register_failureF sg Ø ZZñ $Ø× Ò Ü ? d×&7Ñ&7Ñ7Ø×(Ò(¨AÑ-Ö(à×$Ò$¨Ñ)Õ$à × !Ñ !Ô #÷ $÷ $ñ $ús A A5Á5A>c ó || _ y ©N)r/ r s r r z+CommandFailureDetector.set_command_executorP s
|
Ø!1Õ r c óö | j 5 | j t j « cxk r| j k sn | j « | xj dz c_ d d d « y # 1 sw Y y xY wr> )r; r6 r r5 r7 Ú_resetr4 r s r r z1CommandFailureDetector.register_command_executionS sU Ø ZZñ )Ø×#Ñ#¤h§l¡l£nÔE°t·~±~ÔEØ à × #Ò # qÑ (Õ #÷ )÷ )ñ )ús AA/Á/A8c ó2 | j | j k\ r~| j t j | j | j
|
z « k\ rDt j | j j j _ | j « y y y rC ) r8 r0 ÚmathÚceilr4 r1 ÚCBStateÚOPENr/ Úactive_databaseÚcircuitÚstaterE ©r s r rA z'CommandFailureDetector._check_thresholdZ ss Ø × Ñ 4×#9Ñ#9Ò 9¸d×>RÑ>RÜ IId×-Ñ-°×0LÑ0LÑLÓ Mò?
|
ô DKÇ<Á<D× "Ñ "× 2Ñ 2× :Ñ :Ô @Ø KKMð ?
|
Ð 9r c óä | j 5 t j « | _ | j t | j
|
¬« z | _ d| _ d| _ d d d « y # 1 sw Y y xY w)Nr- r ) r; r r5 r6 r r2 r7 r8 r4 rN s r rE z CommandFailureDetector._reseta s` Ø ZZñ (Ü '||~DÔ Ø !× -Ñ -´ Ø ×6Ñ6ô1ñ DNð $%DÔ Ø&'DÔ #÷ (÷ (ñ (ús AA&Á&A/r )r! r" r# Ú__doc__ÚDEFAULT_MIN_NUM_FAILURESÚ DEFAULT_FAILURE_RATE_THRESHOLDÚ!DEFAULT_FAILURES_DETECTION_WINDOWÚintÚfloatr r r r$ r< r% r r r rA rE r r r r' r' ! s ñð !9Ø(FØ*KØ7;ñ 'à ð 'ð !&ð 'ð #(ð 'ð
|
d 4¨ ¡?Ñ 3Ñ4ð 'ð
|
ó 'ð@$¨)ð $¸%ð $ÀDó $ó2ð)¨eð )¸ó )òô(r r' )rG r9 Úabcr r r r Útypingr r Útyping_extensionsr Úredis.multidb.circuitr
|
rI rQ rR rS r r' r r r ú<module>rZ sF ðÛ Û ß #ß (ß å &å 2à Ð Ø!$Ð Ø$%Ð !ô cô ô"G(_õ G(r
|
