ph"VSSKJrJr SSKJrJrJrJr SSKrSSK J r J r J r SSK JrJr SSKJrJrJrJr SSKJrJr SSKJrJrJrJrJrJrJr SS K J!r! SS K"J#r#J$r$ SS K%J&r& SS K'J(r(J)r) SS K*J+r+J,r,J-r- SSK.J/r/J0r0J1r1J2r2 Sr3S\)4Sjr4\"SS55r5\"SS55r6g)) dataclassfield)ListOptionalTypeUnionN)ConnectionPoolRedis RedisCluster)Database Databases)DEFAULT_FAILOVER_ATTEMPTSDEFAULT_FAILOVER_DELAYAsyncFailoverStrategyWeightBasedFailoverStrategy)AsyncFailureDetectorFailureDetectorAsyncWrapper)DEFAULT_HEALTH_CHECK_DELAYDEFAULT_HEALTH_CHECK_INTERVALDEFAULT_HEALTH_CHECK_POLICYDEFAULT_HEALTH_CHECK_PROBES HealthCheckHealthCheckPoliciesPingHealthCheck)Retry)ExponentialWithJitterBackoff NoBackoff) WeightedList)EventDispatcherEventDispatcherInterface)DEFAULT_GRACE_PERIODCircuitBreakerPBCircuitBreakerAdapter)DEFAULT_FAILURE_RATE_THRESHOLD!DEFAULT_FAILURES_DETECTION_WINDOWDEFAULT_MIN_NUM_FAILURESCommandFailureDetectorxreturnc[5$N)rV/home/james-whalen/.local/lib/python3.13/site-packages/redis/asyncio/multidb/config.pydefault_event_dispatcherr/.s  r-c\rSrSr%SrSr\\S'\"\ S9r \ \S'Sr \ \ \S'Sr\ \\S 'Sr\ \\S '\r\\S 'Sr\ \ \S 'S \4SjrSrg)DatabaseConfig2a 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) pybreakerr"r:r#)selfcircuit_breakers r.default_circuit_breaker&DatabaseConfig.default_circuit_breakerTs##22ARARS&77r-r,)__name__ __module__ __qualname____firstlineno____doc__r3float__annotations__rdictr6r7rstrr8r r9r"r!r:r;rA__static_attributes__r,r-r.r1r12ss0FE5M45"Hhsm"*.Ix'.(,GXn %,.L%.&*hsm*88r-r1c\rSrSr%Sr\\\S'\r \ \ \\ 4\S'\ "\"SSS9SS 9r\ \S 'S r\\\\S '\r\\S '\r\\S'\r\\S'S r\\\\S'\r\\S'\r \\S'\!r"\\S'\#r$\%\S'S r&\\'\S'\(r)\\S'\*r+\\S'\,r-\\S'\."\/S9r0\1\S'S\24Sjr3S\\4Sjr4S\\4Sjr5S\'4Sjr6S r7g )! MultiDbConfigYa 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. 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. 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_policyfailover_strategyfailover_attemptsfailover_delayauto_fallback_intervalr4event_dispatcherr)c [5nURGHSnURRS[ S[ 5S905 UR (a2URR "UR 40URD6nO|UR(aOURR[ S[ 5S95 URRURS9nOUR"S0URD6nURcUR5O URnUR[UUURURS9UR5 GMV U$)Nretryr)rXrW)connection_pool)clientr9r3r;r,)rrPr6updaterrr7rQr8 set_retryr9rAaddr r3r;)r? databasesdatabase_configrkr9s r.roMultiDbConfig.databasessP N #44O  ) ) 0 0%9;?@ ''**33#,,0?0M0M!**))33!Y[9**44$3$=$=5**K_-J-JK#**2 779$,,  MM!#*11%4%E%E   && 5 5Hr-ch[[URURURS95/$)N)r[r\failure_detection_window)rr'r[r\r]r?s r.default_failure_detectors'MultiDbConfig.default_failure_detectorss7 '&%)%:%:+/+F+F-1-K-K   r-c[5/$r+)rrts r.default_health_checks#MultiDbConfig.default_health_checkss    r-c[5$r+)rrts r.default_failover_strategy'MultiDbConfig.default_failover_strategys *,,r-r,)8rCrDrErFrGrr1rIr rQrrr rrrYrZrrr&r[intr$r\rHr%r]r^rrr_rr`rrarrbrrcrrrdrreDEFAULT_AUTO_FALLBACK_INTERVALrfrr/rgr r rorurxr{rLr,r-r.rNrNYsJ%N>**5:L$uUL012: ,! redis.asyncior r r redis.asyncio.multidb.databaser r redis.asyncio.multidb.failoverrrrr&redis.asyncio.multidb.failure_detectorrr!redis.asyncio.multidb.healthcheckrrrrrrrredis.asyncio.retryr redis.backoffrrredis.data_structurer redis.eventrr redis.multidb.circuitr!r"r#redis.multidb.failure_detectorr$r%r&r'r~r/r1rNr,r-r.rs(..==> &A-A "%": #8#8 #8L x-x- x-r-