Ë
|
|
çúh5² ã óz U d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z d dl
|
m Z d dl m Z mZmZ d dlmZmZmZmZmZmZmZmZmZmZ d dlm Z m Z m Z d dl m Z m!Z!m"Z"m#Z#m$Z$m%Z% dd l&m'Z'm(Z(m)Z)m*Z* dd
|
l+m,Z, dd l-m.Z. dd l/m0Z0m1Z1 dd l2m3Z3m4Z4 ddl5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z> ddl?m@Z@mAZAmBZBmCZC ddlDmEZE ddlFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZO eIr d dlPZPd dlPmQZQ ndZPdZQeHrd dlRZRdZSdZTdZUdZVdZW eX« ZYeee)e*e(f eZd< eHre(Z[ne)Z[ G d d« Z\ G d d « Z] G d d « Z^ G d d « Z_ G d! d"e_e^« Z` G d# d$e`« Za G d% d&e_e^« Zb G d' d(ea« Zc G d) d*e`« Zdd+Zed, Zfd- Zgeheieiefefejehehefegegeid. Zkd/ Zl ed0d1¬2« Zm G d3 d4e« Zn G d5 d6« Zo G d7 d1eoen« Zp G d8 d9ep« Zqy):é N)ÚABCÚabstractmethod)Úchain)ÚEmptyÚFullÚ LifoQueue)
|
ÚAnyÚCallableÚDictÚIterableÚListÚLiteralÚOptionalÚTypeÚTypeVarÚUnion)Úparse_qsÚunquoteÚurlparse)Ú
|
CacheEntryÚCacheEntryStatusÚ CacheFactoryÚCacheFactoryInterfaceÚCacheInterfaceÚCacheKeyé )ÚEncoderÚ_HiredisParserÚ _RESP2ParserÚ _RESP3Parser)ÚTokenInterface)Ú NoBackoff)ÚCredentialProviderÚ"UsernamePasswordCredentialProvider)Ú AfterConnectionReleasedEventÚEventDispatcher) ÚAuthenticationErrorÚ$AuthenticationWrongNumberOfArgsErrorÚChildDeadlockedErrorÚConnectionErrorÚ DataErrorÚMaxConnectionsErrorÚ
|
RedisErrorÚ ResponseErrorÚ TimeoutError)ÚMaintenanceStateÚMaintNotificationsConfigÚ#MaintNotificationsConnectionHandlerÚ MaintNotificationsPoolHandler)ÚRetry) ÚCRYPTOGRAPHY_AVAILABLEÚHIREDIS_AVAILABLEÚ SSL_AVAILABLEÚcompare_versionsÚdeprecated_argsÚ ensure_stringÚformat_error_messageÚget_lib_versionÚ str_if_bytes)Ú VerifyFlagsó *ó $s
|
ó é Ú DefaultParserc ó e Zd ZdefdZy)ÚHiredisRespSerializerÚargsc ó¬ g }t |d t « r1t |d j « j « « |dd z }n)d|d v r"t |d j « « |dd z } |j t j |« « |S # t $ r3 t j « \ }}}t |« j |« w xY w©ú2Pack a series of arguments into the Redis protocolr r Nó ) Ú
|
isinstanceÚstrÚtupleÚencodeÚsplitÚappendÚhiredisÚ pack_commandÚ TypeErrorÚsysÚexc_infor+ Úwith_traceback)ÚselfrF ÚoutputÚ_ÚvalueÚ tracebacks õc H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/connection.pyÚpackzHiredisRespSerializer.pack` sÄ àä d1gsÔ #Üa Ó)×/Ñ/Ó1Ó2°T¸!¸"°XÑ=DØ T!W_Üa Ó)¨D°°¨HÑ4Dð =Ø MM'×.Ñ.¨tÓ4Ô 5ð
|
øô ò =Ü"%§,¡,£.Ñ AuiÜEÓ"×1Ñ1°)Ó<Ð <ð =ús Á1$B Â<CN)Ú__name__Ú
|
__module__Ú __qualname__r r] © rA r\ rE rE _ s ð$ô rA rE c ó e Zd ZddZd Zy)ÚPythonRespSerializerNc ó || _ || _ y ©N)Ú_buffer_cutoffrN )rW Ú buffer_cutoffrN s r\ Ú__init__z PythonRespSerializer.__init__r s Ø +ÔØ rA c ón g }t |d t « r1t |d j « j « « |dd z }n)d|d v r"t |d j « « |dd z }t
|
j t t t |« « j « t f« }| j }t | j |« D ]Ï }t |« }t |« |kD s||kD st |t « rat
|
j |t t |« j « t f« }|j |« |j |« t }t
|
j |t t |« j « t |t f« }Ñ |j |« |S rH )rK rL rM rN rO Ú SYM_EMPTYÚjoinÚSYM_STARÚlenÚSYM_CRLFrf ÚmapÚ
|
memoryviewÚ
|
SYM_DOLLARrP )rW rF rX Úbuffrg ÚargÚ
|
arg_lengths r\ r] zPythonRespSerializer.packv si àô d1gsÔ #Üa Ó)×/Ñ/Ó1Ó2°T¸!¸"°XÑ=DØ T!W_Üa Ó)¨D°°¨HÑ4Dä~~x¬¬S°«Y« ×)>Ñ)>Ó)@Ä(Ð KÓLà ×+Ñ+ Üt{{ DÓ)ò Cô SJäD MÒ)Ø Ò-Ü c¤:Ô.ä ~~Ø:¤s¨:£×'=Ñ'=Ó'?ÄÐJóð dÔ#Ø cÔ"Ü ä ~~à Ü"ÜJ×.Ñ.Ó0Ü ØÜ ð ó ð! ð4 dÔØ rA ©ÚreturnN)r^ r_ r` rh r] ra rA r\ rc rc q s ó ó+rA rc c ó e Zd Zed « Zed « Zed « Zed « Zed « Zed « Z ed « Z
|
ed « Z ed « Z ed d « Z ed « Zed d « Ze d d
|
ddd« Zed « Zed « Zeedeeeef eeef f fd« « Zedefd« Zed « Zed « Z ed « Z ed « Z y) ÚConnectionInterfacec ó y re ra ©rW s r\ Ú repr_piecesz ConnectionInterface.repr_pieces¥ ó à rA c ó y re ra ©rW Úcallbacks r\ Úregister_connect_callbackz-ConnectionInterface.register_connect_callback© r| rA c ó y re ra r~ s r\ Úderegister_connect_callbackz/ConnectionInterface.deregister_connect_callback r| rA c ó y re ra ©rW Ú parser_classs r\ Ú
|
set_parserz ConnectionInterface.set_parser± r| rA c ó y re ra rz s r\ Ú get_protocolz ConnectionInterface.get_protocolµ r| rA c ó y re ra rz s r\ ÚconnectzConnectionInterface.connect¹ r| rA c ó y re ra rz s r\ Ú
|
on_connectz ConnectionInterface.on_connect½ r| rA c ó y re ra ©rW rF s r\ Ú
|
disconnectz ConnectionInterface.disconnectÁ r| rA c ó y re ra rz s r\ Ú check_healthz ConnectionInterface.check_healthÅ r| rA Tc ó y re ra ©rW Úcommandr s r\ Úsend_packed_commandz'ConnectionInterface.send_packed_commandÉ r| rA c ó y re ra ©rW rF Úkwargss r\ Ú send_commandz ConnectionInterface.send_commandÍ r| rA c ó y re ra ©rW Útimeouts r\ Úcan_readz ConnectionInterface.can_readÑ r| rA F©Údisconnect_on_errorÚ push_requestc ó y re ra ©rW Údisable_decodingr r s r\ Ú read_responsez!ConnectionInterface.read_responseÕ ó ð rA c ó y re ra r s r\ rR z ConnectionInterface.pack_commandß r| rA c ó y re ra ©rW Úcommandss r\ Ú pack_commandsz!ConnectionInterface.pack_commandsã r| rA rv c ó y re ra rz s r\ Úhandshake_metadataz&ConnectionInterface.handshake_metadataç ó ð rA Útokenc ó y re ra ©rW r® s r\ Úset_re_auth_tokenz%ConnectionInterface.set_re_auth_tokenì r| rA c ó y re ra rz s r\ Úre_authzConnectionInterface.re_authð r| rA c ó y)z
|
Mark the connection to be reconnected on the next command.
|
This is useful when a connection is moved to a different node.
|
Nra rz s r\ Úmark_for_reconnectz&ConnectionInterface.mark_for_reconnectô s ð rA c ó y)zG
|
Returns True if the connection should be reconnected.
|
Nra rz s r\ Úshould_reconnectz$ConnectionInterface.should_reconnectü ó ð
|
rA c ó y)z3
|
Reset the internal flag to False.
|
Nra rz s r\ Úreset_should_reconnectz*ConnectionInterface.reset_should_reconnect r¸ rA N©T©r ©F) r^ r_ r` r r{ r r r r r r r r r r r r¤ rR rª Úpropertyr r ÚbytesrL r¬ r! r± r³ rµ r· rº ra rA r\ rx rx ¤ sç Øñ ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð ò ó ð ð ñ ó ð ð ò ó ð ð ð ð ð !Øó ó ð ð ñ ó ð ð ñ ó ð ð Øð E¨$¨u°e¨|Ñ*<¸dÀ3ÈÀ8¹nÐ*LÑ$Mò ó ó ð ð ð ~ò ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ñ rA rx c ó e Zd ZdZdej
|
dddddfdee dee dddee dee
|
d ee d
|
ee d ee e ef fd Zed e e ef fd« Zed eej$ fd« Zed e e e
|
f fd« Zeed e
|
fd« « Zej. ede
|
fd« « Zeed ee e e f fd« « Zej. edee e e f fd« « Zeed ee e e f fd« « Zej. edee e e f fd« « Zed « Ze d0dddd « Zed « Z d1dee d ee e ef fd Z defd Z d2d Z d2defd!Z d ee
|
fd"Z!ed efd#« Z"e"j. d3d$« Z"d% Z#d4d&ee fd'Z$d4d(ee fd)Z%e&dfd*ee e
|
e'f d+ee fd,Z( d5d-e)d.e)fd/Z*y)6Ú$MaintNotificationsAbstractConnectiona2
|
Abstract class for handling maintenance notifications logic.
|
This class is expected to be used as base class together with ConnectionInterface.
|
|
This class is intended to be used with multiple inheritance!
|
|
All logic related to maintenance notifications is encapsulated in this class.
|
NÚmaint_notifications_configÚ maint_notifications_pool_handlerÚmaintenance_stater0 Ú maintenance_notification_hashÚorig_host_addressÚorig_socket_timeoutÚorig_socket_connect_timeoutÚparserc óX || _ || _ || _ | j |||||« y)aw
|
Initialize the maintenance notifications for the connection.
|
|
Args:
|
maint_notifications_config (MaintNotificationsConfig): The configuration for maintenance notifications.
|
maint_notifications_pool_handler (Optional[MaintNotificationsPoolHandler]): The pool handler for maintenance notifications.
|
maintenance_state (MaintenanceState): The current maintenance state of the connection.
|
maintenance_notification_hash (Optional[int]): The current maintenance notification hash of the connection.
|
orig_host_address (Optional[str]): The original host address of the connection.
|
orig_socket_timeout (Optional[float]): The original socket timeout of the connection.
|
orig_socket_connect_timeout (Optional[float]): The original socket connect timeout of the connection.
|
parser (Optional[Union[_HiredisParser, _RESP3Parser]]): The parser to use for maintenance notifications.
|
If not provided, the parser from the connection is used.
|
This is useful when the parser is created after this object.
|
N)r rÄ rÅ Ú$_configure_maintenance_notifications) rW r rà rÄ rÅ rÆ rÇ rÈ rÉ s r\ rh z-MaintNotificationsAbstractConnection.__init__ s: ð8 +EÔ'Ø!2Ô Ø-JÔ*Ø ×1Ñ1Ø ,Ø Ø Ø 'Ø õ
|
rA rv c ó y re ra rz s r\ Ú _get_parserz0MaintNotificationsAbstractConnection._get_parser< r| rA c ó y re ra rz s r\ Ú _get_socketz0MaintNotificationsAbstractConnection._get_socket@ r| rA c ó y)úª
|
Returns:
|
The RESP protocol version, or ``None`` if the protocol is not specified,
|
in which case the server default will be used.
|
Nra rz s r\ r z1MaintNotificationsAbstractConnection.get_protocolD s ð rA c ó y re ra rz s r\ Úhostz)MaintNotificationsAbstractConnection.hostM r rA rZ c ó y re ra ©rW rZ s r\ rÓ z)MaintNotificationsAbstractConnection.hostR r rA c ó y re ra rz s r\ Úsocket_timeoutz3MaintNotificationsAbstractConnection.socket_timeoutW r rA c ó y re ra rÕ s r\ r× z3MaintNotificationsAbstractConnection.socket_timeout\ r rA c ó y re ra rz s r\ Úsocket_connect_timeoutz;MaintNotificationsAbstractConnection.socket_connect_timeouta r rA c ó y re ra rÕ s r\ rÚ z;MaintNotificationsAbstractConnection.socket_connect_timeoutf r rA c ó y re ra r s r\ r z1MaintNotificationsAbstractConnection.send_commandk r| rA FTr c ó y re ra r¢ s r\ r¤ z2MaintNotificationsAbstractConnection.read_responseo r¥ rA c ó y re ra r s r\ r z/MaintNotificationsAbstractConnection.disconnecty r| rA c ó¶ | j r| j j sd| _ d| _ y|s t d« t |t « st |t « s t d« |r1|j « | _ | j j | « nd| _ t | | j « | _ | j r%|j | j j « |j | j j « |r|n | j | _ |r|n | j | _ |r|| _ y| j$ | _ y)zÈ
|
Enable maintenance notifications by setting up
|
handlers and storing original connection parameters.
|
|
Should be used ONLY with parsers that support push notifications.
|
NzBTo configure maintenance notifications, a parser must be provided!zLMaintenance notifications are only supported with hiredis and RESP3 parsers!)r ÚenabledÚ!_maint_notifications_pool_handlerÚ'_maint_notifications_connection_handlerr- rK r r Úget_handler_for_connectionÚset_connectionr2 Ú set_node_moving_push_handlerÚhandle_notificationÚ set_maintenance_push_handlerrÓ rÆ r× rÇ rÚ rÈ )rW rà rÆ rÇ rÈ rÉ s r\ rË zIMaintNotificationsAbstractConnection._configure_maintenance_notifications} sU ð" ×/Ò/Ø×2Ñ2×:Ò:à59DÔ 2Ø;?DÔ 8Ø áÜ ØTóð ô &¤.Ô1¼*Ø Lô;
|
ô Ø^óð ñ ,ð 1×KÑKÓMð Ô 2ð × 2Ñ 2× AÑ AÀ$Õ Gà59DÔ 2ô 0°°d×6UÑ6UÓ Vð Ô4ð
|
× 1Ò 1Ø × /Ñ /Ø×6Ñ6×JÑJô ð
|
×+Ñ+Ø × 8Ñ 8× LÑ Lô
|
ñ
|
7HÑ!2ÈTÏYÉYÔ á#6Ñ ¸D×<OÑ<Oð Ô ñ
|
+ð (ð Õ(ð ×,Ñ,ð Õ(rA c ó |j « }|j | « | j « j |j « || _ | j sOt | |j « | _ | j « j | j j « y |j | j _ y re )
|
rã rä rÍ rå ræ rá râ r2 Úconfigrç )rW rà Ú%maint_notifications_pool_handler_copys r\ Ú3set_maint_notifications_pool_handler_for_connectionzXMaintNotificationsAbstractConnection.set_maint_notifications_pool_handler_for_connectionÈ s¸ ð -× GÑ GÓ Ið .ð .×<Ñ<¸TÔBØ ×ÑÓ×7Ñ7Ø 1× EÑ Eô
|
ð 2WÔ.ð ×;Ò;ä3ØÐ:×AÑAóð Ô 8ð
|
× Ñ Ó × ;Ñ ;Ø×<Ñ<×PÑPõ ð
|
1×7Ñ7ð × 8Ñ 8Õ ?rA c óà | j « dvr\| j rO| j j r8| j r+t | d« r | j | j |¬« y y y y y y )N©rB Ú2rÓ )r r )r r rà râ ÚhasattrÚ!_enable_maintenance_notifications)rW r s r\ Ú0activate_maint_notifications_handling_if_enabledzUMaintNotificationsAbstractConnection.activate_maint_notifications_handling_if_enabledé sx ð × Ñ Ó xÑ /Ø×/Ò/Ø×/Ñ/×7Ò7Ø×<Ò<ÜfÔ%à × 2Ñ 2Ø+/×+JÑ+JØ )ð 3õ ð &ð =ð 8ð 0ð 0rA c ó¾ t | dd « }| t d« |j || « }| j dddd|j |¬« | j « }|rt |« dk7 r t d « y # t $ rX}t |t « r=|j d
|
k( r.d d l }|j t « }|j d | « n Y d }~y d }~ww xY w) NrÓ zaCannot enable maintenance notifications for connection object that doesn't have a host attribute.ÚCLIENTÚMAINT_NOTIFICATIONSÚONzmoving-endpoint-type©r ÚOKz4The server doesn't support maintenance notificationsÚautor z,Failed to enable maintenance notifications: )ÚgetattrÚ
|
ValueErrorÚget_endpoint_typer rZ r¤ r= r. Ú ExceptionrK rà ÚloggingÚ getLoggerr^ Úwarning) rW r r rÓ Ú endpoint_typeÚresponseÚerý Úloggers r\ rð zFMaintNotificationsAbstractConnection._enable_maintenance_notificationsü sþ ð! Ü4 ¨Ó.DØ|Ü ðBóð ð
|
!;× LÑ LÈTÐSWÓ X Ø×!Ñ!Ø Ø)ØØ*Ø!×'Ñ'Ø!-ð "ô ð ×-Ñ-Ó/Ù ¤<°Ó#9¸TÒ#AÜ'ØNóð ð $Bøô ò ä1mÔ,Ø.×6Ñ6¸&Ò@ó à ×*Ñ*¬8Ó4ØÐ!MÈaÈSÐ QÕRàô Sûð ús A8A; Á; C ÂACÃC c ó´ | j « }|%|j « }|rt |« dk\ r|d S t | dd« }t | dd« }|rJt j ||t j t j « }|rt |d d d « S y# t t f$ r Y yw xY w# t t t j f$ r Y yw xY w) a¨
|
Extract the resolved IP address from an
|
established connection or resolve it from the host.
|
|
First tries to get the actual IP from the socket (most accurate),
|
then falls back to DNS resolution if needed.
|
|
Args:
|
connection: The connection object to extract the IP from
|
|
Returns:
|
str: The resolved IP address, or None if it cannot be determined
|
Nr r rÓ Ú localhostÚportéë é ) rÏ Ú getpeernamerm ÚAttributeErrorÚOSErrorrù ÚsocketÚ getaddrinfoÚ AF_UNSPECÚ SOCK_STREAMrL Úgaierror)rW Ú conn_socketÚ peer_addrrÓ r Ú addr_infos r\ Úget_resolved_ipz4MaintNotificationsAbstractConnection.get_resolved_ip" sì ð"
|
Ø ×*Ñ*Ó,KØÐ&Ø '× 3Ñ 3Ó 5 Ù ¤ Y£ °1Ò!4ð % Q<Ð'ð Ü4 ¨Ó5DÜ4 ¨Ó.DÙô #× .Ñ .Ø$¤× 0Ñ 0´&×2DÑ2Dó ñ ô y¨|¨A¨qÑ 1Ó2Ð2ð
|
øô1 ¤Ð(ò á ð ûô( ¤¬¯ © Ð9ò à àð ús# 6B! ºA%B6 Â!B3Â2B3Â6 CÃCc ó | j S re ©Ú_maintenance_staterz s r\ rÄ z6MaintNotificationsAbstractConnection.maintenance_stateU ó à×&Ñ&Ð&rA c ó || _ y re r )rW Ústates r\ rÄ z6MaintNotificationsAbstractConnection.maintenance_stateY ó
|
à"'Õ rA c óN | j « }|r|j « d S y)z:
|
Returns the peer name of the connection.
|
r N)rÏ r )rW r s r\ r z0MaintNotificationsAbstractConnection.getpeername] s, ð ×&Ñ&Ó( Ù Ø ×*Ñ*Ó,¨QÑ/Ð /ØrA Úrelaxed_timeoutc ó | j « }|r6|dk7 r|n | j }|j |« | j |« y y )Néÿÿÿÿ)rÏ r× Ú
|
settimeoutÚupdate_parser_timeout)rW r r r s r\ Ú update_current_socket_timeoutzBMaintNotificationsAbstractConnection.update_current_socket_timeoutf sH Ø×&Ñ&Ó( Ù Ø)8¸BÒ)>oÀD×DWÑDWGØ × "Ñ " 7Ô +Ø × &Ñ & wÕ /ð rA r c ó¼ | j « }|rJ|j r=t |t « r|r||j _ y t |t
|
« r||_ y y y y re )rÍ Ú_bufferrK r r× r Ú_socket_timeout)rW r rÉ s r\ r! z:MaintNotificationsAbstractConnection.update_parser_timeoutm sO Ø×!Ñ!Ó#Ù fnnÜ&¤,Ô/±GØ07Õ-ÜF¤NÔ3Ø)0Õ&ð 4ð %6rA Útmp_host_addressÚtmp_relaxed_timeoutc ób |r|t k7 rt |« | _ |dk7 r|| _ || _ yy)zd
|
The value of SENTINEL is used to indicate that the property should not be updated.
|
r N)ÚSENTINELrL rÓ r× rÚ )rW r& r' s r\ Úset_tmp_settingsz5MaintNotificationsAbstractConnection.set_tmp_settingsu s9 ñ Ð 0´HÒ <ÜÐ ,Ó-DIØ "Ò $Ø"5DÔ Ø*=DÕ 'ð %rA Úreset_host_addressÚreset_relaxed_timeoutc ót |r| j | _ |r#| j | _ | j | _ y y re )rÆ rÓ rÇ r× rÈ rÚ )rW r+ r, s r\ Úreset_tmp_settingsz7MaintNotificationsAbstractConnection.reset_tmp_settings s8 ñ
|
Ø ×.Ñ.DIÙ Ø"&×":Ñ":DÔ Ø*.×*JÑ*JDÕ 'ð !rA r½ )NNNNNr» )r r0 re ©FF)+r^ r_ r` Ú__doc__r0 ÚNONEr r1 r3 ÚintrL Úfloatr r r rh r rÍ r rÏ r r¾ rÓ Úsetterr× rÚ r r¤ r rË rë rñ rð r rÄ r r" r! r) Úobjectr* Úboolr. ra rA r\ rÁ rÁ s¤ ñð Ø0@×0EÑ0EØ7;Ø+/Ø/3Ø7;Ø@Dñ%
|
à$,Ð-EÑ$Fð%
|
ð +3Ø )ñ+
|
ð%
|
ð .ð %
|
ð (0°¡}ð%
|
ð $ C=ð%
|
ð & e_ð%
|
ð &.¨e¡_ð%
|
ð ~¨|Ð ;Ñ<Ñ=ó%
|
ðN ð U >°<Ð#?Ñ @ò ó ð ð ð X f§m¡mÑ 4ò ó ð ð ð e C¨ Hoò ó ð ð Øð cò ó ó ð ð
|
[[Øð #ò ó ó ð ð Ø𠨨u°c¨zÑ):Ñ ;ò ó ó ð ð ×ÑØð H¨U°5¸#°:Ñ->Ñ$?ò ó ó ð ð Øð ¨°°u¸c°zÑ1BÑ(Cò ó ó ð ð ×"Ñ"Øð ¨H°U¸5À#¸:Ñ5FÑ,Gò ó ó #ð ð ñ ó ð ð ð ð ð !Øó ó ð ð ñ ó ð ð Ø Ø Ø$(Ø@DñI
|
à*2Ø )ñ+
|
ðI
|
ð ~¨|Ð ;Ñ<Ñ=óI
|
ðV Ø0Mó óBð( RVñ$Ø*Bó$ðL1 ¨#¡ ó 1ðf ð'Ð#3ò 'ó ð'ð × Ñ ò(ó ð(òñ0¸XÀe¹_ó 0ñ1¨X°e©_ó 1ð :BØ/3ñ >à" 5¨¨f¨Ñ#5Ñ6ð >ð & e_ó >ð $)Ø&+ñ Kà ð Kð $ô KrA rÁ c : ó
|
e Zd ZdZdddddedddedddd e« ddddd ddddej ddddf d
|
e d e
|
e d e
|
e d e
|
e de deeee ef de de de de de de
|
e de
|
e de
|
e de
|
e deedf de
|
eg df de
|
e d e
|
e d e
|
eg df d e
|
e d e
|
e d e
|
e d!d"d#e
|
e d$e
|
e d%e
|
e d&e
|
e f8d'Zd( Zed) « Z d* Z d+ Z d, Z d- Z d. Z!d/ee"e#e$f fd0Z%d1 Z& dUd3e d4e fd5Z'ed6 « Z(ed7 « Z)d8 Z*d9 Z+dVd3e fd:Z,d; Z-d< Z.d= Z/d> Z0d? Z1d@ Z2dA Z3dVdBZ4dC Z5dWdDZ6 dXd2ddEdFZ7dG Z8dH Z9d/ee e f fdIZ:e;d/ee<e=e=f e<e e f f fdJ« Z>e>j~ dKee<e=e=f e<e e f f fdL« Z>dMe@fdNZAdO ZBd/e
|
eCj fdPZDe;d/e
|
ee e f fdQ« ZEeEj~ dKe
|
ee e f fdR« ZEe;d/e
|
ee e f fdS« ZFeFj~ dKe
|
ee e f fdT« ZFy)YÚAbstractConnectionz0Manages communication to and from a Redis serverr NFúutf-8Ústricti zredis-pyrB ÚdbÚpasswordr× rÚ Úretry_on_timeoutÚretry_on_errorÚencodingÚencoding_errorsÚdecode_responsesÚsocket_read_sizeÚhealth_check_intervalÚ client_nameÚlib_nameÚ lib_versionÚusernameÚretryÚredis_connect_funcÚcredential_providerÚprotocolÚcommand_packerÚevent_dispatcherr rà rÄ r0 rÅ rÆ rÇ rÈ c ó |s|r | t d« |t « | _ n|| _ t j « | _ || _ | | _ || _ || _ || _
|
|| _ || _ || _ ||}|| _ || _ |t u rg } n t# |« } |r| j% t& « | | _ |s | j( rh|t+ t- « d« | _ nt1 j2 |« | _ | j( r?| j. j5 | j( « nt+ t- « d« | _ | | _ d| _ || _ t= ||| « | _ d| _ d| _! | | _" g | _# d| _$ d| _% tM |« } | dk s| dkD r tU d « | | _+ | jV dk( r|
|
tX k( rtZ }
|
| j] |
|
« | j_ |« | _0 d
|
| _1 td jg | |||||| | | jh « y# tN $ r tP } Y ¡tR $ r tU d« w xY w# dk s| dkD r tU d « | | _+ w xY w) a2
|
Initialize a new Connection.
|
To specify a retry policy for specific errors, first set
|
`retry_on_error` to a list of the error/s to retry on, then set
|
`retry` to a valid `Retry` object.
|
To retry on TimeoutError, `retry_on_timeout` can also be set to `True`.
|
NzÂ'username' and 'password' cannot be passed along with 'credential_provider'. Please provide only one of the following arguments:
|
1. 'password' and (optional) 'username'
|
2. 'credential_provider'r r ip zprotocol must be an integerrB é z protocol must be either 2 or 3F)5r+ r& Ú_event_dispatcherÚosÚgetpidÚpidr; rD rE rF rJ r< rG r% Ú_socket_connect_timeoutr= r) ÚlistrP r/ r> r4 r" rH ÚcopyÚdeepcopyÚupdate_supported_errorsrC Únext_health_checkrI r Úencoderr¬ Ú_sockÚ_socket_read_sizeÚ_connect_callbacksrf Ú_re_auth_tokenr2 rS ÚDEFAULT_RESP_VERSIONrú r* rK r r r Ú_construct_command_packerÚ_command_packerÚ_should_reconnectrÁ rh Ú_parser) rW r; r< r× rÚ r= r> r? r@ rA r
rB rC rD rE rF rG rH rI rJ rK rL rM r rà rÄ rÅ rÆ rÇ rÈ Úretry_on_errors_listÚps r\ rh zAbstractConnection.__init__ s~ ñR Ð&9Ð&EÜð+óð ð Ð #Ü%4Ó%6DÕ "à%5DÔ "Ü99;ØØ&ÔØ Ø&ÔØ#6Ô Ø Ø Ø -Ô Ø !Ð )Ø%3Ð "Ø'=Ô$Ø 0Ô Ø XÑ %Ø#%Ñ ä#'¨Ó#7Ð Ù à × 'Ñ '¬ Ô 5Ø 2ÔÙ D×'Ò'Ø}Ü "¤9£;°Ó 2
|
ô "]]¨5Ó 1
|
Ø×"Ò"à
|
|
×2Ñ2°4×3FÑ3FÕGä y{¨AÓ.DJØ%:Ô"Ø!"Ô Ø"4Ô Ü x¨ Ð:JÓK Ø"&Ô Ø
|
Ø!1Ô Ø"$Ô Ø "ÔØ8<Ôð
|
ÜH Að 1uAÜ%Ð&FÓGÐGà DMØ ==AÒ ,´,Ò">ô (LØ Ô%à #× =Ñ =¸nÓ MÔ Ø!&Ô ô -×5Ñ5Ø Ø &Ø ,Ø Ø )Ø Ø Ø 'Ø LLõ
|
|
øô- ò %Ü$AÜò AÜ!Ð"?Ó@Ð @ð Aûð 1uAÜ%Ð&FÓGÐGà DMús$ Æ# H> È>I#É I& ÉI#É#I& É& Jc óä dj | j « D cg c] \ }}| d| c}}« }d| j j d| j j d| dS c c}}w )Nú,ú=ú<ú.ú(z)>)rk r{ Ú __class__r_ r^ )rW ÚkÚvÚ repr_argss r\ Ú__repr__zAbstractConnection.__repr__ sj ØHH°T×5EÑ5EÓ5G× H©T¨Q° 1 Q CjÓ HÓI Ø4>>×,Ñ,Ð-¨Q¨t¯~©~×/FÑ/FÐ.GÀqÈÈ ÐSUÐVÐVùó Is A,
|
c ó y re ra rz s r\ r{ z AbstractConnection.repr_pieces r| rA c óD | j « y # t $ r Y y w xY wre )r rü rz s r\ Ú__del__zAbstractConnection.__del__ s# ð Ø OOÕ øÜò Ù ð ús c ó~ ||S t r
|
t « S t | j | j j
|
« S re )r6 rE rc rf rZ rN )rW Úpackers r\ r` z,AbstractConnection._construct_command_packer" s6 Ø Ð ØMÝ Ü(Ó*Ð *ä'¨×(;Ñ(;¸T¿\¹\×=PÑ=PÓQÐ QrA c ó t j |« }|| j vr | j j |« yy)a^
|
Register a callback to be called when the connection is established either
|
initially or reconnected. This allows listeners to issue commands that
|
are ephemeral to the connection, for example pub/sub subscription or
|
key tracking. The callback must be a _method_ and will be kept as
|
a weak reference.
|
N)ÚweakrefÚ
|
WeakMethodr] rP )rW r Úwms r\ r z,AbstractConnection.register_connect_callback* s; ô × Ñ Ó )Ø T×,Ñ,Ñ ,Ø × #Ñ #× *Ñ *¨2Õ .ð -rA c ó | j j t j |« « y# t $ r Y yw xY w)z÷
|
De-register a previously registered callback. It will no-longer receive
|
notifications on connection events. Calling this is not required when the
|
listener goes away, since the callbacks are kept as weak methods.
|
N)r] Úremoverw rx rú r~ s r\ r z.AbstractConnection.deregister_connect_callback6 s8 ð Ø × #Ñ #× *Ñ *¬7×+=Ñ+=¸hÓ+GÕ HøÜò Ù ð ús .1 ± =¼=c ó4 || j ¬« | _ y)zË
|
Creates a new instance of parser_class with socket size:
|
_socket_read_size and assigns it to the parser for the connection
|
:param parser_class: The required parser class
|
)rB N)r\ rc r s r\ r z AbstractConnection.set_parserA s ñ $°T×5KÑ5KÔL rA rv c ó | j S re )rc rz s r\ rÍ z AbstractConnection._get_parserI s Ø||ÐrA c ó( | j d¬« y)z5Connects to the Redis server if not already connectedTrö N)Úconnect_check_healthrz s r\ r zAbstractConnection.connectL s à ×!Ñ!¨tÐ!Õ4rA Tr Úretry_socket_connectc óf j ry |r# j j fd fd« }n j « }| _ j j |¬« n j « j D cg c] } |« s | c} _ j D ] } |« }|s | « y # t j
|
$ r t d« t $ r }t j |« « d }~ww xY w# t $ r j « w xY wc c}w )Nc ó$ j « S re )Ú_connectrz s r\ ú<lambda>z9AbstractConnection.connect_check_health.<locals>.<lambda>X s ø DMMO rA c ó& j | « S re ©r ©ÚerrorrW s r\ r z9AbstractConnection.connect_check_health.<locals>.<lambda>X s ø ¸4¿?¹?È5Ó;Q rA z Timeout connecting to serverrö )r[ rH Úcall_with_retryr r r r/ r r* Ú_error_messagerI Úon_connect_check_healthr- r r] )rW r r Úsockr Úrefr s ` r\ r z'AbstractConnection.connect_check_healthP s ø ð ::Ø ð
|
:Ù#Øzz×1Ñ1Û+Ó-Qóð }}ð
|
ð
|
Ø×&Ñ&Ð.à×,Ñ,¸,Ð,ÕGð ×'Ñ'¨Ô-ð 37×2IÑ2IÖ"S¨3ÉSÍU¢3Ò"SÔ Ø×*Ñ*ò CÙuHÚÙñ øô- ~~ò ?Ü Ð =Ó>Ð >Üò :Ü! $×"5Ñ"5°aÓ"8Ó9Ð 9ûð :ûô ò à OOÔ Ø ð üò #Ts/ 5C Á 0D  D.ÂD.Ã&D Ã.DÄD ÄD+c ó y re ra rz s r\ r zAbstractConnection._connectw r| rA c ó y re ra rz s r\ Ú _host_errorz AbstractConnection._host_error{ r| rA c ó6 t | j « |« S re )r; r )rW Ú exceptions r\ r z!AbstractConnection._error_message s Ü# D×$4Ñ$4Ó$6¸ ÓBÐBrA c ó( | j d¬« y )NTrö )r rz s r\ r z AbstractConnection.on_connect s Ø ×$Ñ$°$Ð$Õ7rA c ó2 | j j | « | j }d}| j s| j s | j r>| j xs t | j | j « }|j « }|rÁ| j dvr³t | j t « rK| j t « |j | j _ | j j | « t |« dk( rd|d g} | j d| j dg|¢dd i | j « | _ nD|rA | j dg|¢dd i | j « }t% |« d k7 r t' d « | j dvrót | j t « rK| j t « |j | j _ | j j | « | j d| j |¬ « | j « | _ | j j) d« | j k7 r3| j j) d« | j k7 r t+ d« | j- |¬ « | j. rF| j dd| j. |¬ « t% | j « « d k7 r t+ d« | j0 r0| j ddd| j0 |¬ « | j « | j4 r0| j ddd| j4 |¬ « | j « | j6 rF| j d| j6 |¬ « t% | j « « d k7 r t+ d« yy# t" $ r+ | j d|d
|
d ¬ « | j « }Y w xY w# t2 $ r Y Òw xY w# t2 $ r Y ¤w xY w)z=Initialize the connection, authenticate and select a databaseNrí r Údefaultr ÚHELLOÚAUTHr Fr rö r÷ z Invalid Username or Passwords protoÚprotozInvalid RESP versionró ÚSETNAMEzError setting client nameÚSETINFOzLIB-NAMEzLIB-VERÚSELECTzInvalid Database) rc r rJ rG r< r$ Úget_credentialsrK rK r r r ÚEXCEPTION_CLASSESrm r r¤ r¬ r( r= r' Úgetr* rñ rD rE r. rF r; )rW r rÉ Ú auth_argsÚ cred_providerÚ auth_responses r\ r z*AbstractConnection.on_connect_check_health
s» à × Ñ Ô%Ø à à × #Ò #¨¯ ª ¸¿ º à×(Ñ(ò TÜ5°d·m±mÀTÇ]Á]ÓSð ð &×5Ñ5Ó7Iñ ¨hÑ6Ü$,,¬ Ô5ؤ Ô-à17×1IÑ1I Ô.Ø ×'Ñ'¨Ô-Ü9~ Ò"Ø &¨ °!© Ð 5 ð D× Ñ Ø ¨ð Ø1:ò ØINò ð '+×&8Ñ&8Ó&:DÖ #ñ
|
ð D× Ñ fÐ E yÒ E¸uÒ Eð 5Ø $× 2Ñ 2Ó 4 ô MÓ*¨dÓ2Ü)Ð*HÓIÐIð ]] (Ñ *Ü$,,¬ Ô5ؤ Ô-à17×1IÑ1I Ô.Ø ×'Ñ'¨Ô-Ø × Ñ g t§}¡}À<Ð Ô PØ&*×&8Ñ&8Ó&:DÔ #à×'Ñ'×+Ñ+¨HÓ5¸¿ ¹ ÒFØ×+Ñ+×/Ñ/°Ó8¸D¿M¹MÒIä%Ð&<Ó=Ð=ð
|
×=Ñ=È<Ð=ÔXð × Ò Ø × Ñ ØØØ× Ñ Ø )ð ô ô D× .Ñ .Ó 0Ó1°TÒ9Ü%Ð&AÓBÐBð à}}Ø×!Ñ!Ø Ø Ø ØMMØ!-ð "ô ð ×"Ñ"Ô$ð Ø× Ò Ø×!Ñ!Ø Ø Ø Ø×$Ñ$Ø!-ð "ô ð ×"Ñ"Ô$ð
|
77Ø × Ñ h¨¯©¸lÐ Ô KÜD× .Ñ .Ó 0Ó1°TÒ9Ü%Ð&8Ó9Ð9ð :ð øôM 8ò 5ð
|
×!Ñ! &¨)°B©-ÀeÐ!ÔLØ $× 2Ñ 2Ó 4 ð 5ûôj ò Ù ð ûô ò Ù ð ús6 Å(O Ë8<O; Ì5<P
|
Ï0O8Ï7O8Ï; PÐPÐ
|
PÐPc óp | j j « | j }d| _ | j « |yt j
|
« | j k( r |j t j « |j « y# t t f$ r Y #w xY w# t $ r Y yw xY w)z!Disconnects from the Redis serverN) rc Ú on_disconnectr[ rº rQ rR rS Úshutdownr Ú SHUT_RDWRr rS Úclose)rW rF Ú conn_socks r\ r z AbstractConnection.disconnectù s à ×"Ñ"Ô$àJJ Ø
|
à ×#Ñ#Ô%Ø Ð Ø ä 99;$((Ò "ð Ø×"Ñ"¤6×#3Ñ#3Ô4ð Ø OOÕ øô YÐ'ò Ùð ûô
|
ò Ù ð ús$ Á# B ÂB) ÂB&Â%B&Â) B5Â4B5c ó d| _ y )NT©rb rz s r\ rµ z%AbstractConnection.mark_for_reconnect s
|
Ø!%Õ rA c ó | j S re r© rz s r\ r· z#AbstractConnection.should_reconnect s Ø×%Ñ%Ð%rA c ó d| _ y )NFr© rz s r\ rº z)AbstractConnection.reset_should_reconnect s
|
Ø!&Õ rA c óx | j dd¬« t | j « « dk7 r t d« y)z Send PING, expect PONG in returnÚPINGFrö ÚPONGz#Bad response from PING health checkN)r r= r¤ r* rz s r\ Ú
|
_send_pingz AbstractConnection._send_ping s< à ×Ñ&¨uÐÔ5Ü ×*Ñ*Ó,Ó -°Ò 7Ü!Ð"GÓHÐ Hð 8rA c ó$ | j « y)z Function to call when PING failsNr ©rW r s r\ Ú _ping_failedz AbstractConnection._ping_failed ó à ÕrA c ó | j rSt j « | j kD r1| j j | j | j « yyy)z3Check the health of the connection with a PING/PONGN)rC ÚtimeÚ monotonicrY rH r r¯ r² rz s r\ r z AbstractConnection.check_health" sF à × %Ò %¬$¯.©.Ó*:¸T×=SÑ=SÒ*SØ JJ× &Ñ & t§¡¸×8IÑ8IÕ Jð +TÐ %rA c óR | j s| j d¬« |r| j « t |t « r|g}|D ] }| j j |« y
|
# t j $ r | j « t d« t $ ro}| j « t |j « dk( rd|j d }}n |j d }|j d }t d| d| d « d
|
}~wt $ r | j « w xY w) z2Send an already packed command to the Redis serverFrö zTimeout writing to socketr ÚUNKNOWNr zError z while writing to socket. rj N)r[ r r rK rL Úsendallr r r r/ r rm rF r* Ú BaseException)rW r r Úitemr ÚerrnoÚerrmsgs r\ r z&AbstractConnection.send_packed_command' s àzzØ × %Ñ %°5Ð %Ô 9á Ø × Ñ Ô ð Ü'¤3Ô'Ø")Ø ò )Ø
|
|
×"Ñ" 4Õ(ñ )øä~~ò <Ø OOÔ Ü Ð :Ó;Ð ;Üò WØ OOÔ Ü166{aÒ Ø )¨1¯6©6°!©9vàq Ø Ü! F¨5¨'Ð1KÈFÈ8ÐSTÐ"UÓVÐ VûÜ ò ð
|
OOÔ Ø ð ús ²5A( Á(6D& A*DÄ D&c óx | j | j j | |j dd« ¬« y)z+Pack and send a command to the Redis serverr Trö N)r ra r] r r s r\ r z AbstractConnection.send_commandF s9 à × Ñ Ø %D× Ñ × %Ñ % tÐ ,Ø N°DÓ9ð !õ
|
rA c ó | j }|s| j « | j « } | j j |« S # t
|
$ r0}| j « t d| d|j « d}~ww xY w)z8Poll the socket to see if there's data that can be read.úError while reading from z: N) r[ r r rc r r r r* rF )rW r r Ú
|
host_errorr s r\ r zAbstractConnection.can_readM sy àzzÙØ LLNà×%Ñ%Ó'
|
ð VØ<<×(Ñ(¨Ó1Ð 1øäò VØ OOÔ Ü!Ð$=¸j¸\ÈÈAÏFÉFÈ8Ð"TÓUÐ Uûð Vús °A Á BÁ+A?Á?Br c ód | j « } | j dv r | j j ||¬« }n | j j |¬« }| j r&t j « | j z | _ t! |t" « r ||S # t j
|
$ r! |r| j « t d| « t $ r2}|r| j « t d| d|j « d}~wt $ r |r| j « w xY w# ~w xY w)z0Read the response from a previously sent command)Ú3rO )r£ r )r£ zTimeout reading from rÀ z : N)r rK rc r¤ r r r r/ r r* rF rº rC rµ r¶ rY rK r. )rW r£ r r rÁ r r s r\ r¤ z AbstractConnection.read_response\ s% ð ×%Ñ%Ó'
|
ð Ø}} Ñ(Ø <<×5Ñ5Ø%5ÀLð 6ó ð <<×5Ñ5ÐGWÐ5ÓXð" × %Ò %Ü%)§^¡^Ó%5¸×8RÑ8RÑ%RDÔ "ä h¤ Ô .ð Ø ð øô1 ~~ò EÙ"ØÔ!Ü Ð!6°z°lÐ CÓDÐ DÜò WÙ"ØÔ!Ü!Ð$=¸j¸\ÈÈQÏVÉVÈHÐ"UÓVÐ VûÜ ò ñ #ØÔ!Ø ð ûñ ús$ AB!  D, Â!;D)à -D Ä D)Ä,D/c ó4 | j j | S )rI )ra r] r s r\ rR z AbstractConnection.pack_command s à(t×#Ñ#×(Ñ(¨$Ð/Ð/rA c óØ g }g }d}| j }|D ]¬ } | j j | D ] }t |« }||kD s||kD st |t
|
« r*|r$|j t j |« « d}g }||kD st |t
|
« r|j |« y|j |« ||z } ® |r$|j t j |« « |S )z.Pack multiple commands into the Redis protocolr ) rf ra r] rm rK rp rP rj rk ) rW r© rX ÚpiecesÚ buffer_lengthrg ÚcmdÚchunkÚchunklens r\ rª z AbstractConnection.pack_commands sä àØØ Ø ×+Ñ+ àò .CØ2×-Ñ-×2Ñ2°CÐ8ò .Ü u:à! MÒ1Ø -Ò/Ü! %¬Ô4á Ø ¤i§n¡n°VÓ&<Ô=Ø$%MØ FàmÒ+¬z¸%ÄÔ/LØMM %Õ(àMM %Ô(Ø! XÑ-Mñ! .ð .ñ& Ø MM)..¨Ó0Ô 1Ø rA c ó | j S re )rK rz s r\ r z AbstractConnection.get_protocolª s Ø}}Ð rA c ó | j S re ©Ú_handshake_metadatarz s r\ r¬ z%AbstractConnection.handshake_metadata s à×'Ñ'Ð'rA rZ c ó || _ y re rÍ rÕ s r\ r¬ z%AbstractConnection.handshake_metadata± s
|
à#(Õ rA r® c ó || _ y re )r^ r° s r\ r± z$AbstractConnection.set_re_auth_tokenµ s
|
Ø #ÕrA c óÔ | j \| j d| j j d« | j j « « | j « d | _ y y ©Nr Úoid)r^ r Útry_getÚ get_valuer¤ rz s r\ r³ zAbstractConnection.re_auth¸ s` Ø × Ñ Ð *Ø × Ñ ØØ×#Ñ#×+Ñ+¨EÓ2Ø×#Ñ#×-Ñ-Ó/ô ð
|
× Ñ Ô Ø"&DÕ ð +rA c ó | j S re )r[ rz s r\ rÏ z AbstractConnection._get_socket ó ØzzÐrA c ó | j S re ©r% rz s r\ r× z!AbstractConnection.socket_timeoutÅ s à×#Ñ#Ð#rA c ó || _ y re rÙ rÕ s r\ r× z!AbstractConnection.socket_timeoutÉ s
|
à $Õ rA c ó | j S re ©rT rz s r\ rÚ z)AbstractConnection.socket_connect_timeoutÍ s à×+Ñ+Ð+rA c ó || _ y re rÜ rÕ s r\ rÚ z)AbstractConnection.socket_connect_timeoutÑ s
|
à',Õ$rA )TTr» r¼ r½ )Gr^ r_ r` r0 r) rC r< r0 r1 r2 r rL r3 r6 r r r rü r5 r r
|
r# r& r1 r3 rh rp r r{ rs r` r r r r r r rÍ r r r r r r r r rµ r· rº r¯ r² r r r r r¤ rR rª r r¾ r r¿ r¬ r4 r! r± r³ r rÏ r× rÚ ra rA r\ r8 r8 s Ù6ð Ø"&Ø*.Ø26Ø!&ØCKØ Ø 'Ø!&Ø"Ø %Ø%&Ø%)Ø",Ù%4Ó%6Ø"&Ø"&Ø;?Ø<@Ø"#Ø7;Ø6:ØIMð Ø0@×0EÑ0EØ7;Ø+/Ø/3Ø7;ñA@
|
à ð@
|
ð 3-ð@
|
ð ! ð @
|
ð
|
!)¨¡ð @
|
ð ð @
|
ð h t¨I¡Ñ 7¸Ð ?Ñ@ð@
|
ð ð@
|
ð ð@
|
ð ð@
|
ð ð@
|
ð #ð@
|
ð c]ð @
|
ð 3-ð @
|
ð c]ð!@
|
ð" 3-ð#@
|
ð$ S$YÑ ð%@
|
ð& % X¨b°$¨hÑ%7Ñ 8ð'@
|
ð( &Ð&8Ñ 9ð)@
|
ð* 3-ð+@
|
ð, ! ¨"¨d¨(Ñ!3Ñ4ð-@
|
ð. # ?Ñ3ð/@
|
ð0 %-Ð-EÑ$Fð1@
|
ð2 +3Ø )ñ+
|
ð3@
|
ð8 .ð9@
|
ð: (0°¡}ð;@
|
ð< $ C=ð=@
|
ð> & e_ð?@
|
ð@ &.¨e¡_óA@
|
òDWð ñ ó ð òò Rò
|
/ò òMð U >°<À Ð#MÑ Nó ò5ð
|
GKñ% Ø ð% Ø?Có% ðN ñ ó ð ð ñ ó ð òCò8ñr:°Dó r:òhò,&ò&ò'òIò òKó
|
ò>
|
ó Vð" ð*ð !Øô *òX0ò ð< e C¨ Hoó ð ð( E¨$¨u°e¨|Ñ*<¸dÀ3ÈÀ8¹nÐ*LÑ$Mò (ó ð(ð × Ñ ð)¨¨d°5¸%°<Ñ.@À$ÀsÈCÀxÁ.Ð.PÑ(Qò )ó ð)ð$ ~ó $ò'ðX f§m¡mÑ 4ó ð ð$ ¨¨u°c¨zÑ):Ñ ;ò $ó ð$ð ×Ñð% H¨U°5¸#°:Ñ->Ñ$?ò %ó ð%ð ð,¨°°u¸c°zÑ1BÑ(Cò ,ó ð,ð ×"Ñ"ð-¨H°U¸5À#¸:Ñ5FÑ,Gò -ó #ñ-rA r8 c ó e Zd ZdZ d
|
fd Zd Zd Zd Zede fd« Z
|
e
|
j de fd « Z
|
xZ S ) Ú
|
Connectionz4Manages TCP communication to and from a Redis serverc ó || _ t |« | _ || _ |xs i | _ || _ t | di |¤ y ©Nra )Ú_hostr2 r Úsocket_keepaliveÚsocket_keepalive_optionsÚ socket_typeÚsuperrh )rW rÓ r rã rä rå r rl s r\ rh zConnection.__init__Ù sD ø ð
|
ÜI Ø 0Ô Ø(@Ò(FÀBÔ%Ø&ÔÜ ÑÑ"6Ó"rA c óª d| j fd| j fd| j fg}| j r |j d| j f« |S )NrÓ r r; rD )rÓ r r; rD rP ©rW rÆ s r\ r{ zConnection.repr_piecesé sM Ø499Ð%¨°· ± Ð':¸TÀ4Ç7Á7¸OÐLØ × Ò Ø MM=¨$×*:Ñ*:Ð;Ô <Ø rA c ó d}t j | j | j | j t j
|
« D ] }|\ }}}}}d} t j |||« }|j t j t j d« | j rr|j t j t j d« | j j « D ]& \ } }
|
|j t j | |
|
« ( |j | j « |j! |« |j | j" « |c S ||t% d« # t$ $ rO} | }|@ |j' t j( « n# t$ $ r Y nw xY w|j+ « Y d} ~ d} ~ ww xY w)z Create a TCP socket connectionNr z)socket.getaddrinfo returned an empty list)r r rÓ r rå r Ú
|
setsockoptÚ IPPROTO_TCPÚ TCP_NODELAYrã Ú
|
SOL_SOCKETÚ SO_KEEPALIVErä Úitemsr rÚ r r× r r¤ r¥ r¦ ) rW ÚerrÚresÚfamilyÚsocktyper Ú canonnameÚsocket_addressr rm rn rY s r\ r zConnection._connectï s ð
|
ä×%Ñ%Ø IItyy $×"2Ñ"2´F×4FÑ4Fó
|
ó ! !Cð BEÑ >FHe Y°ØDð !Ü }} V¨X°uÓ=à¤× 2Ñ 2´F×4FÑ4FÈÔJð ×(Ò(ØOO¤F×$5Ñ$5´v×7JÑ7JÈAÔNØ $× =Ñ =× CÑ CÓ Eò B1Ø ¬×(:Ñ(:¸A¸qÕAðBð × ;Ñ ;Ô<ð ^Ô,ð × 3Ñ 3Ô4Ø ð1! !ðF ?ØIÜÐAÓBÐBøô ò !ØØÐ#ð Ø ¤f×&6Ñ&6Õ7øÜ"ò Ù ð úàJJLÿùð !ús= ÁD E5Å5 G Å>GÆ F#Æ"GÆ# F/Æ,GÆ.F/Æ/GÇG c ó8 | j d| j S )Nú:)rÓ r rz s r\ r zConnection._host_error s Ø))Adii[Ð)Ð)rA rv c ó | j S re ©râ rz s r\ rÓ zConnection.host s àzzÐrA rZ c ó || _ y re rù rÕ s r\ rÓ zConnection.host$ s à
|
rA )r r FNr ) r^ r_ r` r0 rh r{ r r r¾ rL rÓ r4 Ú __classcell__©rl s @r\ rß rß Ö sg ø Ù:ð Ø Ø Ø!%Øõ #ò ò ,Cò\*ð ðcò ó ðð
|
[[ð#ò ó ôrA rß c ó e Zd ZdZdZdZdededej fdZ
|
d Z d Z d
|
Z d Zd Zd Zd Zd Zd Zd Zd@dZd ZdAdZ dBddddZd Zd Zede e e e f e e e f f fd « Z d e!fd Z"d Z#d Z$d! Z%d" Z&ede fd#« Z'e'jP d$e fd%« Z'ede)e e*e+f fd&« Z,e,jP d$e)e e*e+f fd'« Z,ede)e e*e+f fd(« Z-e-jP d$e)e e*e+f fd)« Z-de)e.j\ fd*Z/de0fd+Z1ede2fd,« Z3e3jP d-e2fd.« Z3d/ Z4d0 Z5dCd2e)e* fd3Z6 dDd4e)e d5e)e* fd6Z7 dEd7e8d8e8fd9Z9d: Z:d; Z;dedd1fd<Z<d= Z=d>e>e e e)e>e f fd?Z?y1)FÚCacheProxyConnections fooz7.4.0ÚredisÚconnÚcacheÚ pool_lockc ó` t j « | _ || _ | j j | _ | j j
|
| _ | j j | _ |j | _ || _ || _ t j « | _ d | _ d | _ | j | j « t# | j t$ « rÂt$ j' | | j j( | j j* | j j, | j j. | j j
|
| j j0 | j j2 | j j5 « « y y re )rQ rR rS Ú_connrH rÓ r rJ Ú
|
_pool_lockÚ_cacheÚ threadingÚRLockÚ _cache_lockÚ_current_command_cache_keyÚ_current_optionsr Ú_enable_tracking_callbackrK rÁ rh r rá rÄ rÅ r× rÚ rÍ )rW r r r s r\ rh z CacheProxyConnection.__init__. s% ô 99;Ø
|
ØZZ×%Ñ%
|
ØJJOO ØJJOO Ø#'×#;Ñ#;Ô Ø#Ø Ü$??Ó,ÔØ*.Ô'Ø $Ô Ø ×&Ñ& t×'EÑ'EÔFä djjÔ"FÔ GÜ 0× 9Ñ 9ØØ
|
|
×5Ñ5Ø
|
|
×<Ñ<Ø
|
|
×,Ñ,Ø
|
|
×8Ñ8Ø
|
|
Ø
|
|
×)Ñ)Ø
|
|
×1Ñ1Ø
|
|
×&Ñ&Ó(õ
|
ð HrA c ó6 | j j « S re )r r{ rz s r\ r{ z CacheProxyConnection.repr_piecesN s Øzz×%Ñ%Ó'Ð'rA c ó: | j j |« y re )r r r~ s r\ r z.CacheProxyConnection.register_connect_callbackQ s Ø
|
|
×,Ñ,¨XÕ6rA c ó: | j j |« y re )r r r~ s r\ r z0CacheProxyConnection.deregister_connect_callbackT s Ø
|
|
×.Ñ.¨xÕ8rA c ó: | j j |« y re )r r r s r\ r z CacheProxyConnection.set_parserW s Ø
|
|
× Ñ lÕ+rA c óp t | j t « r | j j |« y y re )rK r rÁ rë ©rW rà s r\ rë zHCacheProxyConnection.set_maint_notifications_pool_handler_for_connectionZ s. ô djjÔ"FÔ GØ JJ× JÑ JØ0õ ð HrA c ó6 | j j « S re )r r rz s r\ r z!CacheProxyConnection.get_protocolb s Øzz×&Ñ&Ó(Ð(rA c ó | j j « | j j j dd « }|&| j j j dd « }| j j j dd « }|&| j j j dd « }|| t d« t |« }t |« }|| j k7 st || j « dk( r t d« y )Ns serverÚservers versionÚversionz0Cannot retrieve information about server versionr ziTo maximize compatibility with all Redis products, client-side caching is supported by Redis 7.4 or later) r r r¬ r r* r: ÚDEFAULT_SERVER_NAMEr8 ÚMIN_ALLOWED_VERSION)rW Ú server_nameÚ
|
server_vers r\ r z CacheProxyConnection.connecte sô Ø
|
|
×ÑÔ àjj×3Ñ3×7Ñ7¸ À4ÓH Ø Ð Ø **×7Ñ7×;Ñ;¸HÀdÓKKØZZ×2Ñ2×6Ñ6°zÀ4ÓH
|
Ø Ð Ø ×6Ñ6×:Ñ:¸9ÀdÓKJØ Ð Ð!3Ü!Ð"TÓUÐ Uä" :Ó.
|
Ü# KÓ0 ð 4×3Ñ3Ò 3Ü
|
¨D×,DÑ,DÓEÈÒJä!Ø{óð ð KrA c ó8 | j j « y re )r r rz s r\ r z CacheProxyConnection.on_connect| s Ø
|
|
× Ñ Õ rA c ó¬ | j 5 | j j « d d d « | j j | y # 1 sw Y #xY wre )r r Úflushr r r s r\ r z CacheProxyConnection.disconnect sD Ø × Ñ ñ Ø KK× Ñ Ô ÷ à
|
|
× Ñ tÒ$÷ ð ús A
|
Á
|
Ac ó8 | j j « y re )r r rz s r\ r z!CacheProxyConnection.check_health s Ø
|
|
× Ñ Õ!rA Tc ó: | j j |« y re )r r r s r\ r z(CacheProxyConnection.send_packed_command s ð
|
|
×&Ñ& wÕ/rA c ó | j « | j 5 | j j t |d d¬« « s-d | _ | j j |i |¤ d d d « y d d d « |j d« t d« t |d t |j d« « ¬« | _ | j 5 | j j | j
|
« r®| j j | j
|
« }|j | j k7 rf| j 5 |j j « r7|j j d¬« |j j « r7d d d « d d d « y | j j t! | j
|
| j" t$ j& | j ¬« « d d d « | j j |i |¤ y # 1 sw Y ¬xY w# 1 sw Y xY w# 1 sw Y ?xY w) Nr ra )r Ú
|
redis_keysÚkeyszCannot create cache key.T©r )Ú cache_keyÚ cache_valueÚstatusÚconnection_ref)Ú _process_pending_invalidationsr r Ú is_cachabler r
|
r r r rú rM r' r r r¤ Úsetr ÚDUMMY_CACHE_VALUEr Ú IN_PROGRESS)rW rF r Úentrys r\ r z!CacheProxyConnection.send_command sé Ø ×+Ñ+Ô-à × Ñ ñ ð ;;×*Ñ*¬8¸DÀ¹GÐPRÔ+SÔTØ26Ô/Ø'
|
|
×'Ñ'¨Ð8°Ò8Ø÷ ð ð U÷ ð ::fÓ Ð %Ü Ð 7Ó8Ð 8ô +3ØG¬¨f¯j©j¸Ó.@Ó(Aô+
|
Ô'ð × Ñ ñ ð {{t× >Ñ >Ô?Ø ¨×(GÑ(GÓHà×'Ñ'¨4¯:©:Ò5Ø ñ RØ #× 2Ñ 2× ;Ñ ;Ô =Ø !× 0Ñ 0× >Ñ >ÈDÐ >Ô Qð $× 2Ñ 2× ;Ñ ;Õ =÷Rð ÷ ð ð KKOOÜØ "× =Ñ =Ø $× 6Ñ 6Ü+×7Ñ7Ø#'§:¡:ô ô ÷! ð6
|
|
× Ñ Ð0¨Ó0÷W ñ ú÷0Rð Rú÷ ð ús9 AH ÃA0H8ÅAH,Æ H8Æ&AH8È H)È,H5 È1H8È8Ic ó8 | j j |« S re )r r r s r\ r z CacheProxyConnection.can_read¼ s Øzz×"Ñ" 7Ó+Ð+rA Fr c ó° | j 5 | j ¹| j j | j « | j j | j « j t
|
j k7 rTt j | j j | j « j « }d | _ |cd d d « S d d d « | j j |||¬« }| j 5 | j |cd d d « S |1| j j | j g« |cd d d « S | j j | j « }|7t
|
j |_ ||_ | j j |« d | _ d d d « |S # 1 sw Y íxY w# 1 sw Y |S xY w)N)r£ r r )r r
|
r r r& r r, rV rW r% r r¤ Údelete_by_cache_keysÚVALIDr* )rW r£ r r rñ r Ú cache_entrys r\ r¤ z"CacheProxyConnection.read_response¿ s ð × Ñ ñ ð ×/Ñ/Ð;ØKKOO D×$CÑ$CÓDÐPØKKOO D×$CÑ$CÓD×KÑKÜ#×/Ñ/ò0ô mmØKKOO D×$CÑ$CÓD×PÑPóð 37Ô/Ø÷ ÷ ñ ð ::×+Ñ+Ø -Ø 3Ø%ð ,ó
|
ð × Ñ ñ 3à×.Ñ.Ð6Ø ÷ 3ñ 3ð
|
Ð Ø ×0Ñ0°$×2QÑ2QÐ1RÔSØ ÷ 3ñ 3ð ++//¨$×*IÑ*IÓJKð Ð&Ü%5×%;Ñ%; Ô"Ø*2 Ô'Ø Ô,à.2DÔ +÷% 3ð( ÷Q ð ú÷( 3ð( ús% B<F?ÄG Ä )G ÅA%G Æ?GÇ Gc ó4 | j j | S re )r rR r s r\ rR z!CacheProxyConnection.pack_commandì s Ø&tzz×&Ñ&¨Ð-Ð-rA c ó8 | j j |« S re )r rª r¨ s r\ rª z"CacheProxyConnection.pack_commandsï s Øzz×'Ñ'¨Ó1Ð1rA rv c ó. | j j S re )r r¬ rz s r\ r¬ z'CacheProxyConnection.handshake_metadataò s àzz×,Ñ,Ð,rA r® c ó: | j j |« y re )r r± r° s r\ r± z&CacheProxyConnection.set_re_auth_tokenö s Ø
|
|
×$Ñ$ UÕ+rA c ó8 | j j « y re )r r³ rz s r\ r³ z CacheProxyConnection.re_authù s Ø
|
|
×ÑÕ rA c ó8 | j j « y re )r rµ rz s r\ rµ z'CacheProxyConnection.mark_for_reconnectü s Ø
|
|
×%Ñ%Õ'rA c ó6 | j j « S re )r r· rz s r\ r· z%CacheProxyConnection.should_reconnectÿ s Øzz×*Ñ*Ó,Ð,rA c ó8 | j j « y re )r rº rz s r\ rº z+CacheProxyConnection.reset_should_reconnect s Ø
|
|
×)Ñ)Õ+rA c ó. | j j S re ©r rÓ rz s r\ rÓ zCacheProxyConnection.host s àzzÐ rA rZ c ó& || j _ y re r< rÕ s r\ rÓ zCacheProxyConnection.host s à
|
|
rA c ó. | j j S re ©r r× rz s r\ r× z#CacheProxyConnection.socket_timeout s àzz×(Ñ(Ð(rA c ó& || j _ y re r? rÕ s r\ r× z#CacheProxyConnection.socket_timeout s à$)
|
|
Õ!rA c ó. | j j S re ©r rÚ rz s r\ rÚ z+CacheProxyConnection.socket_connect_timeout s àzz×0Ñ0Ð0rA c ó& || j _ y re rB rÕ s r\ rÚ z+CacheProxyConnection.socket_connect_timeout s à,1
|
|
Õ)rA c ó t | j t « r| j j « S t d« )NúCMaintenance notifications are not supported by this connection type)rK r rÁ rÏ ÚNotImplementedErrorrz s r\ rÏ z CacheProxyConnection._get_socket s4 Ü djjÔ"FÔ GØ::×)Ñ)Ó+Ð +ä%ØUóð rA c ó< t |t « s t d« |S )a|
|
Validate that connection instance supports maintenance notifications.
|
With this helper method we ensure that we are working
|
with the correct connection type.
|
After twe validate that connection instance supports maintenance notifications
|
we can safely return the connection instance
|
as MaintNotificationsAbstractConnection.
|
rE )rK rÁ rF ©rW Ú
|
connections r\ Ú,_get_maint_notifications_connection_instancezACacheProxyConnection._get_maint_notifications_connection_instance% s' ô *Ô&JÔKÜ%ØUóð ð Ð rA c óP | j | j « }|j S re ©rJ r rÄ ©rW Úcons r\ rÄ z&CacheProxyConnection.maintenance_state7 s" à×?Ñ?ÀÇ
|
Á
|
ÓKØ×$Ñ$Ð$rA r c óH | j | j « }||_ y re rL )rW r rN s r\ rÄ z&CacheProxyConnection.maintenance_state< s à×?Ñ?ÀÇ
|
Á
|
ÓKØ %Õ rA c óX | j | j « }|j « S re )rJ r r rM s r\ r z CacheProxyConnection.getpeernameA s# Ø×?Ñ?ÀÇ
|
Á
|
ÓKØÓ Ð rA c óX | j | j « }|j « S re )rJ r r rM s r\ r z$CacheProxyConnection.get_resolved_ipE s% Ø×?Ñ?ÀÇ
|
Á
|
ÓKØ×"Ñ"Ó$Ð$rA Nr c ó\ | j | j « }|j |« y re )rJ r r" )rW r rN s r\ r" z2CacheProxyConnection.update_current_socket_timeoutI s$ Ø×?Ñ?ÀÇ
|
Á
|
ÓKØ ×)Ñ)¨/Õ:rA r& r' c ó^ | j | j « }|j ||« y re )rJ r r* )rW r& r' rN s r\ r* z%CacheProxyConnection.set_tmp_settingsM s* ð
|
×?Ñ?ÀÇ
|
Á
|
ÓKØ × Ñ Ð -Ð/BÕCrA r+ r, c ó^ | j | j « }|j ||« y re )rJ r r. )rW r+ r, rN s r\ r. z'CacheProxyConnection.reset_tmp_settingsU s* ð
|
×?Ñ?ÀÇ
|
Á
|
ÓKØ × Ñ Ð 1Ð3HÕIrA c ó8 | j j « y re )r r rz s r\ r z CacheProxyConnection._connect] s Ø
|
|
×ÑÕ rA c ó8 | j j « y re )r r rz s r\ r z CacheProxyConnection._host_error` s Ø
|
|
× Ñ Õ rA c ó |j ddd« |j « |j j | j « y )Nró ÚTRACKINGrõ )r r¤ rc Ú set_invalidation_push_handlerÚ_on_invalidation_callback©rW r s r\ r z.CacheProxyConnection._enable_tracking_callbackc s8 Ø ×Ñ( J°Ô5Ø ×ÑÔ Ø ×2Ñ2°4×3QÑ3QÕRrA c ó | j « r.| j j d¬« | j « r-y y )NTr# )r r r¤ rz s r\ r( z3CacheProxyConnection._process_pending_invalidationsh s+ ØmmoØ JJ× $Ñ $°$Ð $Ô 7ð mmorA Údatac ó | j 5 |d | j j « n | j j |d « d d d « y # 1 sw Y y xY w)Nr )r r r Údelete_by_redis_keys)rW r] s r\ rZ z.CacheProxyConnection._on_invalidation_callbackl sO Ø × Ñ ñ :àAwØ ×!Ñ!Õ#à ×0Ñ0°°a±Ô9÷ :÷ :ñ :ús ?AÁA r» r¼ r½ re )NNr/ )@r^ r_ r` r+ r r rx r r r rh r{ r r r rë r r r r r r r r r¤ rR rª r¾ r r r¿ rL r¬ r! r± r³ rµ r· rº rÓ r4 r r3 r2 r× rÚ r rÏ rÁ rJ r0 rÄ r r r" r* r6 r. r r r r( r rZ ra rA r\ rþ rþ ) sì Ø ÐØ!ÐØ!Ðð à!ð ð ð ð ??ó ò@(ò7ò9ò,òò)òò. ò%ò
|
"ó0ò
|
.1ó`,ð %ð+Ø=AÐPUô+òZ.ò2ð ð- E¨$¨u°e¨|Ñ*<¸dÀ3ÈÀ8¹nÐ*LÑ$Mò -ó ð-ð, ~ó ,ò ò(ò-ò,ð ð cò ó ð ð
|
[[ð #ò ó ð ð ð) ¨¨u°c¨zÑ):Ñ ;ò )ó ð)ð ×Ñð* H¨U°5¸#°:Ñ->Ñ$?ò *ó ð*ð ð1¨°°u¸c°zÑ1BÑ(Cò 1ó ð1ð ×"Ñ"ð2¨H°U¸5À#¸:Ñ5FÑ,Gò 2ó #ð2ðX f§m¡mÑ 4ó ð à -ó ð$ ð%Ð#3ò %ó ð%ð × Ñ ð&Ð'7ò &ó ð&ò!ò%ñ;¸XÀe¹_ó ;ð +/Ø/3ñDà" 3-ðDð & e_óDð $)Ø&+ñJà ðJð $óJò ò!ðSÐ.Að SÀdó Sò
|
8ð:¨d°5¸¸hÀtÈEÁ{Ñ>SÐ9SÑ3TÑ.Uô :rA rþ c óv e Zd ZdZ ddeed deed f fd Z fdZd Z xZ S ) Ú SSLConnectionzåManages SSL connections to and from the Redis server(s).
|
This class extends the Connection class, adding SSL functionality, and making
|
use of ssl.SSLContext (https://docs.python.org/3/library/ssl.html#ssl.SSLContext)
|
Ússl_include_verify_flagsr> Ússl_exclude_verify_flagsc ó8 t s t d« || _ || _ |t j
|
}nWt |t « rGt j
|
t j t j d}||vrt d| « || }|| _
|
|| _ || _ || _ || _ | | _ | j t j
|
k7 r|nd| _ |
|
| _ | | _ | | _ | | _ || _ || _ || _ t1 | d di |¤ y)a! Constructor
|
|
Args:
|
ssl_keyfile: Path to an ssl private key. Defaults to None.
|
ssl_certfile: Path to an ssl certificate. Defaults to None.
|
ssl_cert_reqs: The string value for the SSLContext.verify_mode (none, optional, required),
|
or an ssl.VerifyMode. Defaults to "required".
|
ssl_include_verify_flags: A list of flags to be included in the SSLContext.verify_flags. Defaults to None.
|
ssl_exclude_verify_flags: A list of flags to be excluded from the SSLContext.verify_flags. Defaults to None.
|
ssl_ca_certs: The path to a file of concatenated CA certificates in PEM format. Defaults to None.
|
ssl_ca_data: Either an ASCII string of one or more PEM-encoded certificates or a bytes-like object of DER-encoded certificates.
|
ssl_check_hostname: If set, match the hostname during the SSL handshake. Defaults to True.
|
ssl_ca_path: The path to a directory containing several CA certificates in PEM format. Defaults to None.
|
ssl_password: Password for unlocking an encrypted private key. Defaults to None.
|
|
ssl_validate_ocsp: If set, perform a full ocsp validation (i.e not a stapled verification)
|
ssl_validate_ocsp_stapled: If set, perform a validation on a stapled ocsp response
|
ssl_ocsp_context: A fully initialized OpenSSL.SSL.Context object to be used in verifying the ssl_ocsp_expected_cert
|
ssl_ocsp_expected_cert: A PEM armoured string containing the expected certificate to be returned from the ocsp verification service.
|
ssl_min_version: The lowest supported SSL version. It affects the supported SSL versions of the SSLContext. None leaves the default provided by ssl module.
|
ssl_ciphers: A string listing the ciphers that are allowed to be used. Defaults to None, which means that the default ciphers are used. See https://docs.python.org/3/library/ssl.html#ssl.SSLContext.set_ciphers for more information.
|
|
Raises:
|
RedisError
|
z$Python wasn't built with SSL supportN)ÚnoneÚoptionalÚrequiredz+Invalid SSL Certificate Requirements Flag: Fra )r7 r- ÚkeyfileÚcertfileÚsslÚ CERT_NONErK rL Ú CERT_OPTIONALÚ CERT_REQUIREDÚ cert_reqsrb rc Úca_certsÚca_dataÚca_pathÚcheck_hostnameÚcertificate_passwordÚssl_validate_ocspÚssl_validate_ocsp_stapledÚssl_ocsp_contextÚssl_ocsp_expected_certÚssl_min_versionÚ ssl_ciphersræ rh )rW Ú ssl_keyfileÚ ssl_certfileÚ ssl_cert_reqsrb rc Ú ssl_ca_certsÚ ssl_ca_dataÚssl_check_hostnameÚ ssl_ca_pathÚ ssl_passwordrt ru rv rw rx ry r Ú CERT_REQSrl s r\ rh zSSLConnection.__init__{ s ø õZ Ü Ð CÓDÐ Dà" Ø$ Ø Ð Ü MMMÜ ¤sÔ +ä Ü × -Ñ -Ü × -Ñ -ñIð
|
IÑ-Ü ØAÀ-À ÐQóð ð & mÑ 4MØ&Ø(@Ô%Ø(@Ô%Ø$ Ø" Ø" à"&§.¡.´C·M±MÒ"AÑ Àuð Ôð %1Ô!Ø!2Ô Ø)BÔ&Ø 0Ô Ø&<Ô#Ø .Ô Ø&ÔÜ ÑÑ"6Ó"rA c ó t | « } | j |« S # t t f$ r |j « w xY w)zN
|
Wrap the socket with SSL support, handling potential errors.
|
)ræ r Ú_wrap_socket_with_sslr r- r¦ )rW r rl s r\ r zSSLConnection._connectÌ sH ø ô wÑ Ó!ð Ø×-Ñ-¨dÓ3Ð 3øÜÐ$ò Ø JJLØ ð ús " ¢!Ac óö t j « }| j |_ | j |_ | j
|
r&| j
|
D ] }|xj |z c_ | j r'| j D ] }|xj | z c_ | j s | j r2|j | j | j | j ¬« | j | j | j 2|j | j | j | j ¬« | j | j |_ | j$ r|j' | j$ « | j( du rt* du r t- d« | j. r| j( r t- d« |j1 || j2 ¬« }| j. r+d dl}d
|
d lm } | j: f|j< j? |j< j@ « }|jC | j « |jE | j « n | j: }|jG || jH « |j< jK |tM jL « « }|jO « |jQ | j2 | jR f« |jU « |jW « |S | j( du rRt* rLd
|
d lm,} | || j2 | jR | j « }
|
|
|
j[ « r|S t] d « |S )z
|
Wraps the socket with SSL support.
|
|
Args:
|
sock: The plain socket to wrap with SSL.
|
|
Returns:
|
An SSL wrapped socket.
|
)ri rh r< N)ÚcafileÚcapathÚcadataTFz cryptography is not installed.zKEither an OCSP staple or pure OCSP connection must be validated - not both.)Úserver_hostnamer r )Úocsp_staple_verifier)Ú OCSPVerifierzocsp validation error)/rj Úcreate_default_contextrr rn Ú verify_moderb Ú verify_flagsrc ri rh Úload_cert_chainrs ro rq rp Úload_verify_locationsrx Úminimum_versionry Ú set_ciphersrt r5 r- ru Ú wrap_socketrÓ ÚOpenSSLÚocspr rv ÚSSLÚContextÚ SSLv23_METHODÚuse_certificate_fileÚuse_privatekey_fileÚset_ocsp_client_callbackrw rß r Ú request_ocspr r Ú do_handshaker¤ r Úis_validr* ) rW r ÚcontextÚflagÚsslsockr r Ú
|
staple_ctxrN r Úos r\ r z#SSLConnection._wrap_socket_with_ssl× sÕ ô ×,Ñ,Ó.Ø!%×!4Ñ!4Ô Ø "nnÔØ × (Ò (Ø ×5Ñ5ò -Ø×$Ò$¨Ñ,Ö$ð -à × (Ò (Ø ×5Ñ5ò .Ø×$Ò$¨¨Ñ-Ö$ð .à ==DLLØ × #Ñ #Ø Ø Ø ×2Ñ2ð $ô ð MMÐ %Ø||Ð'Ø||Ð'à × )Ñ )Ø}}¨T¯\©\À$Ç,Á,ð *ô ð × Ñ Ð +Ø&*×&:Ñ&:GÔ #Ø × Ò Ø × Ñ × 0Ñ 0Ô 1Ø × !Ñ ! TÑ )Ô.DÈÑ.MÜ Ð =Ó>Ð >à × )Ò )¨d×.DÒ.DÜ ð óð ð
|
×%Ñ% d¸D¿I¹IÐ%ÓFð × )Ó )Û å 2ð ×$Ñ$Ð,Ø $[[× 0Ñ 0°·±×1JÑ1JÓ K
|
Ø×/Ñ/°· ± Ô>Ø×.Ñ.¨t¯|©|Õ<à !× 2Ñ 2
|
à × /Ñ /Ø$ d×&AÑ&Aô ð
|
++×(Ñ(¨´V·]±]³_ÓECØ × Ñ Ô Ø KK D§I¡IÐ.Ô /Ø × Ñ Ô Ø LLNØNð × !Ñ ! TÑ )Õ.DÝ *á W d§i¡i°·±¸D¿M¹MÓJAØzz|Ø ä%Ð&=Ó>Ð>ØrA )NNrg NNNNTNNFFNNNN)
|
r^ r_ r` r0 r r rh r r rû rü s @r\ ra ra u sv ø ñð ØØ ØBFØBFØØØ ØØØ Ø"'Ø Ø #Ø Øñ#O#ð
|
#+¨4° Ñ+>Ñ"?ð O#ð #+¨4° Ñ+>Ñ"?õ O#ôb öSrA ra c ó6 e Zd ZdZd fd Zd Zd Zd Z xZS )ÚUnixDomainSocketConnectionz4Manages UDS communication to and from a Redis serverc ó@ t | di |¤ || _ || _ y rá )ræ rh Úpathr× )rW r§ r× r rl s r\ rh z#UnixDomainSocketConnection.__init__0 s" ø Ü ÑÑ"6Ò"Ø Ø ,ÕrA c ó d| j fd| j fg}| j r |j d| j f« |S )Nr§ r; rD )r§ r; rD rP rè s r\ r{ z&UnixDomainSocketConnection.repr_pieces5 sB Ø499Ð%¨¨d¯g©g Ð7Ø × Ò Ø MM=¨$×*:Ñ*:Ð;Ô <Ø rA c óª t j t j t j « }|j | j « |j | j « |j | j « |S # t $ rB |j t j « n# t $ r Y nw xY w|j « w xY w)z&Create a Unix domain socket connection) r ÚAF_UNIXr r rÚ r r§ r r¤ r¥ r¦ r× )rW r s r\ r z#UnixDomainSocketConnection._connect; s¢ ä}}V^^¬V×-?Ñ-?Ó@Ø ×3Ñ3Ô4ð Ø LLÔ #ð ×+Ñ+Ô,Ø øô ò ð Ø f× .Ñ .Õ/øÜò Ùð úà JJLØ ð ús0 ÁB  C B1Â0CÂ1 B=Â:CÂ<B=Â=Cc ó | j S re )r§ rz s r\ r z&UnixDomainSocketConnection._host_errorL s ØyyÐrA )Ú N) r^ r_ r` r0 rh r{ r r rû rü s @r\ r¥ r¥ - s ø Ù:õ-ò
|
ò ö"rA r¥ )Ú0ÚFÚFALSEÚNÚNOc óv | | dk( ry t | t « r| j « t v ryt | « S )Nr¬ F)rK rL ÚupperÚ FALSE_STRINGSr6 )rZ s r\ Úto_boolrµ S s4 Ø } ØÜ%Ô %§+¡+£-´=Ñ"@ØÜ ;ÐrA c ó | j dd« j dd« }g }|j d« D ]O }|j « }t t |« st d| « |j t t |« « Q |S )Nú[r¬ ú]rg zInvalid ssl verify flag: )ÚreplacerO Ústriprï r> rú rP rù )rZ Úverify_flags_strr r s r\ Úparse_ssl_verify_flagsr¼ [ s ð }} S¨"Ó-×5Ñ5°c¸2Ó>ÐàLØ ×&Ñ& sÓ+ò 8Øzz|Ü{ DÔ)Ü Ð 8¸¸Ð ?Ó@Ð @Ø×ÑG¤K°Ó 6Õ7ð 8ð
|
ÐrA ) r; r× rÚ rã r= r> Úmax_connectionsrC r rb rc r c óB | j d« s-| j d« s | j d« s t d« t | « } i }t | j « j « D ]N \ }}|s t |« dkD st |d « }t j |« }|r ||« ||< J|||< P | j rt | j « |d< | j rt | j « |d < | j d
|
k( r/| j rt | j « |d < t |d < |S | j rt | j « |d < | j" rt% | j" « |d< | j r6d|vr2 t% t | j « j' dd« « |d< | j dk( r t* |d < |S # t t f$ r t d| d« w xY w# t( t f$ r Y Mw xY w)Nzredis://z rediss://zunix://zRRedis URL must specify one of the following schemes (redis://, rediss://, unix://)r zInvalid value for 'z' in connection URL.rG r< Úunixr§ Úconnection_classrÓ r r; ú/r¬ Úrediss)Ú
|
startswithrú r r Úqueryrï rm r ÚURL_QUERY_ARGUMENT_PARSERSr rS rG r< Úschemer§ r¥ Úhostnamer r2 r¹ r
|
ra )Úurlr ÚnamerZ rÉ s r\ Ú parse_urlrÊ y sù à zÔ"Ø >>+Ô &Ø >>)Ô $äð 5ó
|
ð
|
ô
|
3-CØ Fä § ¡ Ó*×0Ñ0Ó2ò
|
% eÚ SZ !^ÜE !HÓ%EÜ/×3Ñ3°DÓ9FÙðWÙ#)¨%£=F4Lð %t ð
|
%ð ||Ü $ S§\¡\Ó 2zÑØ
|
||Ü $ S§\¡\Ó 2zÑð zzVÒØ 88Ü $ S§X¡XÓ .F6NÜ%?Ð!Ñ"ð& Mð! <<Ü $ S§\¡\Ó 2F6NØ 88Ü §¡]F6Nð 88 FÑ*ð Ü "¤7¨3¯8©8Ó#4×#<Ñ#<¸SÀ"Ó#EÓ Ft ð ::Ò !Ü)6FÐ%Ñ &à MøôC "¤:Ð.ò WÜ$Ð':¸4¸&Ð@TÐ%UÓVÐVðWûô6 #¤JÐ/ò Ùð ús Â- G*Æ 1H Ç* H È H È H Ú_CPÚConnectionPool)Úboundc óä e Zd Zed « Zed « Ze edgdd¬« dee de fd « « Z
|
ed
|
« Z ed e fd « Z edd e fd« Zed « Zedefd« Zedefd« Zy)ÚConnectionPoolInterfacec ó y re ra rz s r\ r z$ConnectionPoolInterface.get_protocol¶ r| rA c ó y re ra rz s r\ Úresetz ConnectionPoolInterface.resetº r| rA Ú*ú)Use get_connection() without args insteadú5.3.0©Ú args_to_warnÚreasonr Ú command_namerv c ó y re ra )rW rÙ r" Úoptionss r\ Úget_connectionz&ConnectionPoolInterface.get_connection¾ s ð rA c ó y re ra rz s r\ Ú get_encoderz#ConnectionPoolInterface.get_encoderÉ r| rA rI c ó y re ra rH s r\ Úreleasez ConnectionPoolInterface.releaseÍ r| rA Úinuse_connectionsc ó y re ra )rW rá s r\ r z"ConnectionPoolInterface.disconnectÑ r| rA c ó y re ra rz s r\ r¦ z ConnectionPoolInterface.closeÕ r| rA rH c ó y re ra )rW rH s r\ Ú set_retryz!ConnectionPoolInterface.set_retryÙ r| rA r® c ó y re ra r° s r\ Úre_auth_callbackz(ConnectionPoolInterface.re_auth_callbackÝ r| rA Nr» )r^ r_ r` r r rÒ r9 r rL rx rÜ rÞ rà r6 r r¦ r4 rå r! rç ra rA r\ rÏ rÏ µ sý Øñ ó ð ð ñ ó ð ð ÙØUØ:Øôð
|
Ø $ SMð à ò ó ó ð ð
|
ñ ó ð ð ð Ð"5ò ó ð ð ñ ¨Dò ó ð ð ñ ó ð ð ð uò ó ð ð ð nò ó ñ rA rÏ c óH e Zd ZdZ d'dee fdZeede e
|
e f fd« « Z e j ede e
|
e f fd« « Z edej fd « Zeded
|
fd « Zeded
|
fd « Zd ZdefdZdefdZdefdZ d(dd
|
ded dee
|
dee def
|
dZ d)dd
|
ded dee dee
|
d ee d ed ed efd Z d*ded dee dee
|
d ee dee
|
dee ded d ed ed ed!efd"Z d# Z d'd$ee
|
fd%Z! d'd$ee
|
fd&Z"y)+Ú(MaintNotificationsAbstractConnectionPoola(
|
Abstract class for handling maintenance notifications logic.
|
This class is mixed into the ConnectionPool classes.
|
|
This class is not intended to be used directly!
|
|
All logic related to maintenance notifications and
|
connection pool handling is encapsulated in this class.
|
Nr c óä |j d« dv }| |r
|
t « }|rF|j r:|s t d« t | |« | _ | j | j
|
« y d | _ y )NrK ©rO rà zWMaintenance notifications handlers on connection are only supported with RESP version 3)r r1 rà r- r3 rá Ú1_update_connection_kwargs_for_maint_notifications)rW r r Úis_protocol_supporteds r\ rh z1MaintNotificationsAbstractConnectionPool.__init__í s ð !'§
|
¡
|
¨:Ó 6¸(Ð BÐ Ø %Ð -Ñ2GÜ)AÓ)CÐ &á %Ð*D×*LÒ*LÙ(Ü Ømóð ô 6SØÐ0ó6DÔ 2ð × BÑ BØ×6Ñ6õ ð 6:DÕ 2rA rv c ó y re ra rz s r\ Úconnection_kwargsz:MaintNotificationsAbstractConnectionPool.connection_kwargs r rA rZ c ó y re ra rÕ s r\ rï z:MaintNotificationsAbstractConnectionPool.connection_kwargs r rA c ó y re ra rz s r\ Ú_get_pool_lockz7MaintNotificationsAbstractConnectionPool._get_pool_lock r| rA rÁ c ó y re ra rz s r\ Ú_get_free_connectionsz>MaintNotificationsAbstractConnectionPool._get_free_connections r| rA c ó y re ra rz s r\ Ú_get_in_use_connectionsz@MaintNotificationsAbstractConnectionPool._get_in_use_connections s ð rA c ój | j r| j j nd}|xr |j S )a
|
Returns:
|
True if the maintenance notifications are enabled, False otherwise.
|
The maintenance notifications config is stored in the pool handler.
|
If the pool handler is not set, the maintenance notifications are not enabled.
|
N)rá ré rà ©rW r s r\ Úmaint_notifications_enabledzDMaintNotificationsAbstractConnectionPool.maint_notifications_enabled s: ð ×5Ò5ð × 2Ñ 2× 9Ò 9àð #ð *ÒPÐ.H×.PÑ.PÐPrA c ó | j « r|j s t d« | j st | |« | _ n|| j _ | j | j « | j | j « y)a#
|
Updates the maintenance notifications configuration.
|
This method should be called only if the pool was created
|
without enabling the maintenance notifications and
|
in a later point in time maintenance notifications
|
are requested to be enabled.
|
z<Cannot disable maintenance notifications after enabling themN)rù rà rú rá r3 ré rì Ú3_update_maint_notifications_configs_for_connectionsrø s r\ Ú!update_maint_notifications_configzJMaintNotificationsAbstractConnectionPool.update_maint_notifications_config. s ð × ,Ñ ,Ô .Ø.×6Ò6ä ØNóð ð ×5Ò5Ü5RØÐ0ó6DÕ 2ð =WD× 2Ñ 2Ô 9ð ×>Ñ>Ø × 2Ñ 2ô
|
ð ×@Ñ@Ø × 2Ñ 2õ
|
rA rà c ó | j « sy| j j ||j d« | j j dd« m| j j | j j d« | j j dd« | j j dd« d« yy)zJ
|
Update the connection kwargs for all future connections.
|
N)rà r rÆ rÓ r× rÚ )rÆ rÇ rÈ )rù rï Úupdateré r r s r\ rì zZMaintNotificationsAbstractConnectionPool._update_connection_kwargs_for_maint_notificationsO s½ ð ×/Ñ/Ô1Ø à × Ñ ×%Ñ%à4TØ.N×.UÑ.Uñ ô
|
ð × !Ñ !× %Ñ %Ð&9¸4Ó @Ð Hð × "Ñ "× )Ñ )à)-×)?Ñ)?×)CÑ)CÀFÓ)KØ+/×+AÑ+A×+EÑ+EØ(¨$ó,ð 48×3IÑ3I×3MÑ3MØ0°$ó4ñ õ
|
ð IrA c ól | j « 5 | j « D ]4 }|j |« |j |_ |j « 6 | j « D ]4 }|j |« |j |_ |j « 6 ddd« y# 1 sw Y yxY w)zLUpdate the maintenance notifications config for all connections in the pool.N)rò rô rë ré r r rö rµ )rW rà r s r\ rû z\MaintNotificationsAbstractConnectionPool._update_maint_notifications_configs_for_connectionso s¹ ð × Ñ Ó "ñ *Ø ×2Ñ2Ó4ò "Ø×HÑHØ4ôð 5×;Ñ;ð Ô/ð Õ!ð "ð ×4Ñ4Ó6ò *Ø×HÑHØ4ôð 5×;Ñ;ð Ô/ð ×'Ñ'Õ)ñ *÷ *÷ *ñ *ús BB*Â*B3r Úmatching_pattern)Úconnected_addressÚconfigured_addressÚnotification_hashÚmatching_addressÚmatching_notification_hashc ó |dk( r|r|j « |k7 ryy|dk( r|r|j |k7 ryy|dk( r|r|j |k7 ryy)z[
|
Check if the connection should be updated based on the matching criteria.
|
r Fr r T)r rÓ rÅ )rW r r r r s r\ Ú_should_update_connectionzBMaintNotificationsAbstractConnectionPool._should_update_connection
sn ð Ð 2Ò 2Ù D×$4Ñ$4Ó$6Ð:JÒ$JØ ð ð Ð!5Ò 5Ù D§I¡IÐ1AÒ$AØ ð ð Ð!4Ò 4á*Ø×6Ñ6Ð:TÒTà ØrA r r0 rÅ Ú host_addressr Úupdate_notification_hashr+ r, c óÈ |r||_ |r||_ ||j |¬« ||j |¬« |s|r|j ||¬« |j |« y)z>
|
Update the settings for a single connection.
|
N)r& )r' )r+ r, )rÄ rÅ r* r. r" ) rW r r rÅ r r r r+ r, s r\ Úupdate_connection_settingszCMaintNotificationsAbstractConnectionPool.update_connection_settings sw ñ Ø%*DÔ "á #à1NDÔ .à Ð #Ø × !Ñ !°<Ð !Ô @à Ð &Ø × !Ñ !°oÐ !Ô Fá Ñ$6Ø × #Ñ #Ø#5Ø&;ð $ô ð
|
×*Ñ*¨?Õ;rA Úinclude_free_connectionsc ó^ | j « 5 | j « D ]0 } | j | |||« s| j | |||||| |
|
¬« 2 | rC| j « D ]0 } | j | |||« s| j | |||||| |
|
¬« 2 ddd« y# 1 sw Y yxY w)a²
|
Update the settings for all matching connections in the pool.
|
|
This method does not create new connections.
|
This method does not affect the connection kwargs.
|
|
:param state: The maintenance state to set for the connection.
|
:param maintenance_notification_hash: The hash of the maintenance notification
|
to set for the connection.
|
:param host_address: The host address to set for the connection.
|
:param relaxed_timeout: The relaxed timeout to set for the connection.
|
:param matching_address: The address to match for the connection.
|
:param matching_notification_hash: The notification hash to match for the connection.
|
:param matching_pattern: The pattern to match for the connection.
|
:param update_notification_hash: Whether to update the notification hash for the connection.
|
:param reset_host_address: Whether to reset the host address to the original address.
|
:param reset_relaxed_timeout: Whether to reset the relaxed timeout to the original timeout.
|
:param include_free_connections: Whether to include free/available connections.
|
)r rÅ r r r r+ r, N)rò rö r r rô ) rW r rÅ r r r r r r r+ r, r r s r\ Úupdate_connections_settingszDMaintNotificationsAbstractConnectionPool.update_connections_settings sé ðF × Ñ Ó "ñ $ Ø ×4Ñ4Ó6ò Ø×1Ñ1ØØ$Ø$Ø.õ ð ×3Ñ3Ø Ø #Ø6SØ%1Ø(7Ø1IØ+=Ø.Cð 4õ ð ñ$ (Ø × 6Ñ 6Ó 8ò DØ×5Ñ5Ø Ø(Ø(Ø2õ ð ×7Ñ7Ø Ø"'Ø:WØ)5Ø,;Ø5MØ/AØ2Gð 8õ ð÷)$ ÷ $ ñ $ ús (B#ºAB#Á?B#Â#B,c ó: | j j |« y)zÜ
|
Update the connection kwargs for all future connections.
|
|
This method updates the connection kwargs for all future connections created by the pool.
|
Existing connections are not affected.
|
N)rï rþ ©rW r s r\ Úupdate_connection_kwargszAMaintNotificationsAbstractConnectionPool.update_connection_kwargs s ð × Ñ ×%Ñ% fÕ-rA Úmoving_address_srcc óÂ | j « 5 | j « D ]& }| j |d|« s|j « ( ddd« y# 1 sw Y yxY w)zÚ
|
Mark all active connections for reconnect.
|
This is used when a cluster node is migrated to a different address.
|
|
:param moving_address_src: The address of the node that is being moved.
|
r N)rò rö r rµ ©rW r r s r\ Ú'update_active_connections_for_reconnectzPMaintNotificationsAbstractConnectionPool.update_active_connections_for_reconnect sb ð × Ñ Ó "ñ .Ø ×4Ñ4Ó6ò .Ø×1Ñ1ØÐ-Ð/Aõð ×+Ñ+Õ-ñ .÷ .÷ .ñ .úó 'A¹AÁA c ó | j « 5 | j « D ]& }| j |d|« s|j « ( ddd« y# 1 sw Y yxY w)zÚ
|
Disconnect all free/available connections.
|
This is used when a cluster node is migrated to a different address.
|
|
:param moving_address_src: The address of the node that is being moved.
|
r N)rò rô r r r s r\ Údisconnect_free_connectionszDMaintNotificationsAbstractConnectionPool.disconnect_free_connections( s` ð × Ñ Ó "ñ &Ø ×2Ñ2Ó4ò &Ø×1Ñ1ØÐ-Ð/Aõð OOÕ%ñ &÷ &÷ &ñ &úr re )r NN)NNNNFFF) NNNNNNr FFFT)#r^ r_ r` r0 r r1 rh r¾ r r rL r rï r4 r r rò r rô rö rù rü r3 rì rû r r2 r6 r r3 r r r r r ra rA r\ ré ré â sÑ ñð JNñ:à$,Ð-EÑ$Fó:ð4 Øð 4¨¨S¨¡>ò ó ó ð ð × Ñ Øð t¨C°¨H¡~ò ó ó ð ð 𠧡ò ó ð ð ð xÐ0VÑ'Wò ó ð ð ð à Ð8Ñ 9ò ó ð ò
|
Qð
|
Ø*Bó
|
ðB Ø0Mó ð@*Ø0Mó*ð6 Ø*.Ø48ñà4ðð "Ø Jñ
|
ðð # 3-ð ð %-¨S¡Mðð
|
óð: /3Ø7;Ø&*Ø+/Ø).Ø#(Ø&+ñ!<à4ð!<ð Ð*Ñ+ð!<ð (0°¡}ð !<ð
|
smð !<ð " % ð !<ð #'ð!<ð !ð!<ð $ó!<ðJ /3Ø7;Ø&*Ø+/Ø*.Ø48ð Ø).Ø#(Ø&+Ø)-ñ GàÐ*Ñ+ðGð (0°¡}ðGð smð Gð
|
" % ð Gð # 3-ð Gð %-¨S¡MðGð "Ø Jñ
|
ðGð #'ðGð !ðGð $ðGð #'ó GòR
|
.ð -1ñ.à $ SMó.ð& -1ñ&à $ SMô&rA ré c ó e Zd ZdZedee dedefd« Ze dddfde
|
e de
|
e d e
|
e fd
|
Zdefd Zedeeef fd « Zej( d eeef fd« Zd Zd)dZd)dZ edgdd¬« d*d+d« ZdefdZd,dZ d-dZ ddde fd Z d.d e ddfd Z d)d Z!d e"ddfd!Z#d"e$fd#Z%d$ Z&d% Z'd& Z(d'e)fd(Z*y)/rÌ a>
|
Create a connection pool. ``If max_connections`` is set, then this
|
object raises :py:class:`~redis.exceptions.ConnectionError` when the pool's
|
limit is reached.
|
|
By default, TCP connections are created unless ``connection_class``
|
is specified. Use class:`.UnixDomainSocketConnection` for
|
unix sockets.
|
:py:class:`~redis.SSLConnection` can be used for SSL enabled connections.
|
|
If ``maint_notifications_config`` is provided, the connection pool will support
|
maintenance notifications.
|
Maintenance notifications are supported only with RESP3.
|
If the ``maint_notifications_config`` is not provided but the ``protocol`` is 3,
|
the maintenance notifications will be enabled by default.
|
|
Any additional keyword arguments are passed to the constructor of
|
``connection_class``.
|
ÚclsrÈ rv c ób t |« }d|v r|d |d< |j |« | di |¤S )a
|
Return a connection pool configured from the given URL.
|
|
For example::
|
|
redis://[[username]:[password]]@localhost:6379/0
|
rediss://[[username]:[password]]@localhost:6379/0
|
unix://[username@]/path/to/socket.sock?db=0[&password=password]
|
|
Three URL schemes are supported:
|
|
- `redis://` creates a TCP socket connection. See more at:
|
<https://www.iana.org/assignments/uri-schemes/prov/redis>
|
- `rediss://` creates a SSL wrapped TCP socket connection. See more at:
|
<https://www.iana.org/assignments/uri-schemes/prov/rediss>
|
- ``unix://``: creates a Unix Domain Socket connection.
|
|
The username, password, hostname, path and all querystring values
|
are passed through urllib.parse.unquote in order to replace any
|
percent-encoded values with their corresponding characters.
|
|
There are several ways to specify a database number. The first value
|
found will be used:
|
|
1. A ``db`` querystring option, e.g. redis://localhost?db=0
|
2. If using the redis:// or rediss:// schemes, the path argument
|
of the url, e.g. redis://localhost/0
|
3. A ``db`` keyword argument to this function.
|
|
If none of these options are specified, the default db=0 is used.
|
|
All querystring options are cast to their appropriate Python types.
|
Boolean arguments can be specified with string values "True"/"False"
|
or "Yes"/"No". Values that cannot be properly cast cause a
|
``ValueError`` to be raised. Once parsed, the querystring arguments
|
and keyword arguments are passed to the ``ConnectionPool``'s
|
class initializer. In the case of conflicting arguments, querystring
|
arguments always win.
|
rÀ ra )rÊ rþ )r rÈ r Ú url_optionss r\ Úfrom_urlzConnectionPool.from_urlO s? ôR n à Ñ 'Ø.4Ð5GÑ.HKÐ*Ñ +à kÔ"Ù}V}Ð rA Nr½ Ú cache_factoryr c óä |xs d}t |t « r|dk r t d« || _ || _ || _ d | _ || _ |j d« s|j d« rË| j j d« dvr t d« | j j d« }|#t |t « s t d « || _ nc| j | j j « | _ n7t | j j d« « j « | _ |j dd « |j dd « | j j d
|
d « | _ | j t « | _ t! j" « | _ t! j" « | _ t) j* | fd |i|¤ | j- « y ) Nl r z,"max_connections" must be a positive integerÚ cache_configr rK rë z4Client caching is only supported with RESP version 3z#Cache must implement CacheInterfacerM r )rK r2 rú rÀ Ú_connection_kwargsr½ r Ú_cache_factoryr r- r Ú get_cacher ÚpoprP r& r r Ú
|
_fork_lockÚ_lockré rh rÒ )rW rÀ r½ r r rï r s r\ rh zConnectionPool.__init__ sº ð *Ò2¨UÜ/¬3Ô/°?ÀQÒ3FÜ Ð KÓLÐ Là 0Ô Ø"3Ô Ø .Ô Ø
|
Ø +Ôà × Ñ Ô 0Ð4E×4IÑ4IÈ'Ô4RØ×&Ñ&×*Ñ*¨:Ó6¸hÑFÜ Ð!WÓXÐXà×+Ñ+×/Ñ/°Ó8EàÐ Ü! %¬ Ô8Ü$Ð%JÓKÐKà "
|
à×&Ñ&Ð2Ø!%×!4Ñ!4×!>Ñ!>Ó!@DJä!-Ø ×/Ñ/×3Ñ3°NÓCó"ç ikð Jð × Ñ g tÔ,Ø× Ñ n¨dÔ3à!%×!8Ñ!8×!<Ñ!<Ð=OÐQUÓ!VÔ Ø × !Ñ !Ð )Ü%4Ó%6DÔ "ô $//Ó+Ü __Ó&
|
ä0×9Ñ9Ø ñ
|
à'Að
|
ð ò
|
ð
|
|
rA c óT dj | j j « D cg c] \ }}| d| c}}« }d| j j d| j j
|
d| j j d| j j
|
d| d S c c}}w )Nrg rh ri rj z(<rk z)>)>)rk rï rï rl r_ r^ rÀ )rW rm rn Ú conn_kwargss r\ rp zConnectionPool.__repr__À s Øhh°t×7MÑ7M×7SÑ7SÓ7U× V©t¨q°! 1 # Q q c¢
|
Ó VÓW à×)Ñ)Ð*¨!¨D¯N©N×,CÑ,CÐ+DØ×&Ñ&×1Ñ1Ð2°!°D×4IÑ4I×4RÑ4RÐ3SØ }Dð "ð
|
ùó Ws ©B$
|
c ó | j S re ©r! rz s r\ rï z ConnectionPool.connection_kwargsÈ r rA rZ c ó || _ y re r* rÕ s r\ rï z ConnectionPool.connection_kwargsÌ r rA c ó: | j j dd« S )rÑ rK N)rï r rz s r\ r zConnectionPool.get_protocolÐ s ð ×%Ñ%×)Ñ)¨*°dÓ;Ð;rA c óp d| _ g | _ t « | _ t j
|
« | _ y )Nr )Ú_created_connectionsÚ_available_connectionsr* Ú_in_use_connectionsrQ rR rS rz s r\ rÒ zConnectionPool.resetØ s+ Ø$%Ô!Ø&(Ô#Ü#&£5Ô ô 99;rA c óf | j t j « k7 rq| j j d¬« }|st
|
| j t j « k7 r| j « | j j « y y # | j j « w xY w)Né )r )rS rQ rR r% Úacquirer) rÒ rà )rW Úacquireds r\ Ú _checkpidzConnectionPool._checkpidè s ðF 88ryy{Ò "Ø×.Ñ.°qÐ.Ó9HÙÜ*Ð*ð *Ø88ryy{Ò*ØJJLà×'Ñ'Õ)ð #øð ×'Ñ'Õ)ús Á1B  B0rÓ rÔ rÕ rÖ rß c ó | j « | j 5 | j j « }| j j |« ddd« j « |j « r'| j | j « s t d« |S # t $ r | j « }Y w xY w# 1 sw Y sxY w# t t t f$ r? |j « |j « |j « r t d« Y |S w xY w# t $ r | j# « w xY w)z Get a connection from the poolNúConnection has dataúConnection not ready)r5 r& r/ r$ Ú
|
IndexErrorÚmake_connectionr0 Úaddr r r rù r* r/ r r rº rà ©rW rÙ r" rÛ rI s r\ rÜ z ConnectionPool.get_connection
|
s< ð ÔØ ZZñ 5ð 4Ø !× 8Ñ 8× <Ñ <Ó >
|
ð × $Ñ $× (Ñ (¨Ô 4÷ 5ð à × Ñ Ô ð
|
Bà ×'Ñ'Ô)Ø
|
|
Ð*Ø × <Ñ <Ô >ä)Ð*?Ó@Ð@ð Ðøô9 ò 4Ø !× 1Ñ 1Ó 3
|
ð 4ú÷ 5ð 5ûô* $¤\´7Ð;ò BØ×%Ñ%Ô'Ø×"Ñ"Ô$Ø ×&Ñ&Ô(Ü)Ð*@ÓAÐAð )ð Ðð Bûô
|
ò ð LLÔ $Ø ð úsX CB'¹CÁ D( Á.7C Â'Cà CÃCÃCÃCÃAD%Ä!D( Ä$D%Ä%D( Ä( Ec ó | j }t |j dd« |j dd« |j dd« ¬« S )z,Return an encoder based on encoding settingsr? r9 r@ r: rA F)r? r@ rA )rï r r r s r\ rÞ zConnectionPool.get_encoderA
|
sF à×'Ñ'ÜØZZ
|
¨GÓ4Ø "JJÐ'8¸(Ó CØ #ZZÐ(:¸EÓ Bô
|
ð
|
rA c ó< | j | j k\ r t d« | xj dz c_ t | j « }| j
|
1t | j di |¤| j
|
| j « S | j di |¤S )zCreate a new connectionzToo many connectionsr ra ) r. r½ r, Údictrï r rþ rÀ r& r s r\ r: z ConnectionPool.make_connectionJ
|
s à × $Ñ $¨×(<Ñ(<Ò <Ü%Ð&<Ó=Ð =Ø ×!Ò! QÑ&Õ!äd×,Ñ,Ó-à ::Ð !Ü'Ø%×%Ñ%Ñ/¨Ñ/°·±¸T¿Z¹Zóð ð %t×$Ñ$Ñ. vÑ.Ð.rA rI c óä | j « | j 5 | j j |« | j |« r`|j « r|j « | j j |« | j j t |« « n|j « ddd« y ddd« y# t $ r Y ddd« yw xY w# 1 sw Y yxY w)z(Releases the connection back to the poolN) r5 r& r0 r{ ÚKeyErrorÚowns_connectionr· r r/ rP rP Údispatchr% rH s r\ rà zConnectionPool.releaseX
|
sÞ à ÔØ ZZñ ð Ø×(Ñ(×/Ñ/°
|
Ô;ð ×#Ñ# JÔ/Ø ×.Ñ.Ô0Ø ×)Ñ)Ô+Ø×+Ñ+×2Ñ2°:Ô>Ø×&Ñ&×/Ñ/Ü0°Ó<õð ×%Ñ%Ô'Ø÷+ ð ð÷ ð øô ò ð ÷ ð ð ú÷ ð ús. C&CºBC&à C#ÃC&Ã"C#Ã#C&Ã&C/c ó4 |j | j k( S re )rS rH s r\ rB z ConnectionPool.owns_connectionr
|
s Ø~~ §¡Ñ)Ð)rA rá c óô | j « | j 5 |r!t | j | j « }n | j }|D ] }|j « ddd« y# 1 sw Y yxY w)a
|
Disconnects connections in the pool
|
|
If ``inuse_connections`` is True, disconnect connections that are
|
currently in use, potentially by other threads. Otherwise only disconnect
|
connections that are idle in the pool.
|
N)r5 r& r r/ r0 r ©rW rá Ú connectionsrI s r\ r zConnectionPool.disconnectu
|
sp ð ÔØ ZZñ (Ù Ü #Ø×/Ñ/°×1IÑ1Ió ð #× 9Ñ 9 à )ò (
|
Ø×%Ñ%Õ'ñ (÷ (÷ (ñ (ús AA.Á.A7c ó$ | j « y)z-Close the pool, disconnecting all connectionsNr rz s r\ r¦ zConnectionPool.close
|
r³ rA rH c ó | j j d|i« | j D ] }||_ | j D ] }||_ y )NrH )rï rþ r/ rH r0 )rW rH r s r\ rå zConnectionPool.set_retry
|
sS Ø × Ñ ×%Ñ% w°Ð&6Ô7Ø×/Ñ/ò DØ DJð à×,Ñ,ò DØ DJñ rA r® c ó> j 5 j D ]G j j fd fd« j j fd fd« I j D ] j « d d d « y # 1 sw Y y xY w)Nc ód j dj d« j « « S rÒ )r rÔ rÕ )r r® s r\ r z1ConnectionPool.re_auth_callback.<locals>.<lambda>
|
s) ø D× -Ñ -Ø § ¡ ¨eÓ 4°e·o±oÓ6Gó rA c ó& j | « S re ©Ú_mockr s r\ r z1ConnectionPool.re_auth_callback.<locals>.<lambda>
|
s ø $§*¡*¨UÓ"3 rA c ó$ j « S re )r¤ )r s r\ r z1ConnectionPool.re_auth_callback.<locals>.<lambda>
|
s ø D× .Ñ .Ó 0 rA c ó& j | « S re rM r s r\ r z1ConnectionPool.re_auth_callback.<locals>.<lambda>
|
s ø ÀÇ
|
Á
|
È5Ó@Q rA )r& r/ rH r r0 r± )rW r® r s ``@r\ rç z ConnectionPool.re_auth_callback
|
s ú Ø ZZñ .Ø ×3Ñ3ò Ø
|
|
×*Ñ*ôó 4ô ð
|
|
×*Ñ*Û0Ó2Qõð ð ×0Ñ0ò .Ø×&Ñ& uÕ-ñ .÷ .÷ .ñ .ús A9BÂB c ó | j S re )r& rz s r\ rò z ConnectionPool._get_pool_lock£
|
r× rA c ó^ | j 5 | j cd d d « S # 1 sw Y y xY wre )r& r/ rz s r\ rô z$ConnectionPool._get_free_connections¦
|
s' Ø ZZñ /Ø×.Ñ.÷ /÷ /ò /úó #£,c ó^ | j 5 | j cd d d « S # 1 sw Y y xY wre )r& r0 rz s r\ rö z&ConnectionPool._get_in_use_connectionsª
|
s' Ø ZZñ ,Ø×+Ñ+÷ ,÷ ,ò ,úrS r c ó K yw)z
|
Dummy functions, needs to be passed as error callback to retry object.
|
:param error:
|
:return:
|
Nra r± s r\ rN zConnectionPool._mock®
|
s è ø ð ùs ru re )rv rß )rv rx )rI rß rv Nr» )+r^ r_ r` r0 Ú classmethodr rË rL r rß r r2 r r1 rh rp r¾ r r rï r4 r rÒ r5 r9 rÜ r rÞ r: rà rB r6 r r¦ r4 rå r! rç rò rô rö r- rN ra rA r\ rÌ rÌ : s ñð( ð. d3ið . cð . ¸ò . ó ð. ðd $Ø)-Ø9=ØIMñ >ð " # ð>ð Ð 5Ñ6ð >ð
|
%-Ð-EÑ$Fó >ð@
|
#ó
|
ð ð' 4¨¨S¨¡>ò 'ó ð'ð × Ñ ð( t¨C°¨H¡~ò (ó ð(ò<ó ó -*ñ^ ØUØ:Øôó
|
#ó ð
|
#ðJ
|
Wó
|
ó /ó ð4*¨,ð *¸3ó *ñ(¨Dð (¸Dó (ó(ð uð ¨ó ð . nó .ò ò/ò,ð ô rA c ó e Zd ZdZddeef fd Zd Zd Z e dgdd ¬
|
« dd « Z
|
d Z dd e fdZ d Zd Zde fdZ xZS )ÚBlockingConnectionPoola
|
Thread-safe blocking connection pool::
|
|
>>> from redis.client import Redis
|
>>> client = Redis(connection_pool=BlockingConnectionPool())
|
|
It performs the same function as the default
|
:py:class:`~redis.ConnectionPool` implementation, in that,
|
it maintains a pool of reusable connections that can be shared by
|
multiple redis clients (safely across threads if required).
|
|
The difference is that, in the event that a client tries to get a
|
connection from the pool when all of connections are in use, rather than
|
raising a :py:class:`~redis.ConnectionError` (as the default
|
:py:class:`~redis.ConnectionPool` implementation does), it
|
makes the client wait ("blocks") for a specified number of seconds until
|
a connection becomes available.
|
|
Use ``max_connections`` to increase / decrease the pool size::
|
|
>>> pool = BlockingConnectionPool(max_connections=10)
|
|
Use ``timeout`` to tell it either how many seconds to wait for a connection
|
to become available, or to block forever:
|
|
>>> # Block forever.
|
>>> pool = BlockingConnectionPool(timeout=None)
|
|
>>> # Raise a ``ConnectionError`` after five seconds if a connection is
|
>>> # not available.
|
>>> pool = BlockingConnectionPool(timeout=5)
|
é2 é c ób || _ || _ d| _ d| _ t | d||d|¤ y )NF)rÀ r½ ra )Ú queue_classr Ú_in_maintenanceÚ_lockedræ rh )rW r½ r rÀ r\ rï rl s r\ rh z BlockingConnectionPool.__init__Ù
|
sE ø ð 'ÔØ Ø $Ô Ø Ü Ñð
|
Ø -Ø +ñ
|
ð ó
|
rA c ó@ | j r!| j j « d| _ | j | j
|
« | _ | j j d « # t $ r Y nw xY wg | _ | j rw | j j « n# t $ r Y nw xY wd| _ nD# | j r3 | j j « n# t $ r Y nw xY wd| _ w w xY wt j « | _ y )NTF)r] r& r3 r^ r\ r½ ÚpoolÚ
|
put_nowaitr Ú _connectionsrà rü rQ rR rS rz s r\ rÒ z BlockingConnectionPool.resetë
|
sþ ð %Ø×#Ò#Ø
|
|
×"Ñ"Ô$Ø # Ø ×(Ñ(¨×)=Ñ)=Ó>DIØðØII×(Ñ(¨Ô.ð øô ò Ùðúð
|
!#DÔ à||ðØJJ×&Ñ&Õ(øÜ ò Ùðúà $ øð ||ðØJJ×&Ñ&Õ(øÜ ò Ùðúà $ ð úô 99;sf AC ÁA- Á,C Á- A9Á6C Á8A9Á9
|
C ÂB+ Â+ B7Â6B7à DÃC+Ã*DÃ+ C7Ã4DÃ6C7Ã7 Dc ód | j r!| j j « d| _ | j <t | j di | j ¤| j | j « }n | j di | j ¤}| j j |« || j r# | j j « d| _ S S # t $ r Y w xY w# | j r3 | j j « n# t $ r Y nw xY wd| _ w w xY w)zMake a fresh connection.TFra ) r] r& r3 r^ r rþ rÀ rï rb rP rà rü rH s r\ r: z&BlockingConnectionPool.make_connection s ð %Ø×#Ò#Ø
|
|
×"Ñ"Ô$Ø # àzzÐ%Ü 1Ø)D×)Ñ)ÑC¨D×,BÑ,BÑCØJJØJJó
|
ð 3T× 2Ñ 2Ñ L°T×5KÑ5KÑ L
|
Ø × Ñ × $Ñ $ ZÔ 0Ø à||ðØJJ×&Ñ&Ô(ð % ð øô !ò Ùðûð ||ðØJJ×&Ñ&Õ(øÜ ò Ùðúà $ ð úsB B-C. Â<C à C+Ã*C+Ã. D/Ã<DÄD/Ä D#Ä D/Ä"D#Ä# D/rÓ rÔ rÕ rÖ c ót | j « d} | j r!| j j « d| _ | j
|
j d| j ¬« }|| j « }| j r# | j j « d| _ |j « |j « r t d« |S # t $ r t d« w xY w# t $ r Y [w xY w# | j r3 | j j « n# t $ r Y nw xY wd| _ w w xY w# t t t f$ r? |j# « |j « |j « r t d« Y |S w xY w# t$ $ r | j |« w xY w)a7
|
Get a connection, blocking for ``self.timeout`` until a connection
|
is available from the pool.
|
|
If the connection returned is ``None`` then creates a new connection.
|
Because we use a last-in first-out queue, the existing connections
|
(having been returned to the pool after the initial ``None`` values
|
were added) will be returned before ``None`` values. This means we only
|
create new connections when we need to, i.e.: the actual number of
|
connections will only increase in response to demand.
|
NT)Úblockr zNo connection available.Fr7 r8 )r5 r] r& r3 r^ r` r r r r* r: rà rü r r r/ r r rº r< s r\ rÜ z%BlockingConnectionPool.get_connection' s¸ ð$ Ôð
|
ð %Ø×#Ò#Ø
|
|
×"Ñ"Ô$Ø # ð BØ !YY]]°¸t¿|¹|]Ó L
|
ð Ð!Ø !× 1Ñ 1Ó 3
|
à||ðØJJ×&Ñ&Ô(ð % ð à × Ñ Ô ð
|
BØ ×&Ñ&Ô(Ü)Ð*?Ó@Ð@ð )ð ÐøôK ò Bô &Ð&@ÓAÐAð Bûô !ò Ùðûð ||ðØJJ×&Ñ&Õ(øÜ ò Ùðúà $ ð ûô" $¤\´7Ð;ò BØ×%Ñ%Ô'Ø×"Ñ"Ô$Ø ×&Ñ&Ô(Ü)Ð*@ÓAÐAð )ð Ðð Bûô
|
ò à LLÔ $Ø ð ús -D Á'C Á)D ÂC2 Â+F Â<E ÃC/Ã/D Ã2 C>Ã=C>Ä EÄD*Ä)EÄ* D6Ä3EÄ5D6Ä6 EÅAFÆF ÆFÆF Æ F7c ó | j « | j r!| j j « d| _ | j |« s\|j « | j j d« | j r# | j j « d| _ yy|j « r|j « | j j |« | j r# | j j « d| _ yy# t $ r Y w xY w# t $ r Y Jw xY w# t $ r Y 2w xY w# | j r3 | j j « n# t $ r Y nw xY wd| _ w w xY w)z)Releases the connection back to the pool.TNF) r5 r] r& r3 r^ rB r r` ra rà rü r· r rH s r\ rà z BlockingConnectionPool.releasek sf ð Ôð %Ø×#Ò#Ø
|
|
×"Ñ"Ô$Ø # Ø×'Ñ'¨
|
Ô3ð
|
×%Ñ%Ô'Ø ×$Ñ$ TÔ*Øð ||ðØJJ×&Ñ&Ô(ð % ð ð ×*Ñ*Ô,Ø×%Ñ%Ô'ð Ø ×$Ñ$ ZÔ0ð ||ðØJJ×&Ñ&Ô(ð % ð øô !ò Ùðûô ò ñ ð ûô !ò Ùðûð ||ðØJJ×&Ñ&Õ(øÜ ò Ùðúà $ ð úsx A)E  D Â, E à D' Ã5D6 Ä D$Ä#D$Ä' D3Ä0E Ä2D3Ä3E Ä6 EÅEÅ FÅE.Å-FÅ. E:Å7FÅ9E:Å: Frá c óò | j « | j r!| j j « d| _ |r | j
|
}n| j « }|D ] }|j « | j r# | j j « d| _ yy# t $ r Y w xY w# | j r3 | j j « n# t $ r Y nw xY wd| _ w w xY w)zLDisconnects either all connections in the pool or just the free connections.TFN)
|
r5 r] r& r3 r^ rb rô r rà rü rF s r\ r z!BlockingConnectionPool.disconnect så à Ôð %Ø×#Ò#Ø
|
|
×"Ñ"Ô$Ø # Ù Ø "× /Ñ / à "× 8Ñ 8Ó : Ø )ò (
|
Ø×%Ñ%Õ'ñ (ð ||ðØJJ×&Ñ&Ô(ð % ð øô !ò Ùðûð ||ðØJJ×&Ñ&Õ(øÜ ò Ùðúà $ ð úsB A#B5 ÂB& Â& B2Â1B2Â5 C6ÃC à C6à C*Ã'C6Ã)C*Ã* C6c ó | j 5 | j j D ch c] }|s| c}cd d d « S c c}w # 1 sw Y y xY wre )r& r` Úqueuer[ s r\ rô z,BlockingConnectionPool._get_free_connections¢ s> Ø ZZñ >Ø%)§Y¡Y§_¡_Ö=TºDÒ=÷ >ñ >ùÚ=÷ >ð >ús A¦>®>²A¾AÁA c óä | j 5 | j j D ch c] }|s| }}| j D ch c] }||vs| c}cd d d « S c c}w c c}w # 1 sw Y y xY wre )r& r` ri rb )rW r Úconnections_in_queues r\ rö z.BlockingConnectionPool._get_in_use_connections¦ sl Ø ZZñ à59·Y±Y·_±_Ö#M¨TÊ¢DÐ#MÐ Ð#Mð "&×!2Ñ!2öØ °dÐBVÒ6Vò÷ ñ ùâ#Mùò÷ ð ús2 A&¦A ®A ²A&Á A!Á A!ÁA&Á
|
A&Á&A/Úin_maintenancec ó || _ y)a
|
Sets a flag that this Blocking ConnectionPool is in maintenance mode.
|
|
This is used to prevent new connections from being created while we are in maintenance mode.
|
The pool will be in maintenance mode only when we are processing a MOVING notification.
|
N)r] )rW rl s r\ Úset_in_maintenancez)BlockingConnectionPool.set_in_maintenance° s ð .Õ rA re r» )r^ r_ r` r0 rß r rh rÒ r: r9 rÜ rà r6 r rô rö rn rû rü s @r\ rX rX ·
|
st ø ñ ðF ØØ#Ø õ
|
ò$! òF%ñ2 ØUØ:Øôò
|
=ó ð
|
=ò~ %ñD%¨Dó %ò*>òð.°÷ .rA rX )rrV rQ r rT r rµ rw Úabcr r Ú itertoolsr ri r r r Útypingr r
|
r r r r r r r r Ú urllib.parser r r Ú redis.cacher r r r r r Ú_parsersr r r r Ú
|
auth.tokenr! Úbackoffr" Ú credentialsr# r$ Úeventr% r& Ú
|
exceptionsr' r( r) r* r+ r, r- r. r/ Úmaint_notificationsr0 r1 r2 r3 rH r4 Úutilsr5 r6 r7 r8 r9 r: r; r< r= rj r> rQ rl rq rn rj r_ r5 r) Ú__annotations__rC rE rc rx rÁ r8 rß rþ ra r¥ r´ rµ r¼ r2 r3 rU rÅ rÊ rË rÏ ré rÌ rX ra rA r\ ú<module>r} sü ðÜ Û Û Û
|
Û Û Û ß #Ý ß (Ñ (÷ ÷ ÷ ÷ 5Ñ 4÷÷ ÷ JÓ IÝ &Ý ß Oß @÷
|
÷
|
õ
|
÷ó õ ÷
|
÷
|
õ
|
ñ ÛÞ à
|
CØKáÛà Ø
|
Ø Ø àÐ á 8àE,¨ °nÐDÑEÑFÓ FÙØ"Mà M÷ñ ÷$0ñ 0÷fd ñ d ÷NAKñ AKôH D -Ð=Ð?Rô D -ôNPÐ#ô PôfI:Ð?ÐATô I:ôX
|
uJô uôp Ð!3ô ðF / òò ð ØØ #Ø Ø ØØØ Ø!Ø 6Ø 6Øñ Ð ò 6ñr eÐ+Ô,ô* cô * ÷ZU&ñ U&ôp
|
z Ð=Ð?Vô z ôz @.^õ @.rA
|
