ó
    ˆpühï  ã                   óL   • S SK JrJr  S SKJr   " S S\5      r " S S\5      rg)é    )ÚABCÚabstractmethod)ÚFailureDetectorc                   ód   • \ rS rSr\S\S\SS4S j5       r\S\SS4S j5       r\S
S j5       r	S	r
g)ÚAsyncFailureDetectoré   Ú	exceptionÚcmdÚreturnNc              ƒ   ó   #   • g7f)z:Register a failure that occurred during command execution.N© ©Úselfr	   r
   s      Ú`/home/james-whalen/.local/lib/python3.13/site-packages/redis/asyncio/multidb/failure_detector.pyÚregister_failureÚ%AsyncFailureDetector.register_failure   ó
   é € ð 	ùó   ‚c              ƒ   ó   #   • g7f)zRegister a command execution.Nr   ©r   r
   s     r   Úregister_command_executionÚ/AsyncFailureDetector.register_command_execution   r   r   c                 ó   • g)z*Set the command executor for this failure.Nr   ©r   Úcommand_executors     r   Úset_command_executorÚ)AsyncFailureDetector.set_command_executor   s   € ð 	ó    r   ©r   N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   Ú	ExceptionÚtupler   r   r   Ú__static_attributes__r   r   r   r   r      s_   † Øð°	ð Àð È$ó ó ðð ð°Eð ¸dó ó ðð óó ór   r   c                   ó\   • \ rS rSrSrS\SS4S jrS\S\SS4S	 jr	S\SS4S
 jr
SS jrSrg)ÚFailureDetectorAsyncWrapperé   z)
Async wrapper for the failure detector.
Úfailure_detectorr   Nc                 ó   • Xl         g ©N©Ú_failure_detector)r   r*   s     r   Ú__init__Ú$FailureDetectorAsyncWrapper.__init__   s   € Ø!1Õr   r	   r
   c              ƒ   óB   #   • U R                   R                  X5        g 7fr,   )r.   r   r   s      r   r   Ú,FailureDetectorAsyncWrapper.register_failure   s   é € Ø×Ñ×/Ñ/°	Õ?ùó   ‚c              ƒ   óB   #   • U R                   R                  U5        g 7fr,   )r.   r   r   s     r   r   Ú6FailureDetectorAsyncWrapper.register_command_execution"   s   é € Ø×Ñ×9Ñ9¸#Õ>ùr3   c                 ó:   • U R                   R                  U5        g r,   )r.   r   r   s     r   r   Ú0FailureDetectorAsyncWrapper.set_command_executor%   s   € Ø×Ñ×3Ñ3Ð4DÕEr   r-   r   )r    r!   r"   r#   Ú__doc__r   r/   r$   r%   r   r   r   r&   r   r   r   r(   r(      sQ   † ñð2¨ð 2¸Tô 2ð@°	ð @Àð @È$ô @ð?°Eð ?¸dô ?÷Fr   r(   N)Úabcr   r   Úredis.multidb.failure_detectorr   r   r(   r   r   r   Ú<module>r;      s&   ðß #å :ô˜3ô ô"FÐ"6õ Fr   