Dashboard
PHP:
8.3.33
OS:
Linux
User:
letter7
/
/
usr
/
lib
/
mysqlsh
/
lib
/
python3.8
/
site-packages
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: circuitbreaker.cpython-38.pyc
U �:�e�( � @ s< d dl mZ d dl mZ d dl mZ d dl mZ d dlmZ d dlmZmZ d dl m Z m Z d dl m Z mZ d d lmZmZ zd d lmZ W n ek r� d d lmZ Y nX z efZW n ek r� eefZY nX d Zd Zd Z dd� Z dd� Z G dd� de �Z G dd� de!�Z"G dd� de �Z#ddddde fdd�Z$dS )� )�unicode_literals)�division)�print_function)�absolute_import)�wraps)�datetime� timedelta)�isgeneratorfunction�isclass)�AnyStr�Iterable)�ceil�floor)� monotonic�closed�openZ half_openc s � fdd�}|S )zOBuild a predicate function that checks if an exception is a subtype from a listc s t | � �S �N)� issubclass)Z thrown_type�_�� exc_types� �A/usr/local/python38/lib/python3.8/site-packages/circuitbreaker.py� matches_types s z(in_exception_list.<locals>.matches_typesr )r r r r r �in_exception_list s r c C sx t | �r t| t�r t| �}nXz&t| � t| t�r8td��t| � }W n0 tk rr t | �rbt | �rjtd��| }Y nX |S )az Build a failure predicate_function. The returned function has the signature (Type[Exception], Exception) -> bool. Return value True indicates a failure in the underlying function. :param expected_exception: either an type of Exception, iterable of Exception types, or a predicate function. If an Exception type or iterable of Exception types, the failure predicate will return True when a thrown exception type matches one of the provided types. If a predicate function, it will just be returned as is. :return: callable (Type[Exception], Exception) -> bool z9expected_exception cannot be a string. Did you mean name?z1expected_exception does not look like a predicate) r r � Exceptionr �iter� isinstance� STRING_TYPES� ValueError� TypeError�callable)�expected_exceptionZfailure_predicater r r �build_failure_predicate& s r# c @ s� e Zd ZdZdZeZdZd*dd�Zdd� Z dd � Z d d � Z d d � Z dd� Z dd� Zdd� Zdd� Zedd� �Zedd� �Zedd� �Zed d � �Zed d � �Zed d!� �Zed"d#� �Zed$d%� �Zed&d'� �Zd(d)� ZdS )+�CircuitBreaker� � Nc C s� d| _ d| _|p| j| _|p | j| _|sVzt| �jd }W n tk rT t j }Y nX t |�| _ |ph| j | _|| _t| _t� | _dS )a� Construct a circuit breaker. :param failure_threshold: break open after this many failures :param recovery_timeout: close after this many seconds :param expected_exception: either an type of Exception, iterable of Exception types, or a predicate function. :param name: name for this circuitbreaker :param fallback_function: called when the circuit is opened :return: Circuitbreaker instance :rtype: Circuitbreaker Nr �EXPECTED_EXCEPTION)� _last_failure�_failure_count�FAILURE_THRESHOLD�_failure_threshold�RECOVERY_TIMEOUT�_recovery_timeout�type�__dict__�KeyErrorr$ r' r# � is_failure�FALLBACK_FUNCTION�_fallback_function�_name� STATE_CLOSED�_stater �_opened)�self�failure_threshold�recovery_timeoutr" �name�fallback_functionr r r �__init__N s zCircuitBreaker.__init__c C s | � |�S r )�decorate)r8 �wrappedr r r �__call__y s zCircuitBreaker.__call__c C s d S r r �r8 r r r � __enter__| s zCircuitBreaker.__enter__c C s, |r | � ||�r || _| �� n| �� dS )NF)r1 r( � _CircuitBreaker__call_failed� _CircuitBreaker__call_succeeded)r8 �exc_type� exc_valueZ _tracebackr r r �__exit__ s zCircuitBreaker.__exit__c sp �j dkr4z �j�_ W n tk r2 �j�_ Y nX t��� t��rN�j� n�j� t ��� ��fdd��}|S )z; Applies the circuit breaker to a function Nc s0 �j r �jr�j| |�S t���� �f| �|�S r )�openedr< �CircuitBreakerError)�args�kwargs��call�functionr8 r r �wrapper� s z(CircuitBreaker.decorate.<locals>.wrapper) r4 � __qualname__�AttributeError�__name__�CircuitBreakerMonitor�registerr �call_generatorrM r )r8 rN rO r rL r r> � s zCircuitBreaker.decoratec O s& | � |||�W 5 Q R � S Q R X dS )z� Calls the decorated function and applies the circuit breaker rules on success or failure :param func: Decorated function Nr )r8 �funcrJ rK r r r rM � s zCircuitBreaker.callc o s* | � |||�D ] }|V qW 5 Q R X dS )z� Calls the decorated generator function and applies the circuit breaker rules on success or failure :param func: Decorated generator function Nr )r8 rV rJ rK �elr r r rU � s z CircuitBreaker.call_generatorc C s t | _d| _d| _dS )zR Close circuit after successful execution and reset failure count Nr )r5 r6 r( r) rA r r r Z__call_succeeded� s z CircuitBreaker.__call_succeededc C s, | j d7 _ | j | jkr(t| _t� | _dS )zO Count failure and open circuit, if threshold has been reached � N)r) r+ � STATE_OPENr6 r r7 rA r r r Z __call_failed� s z CircuitBreaker.__call_failedc C s | j tkr| jdkrtS | j S �Nr )r6 rY �open_remaining�STATE_HALF_OPENrA r r r �state� s zCircuitBreaker.statec C s t �� t| jd� S )zq The approximate datetime when the circuit breaker will try to recover :return: datetime )�seconds)r �utcnowr r[ rA r r r � open_until� s zCircuitBreaker.open_untilc C s* | j | j t� }|dkr"t|�S t|�S )zk Number of seconds remaining, the circuit breaker stays in OPEN state :return: int r )r7 r- r r r )r8 Zremainr r r r[ � s z CircuitBreaker.open_remainingc C s | j S r )r) rA r r r � failure_count� s z CircuitBreaker.failure_countc C s | j tkS r )r] r5 rA r r r r � s zCircuitBreaker.closedc C s | j tkS r )r] rY rA r r r rH � s zCircuitBreaker.openedc C s | j S r �r4 rA r r r r; � s zCircuitBreaker.namec C s | j S r )r( rA r r r � last_failure� s zCircuitBreaker.last_failurec C s | j S r )r3 rA r r r r< � s z CircuitBreaker.fallback_functionc O s | j S r rb �r8 rJ rK r r r �__str__� s zCircuitBreaker.__str__)NNNNN) rR � __module__rP r* r, r r' r2 r= r@ rB rG r> rM rU rD rC �propertyr] r` r[ ra r rH r; rc r< re r r r r r$ H sJ � + r$ c s$ e Zd Z� fdd�Zdd� Z� ZS )rI c s t t| �j||� || _dS )zf :param circuit_breaker: :param args: :param kwargs: :return: N)�superrI r= �_circuit_breaker)r8 �circuit_breakerrJ rK �� __class__r r r= � s z CircuitBreakerError.__init__c O s* d| j j| j j| j jt| j j�| j jf S )NzMCircuit "%s" OPEN until %s (%d failures, %d sec remaining) (last_failure: %r))ri r; r` ra �roundr[ rc rd r r r re s �zCircuitBreakerError.__str__)rR rf rP r= re � __classcell__r r rk r rI � s rI c @ sX e Zd Zi Zedd� �Zedd� �Zedd� �Zedd� �Zed d � �Z ed d � �Z d S )rS c C s || j |j< d S r )�circuit_breakersr; )�clsrj r r r rT s z CircuitBreakerMonitor.registerc C s t t| �� ��dkS rZ )�len�list�get_open�rp r r r � all_closed s z CircuitBreakerMonitor.all_closedc C s | j �� S r )ro �valuesrt r r r � get_circuits s z"CircuitBreakerMonitor.get_circuitsc C s | j �|�S r )ro �get)rp r; r r r rx s zCircuitBreakerMonitor.getc c s | � � D ]}|jr|V qd S r )rw rH �rp �circuitr r r rs % s z CircuitBreakerMonitor.get_openc c s | � � D ]}|jr|V qd S r )rw r ry r r r � get_closed, s z CircuitBreakerMonitor.get_closedN) rR rf rP ro � classmethodrT ru rw rx rs r{ r r r r rS s rS Nc C s* t | �r|� �| �S || ||||d�S d S )N)r9 r: r" r; r< )r! r> )r9 r: r" r; r< rp r r r rz 4 s �rz )%� __future__r r r r � functoolsr r r �inspectr r �typingr r �mathr r �timer � ImportError� basestringr � NameError�bytes�strr5 rY r\ r r# �objectr$ r rI rS rz r r r r �<module> s@ " 3%�
Save
Cancel