phP(%SSKrSSKrSSKJrJr SSKJr SSKJrJ r J r J r SSK J r SSKJrJr SSKJr SSKJr SS KJr SS KJr S rS rS rSr\R:"\5r"SS\5r "SS\5r!"SS\!5r""SS\"5r#"SS\"5r$"SS\"5r%"SS\5r&\&RNr(\&\)S'"SS\ 5r*"S S!\ 5r+g)"N)ABCabstractmethod)Enum)ListOptionalTupleUnion)Redis)DEFAULT_TIMEOUTAsyncHTTPClientWrapper) NoBackoff) HttpClient)UnhealthyDatabaseException)Retryg?ic,\rSrSr\S\4Sj5rSrg) HealthCheckreturnc # g7f)z(Function to determine the health status.N)selfdatabases [/home/james-whalen/.local/lib/python3.13/site-packages/redis/asyncio/multidb/healthcheck.py check_healthHealthCheck.check_health  rN)__name__ __module__ __qualname____firstlineno__rboolr__static_attributes__rrrrs d  r&rc~\rSrSrSr\\S\4Sj55r\\S\ 4Sj55r \S\ \ S\ 4Sj5rSrg ) HealthCheckPolicyz! Health checks execution policy. rcg)z*Number of probes to execute health checks.Nrrs rhealth_check_probes%HealthCheckPolicy.health_check_probes" r&cg)z"Delay between health check probes.Nrr+s rhealth_check_delay$HealthCheckPolicy.health_check_delay(r.r& health_checksc # g7f)z8Execute health checks and return database health status.Nrrr2rs rexecuteHealthCheckPolicy.execute.rrrN)r r!r"r#__doc__propertyrintr,floatr0rrr$r5r%rr&rr(r(st S   E   4 +< 4  r&r(cx\rSrSrS\S\4Sjr\S\4Sj5r\S\4Sj5r \ S\ \ S\ 4S j5rS rg ) AbstractHealthCheckPolicy4r,r0c>US:a [S5eXlX lg)Nz*health_check_probes must be greater than 0) ValueError_health_check_probes_health_check_delay)rr,r0s r__init__"AbstractHealthCheckPolicy.__init__5s"  "IJ J$7!#5 r&rcUR$N)rAr+s rr,-AbstractHealthCheckPolicy.health_check_probes;s(((r&cUR$rF)rBr+s rr0,AbstractHealthCheckPolicy.health_check_delay?s'''r&r2c # g7frFrr4s rr5!AbstractHealthCheckPolicy.executeCs r)rBrAN)r r!r"r#r9r:rCr8r,r0rrrr$r5r%rr&rr<r<4sr6C6U6 )S))(E(( 4 +< 4  r&r<cP^\rSrSrSrS\S\4U4SjjrS\\ S\ 4Sjr S r U=r $) HealthyAllPolicyHzE Policy that returns True if all health check probes are successful. r,r0c$>[TU]X5 grFsuperrCrr,r0 __class__s rrCHealthyAllPolicy.__init__M ,Ar&r2rcX# UH~n[UR5HbnURU5IShvN (d gX@RS- :dM:[ R "UR5IShvN Md M gNR![an[ SX%5eSnAff=fN-7f)NFUnhealthy databaser?Tranger,r ExceptionrasynciosleeprB)rr2r health_checkattemptes rr5HealthyAllPolicy.executePs)L !9!9:X!-!:!:8!DDD$E 5599!--(@(@AAA;*E X45I8WWXBsIB*B B B B*#B*:B(; B*B  B% B  B%%B*rr r!r"r#r7r9r:rCrrr$r5r% __classcell__rSs@rrMrMHs;BCBUB 4 +< 4  r&rMcP^\rSrSrSrS\S\4U4SjjrS\\ S\ 4Sjr S r U=r $) HealthyMajorityPolicy^zO Policy that returns True if a majority of health check probes are successful. r,r0c$>[TU]X5 grFrPrRs rrCHealthyMajorityPolicy.__init__crUr&r2rc# UHnURS-S:XaURS- nOURS-S- n[UR5HlnURU5IShvN (dUS-nUS::a gXPRS- :dMD[ R "UR5IShvN Mn M gN\![a!nUS-nUS::a [ SX&5eSnANmSnAff=fN=7f)Nrr?FrWT)r,rYrrZrr[r\rB)rr2rr]allowed_unsuccessful_probesr^r_s rr5HealthyMajorityPolicy.executefs)L''!+q0.2.F.F.J+/3/G/G!/Kq.P+ !9!9: !-!:!:8!DDD3q836!;#(5599!--(@(@AAA; **E!/14/2a780(8BsTAC9C *C+C ?C9#C99C7: C9C  C4C/*C9/C44C9rrarcs@rrere^s;BCBUB4 +<4r&recP^\rSrSrSrS\S\4U4SjjrS\\ S\ 4Sjr S r U=r $) HealthyAnyPolicyzL Policy that returns True if at least one health check probe is successful. r,r0c$>[TU]X5 grFrPrRs rrCHealthyAnyPolicy.__init__rUr&r2rc# SnUHnSn[UR5HenURU5IShvN (aSn OCSnX`RS- :dM=[ R "UR5IShvN Mg U(d U(dUs $U(aMU(dMUe U$Nz![an[ SX'5nSnANSnAff=fNW7f)NFTrWr?rX)rr2r is_healthyr] exceptionr^r_s rr5HealthyAnyPolicy.executes )LI !9!9: )66x@@@%) %* 5599!--(@(@AAA;i!!ZII+*.%A ! :,h!I Bsh"CB6B4 B6CB6 C#CCC%C.C4B66 C C CCCrrarcs@rrnrns;BCBUB4 +<4r&rnc \rSrSr\r\r\r Sr g)HealthCheckPoliciesrN) r r!r"r#rM HEALTHY_ALLreHEALTHY_MAJORITYrn HEALTHY_ANYr%rr&rrwrws"K,"Kr&rwDEFAULT_HEALTH_CHECK_POLICYc&\rSrSrSrS\4SjrSrg)PingHealthCheckz% Health check based on PING command. rc2# [UR[5(a#URRS5IShvN $URR 5nUH-nUR RS5IShvN (aM- g gNRN7f)NPINGFT) isinstanceclientr execute_command get_nodesredis_connection)rr all_nodesnodes rrPingHealthCheck.check_healthsz hoou - -!88@@ @!113I!!22BB6JJJ "A Ks*>BBABBBBBrN)r r!r"r#r7r$rr%rr&rr~r~s d r&r~c\rSrSrSrS\\SSSSSSSS4 S\S\S\S \ \ \ \ 4S \ S \ \ S \ \ S \ \ \ \4S\ \ S\ \ S\ \ 4SjjrS\ 4SjrSrg)LagAwareHealthCheckz 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_tolerancetimeout auth_basic verify_tlsca_fileca_pathca_dataclient_cert_fileclient_key_fileclient_key_passwordc |[[UU[[5SS9UUUUU U U S9 5UlXlX lg)a3 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) 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) rrretryrrrrrrrN)r rrr _http_client_rest_api_port_lag_aware_tolerance) rrrrrrrrrrrrs rrCLagAwareHealthCheck.__init__sO@3 %IK3%!1 /$7   ,$7!r&rc# URc [S5e[UR[5(aURR 5SnO#URR SRnURSUR3nX0RRl SnURRS5IShvN H3nUSH'nUSU:XaUn MUSH nXr:XdM Un M% M) M5 Uc [RS 5 [S 5eS US S UR3nURRUSS9IShvN gNN7f)Nz[Database health check url is not set. Please check DatabaseConfig for the current database.hostr: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_urlr@rrr get_connection_kwargs startup_nodesrrrbase_urlgetloggerwarningr) rrdb_hostr matching_bdbbdbendpointrurls rr LagAwareHealthCheck.check_healths{  $ $ ,m  hoou - -oo;;=fEGoo33A6;;G//0$2E2E1FG,4  ) **..z:::C ,J'72#&L%V,D'* - -;   NNU V<= = U+,-??C?X?X>Y [ ##CU#;;;/;( (04!%!%/3*.)--1/8/8!/8 /8 U38_- /8  /8#/8#/8%U +,/8#3-/8"#/8&c]/8b'd'r&r),r[loggingabcrrenumrtypingrrrr redis.asyncior redis.asyncio.http.http_clientr r redis.backoffr redis.http.http_clientrredis.multidb.exceptionr redis.retryrDEFAULT_HEALTH_CHECK_PROBESDEFAULT_HEALTH_CHECK_INTERVALDEFAULT_HEALTH_CHECK_DELAYr getLoggerr rrr(r<rMrernrwryr|__annotations__r~rrr&rrs#//R#-> ! "   8 $ #   . 1 (0,5B"0"J#$# 4G3R3R0Rk$^+^r&