o Ljf&@srddlmZmZddlmZddlmZmZmZm Z ddl Z ddl m Z m Z mZddlmZmZmZddlmZmZddlmZmZmZmZdd lmZmZdd lmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&dd l'm(Z(dd l)m*Z*m+Z+dd l,m-Z-ddl.m/Z/m0Z0ddl1m2Z2m3Z3m4Z4ddl5m6Z6m7Z7m8Z8m9Z9dZ:GdddeZ;de0fddZdS)) dataclassfield)Enum)ListOptionalTypeUnionN)DEFAULT_RETRY_BASEDEFAULT_RETRY_CAPDEFAULT_RETRY_COUNT)ConnectionPoolRedis RedisCluster)Database Databases)DEFAULT_FAILOVER_ATTEMPTSDEFAULT_FAILOVER_DELAYAsyncFailoverStrategyWeightBasedFailoverStrategy)AsyncFailureDetectorFailureDetectorAsyncWrapper)DEFAULT_HEALTH_CHECK_DELAYDEFAULT_HEALTH_CHECK_INTERVALDEFAULT_HEALTH_CHECK_POLICYDEFAULT_HEALTH_CHECK_PROBESDEFAULT_HEALTH_CHECK_TIMEOUT HealthCheckHealthCheckPoliciesPingHealthCheck)Retry)ExponentialWithJitterBackoff NoBackoff) WeightedList)EventDispatcherEventDispatcherInterface)DEFAULT_GRACE_PERIODCircuitBreakerPBCircuitBreakerAdapter)DEFAULT_FAILURE_RATE_THRESHOLD!DEFAULT_FAILURES_DETECTION_WINDOWDEFAULT_MIN_NUM_FAILURESCommandFailureDetectorxc@seZdZdZdZdZdS)InitialHealthCheck all_availablemajority_available one_availableN)__name__ __module__ __qualname__ ALL_AVAILABLEMAJORITY_AVAILABLE ONE_AVAILABLEr7r7Z/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/redis/asyncio/multidb/config.pyr-1sr-returncCtSN)r#r7r7r7r8default_event_dispatcher7r<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) pybreakerr&rFr')selfcircuit_breakerr7r7r8default_circuit_breaker]sz&DatabaseConfig.default_circuit_breaker)r1r2r3__doc__r?float__annotations__rdictrBrCrstrrDr rEr&r%rFrGrLr7r7r7r8r>;s   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 rTrrrrr r r r rYrZrrr*r[intr(r\rNr)r]r^rrr_rr`rrarrbrrcrrdrrrerrfDEFAULT_AUTO_FALLBACK_INTERVALrgrr<rhr$r-r4rirrprtrurvr7r7r7r8rRbs@  +           )  rR)? dataclassesrrenumrtypingrrrrrIredis._defaultsr r r redis.asyncior r rredis.asyncio.multidb.databaserrredis.asyncio.multidb.failoverrrrr&redis.asyncio.multidb.failure_detectorrr!redis.asyncio.multidb.healthcheckrrrrrrrrredis.asyncio.retryr redis.backoffr r!redis.data_structurer" redis.eventr#r$redis.multidb.circuitr%r&r'redis.multidb.failure_detectorr(r)r*r+rxr-r<r>rRr7r7r7r8s. (  &