lQjyddlmZddlmZmZmZmZddlmZm Z ededefZ edeeZ Gdd eZ Gd d eZ y ) )abstractmethod) AwaitableCallableTypeVarAny) ComponentSystemT.)boundAcFeZdZdZdeddffd ZededefdZxZ S)RateLimitEnforcerz Rate limit enforcer. Implemented as a wrapper around server functions to block requests if rate limits are exceeded. systemreturnNc$t||yNsuper__init__selfr __class__s a/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/chromadb/rate_limit/__init__.pyrzRateLimitEnforcer.__init__  funccyrrrs r rate_limitzRateLimitEnforcer.rate_limit r) __name__ __module__ __qualname____doc__r rrr r __classcell__rs@rrr = !v!$! q Q  rrcFeZdZdZdeddffd ZededefdZxZ S)AsyncRateLimitEnforcerz Rate limit enforcer. Implemented as a wrapper around async functions to block requests if rate limits are exceeded. rrNc$t||yrrrs rrzAsyncRateLimitEnforcer.__init__rrrcyrrrs rr z!AsyncRateLimitEnforcer.rate_limit"r!r) r"r#r$r%r rrr r r&r's@rr*r*r(rr*N)abcrtypingrrrrchromadb.configrr r r rr*rrrr0sN44- CxS)* Cy~&     Y  r