o <СЁiяу@s@ddlmZmZddlmZGddДdeГZGddДdeГZdS)щ)┌ABC┌abstractmethod)┌FailureDetectorc@sJeZdZedededdfddДГZededdfddДГZedd d ДГZdS)┌AsyncFailureDetector┌ exception┌cmd┌returnNc├єБdS)z:Register a failure that occurred during command execution.Nйй┌selfrrr r ·e/root/parts/websockify/install/lib/python3.10/site-packages/redis/asyncio/multidb/failure_detector.py┌register_failureєАz%AsyncFailureDetector.register_failurec├r )zRegister a command execution.Nr йrrr r r ┌register_command_executionrz/AsyncFailureDetector.register_command_executioncCsdS)z*Set the command executor for this failure.Nr йr┌command_executorr r r ┌set_command_executorsz)AsyncFailureDetector.set_command_executorйrN) ┌__name__┌ __module__┌__qualname__r┌ Exception┌tuplerrrr r r r rsrc@sTeZdZdZdeddfddДZdededdfd d ДZdeddfddДZ dd dДZ dS)┌FailureDetectorAsyncWrapperz1 Async wrapper for the failure detector. ┌failure_detectorrNcCs ||_dSйN)┌_failure_detector)rrr r r ┌__init__s z$FailureDetectorAsyncWrapper.__init__rrc├sБ|jа||бdSr)rrrr r r rsАz,FailureDetectorAsyncWrapper.register_failurec├sБ|jа|бdSr)rrrr r r r"sАz6FailureDetectorAsyncWrapper.register_command_executioncCs|jа|бdSr)rrrr r r r%sz0FailureDetectorAsyncWrapper.set_command_executorr)rrr┌__doc__rrrrrrrr r r r rsrN)┌abcrr┌redis.multidb.failure_detectorrrrr r r r ┌s