\jLddlmZGddZGddZGddZy) )Randomc(eZdZdZdZdZdZdZy)RetryDelayStrategyaEncapsulation of configurable backoff/jitter behavior, used for stream connections. - The system can either be in a "good" state or a "bad" state. The initial state is "bad"; the caller is responsible for indicating when it transitions to "good". When we ask for a new retry delay, that implies the state is now transitioning to "bad". - There is a configurable base delay, which can be changed at any time (if the SSE server sends us a "retry:" directive). - There are optional strategies for applying backoff and jitter to the delay. This object is meant to be used from a single thread once it's been created; its methods are not safe for concurrent use. cX||_||_||_||_d|_d|_y)Nr)_RetryDelayStrategy__base_delay#_RetryDelayStrategy__reset_interval_RetryDelayStrategy__backoff_RetryDelayStrategy__jitter _RetryDelayStrategy__retry_count_RetryDelayStrategy__good_since)self base_delayreset_intervalbackoff_strategyjitter_strategys C/root/env/lib/python3.12/site-packages/ldclient/impl/retry_delay.py__init__zRetryDelayStrategy.__init__s0& .)'  c~|jr/|jr#||jz |jk\rd|_d|_|j}|jr&|jj ||j}|xjdz c_|j r|j j|}|S)a(Computes the next retry interval. This also sets the current state to "bad". Note that current_time is passed as a parameter instead of computed by this function to guarantee predictable behavior in tests. :param float current_time: the current time, in seconds rN)r rr rr apply_backoffr apply_jitter)r current_timedelays rnext_retry_delayz#RetryDelayStrategy.next_retry_delays   !6!6L4K\K\<\`d`u`u>NN008J8JKE a ==MM..u5E rc||_y)zMarks the current state as "good" and records the time. :param float good_since: the time that the state became "good", in seconds N)r )r good_sinces rset_good_sincez!RetryDelayStrategy.set_good_since/s 'rc ||_d|_y)aChanges the initial retry delay and resets the backoff (if any) so the next retry will use that value. This is used to implement the optional SSE behavior where the server sends a "retry:" command to set the base retry to a specific value. Note that we will still apply a jitter, if jitter is enabled, and subsequent retries will still increase exponentially. rN)rr )r rs rset_base_delayz!RetryDelayStrategy.set_base_delay6s'rN)__name__ __module__ __qualname____doc__rrrr rrrrs !&' rrceZdZdZdZdZy)DefaultBackoffStrategyaThe default implementation of exponential backoff, which doubles the delay each time up to the specified maximum. If a reset_interval was specified for the RetryDelayStrategy, and the system has been in a "good" state for at least that long, the delay is reset back to the base. This avoids perpetually increasing delays in a situation where failures are rare). c||_yN"_DefaultBackoffStrategy__max_delay)r max_delays rrzDefaultBackoffStrategy.__init__Is $rcL|d|zz}||jkr|S|jS)Nr*)r r retry_countds rrz$DefaultBackoffStrategy.apply_backoffLs/ Q+% &)))q?t/?/??rN)r!r"r#r$rrr%rrr'r'As%@rr'ceZdZdZddZdZy)DefaultJitterStrategyzbThe default implementation of jitter, which subtracts a pseudo-random amount from each delay. Nc2||_t||_y)zCreates an instance. :param float ratio: a number in the range [0.0, 1.0] representing 0%-100% jitter :param int rand_seed: if not None, will use this random seed (for test determinacy) N)_DefaultJitterStrategy__ratior_DefaultJitterStrategy__random)r ratio rand_seeds rrzDefaultJitterStrategy.__init__Ss  y) rc\||jj|jz|zz Sr))r5randomr4)r rs rrz"DefaultJitterStrategy.apply_jitter\s( ,,.=EFFrr))r!r"r#r$rrr%rrr2r2Ps*Grr2N)r9rrr'r2r%rrr:s+::x @ @ G Gr