/ i(UddlZddlmZmZmZmZmZmZer ddlm Z n#e $reZ YnwxYweZ GddZ da ee e d<de fdZdS) N) TYPE_CHECKINGAnyCallableDictListOptional) Observationc eZdZdZd deeeegeefffdZ dedegeefddfdZ dedeegeeffd Z d d Z de fd ZdS)ObservablesRegistryzG Global registry for storing callbacks for observable metrics. NregistrycH|pi|_tj|_dSN) _registry threadingLock_lock)selfr s C:\Users\Dell Inspiron 16\Desktop\tws\AgrotaPowerBi\back-agrota-powerbi\mcp-client-agrota\venv\Lib\site-packages\redis/observability/registry.py__init__zObservablesRegistry.__init__s !R^%% namecallbackreturnc|j5|j|g|ddddS#1swxYwYdS)z? Register a callback for an observable metric. N)rr setdefaultappend)rrrs rregisterzObservablesRegistry.registersZ A A N % %dB / / 6 6x @ @ @ A A A A A A A A A A A A A A A A A As/AA Acz|j5|j|gcdddS#1swxYwYdS)z= Get all callbacks for an observable metric. N)rrget)rrs rrzObservablesRegistry.getsZ 0 0>%%dB// 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0s 044cx|j5|jddddS#1swxYwYdS)z% Clear the registry. N)rrclearrs rr!zObservablesRegistry.clear&sZ # # N " " " # # # # # # # # # # # # # # # # # #s /33c*t|jS)z9 Get the number of registered callbacks. )lenrr"s r__len__zObservablesRegistry.__len__-s4>"""rr)rN)__name__ __module__ __qualname____doc__rstrrrrrrrr!intr%rrr r s&&c4T#Y0G+H&H!I&&&&ASAHRc],CAAAAA00Xb$s)m%< =0000###########rr _observables_registry_instancerc:ttatS)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) )r-r r,rr!get_observables_registry_instancer/8s &-)<)>)>& ))r)rtypingrrrrrropentelemetry.metricsr ImportErrorr r-__annotations__r/r,rrr4sEEEEEEEEEEEEEEEE5555555  K"#"#"#"#"#"#"#"#LAE)< =DDD*+>******s  **