File: //home/arjun/projects/env/lib/python3.10/site-packages/redis/__pycache__/backoff.cpython-310.pyc
o
$we� � @ s� d dl Z d dlmZmZ dZdZG dd� de�ZG dd� de�ZG d d
� d
e�ZG d d � d e�Z G d
d� de�Z
G dd� de�Z G dd� de�Z dd� Z
dS )� N)�ABC�abstractmethodg����Mb�?g����Mb�?c @ s$ e Zd ZdZdd� Zedd� �ZdS )�AbstractBackoffzBackoff interfacec C � dS )z�
Reset internal state before an operation.
`reset` is called once at the beginning of
every call to `Retry.call_with_retry`
N� ��selfr r �F/home/arjun/projects/env/lib/python3.10/site-packages/redis/backoff.py�reset
s zAbstractBackoff.resetc C r )z'Compute backoff in seconds upon failureNr �r �failuresr r r �compute s zAbstractBackoff.computeN)�__name__�
__module__� __qualname__�__doc__r
r r
r r r r r
s
r c @ s e Zd ZdZdd� Zdd� ZdS )�ConstantBackoffz Constant backoff upon failurec C s
|| _ dS )z"`backoff`: backoff time in secondsN��_backoff)r �backoffr r r �__init__ s
zConstantBackoff.__init__c C s | j S �Nr r r r r r
" � zConstantBackoff.computeN)r r r r r r
r r r r r s r c s e Zd ZdZ� fdd�Z� ZS )� NoBackoffzNo backoff upon failurec s t � �d� d S �Nr )�superr r �� __class__r r r ) s zNoBackoff.__init__)r r r r r �
__classcell__r r r r r & s r c @ �& e Zd ZdZeefdd�Zdd� ZdS )�ExponentialBackoffz Exponential backoff upon failurec C � || _ || _dS ��e
`cap`: maximum backoff time in seconds
`base`: base backoff time in seconds
N��_cap�_base�r �cap�baser r r r 0 �
zExponentialBackoff.__init__c C s t | j| jd| �S )N� )�minr% r& r r r r r
8 s zExponentialBackoff.computeN�r r r r � DEFAULT_CAP� DEFAULT_BASEr r
r r r r r - � r c @ r )�FullJitterBackoffz Full jitter backoff upon failurec C r! r" r$ r' r r r r ? r* zFullJitterBackoff.__init__c C s t �dt| j| jd| ��S )Nr r+ )�random�uniformr, r% r& r r r r r
G s zFullJitterBackoff.computeNr- r r r r r1 < r0 r1 c @ r )�EqualJitterBackoffz!Equal jitter backoff upon failurec C r! r" r$ r' r r r r N r* zEqualJitterBackoff.__init__c C s* t | j| jd| �d }|t�d|� S )Nr+ r )r, r% r& r2 r3 )r r �tempr r r r
V s zEqualJitterBackoff.computeNr- r r r r r4 K r0 r4 c @ s. e Zd ZdZeefdd�Zdd� Zdd� ZdS ) �DecorrelatedJitterBackoffz(Decorrelated jitter backoff upon failurec C s || _ || _d| _dS )r# r N)r% r& �_previous_backoffr' r r r r ^ s
z"DecorrelatedJitterBackoff.__init__c C s
d| _ d S r )r7 r r r r r
g s
z DecorrelatedJitterBackoff.resetc C s4 t | j| jd �}t�| j|�}t| j|�| _| jS )N� )�maxr& r7 r2 r3 r, r% )r r � max_backoffr5 r r r r
j s z!DecorrelatedJitterBackoff.computeN) r r r r r. r/ r r
r
r r r r r6 [ s
r6 c C s t � S r )r4 r r r r �default_backoffq r r; )r2 �abcr r r. r/ r r r r r1 r4 r6 r; r r r r �<module> s