o LjL'@srddlmZmZddlmZddlmZmZmZm Z ddl Z ddl m Z m Z mZddlmZmZmZddlmZmZmZmZmZmZmZmZddlmZmZdd lm Z dd l!m"Z"m#Z#dd l$m%Z%dd l&m'Z'm(Z(m)Z)dd l*m+Z+m,Z,ddl-m.Z.m/Z/m0Z0m1Z1ddl2m3Z3m4Z4m5Z5m6Z6m7Z7ddl8m9Z9dZ:GdddeZ;de#fddZdS)) 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@seZdZdZdZdZdS)InitialHealthCheck all_availablemajority_available one_availableN)__name__ __module__ __qualname__ ALL_AVAILABLEMAJORITY_AVAILABLE ONE_AVAILABLEr7r7R/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/redis/multidb/config.pyr-/sr-returncCtSN)rr7r7r7r8default_event_dispatcher5r<c@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_urlr9cCstj|jd}t|S)N) reset_timeout) pybreakerrrFr)selfcircuit_breakerr7r7r8default_circuit_breaker[sz&DatabaseConfig.default_circuit_breaker)r1r2r3__doc__r?float__annotations__rdictrBrCrstrrDr rErrrFrGrLr7r7r7r8r>9s   r>c@sneZdZUdZeeed<eZe e ee fed<e e eededZe ed<dZeeeed<eZeed <eZeed <eZeed <dZeeeed <eZ eed <e!Z"eed<e#Z$eed<e%Z&eed<e'Z(e)ed<dZ*ee+ed<e,Z-eed<e.Z/eed<e0Z1eed<e2e3dZ4e5ed<e6j7Z8e6ed<de9fddZ:deefddZ;deefddZr1r2r3rMrr>rOr rTrrr r+rr r rrYrZrr*r(r[intr&r\rNr'r]r^rrr_rr`rrarrbrrcrrdr$r"rer#rfDEFAULT_AUTO_FALLBACK_INTERVALrgrr<rhrr-r4rir!rqrvrxryr7r7r7r8rR`s@  +           0  rR)? dataclassesrrenumrtypingrrrrrIredisr r r redis._defaultsr r r!redis.asyncio.multidb.healthcheckrrrrrrrr redis.backoffrrredis.data_structurer redis.eventrrredis.maint_notificationsrredis.multidb.circuitrrrredis.multidb.databaser r!redis.multidb.failoverr"r#r$r%redis.multidb.failure_detectorr&r'r(r)r* redis.retryr+r{r-r<r>rRr7r7r7r8s. (   &