ng\jG2%SSKrSSKrSSKrSSKJrJr SSKJr SSKJ r J r J r J r J r SSKJr SSKJr SSKJrJr SSKJr SSKJr SSKJr SS KJr SS KJ r SS K!J"r" \ \\4r#S \ S \$4Sjr%S\&S \ S \&4Sjr'Sr(Sr)Sr*Sr+Sr,\RZ"\.5r/"SS\5r0"SS\5r1"SS\15r2"SS\25r3"SS\25r4"SS \25r5"S!S"\5r6\6Rnr8\6\9S#'"S$S%\05r:"S&S'\:5r;"S(S)\:5r#_get_init_params..sX 1KD 6>  JJ    3 3    * *   1s AAA A)r signature__init__ frozenset parametersitems)rsigs r _get_init_paramsr)s=   CLL )C  >>//1   kwargsc|[U5nUR5VVs0sHup4X2;dM X4_M snn$s snnf)zJFilter kwargs to only include parameters accepted by the class's __init__.)r)r')r+rallowedkvs r _filter_kwargsr0%s4s#G#\\^ <^TQq|DAD^ << 7f)z Execute all health checks concurrently with individual timeouts. Each health check runs with its own timeout, and all run in parallel. All exception handling is centralized here - _execute() methods just propagate exceptions naturally. r\c~># [R"TRUT5URS9IShvN $N7f)N)timeout)asynciowait_forr`r@)r\rErs r execute_with_timeout?AbstractHealthCheckPolicy.execute..execute_with_timeouts: )) lH5$99 s 3=;=return_exceptionsTNzUnhealthy databaseF)r4rvgather isinstance Exceptionr)rrWrErxhcresultsresults` ` r rY!AbstractHealthCheckPolicy.executes [   1> ?2"2& ? "   F&),,01ExQWXXV @ s!$BA= BB0B8 Bc # [U5nURRU5nUGc[UR[ [ 45(a7URR5n[U[ 5n[ S0UD6nGO([UR[[45(aURR5R5n[U[5nURRnU(aUSnURRn[US[USS55n [SURUR UR"UR$U URR&S.UD6nO,[)S5e[+S[-UR535eX0RU'U$7f) z Get or create a health check client for the database. Creates a single client instance per database that follows topology changes automatically. For cluster databases, the client handles node discovery and slot mapping internally. rrequire_full_coverage_require_full_coverageT)hostportdynamic_startup_nodes address_remaprretryz?Cluster client has no nodes - cannot create health check clientzUnsupported client type: r7)idrqgetr|client AsyncRedis SyncRedisget_connection_kwargsr0AsyncRedisClusterSyncRedisClustercopy startup_nodes nodes_managergetattrrr_dynamic_startup_nodesrr ValueError TypeErrortype) rrEdb_idr conn_kwargsfiltered_kwargsr first_noderrs r rd$AbstractHealthCheckPolicy.get_clients8 ""5) >(//J +BCC&ooCCE "0j"I#6o6HOO.?AQ-RSS'ooCCEJJL "0>O"P ( = =  !.q!1J$,OO$A$AM -4%/ /GN-) /'__'__.;.R.R&3&A&A.C&oo33 *F%Y ";D&B :  :" :$ :)S))(E((*e** 6G D  r*rc*\rSrSrSrS\S\4SjrSrg)PingHealthChecki{z% Health check based on PING command. rBrc# [U[5(aURS5IShvN $UR5nUH-nURRS5IShvN (aM- g gNHN7f)NPINGFT)r|rexecute_command get_nodesredis_connection)rrErB all_nodesnodes r rFPingHealthCheck.check_healthsm i , ,"226:: :"++-I!!22BB6JJJ "; Ks'*A9A57A9$A7%A90A97A9r7N) rIrJrKrLrMrQrRrFrSr7r*r rr{s 6G D r*rc^\rSrSrSrS\\SSSSSSSS\\\ 4S\ S\ S\ S \ \ \\4S \S \ \S \ \S \ \\\4S\ \S\ \S\ \S\ S\ S\ 4U4SjjjrS\S\4SjrSrU=r$)LagAwareHealthCheckiz Health check available for Redis Enterprise deployments. Verify via REST API that the database is healthy based on different lags. i$NT rest_api_portlag_aware_tolerance http_timeout auth_basic verify_tlsca_fileca_pathca_dataclient_cert_fileclient_key_fileclient_key_passwordr9r=r@c>[[UU[[5SS9UUUUU U U S9 5UlXlX l[TU]!U U US9 g)a8 Initialize LagAwareHealthCheck with the specified parameters. Args: rest_api_port: Port number for Redis Enterprise REST API (default: 9443) lag_aware_tolerance: Tolerance in lag between databases in MS (default: 100) http_timeout: Request timeout in seconds (default: DEFAULT_TIMEOUT) auth_basic: Tuple of (username, password) for basic authentication verify_tls: Whether to verify TLS certificates (default: True) ca_file: Path to CA certificate file for TLS verification ca_path: Path to CA certificates directory for TLS verification ca_data: CA certificate data as string or bytes client_cert_file: Path to client certificate file for mutual TLS client_key_file: Path to client private key file for mutual TLS client_key_password: Password for encrypted client private key r)retries) rurrrrrrrrr)r9r=r@N) rrrr _http_client_rest_api_port_lag_aware_tolerancesuperr$)rrrrrrrrrrrrr9r=r@ __class__s r r$LagAwareHealthCheck.__init__skH3 $%IK3%!1 /$7   ,$7!  31!5  r*rBrc# URc [S5e[UR[[ 45(aURR 5SnO'URR5SRnURSUR3nX@RRl SnURRS5IShvN H3nUSH'nUSU:XaUn MUS H nX:XdM Un M% M) M5 Uc [RS 5 [S 5eS US SUR3n URRU SS9IShvN gNN7f)z Check database health via Redis Enterprise REST API. Note: The client parameter is not used for this health check as it relies on the REST API instead of Redis protocol. The client is accepted for interface compatibility. Nz[Database health check url is not set. Please check DatabaseConfig for the current database.rr:z/v1/bdbs endpointsdns_nameaddrz8LagAwareHealthCheck failed: Couldn't find a matching bdbzCould not find a matching bdbz /v1/bdbs/uidz=/availability?extend_check=lag&availability_lag_tolerance_ms=F) expect_jsonT)health_check_urlrr|rrrrrrrrbase_urlrloggerwarningr) rrErBdb_hostr matching_bdbbdbendpointrurls r rF LagAwareHealthCheck.check_healths  $ $ ,m  hoo I'> ? ?oo;;=fEGoo//1!499G//0$2E2E1FG,4  ) **..z:::C ,J'72#&L%V,D'* - -;   NNU V<= = U+,-??C?X?X>Y [ ##CU#;;;/;( -04!%!%/3*.)--1#>$>&B%8 8 !8  8 U38_- 8  8 #8 #8 %U +,8 #3-8 "#8 &c]8 !!8 ""#8 $$%8 8 t/6G/D//r*r)=rvrloggingabcrrenumrtypingrrrr r redis.asyncior rredis.asyncio.clusterr rredis.asyncio.http.http_clientr r redis.backoffr redis.clientr redis.clusterrredis.http.http_clientrredis.multidb.exceptionr redis.retryrrQr%r)dictr0rDEFAULT_HEALTH_CHECK_INTERVALrrr  getLoggerrIrr4rUrlrrrrrr__annotations__rrrr7r*r rs@#55-CR#+:->*&778 $ 9 =4=d=t=   !  "   8 $$ #$ N