o i(@sUddlZddlmZmZmZmZmZmZer+zddlm Z Wn e y*eZ YnweZ GdddZ da ee e d<de fdd ZdS) N) TYPE_CHECKINGAnyCallableDictListOptional) Observationc @seZdZdZddeeeegeefffddZ dedegeefddfd d Z dedeegeeffd d Z dd dZ de fddZdS)ObservablesRegistryzG Global registry for storing callbacks for observable metrics. NregistrycCs|pi|_t|_dSN) _registry threadingLock_lock)selfr rP/home/ubuntu/.local/lib/python3.10/site-packages/redis/observability/registry.py__init__s zObservablesRegistry.__init__namecallbackreturncCs@|j|j|g|WddS1swYdS)z? Register a callback for an observable metric. N)rr setdefaultappend)rrrrrrregisters"zObservablesRegistry.registercCs8|j|j|gWdS1swYdS)z= Get all callbacks for an observable metric. N)rr get)rrrrrrs $zObservablesRegistry.getcCs6|j|jWddS1swYdS)z% Clear the registry. N)rr clearrrrrr&s "zObservablesRegistry.clearcCs t|jS)z9 Get the number of registered callbacks. )lenr rrrr__len__-s zObservablesRegistry.__len__r )rN)__name__ __module__ __qualname____doc__rstrrrrrrrrintrrrrrr s("" r _observables_registry_instancercCstdurtatS)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 typingrrrrrropentelemetry.metricsr ImportErrorr r%__annotations__r&rrrrs  &