Ë
|
|
çúht ã ó d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZmZ d dl m
|
Z
|
m Z m Z m Z d dlmZ G d de j « Z G d de j « Ze
|
rd d lmZmZ G d
|
d e« Z G d d e« Z G d de« Z G d de« Z G d de« Z G d de« Zde de fdZ G d d« Z G d d « Z G d d « Z!y) é N)ÚABCÚabstractmethod)Ú TYPE_CHECKINGÚLiteralÚOptionalÚUnion)ÚNumberc ó e Zd ZdZdZdZy)ÚMaintenanceStateÚnoneÚmovingÚ maintenanceN)Ú__name__Ú
|
__module__Ú __qualname__ÚNONEÚMOVINGÚ MAINTENANCE© ó õl H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/maint_notifications.pyr r s Ø DØ FØ Kr r c ó* e Zd ZdZdZdZdZdZdZd Z y) Ú EndpointTypez@Valid endpoint types used in CLIENT MAINT_NOTIFICATIONS command.z internal-ipz internal-fqdnz external-ipz external-fqdnr c ó | j S )z$Return the string value of the enum.)Úvalue©Úselfs r Ú__str__zEndpointType.__str__ s àzzÐr N)
|
r r r Ú__doc__Ú INTERNAL_IPÚ INTERNAL_FQDNÚ EXTERNAL_IPÚ EXTERNAL_FQDNr r r r r r r s# ÙJà KØ#MØ KØ#MØ Dór r )Ú$MaintNotificationsAbstractConnectionÚ(MaintNotificationsAbstractConnectionPoolc ón e Zd ZdZdedefdZdefdZede fd« Z
|
edefd« Z edefd « Z y
|
) ÚMaintenanceNotificationaÔ
|
Base class for maintenance notifications sent through push messages by Redis server.
|
|
This class provides common functionality for all maintenance notifications including
|
unique identification and TTL (Time-To-Live) functionality.
|
|
Attributes:
|
id (int): Unique identifier for this notification
|
ttl (int): Time-to-live in seconds for this notification
|
creation_time (float): Timestamp when the notification was created/read
|
ÚidÚttlc ó || _ || _ t j « | _ | j | j z | _ y)zò
|
Initialize a new MaintenanceNotification with unique ID and TTL functionality.
|
|
Args:
|
id (int): Unique identifier for this notification
|
ttl (int): Time-to-live in seconds for this notification
|
N)r( r) ÚtimeÚ monotonicÚ creation_timeÚ expire_at)r r( r) s r Ú__init__z MaintenanceNotification.__init__5 s7 ð ØÜ !^^Ó -ÔØ ×+Ñ+¨d¯h©hÑ6r Úreturnc ó^ t j « | j | j z kD S )z¾
|
Check if this notification has expired based on its TTL
|
and creation time.
|
|
Returns:
|
bool: True if the notification has expired, False otherwise
|
)r+ r, r- r) r s r Ú
|
is_expiredz"MaintenanceNotification.is_expiredB s% ô ~~Ó 4×#5Ñ#5¸¿¹Ñ#@ÑAÐAr c ó y)zã
|
Return a string representation of the maintenance notification.
|
|
This method must be implemented by all concrete subclasses.
|
|
Returns:
|
str: String representation of the notification
|
Nr r s r Ú__repr__z MaintenanceNotification.__repr__L s ð r c ó y)a
|
Compare two maintenance notifications for equality.
|
|
This method must be implemented by all concrete subclasses.
|
Notifications are typically considered equal if they have the same id
|
and are of the same type.
|
|
Args:
|
other: The other object to compare with
|
|
Returns:
|
bool: True if the notifications are equal, False otherwise
|
Nr ©r Úothers r Ú__eq__z MaintenanceNotification.__eq__X s ð r c ó y)a
|
Return a hash value for the maintenance notification.
|
|
This method must be implemented by all concrete subclasses to allow
|
instances to be used in sets and as dictionary keys.
|
|
Returns:
|
int: Hash value for the notification
|
Nr r s r Ú__hash__z MaintenanceNotification.__hash__i s ð r N) r r r r Úintr/ Úboolr2 r Ústrr4 r8 r: r r r r' r' ( sy ñ
|
ð 73ð 7 Só 7ðBDó Bð ð #ò ó ð ð ð tò ó ð ð ð
|
#ò
|
ó ñ
|
r r' c ód e Zd ZdZdedee dee def fd ZdefdZde fd Z
|
defd
|
Z xZ S ) ÚNodeMovingNotificationz
|
This notification is received when a node is replaced with a new node
|
during cluster rebalancing or maintenance operations.
|
r( Ú new_node_hostÚ new_node_portr) c óB t | ||« || _ || _ y)ai
|
Initialize a new NodeMovingNotification.
|
|
Args:
|
id (int): Unique identifier for this notification
|
new_node_host (str): Hostname or IP address of the new replacement node
|
new_node_port (int): Port number of the new replacement node
|
ttl (int): Time-to-live in seconds for this notification
|
N)Úsuperr/ r@ rA )r r( r@ rA r) Ú __class__s r r/ z NodeMovingNotification.__init__} s$ ø ô ÑSÔ!Ø *ÔØ *Õr r0 c ó@ | j }t d|t j « z
|
« }| j j
|
d| j d| j d| j d| j d| j d| d|d d
|
| j « d S ) Nr ú(id=z, new_node_host='z', new_node_port=ú, ttl=ú, creation_time=ú , expires_at=ú , remaining=ú.1fú s, expired=ú)) r. Úmaxr+ r, rD r r( r@ rA r) r- r2 ©r Ú expiry_timeÚ remainings r r4 z NodeMovingNotification.__repr__ s¹ Ønn Ü;¬¯ © Ó)9Ñ9Ó: ð ~~×&Ñ&Ð'ð (Ø''ð Ø "× 0Ñ 0Ð 1ð 2 Ø !× /Ñ /Ð 0ð 1Ø88*ð Ø !× /Ñ /Ð 0ð 1Ø% ð 'Ø" 3ð (ØÓ(Ð)Øð ð
|
r c óÂ t |t « sy| j |j k( xr4 | j |j k( xr | j |j k( S )z
|
Two NodeMovingNotification notifications are considered equal if they have the same
|
id, new_node_host, and new_node_port.
|
F)Ú
|
isinstancer? r( r@ rA r6 s r r8 z NodeMovingNotification.__eq__¢ sY ô
|
%Ô!7Ô8Øà GGuxxÑ ò :Ø×"Ñ" e×&9Ñ&9Ñ9ò :à×"Ñ" e×&9Ñ&9Ñ9ð
|
r c óþ | j rt | j « nd}t | j j
|
t | j « t | j « |f« S # t $ r d}Y Vw xY w)a
|
Return a hash value for the notification to allow
|
instances to be used in sets and as dictionary keys.
|
|
Returns:
|
int: Hash value based on notification type class name, id,
|
new_node_host and new_node_port
|
Nr ) rA r; Ú
|
ValueErrorÚhashrD r r( r= r@ )r Ú node_ports r r: z NodeMovingNotification.__hash__¯ st ð Ø37×3EÒ3ED× .Ñ .Ô/È4Iô à×'Ñ'ÜDGG ÜD×&Ñ&Ó'Øð ó
|
ð
|
øô ò ØIð ús #A. Á. A<Á;A<) r r r r r; r r= r/ r4 r< r8 r: Ú __classcell__©rD s @r r? r? w s_ ø ñð
|
+à ð+ð }ð+ð }ð +ð
|
õ +ð(
|
#ó
|
ð"
|
tó
|
ð
|
#÷
|
r r? c óP e Zd ZdZdedef fd ZdefdZdefdZ defdZ
|
xZ S ) ÚNodeMigratingNotificationat
|
Notification for when a Redis cluster node is in the process of migrating slots.
|
|
This notification is received when a node starts migrating its slots to another node
|
during cluster rebalancing or maintenance operations.
|
|
Args:
|
id (int): Unique identifier for this notification
|
ttl (int): Time-to-live in seconds for this notification
|
r( r) c ó& t | ||« y ©N©rC r/ ©r r( r) rD s r r/ z"NodeMigratingNotification.__init__Ó ó ø Ü ÑSÕ!r r0 c ó& | j | j z }t d|t j « z
|
« }| j
|
j d| j d| j d| j d| d|dd| j « d S ©
|
Nr rF rG rH rI rJ rK rL rM © r- r) rN r+ r, rD r r( r2 rO s r r4 z"NodeMigratingNotification.__repr__Ö ó Ø×(Ñ(¨4¯8©8Ñ3 Ü;¬¯ © Ó)9Ñ9Ó: à~~×&Ñ&Ð'ð (Ø''ð Ø88*ð Ø !× /Ñ /Ð 0ð 1Ø% ð 'Ø" 3ð (ØÓ(Ð)Øð ð
|
r c ó t |t « sy| j |j k( xr t | « t |« u S )z
|
Two NodeMigratingNotification notifications are considered equal if they have the same
|
id and are of the same type.
|
F)rS r[ r( Útyper6 s r r8 z NodeMigratingNotification.__eq__ä s7 ô
|
%Ô!:Ô;ØØww%((Ñ"Ò@¤t¨D£z´T¸%³[Ð'@Ð@r c ój t | j j t | j « f« S ©zÐ
|
Return a hash value for the notification to allow
|
instances to be used in sets and as dictionary keys.
|
|
Returns:
|
int: Hash value based on notification type and id
|
©rV rD r r; r( r s r r: z"NodeMigratingNotification.__hash__í ó& ô T^^×,Ñ,¬c°$·'±'«lÐ;Ó<Ð<r © r r r r r; r/ r= r4 r< r8 r: rX rY s @r r[ r[ Ç óA ø ñ ð"3ð " Sõ "ð
|
#ó
|
ð Ató Að=#÷ =r r[ c óP e Zd ZdZdZdef fd ZdefdZde fdZ
|
defdZ xZ S ) ÚNodeMigratedNotificationa5
|
Notification for when a Redis cluster node has completed migrating slots.
|
|
This notification is received when a node has finished migrating all its slots
|
to other nodes during cluster rebalancing or maintenance operations.
|
|
Args:
|
id (int): Unique identifier for this notification
|
é r( c óB t | |t j « y r] )rC r/ rn Ú DEFAULT_TTL©r r( rD s r r/ z!NodeMigratedNotification.__init__ s ø Ü ÑÔ 5× AÑ AÕBr r0 c ó& | j | j z }t d|t j « z
|
« }| j
|
j d| j d| j d| j d| d|dd| j « d S rb rc rO s r r4 z!NodeMigratedNotification.__repr__ rd r c ó t |t « sy| j |j k( xr t | « t |« u S )z
|
Two NodeMigratedNotification notifications are considered equal if they have the same
|
id and are of the same type.
|
F)rS rn r( rf r6 s r r8 z NodeMigratedNotification.__eq__ s7 ô
|
%Ô!9Ô:ØØww%((Ñ"Ò@¤t¨D£z´T¸%³[Ð'@Ð@r c ój t | j j t | j « f« S rh ri r s r r: z!NodeMigratedNotification.__hash__ rj r © r r r r rq r; r/ r= r4 r< r8 r: rX rY s @r rn rn ø sC ø ñð KðC3õ Cð
|
#ó
|
ð Ató Að=#÷ =r rn c óP e Zd ZdZdedef fd ZdefdZdefdZ defdZ
|
xZ S ) ÚNodeFailingOverNotificationap
|
Notification for when a Redis cluster node is in the process of failing over.
|
|
This notification is received when a node starts a failover process during
|
cluster maintenance operations or when handling node failures.
|
|
Args:
|
id (int): Unique identifier for this notification
|
ttl (int): Time-to-live in seconds for this notification
|
r( r) c ó& t | ||« y r] r^ r_ s r r/ z$NodeFailingOverNotification.__init__6 r` r r0 c ó& | j | j z }t d|t j « z
|
« }| j
|
j d| j d| j d| j d| d|dd| j « d S rb rc rO s r r4 z$NodeFailingOverNotification.__repr__9 rd r c ó t |t « sy| j |j k( xr t | « t |« u S )z
|
Two NodeFailingOverNotification notifications are considered equal if they have the same
|
id and are of the same type.
|
F)rS rx r( rf r6 s r r8 z"NodeFailingOverNotification.__eq__G s7 ô
|
%Ô!<Ô=ØØww%((Ñ"Ò@¤t¨D£z´T¸%³[Ð'@Ð@r c ój t | j j t | j « f« S rh ri r s r r: z$NodeFailingOverNotification.__hash__P rj r rk rY s @r rx rx * rl r rx c óP e Zd ZdZdZdef fd ZdefdZde fdZ
|
defdZ xZ S ) ÚNodeFailedOverNotificationa/
|
Notification for when a Redis cluster node has completed a failover.
|
|
This notification is received when a node has finished the failover process
|
during cluster maintenance operations or after handling node failures.
|
|
Args:
|
id (int): Unique identifier for this notification
|
ro r( c óB t | |t j « y r] )rC r/ r~ rq rr s r r/ z#NodeFailedOverNotification.__init__h s ø Ü ÑÔ 7× CÑ CÕDr r0 c ó& | j | j z }t d|t j « z
|
« }| j
|
j d| j d| j d| j d| d|dd| j « d S rb rc rO s r r4 z#NodeFailedOverNotification.__repr__k rd r c ó t |t « sy| j |j k( xr t | « t |« u S )z
|
Two NodeFailedOverNotification notifications are considered equal if they have the same
|
id and are of the same type.
|
F)rS r~ r( rf r6 s r r8 z!NodeFailedOverNotification.__eq__y s7 ô
|
%Ô!;Ô<ØØww%((Ñ"Ò@¤t¨D£z´T¸%³[Ð'@Ð@r c ój t | j j t | j « f« S rh ri r s r r: z#NodeFailedOverNotification.__hash__ rj r rv rY s @r r~ r~ [ sC ø ñð KðE3õ Eð
|
#ó
|
ð Ató Að=#÷ =r r~ Úhostr0 c ó | j « j d« }d|vryg d¢}|D ] }t j ||« s y y)a§
|
Determine if an FQDN is likely to be internal/private.
|
|
This uses heuristics based on RFC 952 and RFC 1123 standards:
|
- .local domains (RFC 6762 - Multicast DNS)
|
- .internal domains (common internal convention)
|
- Single-label hostnames (no dots)
|
- Common internal TLDs
|
|
Args:
|
host (str): The FQDN to check
|
|
Returns:
|
bool: True if the FQDN appears to be internal/private
|
ú.T)z\.local$z \.internal$z\.corp$z\.lan$z \.intranet$z
|
\.private$F)ÚlowerÚrstripÚreÚsearch)r Ú
|
host_lowerÚinternal_patternsÚpatterns r Ú_is_private_fqdnr sV ð ×$Ñ$ SÓ)Jð *Ñ ØòÐð %ò Ü 99WjÕ )Ùðð
|
r c
|
óz e Zd ZdZ ddeeed f dedee dee fdZ
|
d e fd
|
Z d efd Z d e d dd e fdZy)ÚMaintNotificationsConfiga#
|
Configuration class for maintenance notifications handling behaviour. Notifications are received through
|
push notifications.
|
|
This class defines how the Redis client should react to different push notifications
|
such as node moving, migrations, etc. in a Redis cluster.
|
|
ÚautoNÚenabledÚproactive_reconnectÚrelaxed_timeoutÚ endpoint_typec ó< || _ || _ || _ || _ y)a!
|
Initialize a new MaintNotificationsConfig.
|
|
Args:
|
enabled (bool | "auto"): Controls maintenance notifications handling behavior.
|
- True: The CLIENT MAINT_NOTIFICATIONS command must succeed during connection setup,
|
otherwise a ResponseError is raised.
|
- "auto": The CLIENT MAINT_NOTIFICATIONS command is attempted but failures are
|
gracefully handled - a warning is logged and normal operation continues.
|
- False: Maintenance notifications are completely disabled.
|
Defaults to "auto".
|
proactive_reconnect (bool): Whether to proactively reconnect when a node is replaced.
|
Defaults to True.
|
relaxed_timeout (Number): The relaxed timeout to use for the connection during maintenance.
|
If -1 is provided - the relaxed timeout is disabled. Defaults to 20.
|
endpoint_type (Optional[EndpointType]): Override for the endpoint type to use in CLIENT MAINT_NOTIFICATIONS.
|
If None, the endpoint type will be automatically determined based on the host and TLS configuration.
|
Defaults to None.
|
|
Raises:
|
ValueError: If endpoint_type is provided but is not a valid endpoint type.
|
N)r r r r )r r r r r s r r/ z!MaintNotificationsConfig.__init__¿ s# ð: Ø .Ô Ø#6Ô Ø *Õr r0 c
|
ó | j j d| j d| j d| j d| j
|
d
|
S )Nz (enabled=z, proactive_reconnect=z, relaxed_timeout=z, endpoint_type=rM )rD r r r r r r s r r4 z!MaintNotificationsConfig.__repr__á s` à~~×&Ñ&Ð'ð (Ø||nð %#Ø#'×#;Ñ#;Ð"<ð = Ø #× 3Ñ 3Ð 4ð 5 Ø !× /Ñ /Ð 2Øð ð
|
r c ó | j dk7 S )aK
|
Check if the relaxed_timeout is enabled. The '-1' value is used to disable the relaxed_timeout.
|
If relaxed_timeout is set to None, it will make the operation blocking
|
and waiting until any response is received.
|
|
Returns:
|
True if the relaxed_timeout is enabled, False otherwise.
|
éÿÿÿÿ)r r s r Úis_relaxed_timeouts_enabledz4MaintNotificationsConfig.is_relaxed_timeouts_enabledë s ð ×#Ñ# rÑ)Ð)r r Ú
|
connectionr$ c óü | j | j S t j |« }|j }|rt j
|
S t j S # t $ r Y nw xY w|j « }|rS t j |« }|j }|rt j S t j S # t $ r Y nw xY wt |« }|rt j S t j S )aY
|
Determine the appropriate endpoint type for CLIENT MAINT_NOTIFICATIONS command.
|
|
Logic:
|
1. If endpoint_type is explicitly set, use it
|
2. Otherwise, check the original host from connection.host:
|
- If host is an IP address, use it directly to determine internal-ip vs external-ip
|
- If host is an FQDN, get the resolved IP to determine internal-fqdn vs external-fqdn
|
|
Args:
|
host: User provided hostname to analyze
|
connection: The connection object to analyze for endpoint type determination
|
|
Returns:
|
) r Ú ipaddressÚ
|
ip_addressÚ
|
is_privater r r" rU Úget_resolved_ipr! r# r )r r r Úip_addrr Ú resolved_ips r Úget_endpoint_typez*MaintNotificationsConfig.get_endpoint_typeö sø ð( × Ñ Ð )Ø×%Ñ%Ð %ð Ü ×*Ñ*¨4Ó0Gà ×+Ñ+JÙ/9<×+Ñ+Ð W¼|×?WÑ?WÐ WøÜò á ð úð
|
!×0Ñ0Ó2 á ð Ü#×.Ñ.¨{Ó;Ø $× /Ñ /
|
ñ "ô !×.Ñ.ðô &×3Ñ3ðøô
|
ò áð úô
|
& dÓ+
|
Ù-7|×)Ñ)ÐW¼\×=WÑ=WÐWs/ 2A Á A Á A)Á(A)Á?2C Â2C Ã CÃ C)r Té
|
N)r r r r r r< r r r r r/ r= r4 r r¢ r r r r r µ s ñð 17Ø$(Ø,.Ø04ñ +àtW V_Ð,Ñ-ð +ð "ð +ð " &Ñ)ð +ð
|
Ñ-ó +ðD
|
#ó
|
ð *¨Tó *ð4XØð4XØ%Kð4Xà ô4Xr r c ól e Zd ZdddeddfdZddZd Zd Zd
|
efd Z d
|
e
|
fd Z dd e e fdZd
|
e
|
fdZy)Ú MaintNotificationsPoolHandlerÚpoolr% Úconfigr0 Nc ó~ || _ || _ t « | _ t j
|
« | _ d | _ y r] )r¦ r§ ÚsetÚ_processed_notificationsÚ threadingÚRLockÚ_lockr )r r¦ r§ s r r/ z&MaintNotificationsPoolHandler.__init__. s1 ð
|
Ø Ü(+«Ô%Ü __Ó&
|
Ø r c ó || _ y r] )r )r r s r Úset_connectionz,MaintNotificationsPoolHandler.set_connection9 s Ø$r c ó t | j | j « }| j |_ | j |_ d |_ |S r] )r¥ r¦ r§ rª r r )r Úcopys r Úget_handler_for_connectionz8MaintNotificationsPoolHandler.get_handler_for_connection< s= ô -¨T¯Y©Y¸¿ ¹ ÓDØ(,×(EÑ(EÔ%ØZZ
|
Ø Ø r c óÔ | j 5 t | j « D ]. }|j « s| j j |« 0 d d d « y # 1 sw Y y xY wr] )r Útuplerª r2 Úremove©r Ú notifications r Ú remove_expired_notificationsz:MaintNotificationsPoolHandler.remove_expired_notificationsF s^ Ø ZZñ GÜ % d×&CÑ&CÓ Dò G Ø ×*Ñ*Õ,Ø×1Ñ1×8Ñ8¸ ÕFñ G÷ G÷ Gñ Gús )A · A Á A'r· c ó | j « t |t « r| j |« S t j
|
d| « y ©Nz Unhandled notification type: )r¸ rS r? Ú handle_node_moving_notificationÚloggingÚerrorr¶ s r Úhandle_notificationz1MaintNotificationsPoolHandler.handle_notificationL s> Ø ×)Ñ)Ô+ä lÔ$:Ô ;Ø×7Ñ7¸ ÓEÐ Eä MMÐ 9¸,¸ ÐHÕ Ir c óV | j j s| j j « sy | j 5 || j v r
|
d d d « y | j
|
j 5 | j j s| j j « r | j r| j j « nd }t | j
|
dd« r| j
|
j d« | j
|
j t j t |« | j j |j |ddd¬« | j j r\|j | j! |« n>t# j$ |j& dz | j |f¬« j) « t j t |« d}|j |j+ d |j i« | j j « r<|j+ | j j | j j d
|
« | j
|
j, d i |¤ t | j
|
dd« r| j
|
j d« d d d « t# j$ |j& | j. |f¬« j) « | j j1 |« d d d « y # 1 sw Y hxY w# 1 sw Y y xY w) NÚset_in_maintenanceFTÚconnected_address)ÚstateÚ maintenance_notification_hashr Ú host_addressÚmatching_addressÚmatching_patternÚupdate_notification_hashÚinclude_free_connectionsé )Úargs)Úmaintenance_staterà r )Úsocket_timeoutÚsocket_connect_timeoutr )r§ r r r rª r¦ r Ú getpeernameÚgetattrrÀ Úupdate_connections_settingsr r rV r r@ Úrun_proactive_reconnectr« ÚTimerr) ÚstartÚupdateÚupdate_connection_kwargsÚ handle_node_moved_notificationÚadd)r r· Úmoving_address_srcÚkwargss r r» z=MaintNotificationsPoolHandler.handle_node_moving_notificationT s à ×/Ò/ØKK×;Ñ;Ô=à Ø ZZñ S <Øt× <Ñ <Ñ<ð ÷ S <ð S <ð ñ D <àKK×3Ò3Ø{{×>Ñ>Õ@ð :>¿ º ×3Ñ3Ô5Èdð 'ô tyyÐ*>ÀÔFð ×4Ñ4°TÔ:ð II×9Ñ9Ü .× 5Ñ 5Ü6:¸<Ó6HØ(,¯ © ×(CÑ(CØ%1×%?Ñ%?Ø);Ø)<Ø15Ø15ð :ô ð {{×6Ò6Ø'×5Ñ5ÐAØ × 8Ñ 8Ð9KÕ Lä %OOØ ,× 0Ñ 0°1Ñ 4Ø $× <Ñ <Ø&8Ð%:ô ÷ $egô .>×-DÑ-DÜ9=¸lÓ9Kñ$Fð $×1Ñ1Ð=ð à &¨ ×(BÑ(Bð ôð
|
{{×>Ñ>Ô@Ø à26·+±+×2MÑ2MØ:>¿+¹+×:UÑ:Uñ ôð 7DII×6Ñ6Ñ@¸Ò@ä tyyÐ*>ÀÔFØ ×4Ñ4°UÔ;÷ID <ôL OOØ × Ñ Ø×3Ñ3Ø"_ô ÷ egà × )Ñ )× -Ñ -¨lÔ ;÷gS <ð S <÷D <ð D <ú÷S <ð S <ús+ ¾L ÁL Á-H?LÊ,A L ÌL ÌL Ì L(rØ c ó | j 5 | j j 5 | j j |¬« | j j |¬« ddd« ddd« y# 1 sw Y xY w# 1 sw Y yxY w)zå
|
Run proactive reconnect for the pool.
|
Active connections are marked for reconnect after they complete the current command.
|
Inactive connections are disconnected and will be connected on next use.
|
)rØ N)r r¦ Ú'update_active_connections_for_reconnectÚdisconnect_free_connections)r rØ s r rÑ z5MaintNotificationsPoolHandler.run_proactive_reconnect¯ s~ ð ZZñ Ø ñ
|
ð ×AÑAØ'9ð Bô ð
|
×5Ñ5Ø'9ð 6ô ÷
|
÷ ð ÷
|
ð
|
ú÷ ð ús" A:¤9A.Á A:Á.A7 Á3A:Á:Bc ó t |« }| j 5 | j j j d« |k( r¡| j j j d« }| j j j d« }| j j j d« }t
|
j d|||d} | j j d i |¤ | j j 5 | j j « }| j j }| j j dt
|
j d|dd ||d ¬
|
« ddd« ddd« y# 1 sw Y xY w# 1 sw Y yxY w) zN
|
Handle the cleanup after a node moving notification expires.
|
rà Úorig_host_addressÚorig_socket_timeoutÚorig_socket_connect_timeoutN)rË rà r rÌ rÍ r Únotification_hashT) r r rà Úmatching_notification_hashrÆ rÇ Úreset_relaxed_timeoutÚreset_host_addressrÈ r ) rV r r¦ Úconnection_kwargsÚgetr r rÕ r§ r r rÐ ) r r· rá Ú orig_hostrß Úorig_connect_timeoutrÙ rã rä s r rÖ z<MaintNotificationsPoolHandler.handle_node_moved_notification s` ô ! Ó .Ðà ZZñ & ð
|
×+Ñ+×/Ñ/Ð0OÓPØ$ò%ð !II× 7Ñ 7× ;Ñ ;Ð<OÓ P Ø&*§i¡i×&AÑ&A×&EÑ&EØ)ó'Ð#ð (,§y¡y×'BÑ'B×'FÑ'FØ1ó(Ð$ô *:×)>Ñ)>Ø59Ø %Ø&9Ø.Bñ ð 3 ×2Ñ2Ñ<°VÒ<à ñ Ø(,¯ © ×(OÑ(OÓ(QÐ%Ø%)§[¡[×%DÑ%DÐ"à ×5Ñ5Ø$&Ü*×/Ñ/Ø26Ø/@Ø%8Ø-1Ø*?Ø'9Ø-1ð 6ô
|
÷ ÷1& ð & ÷0 ð ú÷1& ð & ús% C E8Ã8A#E,ÅE8Å,E5 Å1E8Å8F)r r$ r] )r r r r r/ r¯ r² r¸ r' r¾ r? r» r r= rÑ rÖ r r r r¥ r¥ - so ð à8ð ð )ð ð
|
ó ó%òòGð JÐ0Gó JðY<Ð<Ró Y<ñv¸(À3¹-ó ð&,Ð;Qô ,r r¥ c ón e Zd ZU edededediZee d e
|
f e d< ddde dd fd
|
Z d efd Zd efdZd Zy )Ú#MaintNotificationsConnectionHandleré r r' Ú_NOTIFICATION_TYPESr r$ r§ r0 Nc ó || _ || _ y r] )r r§ )r r r§ s r r/ z,MaintNotificationsConnectionHandler.__init__ú s ð
|
%Ø r r· c óê | j j |j d « }|t j d| « y |r | j t j « y | j « y rº ) rì ræ rD r¼ r½ Ú%handle_maintenance_start_notificationr r Ú)handle_maintenance_completed_notification)r r· Únotification_types r r¾ z7MaintNotificationsConnectionHandler.handle_notification sc à × 4Ñ 4× 8Ñ 8¸ ×9OÑ9OÐQUÓ VÐà Ð $Ü MMÐ 9¸,¸ ÐHÔ IØ á Ø × 6Ñ 6Ô7G×7SÑ7SÕ Tà × :Ñ :Õ <r rË c óh | j j t j k( s| j j « sy || j _ | j j | j j ¬« | j j | j j « y )N)Útmp_relaxed_timeout) r rË r r r§ r Úset_tmp_settingsr Ú update_current_socket_timeout)r rË s r rï zIMaintNotificationsConnectionHandler.handle_maintenance_start_notification s~ ð OO× -Ñ -Ô1A×1HÑ1HÒ HØ;;×:Ñ:Ô<à à,=Ô)Ø ×(Ñ(Ø $§ ¡ × ;Ñ ;ð )ô
|
ð ×5Ñ5°d·k±k×6QÑ6QÕRr c ó4 | j j t j k( s| j j « sy | j j d¬« | j j d« t j | j _ y )NT)rã r ) r rË r r r§ r Úreset_tmp_settingsrõ r r s r rð zMMaintNotificationsConnectionHandler.handle_maintenance_completed_notification sk ð OO× -Ñ -Ô1A×1HÑ1HÒ HØ;;×:Ñ:Ô<à Ø ×*Ñ*ÀÐ*ÔFð ×5Ñ5°bÔ9Ü,<×,AÑ,AÕ)r )r r r r[ rx rn r~ rì Údictrf r; Ú__annotations__r r/ r' r¾ r rï rð r r r rê rê ñ s{
ð " 1Ø# QØ !Ø" Að GÐdÐ#<Ñ =¸sÐ BÑCó ð à:ð ð )ð ð
|
ó ð =Ð0Gó =ðSØ!1óSó Br rê )"Úenumr r¼ r r« r+ Úabcr r Útypingr r r r Ú redis.typingr ÚEnumr r Úredis.connectionr$ r% r' r? r[ rn rx r~ r= r< r r r¥ rê r r r ú<module>r sà ðÛ Û Û Û Û Û ß #ß :Ó :å ô tyyô ô 499ô ñ ÷ô L cô L ô^M
|
Ð 4ô M
|
ô`.=Ð 7ô .=ôb/=Ð 6ô /=ôd.=Ð"9ô .=ôb/=Ð!8ô /=ðd%3ð % 4ó %÷PuXñ uX÷pAñ A÷H9Bò 9Br
|
