5j1SSKJr SSKrSSKJrJr SSKJr SSKJ r SSK J r SSK J r JrJrJrJrJr SSKJr SS jr\"S S 9"S S \\ S95r"SS\5r"SS\5rg)) annotationsN)ABCabstractmethod) versionadded)errors)StorageRegistry)Any AwaitableCallablePRcast)LazyDependencycJ^[R"T5SU4Sjj5nU$)Nc># [[US5nT"U0UD6IShvN $N!URa.nUR(a[R "U5UeeSnAff=f7f)Nr)rStoragebase_exceptionswrap_exceptionsr StorageError)argskwargsinstanceexcfns V/root/lseg-credit/backend/venv/lib/python3.13/site-packages/limits/aio/storage/base.pyinner_wrap_errors..innersea) T,V,, ,,'' ''))#.C7  s0A+ *(*A+*A()A##A((A+)rzP.argsrzP.kwargsreturnr ) functoolswraps)rrs` r _wrap_errorsr!s'__R Lz2.1)versionc^\rSrSr%SrS\S'SU4SjjrSSU4Sjjjr\\ SSj55r \ SSSjj5r \ SS j5r \ SS j5r \ SS j5r\ SS j5r\ SS j5rSrU=r$)r%zB Base class to extend when implementing an async storage backend. zlist[str] | NoneSTORAGE_SCHEMEc >[TU]"S0UD6 SH!n[X[[ X555 M# [TU]"S0UD6 g)N>getincrcheckclearreset get_expiry)super__init_subclass__setattrr!getattrclsrmethod __class__s rr0Storage.__init_subclass__.sG !+F+ F Cgc.B!C D  !+F+r"c .>[TU]5 X lg)zu :param wrap_exceptions: Whether to wrap storage exceptions in :exc:`limits.errors.StorageError` before raising it. N)r/__init__r)selfuriroptionsr6s rr9Storage.__init__;s .r"c[e)NNotImplementedErrorr:s rrStorage.base_exceptionsHs "!r"c# [e7f)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 r?)r:keyexpiryamounts rr) Storage.incrMs "! c# [e7f)z2 :param key: the key to get the counter value for r?r:rDs rr( Storage.getX "!rHc# [e7f)z+ :param key: the key to get the expiry for r?rJs rr-Storage.get_expiry_rLrHc# [e7f)z check if storage is healthy r?rAs rr* Storage.checkfrLrHc# [e7f)z reset storage to clear limits r?rAs rr, Storage.resetmrLrHc# [e7f)zI resets the rate limit key :param key: the key to clear rate limits for r?rJs rr+ Storage.clearts "!rH)rrr rNone)NF)r;z str | Nonerboolr<zfloat | str | boolrrV)rz-type[Exception] | tuple[type[Exception], ...])rDstrrEintrFr[rr[)rDrZrr[)rDrZrfloat)rrW)rz int | None)rDrZrrV)__name__ __module__ __qualname____firstlineno____doc____annotations__r0r9propertyrrr)r(r-r*r,r+__static_attributes__ __classcell__r6s@rrr%s%$E , % /  / /& /  / /"""""" "" "" "" ""r"r) metaclassc^\rSrSrSrSU4Sjjr\SS Sjj5r\S Sj5rSr U=r $) MovingWindowSupport~zb Abstract base class for async storages that support the :ref:`strategies:moving window` strategy c v>SH"n[UU[[X555 M$ [TU]"S0UD6 g)N> acquire_entryget_moving_windowr.r1r!r2r/r0r3s rr0%MovingWindowSupport.__init_subclass__s> F WS12    !+F+r"c# [e7f)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 r?r:rDlimitrErFs rrl!MovingWindowSupport.acquire_entrys "!rHc# [e7f)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) r?)r:rDrrrEs rrm%MovingWindowSupport.get_moving_windows "!rHr.rUrX rDrZrrr[rEr[rFr[rrW)rDrZrrr[rEr[rztuple[float, int]) r]r^r_r`rar0rrlrmrdrerfs@rriri~s ,?@ " "" ",/ "9< "  " " " "" ",/ "  " "r"ric^\rSrSrSrSU4Sjjr\S S Sjj5r\S Sj5r\S Sj5r Sr U=r $) SlidingWindowCounterSupportzk Abstract base class for async storages that support the :ref:`strategies:sliding window counter` strategy c v>SH"n[UU[[X555 M$ [TU]"S0UD6 g)N>get_sliding_windowclear_sliding_windowacquire_sliding_window_entryr.rnr3s rr0-SlidingWindowCounterSupport.__init_subclass__s> F WS12    !+F+r"c# [e7f)a Acquire an entry if the weighted count of the current and previous windows is less than or equal to the limit :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 r?rqs rr}8SlidingWindowCounterSupport.acquire_sliding_window_entrys ""!rHc# [e7f)a` Return the previous and current window information. :param key: the rate limit key :param expiry: the rate limit expiry, needed to compute the key in some implementations :return: a tuple of (int, float, int, float) with the following information: - previous window counter - previous window TTL - current window counter - current window TTL r?r:rDrEs rr{.SlidingWindowCounterSupport.get_sliding_windows "!rHc # g7f)z Resets the rate limit key(s) for the sliding window :param key: the key to clear rate limits for :param expiry: the rate limit expiry, needed to compute the key in some implemenations Nr.rs rr|0SlidingWindowCounterSupport.clear_sliding_windows  sr.rUrXrv)rDrZrEr[rztuple[int, float, int, float])rDrZrEr[rrV) r]r^r_r`rar0rr}r{r|rdrerfs@rrxrxs ,  " "" "  "  ""$"" #" &""   r"rx)rCallable[P, Awaitable[R]]rr) __future__rrabcrrdeprecated.sphinxrlimitsrlimits._storage_schemer limits.typingr r r r r r limits.utilrr!rrirxr.r"rrsz"#*2' !   eU"nU"U"p*"#*"Z? #? r"