File: //opt/alt/python311/lib/python3.11/site-packages/redis/__pycache__/backoff.cpython-311.pyc
�
$�;fu
� �� � d dl Z d dlmZmZ G d� de� � Z G d� de� � Z G d� de� � Z G d � d
e� � Z G d � d e� � Z G d
� de� � Z G d� de� � Z
dS )� N)�ABC�abstractmethodc �. � e Zd ZdZd� Zed� � � ZdS )�AbstractBackoffzBackoff interfacec � � dS )z�
Reset internal state before an operation.
`reset` is called once at the beginning of
every call to `Retry.call_with_retry`
N� ��selfs �@/opt/alt/python311/lib/python3.11/site-packages/redis/backoff.py�resetzAbstractBackoff.reset s � �
�� c � � dS )z'Compute backoff in seconds upon failureNr �r
�failuress r �computezAbstractBackoff.compute s � �
�r
N)�__name__�
__module__� __qualname__�__doc__r r r r r
r r r sD � � � � � ���
�
�
� �
�
� �^�
�
�
r
r c � � e Zd ZdZd� Zd� ZdS )�ConstantBackoffz Constant backoff upon failurec � � || _ dS )z"`backoff`: backoff time in secondsN��_backoff)r
�backoffs r �__init__zConstantBackoff.__init__ s
� � ��
�
�
r
c � � | j S )Nr r s r r zConstantBackoff.compute s
� ��}� r
N�r r r r r r r r
r r r s8 � � � � � �'�'� � � � � � � � r
r c �" � � e Zd ZdZ� fd�Z� xZS )� NoBackoffzNo backoff upon failurec �J �� t � � � d� � d S �Nr )�superr )r
� __class__s �r r zNoBackoff.__init__$ s! �� �
����������r
)r r r r r �
__classcell__)r$ s @r r r ! s> �� � � � � �!�!� � � � � � � � � r
r c � � e Zd ZdZd� Zd� ZdS )�ExponentialBackoffz Exponential backoff upon failurec �" � || _ || _ dS ��e
`cap`: maximum backoff time in seconds
`base`: base backoff time in seconds
N��_cap�_base�r
�cap�bases r r zExponentialBackoff.__init__+ � � �
�� ���
�
�
r
c �B � t | j | j d|z z � � S )N� )�minr, r- r s r r zExponentialBackoff.compute3 s � ��4�9�d�j�1��=� 8�9�9�9r
Nr r r
r r' r' ( s8 � � � � � �*�*�� � �:� :� :� :� :r
r' c � � e Zd ZdZd� Zd� ZdS )�FullJitterBackoffz Full jitter backoff upon failurec �" � || _ || _ dS r) r+ r. s r r zFullJitterBackoff.__init__: r1 r
c �h � t j dt | j | j d|z z � � � � S )Nr r3 )�random�uniformr4 r, r- r s r r zFullJitterBackoff.computeB s+ � ��~�a��T�Y��
�Q�(�]�0J�!K�!K�L�L�Lr
Nr r r
r r6 r6 7 s= � � � � � �*�*�� � �M� M� M� M� Mr
r6 c � � e Zd ZdZd� Zd� ZdS )�EqualJitterBackoffz!Equal jitter backoff upon failurec �" � || _ || _ dS r) r+ r. s r r zEqualJitterBackoff.__init__I r1 r
c �x � t | j | j d|z z � � dz }|t j d|� � z S )Nr3 r )r4 r, r- r9 r: )r
r �temps r r zEqualJitterBackoff.computeQ s: � ��4�9�d�j�1��=� 8�9�9�A�=���f�n�Q��-�-�-�-r
Nr r r
r r< r< F s8 � � � � � �+�+�� � �.� .� .� .� .r
r< c �$ � e Zd ZdZd� Zd� Zd� ZdS )�DecorrelatedJitterBackoffz(Decorrelated jitter backoff upon failurec �0 � || _ || _ d| _ dS )r* r N)r, r- �_previous_backoffr. s r r z"DecorrelatedJitterBackoff.__init__Y s � �
�� ���
�!"�� � � r
c � � d| _ d S r" )rC r s r r z DecorrelatedJitterBackoff.resetb s � �!"�� � � r
c � � t | j | j dz � � }t j | j |� � }t | j |� � | _ | j S )N� )�maxr- rC r9 r: r4 r, )r
r � max_backoffr? s r r z!DecorrelatedJitterBackoff.computee sK � ��$�*�d�&<�q�&@�A�A� ��~�d�j�+�6�6��!$�T�Y��!5�!5�� ��%�%r
N)r r r r r r r r r
r rA rA V sG � � � � � �2�2�#� #� #�#� #� #�&� &� &� &� &r
rA ) r9 �abcr r r r r r' r6 r< rA r r
r �<module>rJ s^ ��
�
�
�
� #� #� #� #� #� #� #� #�
�
�
�
�
�c�
�
�
�" � � � � �o� � � � � � � � �� � � � :� :� :� :� :� � :� :� :� M� M� M� M� M�� M� M� M�
.�
.�
.�
.�
.� �
.�
.�
.� &� &� &� &� &�� &� &� &� &� &r