ng\jL'SSKJrJr SSKJr SSKJrJrJrJ r SSK r SSK J r J r Jr SSKJrJrJr SSKJrJrJrJrJrJrJrJr SSKJrJr SS KJ r SS K!J"r"J#r# SS K$J%r% SS K&J'r'J(r(J)r) SS K*J+r+J,r, SSK-J.r.J/r/J0r0J1r1 SSK2J3r3J4r4J5r5J6r6J7r7 SSK8J9r9 Sr:"SS\5r;S\#4Sjr<\"SS55r=\"SS55r>g)) dataclassfield)Enum)ListOptionalTypeUnionN)ConnectionPoolRedis RedisCluster)DEFAULT_RETRY_BASEDEFAULT_RETRY_CAPDEFAULT_RETRY_COUNT)DEFAULT_HEALTH_CHECK_DELAYDEFAULT_HEALTH_CHECK_INTERVALDEFAULT_HEALTH_CHECK_POLICYDEFAULT_HEALTH_CHECK_PROBESDEFAULT_HEALTH_CHECK_TIMEOUT HealthCheckHealthCheckPoliciesPingHealthCheck)ExponentialWithJitterBackoff NoBackoff) WeightedList)EventDispatcherEventDispatcherInterface)MaintNotificationsConfig)DEFAULT_GRACE_PERIODCircuitBreakerPBCircuitBreakerAdapter)Database Databases)DEFAULT_FAILOVER_ATTEMPTSDEFAULT_FAILOVER_DELAYFailoverStrategyWeightBasedFailoverStrategy)DEFAULT_FAILURE_RATE_THRESHOLD!DEFAULT_FAILURES_DETECTION_WINDOWDEFAULT_MIN_NUM_FAILURESCommandFailureDetectorFailureDetector)Retryxc \rSrSrSrSrSrSrg)InitialHealthCheck/ all_availablemajority_available one_availableN)__name__ __module__ __qualname____firstlineno__ ALL_AVAILABLEMAJORITY_AVAILABLE ONE_AVAILABLE__static_attributes__r4O/home/edenadmin/noVNC/venv/lib/python3.13/site-packages/redis/multidb/config.pyr/r//s#M-#Mr=r/returnc[5$N)rr4r=r>default_event_dispatcherrB5s  r=c\rSrSr%SrSr\\S'\"\ S9r \ \S'Sr \ \ \S'Sr\ \\S 'Sr\ \\S '\r\\S 'Sr\ \ \S 'S \4SjrSrg)DatabaseConfig9a Dataclass representing the configuration for a database connection. This class is used to store configuration settings for a database connection, including client options, connection sourcing details, circuit breaker settings, and cluster-specific properties. It provides a structure for defining these attributes and allows for the creation of customized configurations for various database setups. Attributes: weight (float): Weight of the database to define the active one. client_kwargs (dict): Additional parameters for the database client connection. from_url (Optional[str]): Redis URL way of connecting to the database. from_pool (Optional[ConnectionPool]): A pre-configured connection pool to use. circuit (Optional[CircuitBreaker]): Custom circuit breaker implementation. grace_period (float): Grace period after which we need to check if the circuit could be closed again. health_check_url (Optional[str]): URL for health checks. Cluster FQDN is typically used on public Redis Enterprise endpoints. Methods: default_circuit_breaker: Generates and returns a default CircuitBreaker instance adapted for use. g?weightdefault_factory client_kwargsNfrom_url from_poolcircuit grace_periodhealth_check_urlr?cT[R"URS9n[U5$)N) reset_timeout) pybreakerrrMr )selfcircuit_breakers r>default_circuit_breaker&DatabaseConfig.default_circuit_breaker[s##22ARARS&77r=r4)r5r6r7r8__doc__rFfloat__annotations__rdictrIrJrstrrKr rLrrrMrNrTr<r4r=r>rDrD9ss0FE5M45"Hhsm"*.Ix'.(,GXn %,.L%.&*hsm*88r=rDc\rSrSr%Sr\\\S'\r \ \ \\ 4\S'\ "\"\\S9\S9r\ \S'Sr\\\\S '\r\\S '\r\\S '\r\\S 'Sr\\\\S '\ r!\\S'\"r#\\S'\$r%\\S'\&r'\\S'\(r)\*\S'Sr+\\,\S'\-r.\\S'\/r0\\S'\1r2\\S'\3"\4S9r5\6\S'\7Rpr9\7\S'S\:4Sjr;S\\4SjrSr?g) MultiDbConfig`a\ Configuration class for managing multiple database connections in a resilient and fail-safe manner. Attributes: databases_config: A list of database configurations. client_class: The client class used to manage database connections. command_retry: Retry strategy for executing database commands. failure_detectors: Optional list of additional failure detectors for monitoring database failures. min_num_failures: Minimal count of failures required for failover failure_rate_threshold: Percentage of failures required for failover failures_detection_window: Time interval for tracking database failures. health_checks: Optional list of additional health checks performed on databases. health_check_interval: Time interval for executing health checks. health_check_probes: Number of attempts to evaluate the health of a database. health_check_delay: Delay between health check attempts. health_check_timeout: Timeout for the full health check operation (including all probes). health_check_policy: Policy for determining database health based on health checks. failover_strategy: Optional strategy for handling database failover scenarios. failover_attempts: Number of retries allowed for failover operations. failover_delay: Delay between failover attempts. auto_fallback_interval: Time interval to trigger automatic fallback. event_dispatcher: Interface for dispatching events related to database operations. initial_health_check_policy: Defines the policy used to determine whether the databases setup is healthy during the initial health check. Methods: databases: Retrieves a collection of database clients managed by weighted configurations. Initializes database clients based on the provided configuration and removes redundant retry objects for lower-level clients to rely on global retry logic. default_failure_detectors: Returns the default list of failure detectors used to monitor database failures. default_health_checks: Returns the default list of health checks used to monitor database health with specific retry and backoff strategies. default_failover_strategy: Provides the default failover strategy used for handling failover scenarios with defined retry and backoff configurations. databases_config client_class)basecap)backoffretries command_retryNfailure_detectorsmin_num_failuresfailure_rate_thresholdfailures_detection_window health_checkshealth_check_intervalhealth_check_probeshealth_check_delayhealth_check_timeouthealth_check_policyfailover_strategyfailover_attemptsfailover_delayauto_fallback_intervalrGevent_dispatcherinitial_health_check_policyr?c [5nURGHkn[S[5S9URS'SUR;a[ SS9URS'UR (a2URR "UR 40URD6nO|UR(aOURR[S[5S95 URRURS9nOUR"S 0URD6nURcUR5O URnUR[UUURURS9UR5 GMn U$) Nr)rcrbretrymaint_notifications_configF)enabled)connection_pool)clientrLrFrNr4)rr^r,rrIrrJr_rK set_retryrLrTaddr!rFrN)rR databasesdatabase_configrzrLs r>r}MultiDbConfig.databasessq N #44O6;9;6O ) )' 2 ,?3P3PP,U; --.JK''**33#,,0?0M0M!**))33!Y[9**44$3$=$=5**K_-J-JK#**2 779$,,  MM!#*11%4%E%E   && C 5Vr=cV[URURURS9/$)N)rfrgfailure_detection_window)r*rfrgrhrRs r>default_failure_detectors'MultiDbConfig.default_failure_detectorss/ "!%!6!6'+'B'B)-)G)G   r=cV[URURURS9/$)N)rkrlrm)rrkrlrmrs r>default_health_checks#MultiDbConfig.default_health_checkss/ $($<$<#'#:#:%)%>%>   r=c[5$rA)r&rs r>default_failover_strategy'MultiDbConfig.default_failover_strategys *,,r=r4)@r5r6r7r8rVrrDrXr r_rr r r,rr rrrdrerr+r)rfintr'rgrWr(rhrirrrjrrkrrlrrmrrnrror%r#rpr$rqDEFAULT_AUTO_FALLBACK_INTERVALrrrrBrsrr/r9rtr"r}rrrr<r4r=r>r\r\`sn)V>**5:L$uUL012: ,#): $ M5 :>x_ 56=4c4$BEB'HuH15M8D-.5#@5@:: ::">%>/J,J48x 0186s62NE2$BEB1602.7I6V6V!3V.9.` 4+@  tK'8 -+;-r=r\)? dataclassesrrenumrtypingrrrr rQredisr r r redis._defaultsr rr!redis.asyncio.multidb.healthcheckrrrrrrrr redis.backoffrrredis.data_structurer redis.eventrrredis.maint_notificationsrredis.multidb.circuitrrr redis.multidb.databaser!r"redis.multidb.failoverr#r$r%r&redis.multidb.failure_detectorr'r(r)r*r+ redis.retryr,rr/rBrDr\r4r=r>rs(..55VV   B-A> 7 !$$$ ": #8#8 #8L J-J- J-r=