Ë
|
|
çúhä
|
ã ó d dl mZ d dlmZ d dlmZ d dlmZ d dlm Z m
|
Z
|
G d d« Z G d d e « Z G d
|
d e « Z G d d e « Zy)é )ÚList)ÚRedis)Ú AsyncDatabase)ÚAsyncFailureDetector)ÚAsyncEventListenerInterfaceÚAsyncOnCommandsFailEventc ól e Zd ZdZdedefdZedefd« Zedefd« Zed « Z ed « Z
|
y
|
) ÚAsyncActiveDatabaseChangedzE
|
Event fired when an async active database has been changed.
|
Ú old_databaseÚ new_databasec ó< || _ || _ || _ || _ y ©N)Ú _old_databaseÚ _new_databaseÚ_command_executorÚ_kwargs)Úselfr r Úcommand_executorÚkwargss õn H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/asyncio/multidb/event.pyÚ__init__z#AsyncActiveDatabaseChanged.__init__ s# ð *ÔØ )ÔØ!1Ô Ø ó Úreturnc ó | j S r )r ©r s r r z'AsyncActiveDatabaseChanged.old_database ó à×!Ñ!Ð!r c ó | j S r )r r s r r z'AsyncActiveDatabaseChanged.new_database r r c ó | j S r )r r s r r z+AsyncActiveDatabaseChanged.command_executor" s à×%Ñ%Ð%r c ó | j S r )r r s r r z!AsyncActiveDatabaseChanged.kwargs& s à||Ðr N) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r Úpropertyr r r r © r r r
|
r
|
s| ñð
|
à#ð
|
ð $ó
|
ð ð"mò "ó ð"ð ð"mò "ó ð"ð ñ&ó ð&ð ñ ó ñ r r
|
c ó e Zd ZdZdefdZy)Ú"ResubscribeOnActiveDatabaseChangedzO
|
Re-subscribe the currently active pub / sub to a new active database.
|
Úeventc ón K |j j }| |j j j di |j
|
¤}|j |_ |j |_ |j d « d { ||j _ |j « d { y y 7 /7 w)Nr% )
|
r Ú active_pubsubr ÚclientÚpubsubr ÚchannelsÚpatternsÚ
|
on_connectÚaclose)r r( Ú
|
old_pubsubÚ
|
new_pubsubs r Úlistenz)ResubscribeOnActiveDatabaseChanged.listen0 s è ø Ø×+Ñ+×9Ñ9
|
à Ð !à9×+Ñ+×2Ñ2×9Ñ9ÑI¸E¿L¹LÑIJØ",×"5Ñ"5JÔ Ø",×"5Ñ"5JÔ Ø ×'Ñ'¨Ó-× -Ð -Ø3=E× "Ñ "Ô 0Ø ×#Ñ#Ó%× %Ñ %ð "ð
|
.øà %ús$ A?B5ÂB1Â(B5Â*B3Â+B5Â3B5N©r r! r" r# r
|
r3 r% r r r' r' + s ñð
|
&Ð"<ô
|
&r r' c ó e Zd ZdZdefdZy)Ú&CloseConnectionOnActiveDatabaseChangedz6
|
Close connection to the old active database.
|
r( c ó K |j j j « d { t |j j t « rm|j j j
|
j « d { |j j j
|
j « d { y y 7 7 >7
|
wr )r r+ r0 Ú
|
isinstancer Úconnection_poolÚ'update_active_connections_for_reconnectÚ
|
disconnect)r r( s r r3 z-CloseConnectionOnActiveDatabaseChanged.listenB s è ø Ø× Ñ ×'Ñ'×.Ñ.Ó0×0Ð0ä e×(Ñ(×/Ñ/´Ô 7Ø×$Ñ$×+Ñ+×;Ñ;×cÑcÓe× eÐ eØ×$Ñ$×+Ñ+×;Ñ;×FÑFÓH× HÑ Hð 8ð 1øð føØ Hús4 (CªC«ACÂCÂ5CÂ:CÂ;CÃCÃCNr4 r% r r r6 r6 = s ñðIÐ"<ô Ir r6 c ó2 e Zd ZdZdee fdZdeddfdZy)ÚRegisterCommandFailureza
|
Event listener that registers command failures and passing it to the failure detectors.
|
Úfailure_detectorsc ó || _ y r )Ú_failure_detectors)r r> s r r z RegisterCommandFailure.__init__O s
|
Ø"3Õ r r( r Nc ó K | j D ]0 }|j |j |j « d { 2 y 7 wr )r@ Úregister_failureÚ exceptionÚcommands)r r( Úfailure_detectors r r3 z RegisterCommandFailure.listenR s? è ø Ø $× 7Ñ 7ò UÐ Ø"×3Ñ3°E·O±OÀUÇ^Á^ÓT× TÑ Tñ UØ Tús 9A»A¼A) r r! r" r# r r r r r3 r% r r r= r= J s0 ñð4¨$Ð/CÑ*Dó 4ðUÐ":ð U¸tô Ur r= N)Útypingr Ú redis.asyncior Ú redis.asyncio.multidb.databaser Ú&redis.asyncio.multidb.failure_detectorr Ú redis.eventr r r
|
r' r6 r= r% r r ú<module>rK sJ ðÝ å Ý 8Ý Gß M÷ ñ ôD&Ð)Dô &ô$
|
IÐ-Hô
|
Iô
|
UÐ 8õ
|
Ur
|
