o <‘ði(ã@sŠUddlZddlmZmZmZmZmZmZer+zddlm Z Wn e y*eZ YnweZ Gdd„dƒZdaeee d<defdd „ZdS) éN)Ú TYPE_CHECKINGÚAnyÚCallableÚDictÚListÚOptional)ÚObservationc @s”eZdZdZddeeeegeefffdd„Z dedegeefddfd d „Z dedeegeeffdd„Zdd d„Zde fdd„ZdS)ÚObservablesRegistryzG Global registry for storing callbacks for observable metrics. NÚregistrycCs|pi|_t ¡|_dS©N)Ú _registryÚ threadingÚLockÚ_lock)Úselfr ©rú[/root/parts/websockify/install/lib/python3.10/site-packages/redis/observability/registry.pyÚ__init__s zObservablesRegistry.__init__ÚnameÚcallbackÚreturncCs@|j|j |g¡ |¡WdƒdS1swYdS)z? Register a callback for an observable metric. N)rrÚ setdefaultÚappend)rrrrrrÚregisters"ÿzObservablesRegistry.registercCs8|j|j |g¡WdƒS1swYdS)z= Get all callbacks for an observable metric. N)rrÚget)rrrrrrs$ÿzObservablesRegistry.getcCs6|j|j ¡WdƒdS1swYdS)z% Clear the registry. N)rrÚclear©rrrrr&s"ÿzObservablesRegistry.clearcCs t|jƒS)z9 Get the number of registered callbacks. )ÚlenrrrrrÚ__len__-s zObservablesRegistry.__len__r)rN)Ú__name__Ú __module__Ú__qualname__Ú__doc__rÚstrrrrrrrrÚintrrrrrr s("" r Ú_observables_registry_instancercCstdurtƒatS)aJ Get the global observables registry singleton instance. This is the Pythonic way to get the singleton instance. Returns: The global ObservablesRegistry singleton Example: >>> >>> registry = get_observables_registry_instance() >>> registry.register('my_metric', my_callback) N)r%r rrrrÚ!get_observables_registry_instance8sr&)r ÚtypingrrrrrrÚopentelemetry.metricsrÚImportErrorr r%Ú__annotations__r&rrrrÚs ÿ&