o
    <i&                     @   s^  d dl mZmZ d dlmZ d dlmZmZmZm	Z	 d dl
Z
d dlmZmZmZ d dlmZmZmZmZmZmZmZmZ d dlmZmZ d dlmZ d d	lmZmZ d d
l m!Z! d dl"m#Z#m$Z$m%Z% d dl&m'Z'm(Z( d dl)m*Z*m+Z+m,Z,m-Z- d dl.m/Z/m0Z0m1Z1m2Z2m3Z3 d dl4m5Z5 dZ6G dd deZ7defddZ8eG dd dZ9eG dd dZ:dS )    )	dataclassfield)Enum)ListOptionalTypeUnionN)ConnectionPoolRedisRedisCluster)DEFAULT_HEALTH_CHECK_DELAYDEFAULT_HEALTH_CHECK_INTERVALDEFAULT_HEALTH_CHECK_POLICYDEFAULT_HEALTH_CHECK_PROBESDEFAULT_HEALTH_CHECK_TIMEOUTHealthCheckHealthCheckPoliciesPingHealthCheck)ExponentialWithJitterBackoff	NoBackoff)WeightedList)EventDispatcherEventDispatcherInterface)MaintNotificationsConfig)DEFAULT_GRACE_PERIODCircuitBreakerPBCircuitBreakerAdapter)Database	Databases)DEFAULT_FAILOVER_ATTEMPTSDEFAULT_FAILOVER_DELAYFailoverStrategyWeightBasedFailoverStrategy)DEFAULT_FAILURE_RATE_THRESHOLD!DEFAULT_FAILURES_DETECTION_WINDOWDEFAULT_MIN_NUM_FAILURESCommandFailureDetectorFailureDetector)Retryx   c                   @   s   e Zd ZdZdZdZdS )InitialHealthCheckall_availablemajority_availableone_availableN)__name__
__module____qualname__ALL_AVAILABLEMAJORITY_AVAILABLEONE_AVAILABLE r4   r4   S/root/parts/websockify/install/lib/python3.10/site-packages/redis/multidb/config.pyr*   .   s    r*   returnc                   C      t  S N)r   r4   r4   r4   r5   default_event_dispatcher4      r9   c                   @   s   e Zd ZU dZdZeed< eedZ	eed< dZ
ee ed< dZee ed< dZee ed	< eZeed
< dZee ed< defddZdS )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      ?weightdefault_factoryclient_kwargsNfrom_url	from_poolcircuitgrace_periodhealth_check_urlr6   c                 C   s   t j| jd}t|S )N)reset_timeout)	pybreakerr   rC   r   )selfcircuit_breakerr4   r4   r5   default_circuit_breakerZ   s   z&DatabaseConfig.default_circuit_breaker)r.   r/   r0   __doc__r<   float__annotations__r   dictr?   r@   r   strrA   r	   rB   r   r   rC   rD   rI   r4   r4   r4   r5   r;   8   s   
 r;   c                   @   sn  e Zd ZU dZee ed< eZe	e
eef  ed< eedddddZeed	< d
Zeee  ed< eZeed< eZeed< eZeed< d
Zeee  ed< eZeed< eZeed< e Z!eed< e"Z#eed< e$Z%e&ed< d
Z'ee( ed< e)Z*eed< e+Z,eed< e-Z.eed< e/e0dZ1e2ed< e3j4Z5e3ed< de6fddZ7dee fdd Z8dee fd!d"Z9de(fd#d$Z:d
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_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   
   )basecap   )backoffretriescommand_retryNfailure_detectorsmin_num_failuresfailure_rate_thresholdfailures_detection_windowhealth_checkshealth_check_intervalhealth_check_probeshealth_check_delayhealth_check_timeouthealth_check_policyfailover_strategyfailover_attemptsfailover_delayauto_fallback_intervalr=   event_dispatcherinitial_health_check_policyr6   c              	   C   s   t  }| jD ]d}tdt d|jd< d|jvrtdd|jd< |jr/| jj|jfi |j}n |jrF|j	tdt d | jj|jd}n	| jd	i |j}|j
d u rX| n|j
}|t|||j|jd|j q|S )
Nr   )rX   rW   retrymaint_notifications_configF)enabled)connection_pool)clientrB   r<   rD   r4   )r   rP   r(   r   r?   r   r@   rQ   rA   	set_retryrB   rI   addr   r<   rD   )rG   	databasesdatabase_configrn   rB   r4   r4   r5   rq      sH   



zMultiDbConfig.databasesc                 C      t | j| j| jdgS )N)r[   r\   failure_detection_window)r&   r[   r\   r]   rG   r4   r4   r5   default_failure_detectors      z'MultiDbConfig.default_failure_detectorsc                 C   rs   )N)r`   ra   rb   )r   r`   ra   rb   ru   r4   r4   r5   default_health_checks   rw   z#MultiDbConfig.default_health_checksc                 C   r7   r8   )r"   ru   r4   r4   r5   default_failover_strategy   r:   z'MultiDbConfig.default_failover_strategy);r.   r/   r0   rJ   r   r;   rL   r
   rQ   r   r   r   r(   r   rY   rZ   r   r'   r%   r[   intr#   r\   rK   r$   r]   r^   r   r   r_   r   r`   r   ra   r   rb   r   rc   r   rd   r!   r   re   r    rf   DEFAULT_AUTO_FALLBACK_INTERVALrg   r   r9   rh   r   r*   r1   ri   r   rq   rv   rx   ry   r4   r4   r4   r5   rO   _   s:   
 +0		rO   );dataclassesr   r   enumr   typingr   r   r   r   rF   redisr	   r
   r   !redis.asyncio.multidb.healthcheckr   r   r   r   r   r   r   r   redis.backoffr   r   redis.data_structurer   redis.eventr   r   redis.maint_notificationsr   redis.multidb.circuitr   r   r   redis.multidb.databaser   r   redis.multidb.failoverr   r    r!   r"   redis.multidb.failure_detectorr#   r$   r%   r&   r'   redis.retryr(   r{   r*   r9   r;   rO   r4   r4   r4   r5   <module>   s,    (
&