Oǻi(UddlZddlmZmZmZmZmZmZer ddlm Z neZ GddZ da ee e d<de fdZy#e $reZ Y$wxYw) N) TYPE_CHECKINGAnyCallableDictListOptional) Observationc eZdZdZd deeeegeefffdZ dedegeefddfdZ dedeegeeffd Z d d Z de fd Zy)ObservablesRegistryzG Global registry for storing callbacks for observable metrics. NregistrycL|xsi|_tj|_yN) _registry threadingLock_lock)selfr s Z/opt/lhia/marcimex/agent/venv/lib/python3.12/site-packages/redis/observability/registry.py__init__zObservablesRegistry.__init__s!R^^% namecallbackreturnc|j5|jj|gj|dddy#1swYyxYw)z? Register a callback for an observable metric. N)rr setdefaultappend)rrrs rregisterzObservablesRegistry.registersCZZ A NN % %dB / 6 6x @ A A As ,AA c~|j5|jj|gcdddS#1swYyxYw)z= Get all callbacks for an observable metric. N)rrget)rrs rrzObservablesRegistry.gets4ZZ 0>>%%dB/ 0 0 0s3<cz|j5|jjdddy#1swYyxYw)z% Clear the registry. N)rrclearrs rr!zObservablesRegistry.clear&s0ZZ # NN " # # #s1:c,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],CAA00Xb$s)m%< =0###rr _observables_registry_instancerc.t tatS)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,rrr4sfEE5K"#"#LAE)< =D*+>*_  s=AA