5j_SSKJr SSKrSSKJrJr SSKJr SSKJ r SSK J r J r J r JrJr SSKJr SSjr"S S \\ S 9r"S S \5r"SS\5r"SS5rg)) annotationsN)ABCabstractmethod)errors)StorageRegistry)AnyCallablePRcast)LazyDependencycJ^[R"T5SU4Sjj5nU$)Nc>[[US5nT"U0UD6$!URa.nUR(a[R "U5UeeSnAff=f)Nr)r Storagebase_exceptionswrap_exceptionsr StorageError)argskwargsinstanceexcfns R/root/lseg-credit/backend/venv/lib/python3.13/site-packages/limits/storage/base.pyinner_wrap_errors..inners]a) t&v& &'' ''))#.C7  sA)AA)rzP.argsrzP.kwargsreturnr ) functoolswraps)rrs` r _wrap_errorsrs'__R Lc^\rSrSr%SrS\S'SU4SjjrSSU4Sjjjr\\ SSj55r \ SSSjj5r \ SS j5r \ SS j5r \ SS j5r\ SS j5r\ SS j5rSrU=r$)r"z; Base class to extend when implementing a storage backend. zlist[str] | NoneSTORAGE_SCHEMEc t>SH!n[X[[X555 M# [TU]"S0UD6 g)N>getincrcheckclearreset get_expirysetattrrgetattrsuper__init_subclass__clsrmethod __class__s rr0Storage.__init_subclass__*s7 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)selfuriroptionsr4s rr7Storage.__init__6s .r c[e)NNotImplementedErrorr8s rrStorage.base_exceptionsDs "!r c[e)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=)r8keyexpiryamounts rr& Storage.incrIs "!r c[e)z2 :param key: the key to get the counter value for r=r8rBs rr% Storage.getT "!r c[e)z+ :param key: the key to get the expiry for r=rGs rr*Storage.get_expiry[rIr c[e)z check if storage is healthy r=r?s rr' Storage.checkbrIr c[e)z reset storage to clear limits r=r?s rr) Storage.resetirIr c[e)zI resets the rate limit key :param key: the key to clear rate limits for r=rGs rr( Storage.clearps "!r )rrrrNone)NF)r9z str | Nonerboolr:zfloat | str | bool)rz-type[Exception] | tuple[type[Exception], ...])rBstrrCintrDrXrrX)rBrWrrX)rBrWrfloat)rrT)rz int | None)rBrWrrS)__name__ __module__ __qualname____firstlineno____doc____annotations__r0r7propertyrrr&r%r*r'r)r(__static_attributes__ __classcell__r4s@rrr"s%$E , % /  / /& / /"""""" "" "" "" ""r r) metaclassc\^\rSrSrSrSU4Sjjr\SS Sjj5r\S Sj5rSr U=r $) MovingWindowSupportzz\ Abstract base class for storages that support the :ref:`strategies:moving window` strategy c v>SH"n[UU[[X555 M$ [TU]"S0UD6 g)N> acquire_entryget_moving_windowr+r,r1s rr0%MovingWindowSupport.__init_subclass__s> F WS12    !+F+r c[e)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=r8rBlimitrCrDs rri!MovingWindowSupport.acquire_entrys "!r c[e)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=)r8rBrnrCs rrj%MovingWindowSupport.get_moving_windows "!r r+rRrU rBrWrnrXrCrXrDrXrrT)rBrWrnrXrCrXrztuple[float, int]) rZr[r\r]r^r0rrirjrarbrcs@rrfrfzs5 ,"" " "r rfc^\rSrSrSrSU4Sjjr\S S Sjj5r\S Sj5r\S Sj5r Sr U=r $) SlidingWindowCounterSupportzf Abstract base class for 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+r,r1s rr0-SlidingWindowCounterSupport.__init_subclass__s> F WS12    !+F+r c[e)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=rms rry8SlidingWindowCounterSupport.acquire_sliding_window_entrys "!r c[e)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=r8rBrCs rrw.SlidingWindowCounterSupport.get_sliding_windows "!r cg)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+r~s rrx0SlidingWindowCounterSupport.clear_sliding_windows r r+rRrUrr)rBrWrCrXrztuple[int, float, int, float])rBrWrCrXrrS) rZr[r\r]r^r0rryrwrxrarbrcs@rrtrts ,?@ " "" ",/ "9< "  " """ #" &""   r rtc,\rSrSrSr\SSj5rSrg)TimestampedSlidingWindowz\Helper class for storage that support the sliding window counter, with timestamp based keys.cPUS[X2- U- 53US[X2- 534$)a returns the previous and the current window's keys. :param key: the key to get the window's keys from :param expiry: the expiry of the limit item, in seconds :param at: the timestamp to get the keys from. Default to now, ie ``time.time()`` Returns a tuple with the previous and the current key: (previous, current). Example: - key = "mykey" - expiry = 60 - at = 1738576292.6631825 The return value will be the tuple ``("mykey/28976271", "mykey/28976270")``. /)rX)r2rBrCats rsliding_window_keys,TimestampedSlidingWindow.sliding_window_keyss:$aR[F2345#aBK@P?Q7RRRr r+N)rBrWrCrXrrYrztuple[str, str])rZr[r\r]r^ classmethodrrar+r rrrsfSSr r)rCallable[P, R]rr) __future__rrabcrrlimitsrlimits._storage_schemer limits.typingrr r r r limits.utilr rrrfrtrr+r rrso"#2'    U"nU"p&"#&"R; #; |SSr