Ë
|
|
çúh¢ ã ó d dl mZ d dlmZ d dlmZmZ d dlmZ d dl m
|
Z
|
G d d« Z G d d e« Z G d
|
d e« Z G d d e« Zy)é )ÚList)ÚRedis)ÚEventListenerInterfaceÚOnCommandsFailEvent)Ú SyncDatabase)ÚFailureDetectorc ól e Zd ZdZdedefdZedefd« Zedefd« Zed « Z ed « Z
|
y
|
) ÚActiveDatabaseChangedz?
|
Event fired when an active database has been changed.
|
Ú old_databaseÚ new_databasec ó< || _ || _ || _ || _ y ©N)Ú _old_databaseÚ _new_databaseÚ_command_executorÚ_kwargs)Úselfr r Úcommand_executorÚkwargss õf H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/multidb/event.pyÚ__init__z ActiveDatabaseChanged.__init__ s# ð *ÔØ )ÔØ!1Ô Ø ó Úreturnc ó | j S r )r ©r s r r z"ActiveDatabaseChanged.old_database ó à×!Ñ!Ð!r c ó | j S r )r r s r r z"ActiveDatabaseChanged.new_database r r c ó | j S r )r r s r r z&ActiveDatabaseChanged.command_executor" s à×%Ñ%Ð%r c ó | j S r )r r s r r z ActiveDatabaseChanged.kwargs& s à||Ðr N) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r Úpropertyr r r r © r r r
|
r
|
s| ñð
|
à"ð
|
ð #ó
|
ð ð"lò "ó ð"ð ð"lò "ó ð"ð ñ&ó ð&ð ñ ó ñ r r
|
c ó e Zd ZdZdefdZy)Ú"ResubscribeOnActiveDatabaseChangedzO
|
Re-subscribe the currently active pub / sub to a new active database.
|
Úeventc ó` |j j }| |j j j di |j
|
¤}|j |_ |j |_ |j |_ |j d « ||j _ |j « y y )Nr% ) r Ú active_pubsubr ÚclientÚpubsubr ÚchannelsÚpatternsÚshard_channelsÚ
|
on_connectÚclose)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Ô Ø(2×(AÑ(AJÔ %Ø × !Ñ ! $Ô 'Ø3=E× "Ñ "Ô 0Ø × Ñ Õ ð "r N©r r! r" r# r
|
r4 r% r r r' r' + s ñð Ð 1ô r r' c ó e Zd ZdZdefdZy)Ú&CloseConnectionOnActiveDatabaseChangedz6
|
Close connection to the old active database.
|
r( c óX |j j j « t |j j t « r]|j j j
|
j « |j j j
|
j « y |j j j j j « D ]J }|j j
|
j « |j j
|
j « L y r ) r r+ r1 Ú
|
isinstancer Úconnection_poolÚ'update_active_connections_for_reconnectÚ
|
disconnectÚ nodes_managerÚ nodes_cacheÚvaluesÚredis_connection)r r( Únodes r r4 z-CloseConnectionOnActiveDatabaseChanged.listenC sÎ Ø ×Ñ×!Ñ!×'Ñ'Ô)ä e×(Ñ(×/Ñ/´Ô 7Ø × Ñ × %Ñ %× 5Ñ 5× ]Ñ ]Ô _Ø × Ñ × %Ñ %× 5Ñ 5× @Ñ @Õ Bà ×*Ñ*×1Ñ1×?Ñ?×KÑK×RÑRÓTò CØ×%Ñ%×5Ñ5×]Ñ]Ô_Ø×%Ñ%×5Ñ5×@Ñ@ÕBñ Cr Nr5 r% r r r7 r7 > s ñð CÐ 1ô Cr r7 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 rD s r r z RegisterCommandFailure.__init__T s
|
Ø"3Õ r r( r Nc ór | j D ]( }|j |j |j « * y r )rF Úregister_failureÚ exceptionÚcommands)r r( Úfailure_detectors r r4 z RegisterCommandFailure.listenW s2 Ø $× 7Ñ 7ò OÐ Ø × -Ñ -¨e¯o©o¸u¿~¹~Õ Nñ Or ) r r! r" r# r r r r r4 r% r r rC rC O s/ ñð4¨$¨Ñ*?ó 4ðOÐ /ð O°Dô Or rC N)Útypingr Ú redis.clientr Ú redis.eventr r Úredis.multidb.databaser Ú redis.multidb.failure_detectorr r
|
r' r7 rC r% r r ú<module>rQ sJ ðÝ å ß CÝ /Ý :÷ ñ ôD Ð)?ô ô&CÐ-Cô Cô"
|
OÐ 3õ
|
Or
|
