�
J�gi � �� � d dl Z d dlmZmZ dZdZ 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 G d� de� � Z d� Z
dS )� N)�ABC�abstractmethodg����Mb�?g����Mb�?c �8 � e Zd ZdZd� Zededefd�� � 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 �]/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/redis/backoff.py�resetzAbstractBackoff.reset
s � �
�� �failures�returnc � � dS )z'Compute backoff in seconds upon failureNr �r
r s r �computezAbstractBackoff.compute s � �
�r
N) �__name__�
__module__� __qualname__�__doc__r r �int�floatr r r
r r r
sW � � � � � ���
�
�
� �
��
��
�
�
� �^�
�
�
r
r c �2 � e Zd ZdZdeddfd�Zdedefd�ZdS )�ConstantBackoffz Constant backoff upon failure�backoffr Nc � � || _ dS )z"`backoff`: backoff time in secondsN��_backoff)r
r s r �__init__zConstantBackoff.__init__ s
� � ��
�
�
r
r c � � | j S �Nr r s r r zConstantBackoff.compute" s
� ��}� r
)r r r r r r r r r r
r r r s^ � � � � � �'�'� �� �$� � � � � �� �� � � � � � r
r c �$ � � e Zd ZdZd� fd� Z� xZS )� NoBackoffzNo backoff upon failurer Nc �J �� t � � � d� � d S �Nr )�superr )r
� __class__s �r r zNoBackoff.__init__) s! �� �
����������r
�r N)r r r r r �
__classcell__)r' s @r r# r# & sC �� � � � � �!�!� � � � � � � � � � r
r# c �8 � e Zd ZdZeefdedefd�Zdedefd�Z dS ) �ExponentialBackoffz Exponential backoff upon failure�cap�basec �" � || _ || _ dS ��e
`cap`: maximum backoff time in seconds
`base`: base backoff time in seconds
N��_cap�_base�r
r, r- s r r zExponentialBackoff.__init__0 � � �
�� ���
�
�
r
r r c �B � t | j | j d|z z � � S )N� )�minr2 r3 r s r r zExponentialBackoff.compute8 s � ��4�9�d�j�1�h�;� 6�7�7�7r
N�
r r r r � DEFAULT_CAP� DEFAULT_BASEr r r r r r
r r+ r+ - sh � � � � � �*�*�$/�|� � �E� �u� � � � �8�� 8�� 8� 8� 8� 8� 8� 8r
r+ c �< � e Zd ZdZeefdededdfd�Zdedefd�Z dS ) �FullJitterBackoffz Full jitter backoff upon failurer, r- r Nc �" � || _ || _ dS r/ r1 r4 s r r zFullJitterBackoff.__init__? r5 r
r c �h � t j dt | j | j d|z z � � � � S )Nr r7 )�random�uniformr8 r2 r3 r s r r zFullJitterBackoff.computeG s+ � ��~�a��T�Y��
�Q��[�0H�!I�!I�J�J�Jr
r9 r r
r r= r= < sx � � � � � �*�*�$/�|� � �E� �u� �PT� � � � �K�� K�� K� K� K� K� K� Kr
r= c �< � e Zd ZdZeefdededdfd�Zdedefd�Z dS ) �EqualJitterBackoffz!Equal jitter backoff upon failurer, r- r Nc �" � || _ || _ dS r/ r1 r4 s r r zEqualJitterBackoff.__init__N r5 r
r c �x � t | j | j d|z z � � dz }|t j d|� � z S )Nr7 r )r8 r2 r3 r@ rA )r
r �temps r r zEqualJitterBackoff.computeV s: � ��4�9�d�j�1�h�;� 6�7�7�!�;���f�n�Q��-�-�-�-r
r9 r r
r rC rC K sp � � � � � �+�+�$/�|� � �E� �u� �PT� � � � �.�� .�� .� .� .� .� .� .r
rC c �D � e Zd ZdZeefdededdfd�Zd
d�Zde defd �Z
dS ) �DecorrelatedJitterBackoffz(Decorrelated jitter backoff upon failurer, r- r Nc �0 � || _ || _ d| _ dS )r0 r N)r2 r3 �_previous_backoffr4 s r r z"DecorrelatedJitterBackoff.__init__^ s � �
�� ���
�!"�� � � r
c � � d| _ d S r% )rJ r s r r z DecorrelatedJitterBackoff.resetg s � �!"�� � � r
r c � � t | j | j dz � � }t j | j |� � }t | j |� � | _ | j S )N� )�maxr3 rJ r@ rA r8 r2 )r
r � max_backoffrF s r r z!DecorrelatedJitterBackoff.computej sK � ��$�*�d�&<�q�&@�A�A� ��~�d�j�+�6�6��!$�T�Y��!5�!5�� ��%�%r
r( ) r r r r r: r; r r r r r r r
r rH rH [ s� � � � � � �2�2�$/�|� #� #�E� #�u� #�PT� #� #� #� #�#� #� #� #�&�� &�� &� &� &� &� &� &r
rH c � � t � � S r! )rC r r
r �default_backoffrQ q s � � � � � r
)r@ �abcr r r: r; r r r# r+ r= rC rH rQ r r
r �<module>rS sy ��
�
�
�
� #� #� #� #� #� #� #� #� � �� �
�
�
�
�
�c�
�
�
�" � � � � �o� � � � � � � � �� � � � 8� 8� 8� 8� 8� � 8� 8� 8� K� K� K� K� K�� K� K� K�
.�
.�
.�
.�
.� �
.�
.�
.� &� &� &� &� &�� &� &� &�, � � � � r