o i %@sZddlmZmZddlmZddlmZmZmZm Z ddl Z ddl m Z m Z mZddlmZmZddlmZddlmZmZdd lmZdd lmZmZmZdd lmZmZdd l m!Z!m"Z"m#Z#m$Z$dd l%m&Z&m'Z'm(Z(m)Z)m*Z*ddl+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2ddl3m4Z4dZ5GdddeZ6defddZ7eGdddZ8eGdddZ9dS)) dataclassfield)Enum)ListOptionalTypeUnionN)ConnectionPoolRedis RedisCluster)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)DEFAULT_HEALTH_CHECK_DELAYDEFAULT_HEALTH_CHECK_INTERVALDEFAULT_HEALTH_CHECK_POLICYDEFAULT_HEALTH_CHECK_PROBES HealthCheckHealthCheckPoliciesPingHealthCheck)Retryxc@seZdZdZdZdZdS)InitialHealthCheckZ all_availableZmajority_availableZ one_availableN)__name__ __module__ __qualname__ ALL_AVAILABLEZMAJORITY_AVAILABLEZ ONE_AVAILABLEr.r.K/home/app/Keep/.python/lib/python3.10/site-packages/redis/multidb/config.pyr)-sr)returncCtSN)rr.r.r.r/default_event_dispatcher3r3c@seZdZUdZdZeed<eedZ eed<dZ e e ed<dZ e eed<dZe eed <eZeed <dZe e ed <d efd dZdS)DatabaseConfiga 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_urlr0cCstj|jd}t|S)N)Z reset_timeout) pybreakerrr=r)selfZcircuit_breakerr.r.r/default_circuit_breakerYsz&DatabaseConfig.default_circuit_breaker)r*r+r,__doc__r6float__annotations__rdictr9r:rstrr;r r<rrr=r>rAr.r.r.r/r57s   r5c@sbeZdZUdZeeed<eZe e ee fed<e e dddddZe ed <d Zeeeed <eZeed <eZeed <eZeed<d Zeeeed<eZeed<eZeed<e Z!eed<e"Z#e$ed<d Z%ee&ed<e'Z(eed<e)Z*eed<e+Z,eed<e-e.dZ/e0ed<e1j2Z3e1ed<de4fddZ5deefddZ6deefd d!Z7de&fd"d#Z8d S)$ MultiDbConfiga 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_probes_delay: Delay between health check attempts. 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_probes_delayhealth_check_policyfailover_strategyfailover_attemptsfailover_delayauto_fallback_intervalr7event_dispatcherinitial_health_check_policyr0c Cst}|jD]d}tdtd|jd<d|jvrtdd|jd<|jr/|jj|jfi|j}n |jrF|j tdtd|jj|jd}n |jd i|j}|j durX| n|j }| t |||j|jd|jq|S) Nr)rPrOretryZmaint_notifications_configF)enabled)Zconnection_pool)clientr<r6r>r.)rrHr'r r9rr:rIr;Z set_retryr<rAaddrr6r>)r@ databasesZdatabase_configrcr<r.r.r/resH     zMultiDbConfig.databasescCst|j|j|jdgS)N)rSrTZfailure_detection_window)rrSrTrUr@r.r.r/default_failure_detectorss z'MultiDbConfig.default_failure_detectorscCstgSr2)r&rfr.r.r/default_health_checkssz#MultiDbConfig.default_health_checkscCr1r2)rrfr.r.r/default_failover_strategyr4z'MultiDbConfig.default_failover_strategy)9r*r+r,rBrr5rDr rIrrr r'r rQrRrrrrSintrrTrCrrUrVr$r!rWr#rXr rYr"rZr%r[rrr\rr]DEFAULT_AUTO_FALLBACK_INTERVALr^rr3r_rr)r-r`rrergrhrir.r.r.r/rG^s8  *           0 rG): dataclassesrrenumrtypingrrrrr?Zredisr r r Z redis.backoffr r Zredis.data_structurerZ redis.eventrrZredis.maint_notificationsrZredis.multidb.circuitrrrZredis.multidb.databaserrZredis.multidb.failoverrrrrZredis.multidb.failure_detectorrrrrrZredis.multidb.healthcheckr r!r"r#r$r%r&Z redis.retryr'rkr)r3r5rGr.r.r.r/s,   $ &