Ë
|
|
çúhï ã óL d dl mZmZ d dlmZ G d de« Z G d de« Zy)é )ÚABCÚabstractmethod)ÚFailureDetectorc óV e Zd Zedededdfd« Zededdfd« Zedd« Zy) ÚAsyncFailureDetectorÚ exceptionÚcmdÚreturnNc ó K yw)z:Register a failure that occurred during command execution.N© ©Úselfr r s õy H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/asyncio/multidb/failure_detector.pyÚregister_failurez%AsyncFailureDetector.register_failure ó è ø ð ùó c ó K yw)z Register a command execution.Nr ©r r s r Úregister_command_executionz/AsyncFailureDetector.register_command_execution r r c ó y)z*Set the command executor for this failure.Nr ©r Úcommand_executors r Úset_command_executorz)AsyncFailureDetector.set_command_executor s ð ó ©r
|
N) Ú__name__Ú
|
__module__Ú __qualname__r Ú ExceptionÚtupler r r r r r r r s_ Øð ° ð Àð È$ò ó ð ð ð °Eð ¸dò ó ð ð ò ó ñ r r c óL e Zd ZdZdeddfdZdededdfdZdeddfd Z d d
|
Z
|
y) ÚFailureDetectorAsyncWrapperz1
|
Async wrapper for the failure detector.
|
Úfailure_detectorr
|
Nc ó || _ y ©N)Ú_failure_detector)r r# s r Ú__init__z$FailureDetectorAsyncWrapper.__init__ s
|
Ø!1Õ r r r c óD K | j j ||« y wr% )r& r r s r r z,FailureDetectorAsyncWrapper.register_failure s è ø Ø × Ñ ×/Ñ/° ¸3Õ?ùs c óB K | j j |« y wr% )r& r r s r r z6FailureDetectorAsyncWrapper.register_command_execution" s è ø Ø × Ñ ×9Ñ9¸#Õ>ùs c ó: | j j |« y r% )r& r r s r r z0FailureDetectorAsyncWrapper.set_command_executor% s Ø × Ñ ×3Ñ3Ð4DÕEr r ) r r r Ú__doc__r r' r r r r r r r r r" r" sQ ñð2¨ ð 2¸Tó 2ð@° ð @Àð @È$ó @ð?°Eð ?¸dó ?ôFr r" N)Úabcr r Ú redis.multidb.failure_detectorr r r" r r r ú<module>r. s& ðß #å :ô 3ô ô"FÐ"6õ Fr
|
