Ë
|
|
çúh<7 ã ó d dl Z d dlZd dlmZmZ d dlmZ d dlmZm Z m
|
Z
|
m Z m Z d dl mZ d dlmZmZ G d de« Z G d d
|
e« Z G d d e« Z G d de« Z G d de« Z G d d« Z G d de« Z G d de« Z G d d« Z G d d« Z G d d « Z G d d « Z G d d « Z G d! d"e « Z G d# d$e« Z! G d% d&e« Z" G d' d(e« Z# G d) d*e« Z$ G d+ d,e« Z% G d- d.e« Z&y)/é N)ÚABCÚabstractmethod)ÚEnum)ÚDictÚListÚOptionalÚTypeÚUnion)ÚTokenInterface)ÚCredentialProviderÚStreamingCredentialProviderc ó& e Zd ZdZedefd« Zy)ÚEventListenerInterfacez7
|
Represents a listener for given event object.
|
Úeventc ó y ©N© ©Úselfr s õ^ H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/event.pyÚlistenz EventListenerInterface.listen ó à ó N©Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r Úobjectr r r r r r s" ñð ð Fò ó ñ r r c ó& e Zd ZdZedefd« Zy)ÚAsyncEventListenerInterfacez>
|
Represents an async listener for given event object.
|
r c ó K y wr r r s r r z"AsyncEventListenerInterface.listen ó è ø à ùó Nr r r r r! r! s" ñð ð &ò ó ñ r r! c ór e Zd ZdZedefd« Zedefd« Zedee e e
|
e e e f f fd« Zy)ÚEventDispatcherInterfacezf
|
Represents a dispatcher that dispatches events to listeners
|
associated with given event.
|
r c ó y r r r s r Údispatchz!EventDispatcherInterface.dispatch% r r c ó K y wr r r s r Údispatch_asyncz'EventDispatcherInterface.dispatch_async) r# r$ Úmappingsc ó y)z Register additional listeners.Nr )r r+ s r Úregister_listenersz+EventDispatcherInterface.register_listeners- s ð r N)r r r r r r r( r* r r r r
|
r r! r- r r r r& r& s ñð
|
ð fò ó ð ð ð ¨&ò ó ð ð ð àØ LØ Ð-Ð/JÐJÑKÑ Lð Nñ
|
ò ó ñ r r& c ó, e Zd ZdZdedef fd Z xZS )ÚEventExceptionzM
|
Exception wrapper that adds an event object into exception context.
|
Ú exceptionr c ó@ || _ || _ t | |« y r )r0 r ÚsuperÚ__init__)r r0 r Ú __class__s r r3 zEventException.__init__> s ø Ø"Ø
|
Ü ÑÕ#r )r r r r Ú Exceptionr r3 Ú __classcell__)r4 s @r r/ r/ 9 s ø ñð$ )ð $°F÷ $ñ $r r/ c ó| e Zd Z d deeee ee f fdZ defdZ
|
defdZ deee ee ee f f fdZy)
|
ÚEventDispatcherNÚevent_listenersc ó. t t « gt t « gt t « gt t « gt t « gt t « gi| _ t j « | _ d| _ |r| j# |« yy)z]
|
Dispatcher that dispatches events to listeners associated with given event.
|
N)Ú AfterConnectionReleasedEventÚReAuthConnectionListenerÚ(AfterPooledConnectionsInstantiationEventÚ"RegisterReAuthForPooledConnectionsÚ'AfterSingleConnectionInstantiationEventÚ!RegisterReAuthForSingleConnectionÚ'AfterPubSubConnectionInstantiationEventÚRegisterReAuthForPubSubÚ#AfterAsyncClusterInstantiationEventÚ"RegisterReAuthForAsyncClusterNodesÚ!AsyncAfterConnectionReleasedEventÚ AsyncReAuthConnectionListenerÚ_event_listeners_mappingÚ threadingÚLockÚ_lockÚ _async_lockr- )r r9 s r r3 zEventDispatcher.__init__F s ô )Ü(Ó*ð+ô 5Ü2Ó4ð7ô 4Ü1Ó3ð6ô 4Ô6MÓ6OÐ5PÜ /Ô2TÓ2VÐ1WÜ -Ü-Ó/ð0ð
|
ð Ô%ô& ^^Ó%
|
Ø Ôá Ø × #Ñ # OÕ 4ð r r c ó | j 5 | j j t |« g « }|D ] }|j |« d d d « y # 1 sw Y y xY wr )rJ rG ÚgetÚtyper ©r r Ú listenersÚlisteners r r( zEventDispatcher.dispatchh sU Ø ZZñ 'Ø ×5Ñ5×9Ñ9¼$¸u»+ÀrÓJIà %ò 'Ø Õ&ñ '÷ '÷ 'ñ 'ús >AÁA c ó` K | j t j « | _ | j 4 d { | j j t |« g « }|D ] }|j |« d { d d d « d { y 7 Z7 7 # 1 d { 7 sw Y y xY wwr )rK ÚasynciorI rG rM rN r rO s r r* z EventDispatcher.dispatch_asynco s è ø Ø × Ñ Ð #Ü &||~DÔ à×#Ñ#÷ -ñ -Ø ×5Ñ5×9Ñ9¼$¸u»+ÀrÓJIà %ò -Ø oo eÓ,×,Ñ,ð -÷ -÷ -ñ -øð -øð -ø÷ -÷ -ñ -üsV 6B.¸B¹B.¼?BÁ;BÁ<B B. BÂB.ÂBÂB.ÂB+ B"  B+Â'B.r+ c ó | j 5 |D ]W }|| j v r5t t | j | || z « « | j |< F|| | j |< Y d d d « y # 1 sw Y y xY wr )rJ rG ÚlistÚset)r r+ Ú
|
event_types r r- z"EventDispatcher.register_listenersy s ð ZZñ
|
UØ &ò U
|
Ø ×!>Ñ!>Ñ>Ü@DÜØ × 9Ñ 9¸*Ñ EØ & zÑ 2ñ 3óóAD×1Ñ1°*Ò=ð AIÈÑ@TD×1Ñ1°*Ò=ñ U÷
|
U÷
|
Uñ
|
Uús A A4Á4A=r )r r r r r r r r r r3 r( r* r
|
r! r- r r r r8 r8 D s~ ð ñ 5à!Ø f tÐ$:Ñ ;Ð;Ñ <ñ
|
ó 5ðD'fó 'ð-¨&ó -ðUàØ LØ Ð-Ð/JÐJÑKÑ Lð Nñ
|
ôUr r8 c ó& e Zd ZdZd Zed « Zy)r; zA
|
Event that will be fired before each command execution.
|
c ó || _ y r ©Ú _connection)r Ú
|
connections r r3 z%AfterConnectionReleasedEvent.__init__ s
|
Ø%Õr c ó | j S r rZ ©r s r r\ z'AfterConnectionReleasedEvent.connection ó à× Ñ Ð r N)r r r r r3 Úpropertyr\ r r r r; r; s ñò&ð ñ ó ñ r r; c ó e Zd Zy)rE N©r r r r r r rE rE ó Ør rE c ó e Zd ZdZdZy)Ú
|
ClientType)Úsync)ÚasyncN)r r r ÚSYNCÚASYNCr r r re re s Ø DØ Er re c ót e Zd ZdZ d dededee fdZe d « Z
|
e defd « Z e de edf fd
|
« Z y) r= zQ
|
Event that will be fired after pooled connection instances was created.
|
NÚconnection_poolsÚ client_typeÚcredential_providerc ó. || _ || _ || _ y r )Ú_connection_poolsÚ _client_typeÚ_credential_provider)r rk rl rm s r r3 z1AfterPooledConnectionsInstantiationEvent.__init__¨ s ð "2Ô Ø 'ÔØ$7Õ!r c ó | j S r )ro r^ s r rk z9AfterPooledConnectionsInstantiationEvent.connection_pools² s à×%Ñ%Ð%r Úreturnc ó | j S r ©rp r^ s r rl z4AfterPooledConnectionsInstantiationEvent.client_type¶ ó à× Ñ Ð r c ó | j S r ©rq r^ s r rm z<AfterPooledConnectionsInstantiationEvent.credential_providerº ó à×(Ñ(Ð(r r )r r r r r re r r r3 r` rk rl r
|
rm r r r r= r= £ s ñð =Añ 8à ð8ð ð8ð &Ð&8Ñ 9ó 8ð ñ&ó ð&ð ð!Zò !ó ð!ð ð) UÐ+=¸tÐ+CÑ%Dò )ó ñ)r r= c óÀ e Zd ZdZdedeej ej f fdZ
|
e d « Z e defd« Z e deej ej f fd« Zy )
|
r? z¹
|
Event that will be fired after single connection instances was created.
|
|
:param connection_lock: For sync client thread-lock should be provided,
|
for async asyncio.Lock
|
rl Úconnection_lockc ó. || _ || _ || _ y r )r[ rp Ú_connection_lock)r r\ rl r{ s r r3 z0AfterSingleConnectionInstantiationEvent.__init__Ç s ð &ÔØ 'ÔØ /Õ r c ó | j S r rZ r^ s r r\ z2AfterSingleConnectionInstantiationEvent.connectionÑ r_ r rs c ó | j S r ru r^ s r rl z3AfterSingleConnectionInstantiationEvent.client_typeÕ rv r c ó | j S r ©r} r^ s r r{ z7AfterSingleConnectionInstantiationEvent.connection_lockÙ ó à×$Ñ$Ð$r N)r r r r re r
|
rH ÚRLockrS rI r3 r` r\ rl r{ r r r r? r? ¿ s ñð0ð ð0ð y°· ± Ð <Ñ=ó 0ð ñ ó ð ð ð!Zò !ó ð!ð ð% y§¡¸¿ ¹ Ð'DÑ!Eò %ó ñ%r r? c óÌ e Zd Zdedeej ej f fdZ e
|
d « Z e
|
d « Z e
|
defd« Z e
|
deej ej f fd« Zy )
|
rA rl r{ c ó< || _ || _ || _ || _ y r )Ú_pubsub_connectionÚ_connection_poolrp r} )r Úpubsub_connectionÚconnection_poolrl r{ s r r3 z0AfterPubSubConnectionInstantiationEvent.__init__ß s$ ð #4Ô Ø /Ô Ø 'ÔØ /Õ r c ó | j S r )r r^ s r r z9AfterPubSubConnectionInstantiationEvent.pubsub_connectionë s à×&Ñ&Ð&r c ó | j S r )r r^ s r r z7AfterPubSubConnectionInstantiationEvent.connection_poolï r r rs c ó | j S r ru r^ s r rl z3AfterPubSubConnectionInstantiationEvent.client_typeó rv r c ó | j S r r r^ s r r{ z7AfterPubSubConnectionInstantiationEvent.connection_lock÷ r r N)r r r re r
|
rH r rS rI r3 r` r r rl r{ r r r rA rA Þ s ð
|
0ð ð
|
0ð
|
y°· ± Ð <Ñ=ó
|
0ð ñ'ó ð'ð ñ%ó ð%ð ð!Zò !ó ð!ð ð% y§¡¸¿ ¹ Ð'DÑ!Eò %ó ñ%r rA c ó` e Zd ZdZ d dedee fdZedefd« Z ede
|
edf fd« Z y)
|
rC z±
|
Event that will be fired after async cluster instance was created.
|
|
Async cluster doesn't use connection pools,
|
instead ClusterNode object manages connections.
|
NÚnodesrm c ó || _ || _ y r )Ú_nodesrq )r r rm s r r3 z,AfterAsyncClusterInstantiationEvent.__init__ s ð
|
Ø$7Õ!r rs c ó | j S r )r r^ s r r z)AfterAsyncClusterInstantiationEvent.nodes s à{{Ðr c ó | j S r rx r^ s r rm z7AfterAsyncClusterInstantiationEvent.credential_provider ry r r ) r r r r Údictr r r3 r` r r
|
rm r r r rC rC ü sk ñð =Añ8àð8ð &Ð&8Ñ 9ó8ð ðtò ó ðð ð) UÐ+=¸tÐ+CÑ%Dò )ó ñ)r rC c óL e Zd ZdZdedefdZedefd« Zedefd« Z y) ÚOnCommandsFailEventzD
|
Event fired whenever a command fails during the execution.
|
Úcommandsr0 c ó || _ || _ y r )Ú _commandsÚ
|
_exception)r r r0 s r r3 z OnCommandsFailEvent.__init__ s ð
|
"Ø#r rs c ó | j S r )r r^ s r r z OnCommandsFailEvent.commands" s à~~Ð r c ó | j S r )r r^ s r r0 z OnCommandsFailEvent.exception& s àÐ r N)
|
r r r r Útupler5 r3 r` r r0 r r r r r sT ñð$àð$ð ó$ð ð %ò ó ð ð ð 9ò ó ñ r r c ó e Zd Zy)ÚAsyncOnCommandsFailEventNrb r r r r r + rc r r c ó e Zd ZdZdefdZy)r< zG
|
Listener that performs re-authentication of given connection.
|
r c ó8 |j j « y r ©r\ Úre_authr s r r z ReAuthConnectionListener.listen4 s Ø ×Ñ× Ñ Õ"r N)r r r r r; r r r r r< r< / s ñð#Ð 8ô #r r< c ó e Zd ZdZdefdZy)rF zM
|
Async listener that performs re-authentication of given connection.
|
r c óT K |j j « d { y 7 wr r¢ r s r r z$AsyncReAuthConnectionListener.listen= s è ø Ø× Ñ ×&Ñ&Ó(×(Ò(ús ( &¡(N)r r r r rE r r r r rF rF 8 s ñð)Ð"Cô )r rF c óF e Zd ZdZd ZdefdZd Zd Zde fdZ
|
de fd Z y
|
) r> z
|
Listener that registers a re-authentication callback for pooled connections.
|
Required by :class:`StreamingCredentialProvider`.
|
c ó d | _ y r ©Ú_eventr^ s r r3 z+RegisterReAuthForPooledConnections.__init__G ó Ø r r c ó¬ t |j t « rº|| _ |j t
|
j k( rK|j j | j « |j j | j « y |j j | j « |j j | j « y y r ) Ú
|
isinstancerm r r© rl re rh Úon_nextÚ_re_authÚon_errorÚ_raise_on_errorÚ_re_auth_asyncÚ_raise_on_error_asyncr s r r z)RegisterReAuthForPooledConnections.listenJ s Ü e×/Ñ/Ô1LÔ MØ DKà× Ñ ¤J§O¡OÒ3Ø×)Ñ)×1Ñ1°$·-±-Ô@Ø×)Ñ)×2Ñ2°4×3GÑ3GÕHà×)Ñ)×1Ñ1°$×2EÑ2EÔFØ×)Ñ)×2Ñ2°4×3MÑ3MÕNð Nr c ó\ | j j D ] }|j |« y r ©r© rk Úre_auth_callback©r ÚtokenÚpools r r® z+RegisterReAuthForPooledConnections._re_authU s) ØKK×0Ñ0ò )DØ × !Ñ ! %Õ (ñ )r c óx K | j j D ] }|j |« d { y 7 wr r´ r¶ s r r± z1RegisterReAuthForPooledConnections._re_auth_asyncY s6 è ø ØKK×0Ñ0ò /DØ×'Ñ'¨Ó.× .Ñ .ñ /Ø .ús .:°8±:Úerrorc ó. t || j « r ©r/ r© ©r rº s r r° z2RegisterReAuthForPooledConnections._raise_on_error] ó Ü U D§K¡KÓ0Ð0r c ó6 K t || j « wr r¼ r½ s r r² z8RegisterReAuthForPooledConnections._raise_on_error_async` ó è ø Ü U D§K¡KÓ0Ð0ùó N) r r r r r3 r= r r® r± r5 r° r² r r r r> r> A s= ñò
|
ð OÐ Dó Oò)ò/ð1 Yó 1ð1°ô 1r r> c óF e Zd ZdZd ZdefdZd Zd Zde fdZ
|
de fd Z y
|
) r@ z
|
Listener that registers a re-authentication callback for single connection.
|
Required by :class:`StreamingCredentialProvider`.
|
c ó d | _ y r r¨ r^ s r r3 z*RegisterReAuthForSingleConnection.__init__j rª r r c ó t |j j t « râ|| _ |j
|
t j k( r_|j j j | j « |j j j | j « y |j j j | j « |j j j | j « y y r )r¬ r\ rm r r© rl re rh r r® r¯ r° r± r² r s r r z(RegisterReAuthForSingleConnection.listenm s½ Ü Ø × Ñ × 0Ñ 0Ô2Mô
|
ð DKà× Ñ ¤J§O¡OÒ3Ø× Ñ ×4Ñ4×<Ñ<¸T¿]¹]ÔKØ× Ñ ×4Ñ4×=Ñ=¸d×>RÑ>RÕSà× Ñ ×4Ñ4×<Ñ<¸T×=PÑ=PÔQØ× Ñ ×4Ñ4×=Ñ=Ø×.Ñ.õð
|
r c ó* | j j 5 | j j j d|j d« |j « « | j j j « d d d « y # 1 sw Y y xY w©NÚAUTHÚoid©r© r{ r\ Ú send_commandÚtry_getÚ get_valueÚ read_response©r r· s r r® z*RegisterReAuthForSingleConnection._re_auth| sk Ø [[× (Ñ (ñ 3Ø KK× "Ñ "× /Ñ /Ø eÓ,¨e¯o©oÓ.?ô ð KK× "Ñ "× 0Ñ 0Ô 2÷ 3÷ 3ñ 3ús A)B Â Bc ó K | j j 4 d { | j j j d|j d« |j « « d { | j j j « d { d d d « d { y 7 7 C7 7 # 1 d { 7 sw Y y xY wwrÆ rÉ rÎ s r r± z0RegisterReAuthForSingleConnection._re_auth_async s¥ è ø Ø;;×.Ñ.÷ 9ñ 9Ø++×(Ñ(×5Ñ5Ø eÓ,¨e¯o©oÓ.?ó÷ ð ð ++×(Ñ(×6Ñ6Ó8× 8Ð 8÷ 9÷ 9ñ 9øð øð 9øð 9ø÷ 9÷ 9ñ 9üsi CB+C¡AB3Á)B-Á*+B3ÂB/ÂB3Â CÂ%B1Â&CÂ-B3Â/B3Â1CÂ3CÂ9B< Â:CÃCrº c ó. t || j « r r¼ r½ s r r° z1RegisterReAuthForSingleConnection._raise_on_error r¾ r c ó6 K t || j « wr r¼ r½ s r r² z7RegisterReAuthForSingleConnection._raise_on_error_async rÀ rÁ N) r r r r r3 r? r r® r± r5 r° r² r r r r@ r@ d s; ñò
|
ð Ð Có ò 3ò9ð1 Yó 1ð1°ô 1r r@ c ó6 e Zd Zd ZdefdZdefdZdefdZ y) rD c ó d | _ y r r¨ r^ s r r3 z+RegisterReAuthForAsyncClusterNodes.__init__ rª r r c óÜ t |j t « rR|| _ |j j | j
|
« |j j | j « y y r )r¬ rm r r© r r® r¯ r° r s r r z)RegisterReAuthForAsyncClusterNodes.listen sR Ü e×/Ñ/Ô1LÔ MØ DKØ × %Ñ %× -Ñ -¨d¯m©mÔ <Ø × %Ñ %× .Ñ .¨t×/CÑ/CÕ Dð Nr r· c ó¦ K | j j D ]2 }| j j | j |« d { 4 y 7 wr )r© r rµ )r r· Úkeys r r® z+RegisterReAuthForAsyncClusterNodes._re_auth sG è ø Ø;;×$Ñ$ò ACØ++×#Ñ# CÑ(×9Ñ9¸%Ó@× @Ñ @ñ AØ @ús AAÁAÁArº c ó6 K t || j « wr r¼ r½ s r r° z2RegisterReAuthForAsyncClusterNodes._raise_on_error rÀ rÁ N)
|
r r r r3 rC r r r® r5 r° r r r rD rD s0 òðEÐ ?ó Eð A Nó Að1¨9ô 1r rD c óN e Zd Zd ZdefdZdefdZdefdZde fdZ
|
de fd Z y
|
) rB c óJ d | _ d | _ d | _ d | _ d | _ y r )r[ r rp r} r© r^ s r r3 z RegisterReAuthForPubSub.__init__¤ s) Ø ÔØ $Ô Ø ÔØ $Ô Ø r r c óÖ t |j j t « rD|j j « dv r&|| _ |j | _ |j | _ |j | _
|
|j | _ | j t j k( r_| j j j | j « | j j j# | j$ « y | j j j | j& « | j j j# | j( « y y y )N)é Ú3)r¬ r rm r Ú get_protocolr© r[ r r rl rp r{ r} re rh r r® r¯ r° r± r² r s r r z RegisterReAuthForPubSub.listen« s Ü Ø × #Ñ #× 7Ñ 7Ô9Tõ
|
à×%Ñ%×2Ñ2Ó4¸Ò@Ø DKØ $× 6Ñ 6DÔ Ø$)×$9Ñ$9DÔ !Ø %× 1Ñ 1DÔ Ø$)×$9Ñ$9DÔ !à× Ñ ¤J§O¡OÒ3Ø× Ñ ×4Ñ4×<Ñ<¸T¿]¹]ÔKØ× Ñ ×4Ñ4×=Ñ=¸d×>RÑ>RÕSà× Ñ ×4Ñ4×<Ñ<¸T×=PÑ=PÔQØ× Ñ ×4Ñ4×=Ñ=Ø×.Ñ.õð Að
|
r r· c ó$ | j 5 | j j d|j d« |j « « | j j « d d d « | j j |« y # 1 sw Y %xY wrÆ ©r} r[ rÊ rË rÌ rÍ r rµ rÎ s r r® z RegisterReAuthForPubSub._re_auth¾ su Ø × "Ñ "ñ -Ø × Ñ × )Ñ )Ø eÓ,¨e¯o©oÓ.?ô ð × Ñ × *Ñ *Ô ,÷ -ð × Ñ ×.Ñ.¨uÕ5÷ -ð -ús ABÂBc ó¢ K | j 4 d { | j j d|j d« |j « « d { | j j « d { d d d « d { | j j |« d { y 7 7 \7 <7 .# 1 d { 7 sw Y >xY w7 "wrÆ rß rÎ s r r± z&RegisterReAuthForPubSub._re_auth_asyncÇ s» è ø Ø×(Ñ(÷ 3ñ 3Ø×"Ñ"×/Ñ/Ø eÓ,¨e¯o©oÓ.?ó÷ ð ð ×"Ñ"×0Ñ0Ó2× 2Ð 2÷ 3÷ 3ð ×#Ñ#×4Ñ4°UÓ;×;Ñ;ð 3øð øð 3øð 3ø÷ 3÷ 3ñ 3úð <úst CB0C>B8ÁB2Á!B8Á7B4Á8B8Á< CÂB6Â"CÂ*C Â+CÂ2B8Â4B8Â6CÂ8C
|
Â>C Â?C
|
ÃCrº c ó. t || j « r r¼ r½ s r r° z'RegisterReAuthForPubSub._raise_on_errorÐ r¾ r c ó6 K t || j « wr r¼ r½ s r r² z-RegisterReAuthForPubSub._raise_on_error_asyncÓ rÀ rÁ N) r r r r3 rA r r r® r± r5 r° r² r r r rB rB £ sD òðÐ Có ð&6nó 6ð<¨.ó <ð1 Yó 1ð1°ô 1r rB )'rS rH Úabcr r Úenumr Útypingr r r r r
|
Úredis.auth.tokenr Úredis.credentialsr r r r! r& r5 r/ r8 r; rE re r= r? rA rC r r r< rF r> r@ rD rB r r r ú<module>rè s ðÛ Û ß #Ý ß 4Õ 4å +ß Mô Sô ô #ô ô sô ô4$Yô $ôFUÐ.ô FU÷R
|
ñ
|
ô Ð(Dô ôô ÷
|
)ñ )÷8 %ñ %÷>%ñ %÷<)ñ )÷2 ñ ô, Ð 2ô ô#Ð 5ô #ô)Ð$?ô )ô 1Ð)?ô 1ôF*1Ð(>ô *1ôZ1Ð)?ô 1ô$11Ð 4õ 11r
|
