Ë
|
|
çúh¥ ã óÚ 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 G d de« Z d Zy)é N)ÚABCÚabstractmethodgü©ñÒMbà?gü©ñÒMb?c ó0 e Zd ZdZd Zededefd« Zy)ÚAbstractBackoffzBackoff interfacec ó y)z
|
Reset internal state before an operation.
|
`reset` is called once at the beginning of
|
every call to `Retry.call_with_retry`
|
N© ©Úselfs õ` H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/backoff.pyÚresetzAbstractBackoff.reset s ð ó ÚfailuresÚreturnc ó y)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
|
s, Ùò ð ð ð ¨ò ó ñ r r c óH e Zd ZdZdeddfdZdefdZdefdZ dedefd Z
|
y)
|
ÚConstantBackoffz Constant backoff upon failureÚbackoffr Nc ó || _ y)z"`backoff`: backoff time in secondsN©Ú_backoff)r
|
r s r Ú__init__zConstantBackoff.__init__ s à r c ó. t | j f« S ©N)Úhashr r s r Ú__hash__zConstantBackoff.__hash__" s ÜT]]Ð$Ó%Ð%r c ó` t |t « st S | j |j k( S r! )Ú
|
isinstancer ÚNotImplementedr ©r
|
Úothers r Ú__eq__zConstantBackoff.__eq__% s% Ü%¤ Ô1Ü!Ð !à}} §¡Ñ.Ð.r r c ó | j S r! r r s r r zConstantBackoff.compute+ s Ø}}Ð r ) r r r r r r r r# Úboolr) r r r r r r sC Ù'ð ð ¨$ó ð&#ó &ð/tó /ð ð ¨ô r r c ó$ e Zd ZdZd fd Z xZS )Ú NoBackoffzNo backoff upon failurec ó$ t | d« y ©Nr )Úsuperr )r
|
Ú __class__s r r zNoBackoff.__init__2 s ø Ü ÑÕr ©r N)r r r r r Ú __classcell__)r1 s @r r- r- / s ø Ù!÷ ñ r r- c óN e Zd ZdZeefdedefdZdefdZ de
|
fdZ dedefd Z y
|
) ÚExponentialBackoffz Exponential backoff upon failureÚcapÚbasec ó || _ || _ y©úe
|
`cap`: maximum backoff time in seconds
|
`base`: base backoff time in seconds
|
N©Ú_capÚ_base©r
|
r6 r7 s r r zExponentialBackoff.__init__9 ó ð
|
Ø
|
r r c óD t | j | j f« S r! ©r" r= r< r s r r# zExponentialBackoff.__hash__A ó ÜTZZ §¡Ð+Ó,Ð,r c ó t |t « st S | j |j k( xr | j |j k( S r! )r% r5 r& r= r< r' s r r) zExponentialBackoff.__eq__D ó8 Ü%Ô!3Ô4Ü!Ð !àzzU[[Ñ(ÒD¨T¯Y©Y¸%¿*¹*Ñ-DÐDr r c óN t | j | j d|z z « S ©Né )Úminr< r= r s r r zExponentialBackoff.computeJ s Ü499djj¨1¨h©;Ñ 6Ó7Ð7r N© r r r r Ú DEFAULT_CAPÚ DEFAULT_BASEr r r r# r+ r) r r r r r5 r5 6 sJ Ù*à$/¸|ñ Eð °uó ð-#ó -ðEtó Eð 8 ð 8¨ô 8r r5 c óR e Zd ZdZeefdededdfdZdefdZ de
|
fdZ d edefd
|
Z y) ÚFullJitterBackoffz Full jitter backoff upon failurer6 r7 r Nc ó || _ || _ yr9 r; r> s r r zFullJitterBackoff.__init__Q r? r c óD t | j | j f« S r! rA r s r r# zFullJitterBackoff.__hash__Y rB r c ó t |t « st S | j |j k( xr | j |j k( S r! )r% rM r& r= r< r' s r r) zFullJitterBackoff.__eq__\ s8 Ü%Ô!2Ô3Ü!Ð !àzzU[[Ñ(ÒD¨T¯Y©Y¸%¿*¹*Ñ-DÐDr r c óv t j dt | j | j d|z z « « S )Nr rG )ÚrandomÚuniformrH r< r= r s r r zFullJitterBackoff.computeb s+ Ü~~a¤ T§Y¡Y°·
|
±
|
¸QÀ¹[Ñ0HÓ!IÓJÐJr rI r r r rM rM N sU Ù*à$/¸|ñ Eð °uð ÐPTó ð-#ó -ðEtó Eð K ð K¨ô Kr rM c óR e Zd ZdZeefdededdfdZdefdZ de
|
fdZ d edefd
|
Z y) ÚEqualJitterBackoffz!Equal jitter backoff upon failurer6 r7 r Nc ó || _ || _ yr9 r; r> s r r zEqualJitterBackoff.__init__i r? r c óD t | j | j f« S r! rA r s r r# zEqualJitterBackoff.__hash__q rB r c ó t |t « st S | j |j k( xr | j |j k( S r! )r% rU r& r= r< r' s r r) zEqualJitterBackoff.__eq__t rD r r c ó t | j | j d|z z « dz }|t j d|« z S )NrG r )rH r< r= rR rS )r
|
r Útemps r r zEqualJitterBackoff.computez s: Ü499djj¨1¨h©;Ñ 6Ó7¸!Ñ;Øfnn Q¨Ó-Ñ-Ð-r rI r r r rU rU f sR Ù+à$/¸|ñ Eð °uð ÐPTó ð-#ó -ðEtó Eð . ð .¨ô .r rU c óZ e Zd ZdZeefdededdfdZdefdZ de
|
fdZ d d Z d
|
edefd Z y) ÚDecorrelatedJitterBackoffz(Decorrelated jitter backoff upon failurer6 r7 r Nc ó. || _ || _ d| _ y)r: r N)r< r= Ú_previous_backoffr> s r r z"DecorrelatedJitterBackoff.__init__ s ð
|
Ø
|
Ø!"Õ r c óD t | j | j f« S r! rA r s r r# z"DecorrelatedJitterBackoff.__hash__ rB r c ó t |t « st S | j |j k( xr | j |j k( S r! )r% r\ r& r= r< r' s r r) z DecorrelatedJitterBackoff.__eq__ s8 Ü%Ô!:Ô;Ü!Ð !àzzU[[Ñ(ÒD¨T¯Y©Y¸%¿*¹*Ñ-DÐDr c ó d| _ y r/ )r^ r s r r z DecorrelatedJitterBackoff.reset s
|
Ø!"Õ r r c óÖ t | j | j dz « }t j | j |« }t | j |« | _ | j S )Né )Úmaxr= r^ rR rS rH r< )r
|
r Ú max_backoffrZ s r r z!DecorrelatedJitterBackoff.compute sP Ü$** d×&<Ñ&<¸qÑ&@ÓA Ü~~djj¨+Ó6Ü!$ T§Y¡Y°Ó!5Ô Ø×%Ñ%Ð%r r2 )r r r r rJ rK r r r r# r+ r) r r r r r r\ r\ sW Ù2à$/¸|ñ #Eð #°uð #ÐPTó #ð-#ó -ðEtó Eó #ð& ð &¨ô &r r\ c óR e Zd ZdZeefdededdfdZdefdZ de
|
fdZ d edefd
|
Z y) Ú ExponentialWithJitterBackoffz-Exponential backoff upon failure, with jitterr6 r7 r Nc ó || _ || _ yr9 r; r> s r r z%ExponentialWithJitterBackoff.__init__¡ r? r c óD t | j | j f« S r! rA r s r r# z%ExponentialWithJitterBackoff.__hash__© rB r c ó t |t « st S | j |j k( xr | j |j k( S r! )r% rg r& r= r< r' s r r) z#ExponentialWithJitterBackoff.__eq__¬ s8 Ü%Ô!=Ô>Ü!Ð !àzzU[[Ñ(ÒD¨T¯Y©Y¸%¿*¹*Ñ-DÐDr r c óx t | j t j « | j z d|z z « S rF )rH r< rR r= r s r r z$ExponentialWithJitterBackoff.compute² s+ Ü499fmmo°·
|
±
|
Ñ :¸QÀ¹[Ñ HÓIÐIr rI r r r rg rg sU Ù7à$/¸|ñ Eð °uð ÐPTó ð-#ó -ðEtó Eð J ð J¨ô Jr rg c ó t « S r! )rU r r r Údefault_backoffrm ¶ s Ü Ó Ð r )rR Úabcr r rJ rK r r r- r5 rM rU r\ rg rm r r r ú<module>ro s ðÛ ß #ð à ô cô ô" oô ô( ô ô8 ô 8ô0Kô Kô0. ô .ô2 & ô &ô>J ?ô Jó0 r
|
