5jr& SSKJr SSKrSSKrSSKrSSKJrJr SSKJ r SSK J r SSK r SSKJrJrJr SSKJr "SS 5r\ "S S 9"S S \\\\55rg)) annotationsN)Counter defaultdict)floor) versionadded)MovingWindowSupportSlidingWindowCounterSupportStorage)TimestampedSlidingWindowc\rSrSrSSjrSrg)Entryc`[R"5UlURU-UlgN)timeatimeexpiry)selfrs X/root/lseg-credit/backend/venv/lib/python3.13/site-packages/limits/aio/storage/memory.py__init__Entry.__init__sYY[ jj6) )rrN)rintreturnNone)__name__ __module__ __qualname____firstlineno__r__static_attributes__rrr r s*rr z2.1)versionc^\rSrSrSrS/rSSU4SjjjrSSjrSSjrSSjr SSjr \ SS j5r SS S jjr SS!S jjrS"S jrS#S jrSS$SjjrS%SjrS&SjrSS$SjjrS'SjrS(SjrS)SjrS*SjrS+SjrSSjrSrU=r$), MemoryStoragez rate limit storage using :class:`collections.Counter` as an in memory storage for fixed & sliding window strategies, and a simple list to implement moving window strategy. z async+memoryc >[5Ul[[R5Ul0Ul0UlSUl[TU]("U4SU0UD6 g)Nwrap_exceptions) rstoragerasyncioLocklocks expirationseventstimersuperr)rurir'_ __class__s rrMemoryStorage.__init__*sK4;9 5@5N -/.0 04  CoCCrcFURR5nUS US U$)Nr.r+)__dict__copyrstates r __getstate__MemoryStorage.__getstate__4s' ""$ 'N 'N rcURRU5 SUl[[R 5Ul[R"UR55 gr) r5updater.rr)r*r+ ensure_future_MemoryStorage__schedule_expiryr7s r __setstate__MemoryStorage.__setstate__:sB U#  . d4467rc8^# [R"5m[URR55HnURUIShvN [ R "U4SjURU5IShvN nURRU/5(aURUSUURU'URRUS5(d8URRUS5 URRUS5 SSS5IShvN M [URR55HnURU[R"5::dM+URRUS5 URRUS5 URRUS5 M gGNGN\N!,IShvN (df  GM=f![ Ra gf=f7f)Nc4>[R"UT*SS9$)NcUR*$r)r)events rAMemoryStorage.__expire_events....Gs 5<<-rkey)bisect bisect_left)evtsnows rrE/MemoryStorage.__expire_events..FsV%7%7 3$,G&r) rlistr-keysr+r) to_threadgetpopr,r(CancelledError)rrHcutoffrLs @r__expire_eventsMemoryStorage.__expire_events@s ))+CDKK,,./::c??#*#4#4 C( $F {{sB//+/;;s+;GV+D C(;;??355 T2 sD1+??0D,,1134##C(DIIK7LL$$S$/$$((d3JJNN3- 5++???$%%   sHAHGH,G$GBG$! H,G"-AHAHHHG$"H$G= *G-+ G= 7 HHHHHc# UR(aURR5(a*[R"UR 55Ulgg7fr)r.doner) create_task_MemoryStorage__expire_eventsrs r__schedule_expiryMemoryStorage.__schedule_expiryYs<zzTZZ__.. ,,T-A-A-CDDJ/sAAc[$r) ValueErrorr[s rbase_exceptionsMemoryStorage.base_exceptions]s rc# URU5IShvN UR5IShvN URUIShvN URU==U- ss'URUU:Xa%[R"5U-UR U'SSS5IShvN URRX5$NNNN%!,IShvN (df  N:=f7f)z increments the counter for a given rate limit key :param key: the key to increment :param expiry: amount in seconds for the key to expire in :param amount: the number to increment by N)rQr>r+r(rr,)rrHramounts rincrMemoryStorage.incrcshhsm$$&&&::c?? LL  ' ||C F*(, f(<  %#?||,, &"???shC(CC(CC(C C( AC C(&C ' C(C( C( C(C%C  C%!C(c# URU5IShvN UR5IShvN URUIShvN [URUU- S5URU'SSS5IShvN URRX5$NNrN\N%!,IShvN (df  N:=f7f)z decrements the counter for a given rate limit key. 0 is the minimum allowed value. :param amount: the number to increment by Nr)rQr>r+maxr()rrHrcs rdecrMemoryStorage.decrss hhsm$$&&&::c?? #DLL$5$> BDLL #?||,, &"???sgCB CB"CB$C *B(5 CB& C"C$C&C(B?.B1 / B?;CcP# URRUS5[R"5::aTURR US5 URR US5 UR R US5 URRUS5$7f)z2 :param key: the key to get the counter value for rN)r,rQrr(rRr+rrHs rrQMemoryStorage.gets{     Q '499; 6 LL  S$ '    d + JJNN3 %||Q''sB$B&c# URRUS5 URRUS5 URRUS5 URRUS5 g7f)z. :param key: the key to clear rate limits for N)r(rRr,r-r+rks rclearMemoryStorage.clearsU d# S$' T" sD!sA2A4c"# XB:agUR5IShvN URUIShvN URRU/5 [R"5nURUX$- nU(a$UR XS- :aSSS5IShvN g[U5/U-URUSS&SSS5IShvN gNN![ a SnNnf=fNLN!,IShvN (df  g=f7f)z :param key: rate limit key to acquire an entry in :param limit: amount of entries allowed :param expiry: expiry of the entry :param amount: the number of entries to acquire FNrT)r>r+r- setdefaultr IndexErrorrr )rrHlimitrrc timestampentrys r acquire_entryMemoryStorage.acquire_entrys >$$&&&::c?? KK " "3 + I &*kk#&6u~&F (::#??).f '? C !$#?? '"    #???sDCDCD2C5+C?C5 D$C1%D* C5 DC3DD C.+C5-C..C51D3D5D ;C> < D Dch# URRU[R"55$7f)z+ :param key: the key to get the expiry for )r,rQrrks r get_expiryMemoryStorage.get_expirys& ##C55s02c# [R"5nURRU/5=n(a-[R"XTU- *SS9nXVS- R U4$US4$7f)z returns the starting point and the number of entries in the moving window :param key: rate limit key :param expiry: expiry of entry :return: (start of window, number of acquired entries) cUR*$r)r)rus rrE1MemoryStorage.get_moving_window..s %++rrGr)rr-rQrIrJr)rrHrsrrtr-oldests rget_moving_windowMemoryStorage.get_moving_windowsnIIK [[__S"- -6 -''f,-3MF1*%++V3 3!|sA*A,c# XB:ag[R"5nURXU5upgURXgX55IShvN unn n n X-U- U -n [U 5U-U:agUR USU-US9IShvN n X-U- U -n [U 5U:aUR Xt5IShvN ggNvN:N 7f)NF)rcT)rsliding_window_keys_get_sliding_window_inforrdrh) rrHrsrrcrL previous_key current_keyprevious_count previous_ttl current_countr1weighted_counts racquire_sliding_window_entry*MemoryStorage.acquire_sliding_window_entrys >iik$($<$=CC1C7C8CCCc# [R"5nURXU5upEURXEX#5IShvN $N7fr)rrrrrHrrLrrs rget_sliding_window MemoryStorage.get_sliding_windowsIiik$($<$A#AA#A!A#!A#c# URU5IShvN nURU5IShvN nUS:Xa [S5nOSXC- U- S-- U-nSXC- S-- U-U-nXWXh4$NSN<7f)Nrr~)rQfloat) rrrrrLrrr current_ttls rr&MemoryStorage._get_sliding_window_infos $xx 55"hh{33 Q  8L3<6"9Q!>?6ILS\Q./69FB ]GG63sA/A+A/A-;A/-A/c # g7f)z check if storage is healthy Tr!r[s rcheckMemoryStorage.check s scB# [[UR5[UR55nURR 5 UR R 5 URR 5 UR R 5 U$7fr)rglenr(r-rnr,r+)r num_itemss rresetMemoryStorage.resetskDLL)3t{{+;<      sBBcUR(a;URR5(dURR5 ggg![a gf=fr)r.rXcancel RuntimeErrorr[s r__del__MemoryStorage.__del__sG zz$**//"3"3 !!##4z   sA A AA)r-r,r+r(r.)NF)r0z str | Noner'boolr1strrr)rdict[str, limits.typing.Any])r8rrr)rr)rz-type[Exception] | tuple[type[Exception], ...])r~)rHrrrrcrrr)rHrrcrrr)rHrrr)rHrrr) rHrrsrrrrcrrr)rHrrr)rHrrsrrrrztuple[float, int])rHrrrrtuple[int, float, int, float])rHrrrrr) rrrrrrrLrrr)rr)rz int | None)rrrr__doc__STORAGE_SCHEMErr9r?rZr>propertyr`rdrhrQrnrvryrrrrrrrrr __classcell__)r2s@rr$r$s %%N ?DDD7;DJMD DD 8 2E 6 - - ("@A",/9< 66",/ 2       B  # & ' HHH H  H ' H rr$) __future__rr)rIr collectionsrrmathrdeprecated.sphinxr limits.typinglimitslimits.aio.storage.baserr r limits.storage.baser r r$r!rrrsc" ,* 9** eD "=?WDDr