o i"@sddlmZddlmZddlmZddlZddlZddlZddlm Z ddlm Z ddlm Z Gdd d e Z Gd d d eZeGd d d ZdS))division) dataclass)fieldN)Any)Callable)Optionalc@seZdZdZdZddedefddZdefd d Z d ed edd fddZ d edefddZ d edd fddZ defddZ edefddZddZd S) RateLimiterz4 A token bucket rate limiter implementation ) _lockcurrent_window_ns time_windowlast_update_ns max_tokensprev_window_rate rate_limittokenstokens_allowed tokens_totaleArr cCsH||_||_||_||_t|_d|_d|_d|_ d|_ t |_ dS)a Constructor for RateLimiter :param rate_limit: The rate limit to apply for number of requests per second. rate limit > 0 max number of requests to allow per second, rate limit == 0 to disallow all requests, rate limit < 0 to allow all requests :type rate_limit: :obj:`int` :param time_window: The time window where the rate limit applies in nanoseconds. default value is 1 second. :type time_window: :obj:`float` rN)rr rr time monotonic_nsr r rrr threadingLockr )selfrr rQ/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/internal/rate_limiter.py__init__s  zRateLimiter.__init__returncCs"t}||}||||S)z Check whether the current request is allowed or not This method will also reduce the number of available tokens by 1 :returns: Whether the current request is allowed or not :rtype: :obj:`bool` )rr _is_allowed_update_rate_counts)r timestamp_nsallowedrrr is_allowed9s  zRateLimiter.is_allowedr rNcCs^|js||_n||j|jkr||_d|_d|_||_|r&|jd7_|jd7_dS)Nr)r r _current_window_raterrr)rr rrrrrJs zRateLimiter._update_rate_countscCs~|jdkrdS|jdkrdS|j$|||jdkr,|jd8_ WddS WddS1s8wYdS)NrFTr")rr _replenishr)rrrrrr^s    $zRateLimiter._is_allowedcCsZz|j|jkr W||_dS||j|j}W||_n||_wt|j|j||j|_dSN)rr r r minr)rrelapsedrrrr$qs   zRateLimiter._replenishcCs|jsdS|j|jS)N?)rrrrrrr#s z RateLimiter._current_window_ratecCs$|jdur |S||jdS)z Return the effective sample rate of this rate limiter :returns: Effective sample rate value 0.0 <= rate <= 1.0 :rtype: :obj:`float`` Ng@)rr#r)rrreffective_rates zRateLimiter.effective_ratecCsd|jj|j|j|j|jS)NzJ{}(rate_limit={!r}, tokens={!r}, last_update_ns={!r}, effective_rate={!r}))format __class____name__rrr r*r)rrr__repr__szRateLimiter.__repr__)r)r- __module__ __qualname____doc__ __slots__intfloatrboolr!rrr$r#propertyr*r.rrrrr s   rc@s eZdZdS)RateLimitExceededN)r-r/r0rrrrr7sr7c @seZdZUdZeed<dZeed<dZeed<dZ e e ed<d Z eed <e d d Zeed <e d d Zeed <e d ejdZeed<e d ejdZejed<ddZdde e defdededefddZde defde deffddZdS)BudgetRateLimiterWithJitteraA budget rate limiter with jitter. The jitter is induced by a uniform distribution. The rate limit can be specified with ``limit_rate`` and the time scale can be controlled with the ``tau`` parameter (which defaults to 1 second). The initial budget is the product between ``limit_rate`` and the time-scale parameter ``tau``, which is also taken as the maximum budget. By default, the ``RateLimitExceeded`` exception is raised when the rate limit is exceeded. This can be changed by setting ``raise_on_exceed`` to ``False``. The ``on_exceed`` argument can be used to pass a callback that is to be called whenever the rate limit is exceeded. The ``call_once`` argument controls whether the callback should be called only once for every rate limit excess or every time the rate limiter is invoked. Instances of this class can also be used as decorators. Since the initial and maximum budget are set to ``limit_rate * tau``, the rate limiter could have an initial burst phase. When this is not desired, ``tau`` should be set to ``1 / limit_rate`` to ensure an initial and maximum budget of ``1``. limit_rater(tauTraise_on_exceedN on_exceedF call_once)initbudget max_budget)r>default_factory last_timer cCsR|jtdkrtd|_|_n|jr|j|j|_|_nd|_|_d|_dS)Ninfr(F)r9r4r?r@r:_on_exceed_calledr)rrr __post_init__s   z)BudgetRateLimiterWithJitter.__post_init__f.argskwargsrcOsd}|j1t}|j|j||jdt7_|jdk}|j|jkr,|j|_||_Wdn1s9wY|rWd|_|jd8_|durU||i|SdS|j durn|j sd| n |jsn| d|_|j rtt t S)z?Make rate-limited calls to a function with the given arguments.Fg?r(NT) r r monotonicr?r9rBrandomr@rDr<r=r;r7)rrFrGrH should_callnowrrrlimits,&    z!BudgetRateLimiterWithJitter.limitcsfdd}|S)Ncsjg|Ri|Sr%)rM)rGrHrFrrr limited_fsz7BudgetRateLimiterWithJitter.__call__..limited_fr)rrFrOrrNr__call__sz$BudgetRateLimiterWithJitter.__call__r%)r-r/r0r1r4__annotations__r:r;r5r<rrr=rr?r@rrIrBrrr rErrMrPrrrrr8s    ( &r8) __future__r dataclassesrrrJrrtypingrrrobjectr Exceptionr7r8rrrrs