5j) SrSSKJr SSKrSSKJrJr SSKJrJ r SSK J r SSK J r SS KJr SS KJr SS KJr S S KJrJr S SKJr "SS\5r"SS\5r"SS\5r\ "SS9"SS\55r\\\S.rg)z' Asynchronous rate limiting strategies ) annotationsN)ABCabstractmethod)floorinf) versionadded) RateLimitItem) StorageTypes)cast) WindowStats)MovingWindowSupportStorage)SlidingWindowCounterSupportc\rSrSrS Sjr\SS.S Sjj5r\SS.S Sjj5r\S Sj5rSSjr S r g ) RateLimiterc>[U[5(deXlgN) isinstancerstorage)selfrs T/root/lseg-credit/backend/venv/lib/python3.13/site-packages/limits/aio/strategies.py__init__RateLimiter.__init__s'7++++ ' rcostc# [e7f)  Consume the rate limit :param item: the rate limit item :param identifiers: variable list of strings to uniquely identify the limit :param cost: The cost of this hit, default 1 :return: True if ``cost`` could be deducted from the rate limit without exceeding it NotImplementedErrorritemr identifierss rhitRateLimiter.hit "! c# [e7f) Check if the rate limit can be consumed :param item: the rate limit item :param identifiers: variable list of strings to uniquely identify the limit :param cost: The expected cost to be consumed, default 1 :return: True if the rate limit is not depleted r"r$s rtestRateLimiter.test(r)r*c# [e7f)z Query the reset time and remaining amount for the limit :param item: the rate limit item :param identifiers: variable list of strings to uniquely identify the limit :return: (reset time, remaining)) r"rr%r&s rget_window_statsRateLimiter.get_window_stats6r)r*cn# URRUR"U65IShvN $N7fr)rclearkey_forr0s rr4RateLimiter.clearDs)\\'' k(BCCCCs ,535)rNrr r%r r&strrintreturnboolr%r r&r9r;r r%r r&r9r;None) __name__ __module__ __qualname____firstlineno__rrr'r-r1r4__static_attributes__rrrrsg(LM " "MN " " "! "14 "  " "Drrcj^\rSrSrSrS U4SjjrSS.S SjjrSS.S SjjrS SjrS r U=r $) MovingWindowRateLimiterHz, Reference: :ref:`strategies:moving window` c>[US5(d)[US5(d[SUR35e[TU]U5 g)N acquire_entryget_moving_windowz@MovingWindowRateLimiting is not implemented for storage of type hasattrr# __class__superrrrrNs rr MovingWindowRateLimiter.__init__MsO G_ - -BU1V1V%",,-/  !rrrc# [[UR5RUR"U6UR UR 5US9IShvN $N7fr!)amountN)r rrrJr5rT get_expiryr$s rr'MovingWindowRateLimiter.hitWsS-t||<JJ LL+ & T__5FtK    sAAAAc# [[UR5RUR"U6UR UR 55IShvN nUSnXQR U- :*$N7fr,Nr)r rrrKr5rTrU)rr%rr&resrTs rr-MovingWindowRateLimiter.testgsg,dll;MM LL+ & KK OO    Qt+++ sAA3A1A3c# [[UR5RUR"U6UR UR 55IShvN up4X1R 5-n[XQR U- 5$N07f)z returns the number of requests remaining within this limit. :param item: the rate limit item :param identifiers: variable list of strings to uniquely identify the limit :return: (reset time, remaining) N)r rrrKr5rTrUr )rr%r& window_start window_itemsresets rr1(MovingWindowRateLimiter.get_window_stats{sq,0 ,  DLL+6 T__EV W&X" 005++ "<== &XsAB B1B rE)rr r;r?r8r=) r@rArBrC__doc__rr'r-r1rD __classcell__rNs@rrGrGHsG"MN NO,(>!>14> >>rrGcR\rSrSrSrSS.S SjjrSS.S SjjrS SjrSrg ) FixedWindowRateLimiterz+ Reference: :ref:`strategies:fixed window` rrc# URRUR"U6UR5US9IShvN UR:*$N7frS)rincrr5rUrTr$s rr'FixedWindowRateLimiter.hitsT,,## k*!$  {{    s:AAAc# URRUR"U65IShvN URU- S-:$N7frX)rgetr5rTr$s rr-FixedWindowRateLimiter.testsA,,""4<<#=> >tASVWAW W >s,AAAc # [SURURRUR"U65IShvN - 5nURR UR"U65IShvN n[ XC5$NEN7f)z Query the reset time and remaining amount for the limit :param item: the rate limit item :param identifiers: variable list of strings to uniquely identify the limit :return: reset time, remaining rN)maxrTrrjr5rUr )rr%r& remainingr^s rr1'FixedWindowRateLimiter.get_window_statssq KK 0 0{1K LL L ll--dllK.HII5,, MIs"=B B 5B 5B6B B rENr8r=) r@rArBrCr`r'r-r1rDrErrrdrds<MN *NO -!-14- -rrdz4.1)versionc^\rSrSrSrS U4SjjrS SjrSS.SSjjrSS.SSjjrSS jr SS jr S r U=r $)SlidingWindowCounterRateLimiterz5 Reference: :ref:`strategies:sliding window counter` c>[US5(a[US5(d[SUR35e[TU]U5 g)Nget_sliding_windowacquire_sliding_window_entryzHSlidingWindowCounterRateLimiting is not implemented for storage of type rLrPs rr(SlidingWindowCounterRateLimiter.__init__sWw 455W 3> > &",,-/  !rc2X#-UR5- U-$)ze Return the approximated by weighting the previous window count and adding the current window count. )rU)rr%previous_countprevious_expires_in current_counts r_weighted_count/SlidingWindowCounterRateLimiter._weighted_counts3doo6GG-WWrrrc# [[UR5RUR"U6UR UR 5U5IShvN $N7f)a Consume the rate limit :param item: The rate limit item :param identifiers: variable list of strings to uniquely identify this instance of the limit :param cost: The cost of this hit, default 1 :return: True if ``cost`` could be deducted from the rate limit without exceeding it N)r rrrvr5rTrUr$s rr'#SlidingWindowCounterRateLimiter.hitsR ' & & LL+ & KK OO       sAAAAc# [[UR5RUR"U6UR 55IShvN upEpgUR XXV5URU- S-:$N,7f)a Check if the rate limit can be consumed :param item: The rate limit item :param identifiers: variable list of strings to uniquely identify this instance of the limit :param cost: The expected cost to be consumed, default 1 :return: True if the rate limit is not depleted Nr)r rrrur5rUr|rT)rr%rr&ryrzr{_s rr-$SlidingWindowCounterRateLimiter.testsGK 'G  T\\;79J KAL=]  &9 kkD 1$ % ALsA A: A8 -A:c  # [[UR5RUR"U6UR 55IShvN unnnn[ SUR[URXXE55- 5n[R"5nU(dU(d [X5$UR 5n [[pU(aXIU- -n U(aXi-n [U[X5-U5$N7f)z Query the reset time and remaining amount for the limit. :param item: The rate limit item :param identifiers: variable list of strings to uniquely identify this instance of the limit :return: (reset time, remaining) Nr)r rrrur5rUrmrTrr|timer rmin) rr%r&ryrzr{current_expires_inrnnowexpiryprevious_reset_incurrent_reset_ins rr10SlidingWindowCounterRateLimiter.get_window_statss"2DLLATT LL+ &(9        KK$$*=  iik-s. .".13+  37N O  1: 3%6!II9UU7 sA D D B6Dc# [[UR5RUR"U6UR 55IShvN $N7fr)r rrclear_sliding_windowr5rUr0s rr4%SlidingWindowCounterRateLimiter.clearAsE '  t||[94??;L MN NNsA A A ArEr7) r%r ryr:rzfloatr{r:r;rr8r=r>) r@rArBrCr`rr|r'r-r1r4rDrarbs@rrrrrs" X X X# X  X  XMN (NO .,V!,V14,V ,V\NNrrr)zsliding-window-counterz fixed-windowz moving-window)r` __future__rrabcrrmathrrdeprecated.sphinxrlimitsr rr typingr utilr rr storage.baserrrGrdrr STRATEGIESrErrrs# #*""150D#0DfC>kC>L;-[;-|ewNkwNwNv>*, r