Xjk?ddlmZmZddlmZmZmZmZddlm Z ddl m Z ddl m ZddlmZmZddlmZddlmZdd lmZdd lmZe eZed Zed Ze d GddZe d GddZeddZ eegeefeeeedfzZ!GddeZ"Gddeee Z#Gdde#e Z$Gdde"Z%Gdde"Z&Gd d!e%Z'Gd"d#e'Z(Gd$d%e#e'e'Z)Gd&d'e%Z*Gd(d)e*Z+Gd*d+e#e*e*Z,Gd,d-e&Z-Gd.d/e-Z.Gd0d1e$e-e-Z/Gd2d3e&Z0Gd4d5e0Z1Gd6d7e$e0e0Z2Gd8d9e%Z3Gd:d;e3Z4Gd<d=e#e3e3Z5Gd>d?e&Z6Gd@dAe6Z7GdBdCe$e6e6Z8GdDdEe%Z9GdFdGe9Z:GdHdIe#e9e9Z;dS)J)ABCabstractmethod)Callable GeneratorIterableSequence) dataclass) getLogger)compile)GenericTypeVar)metrics)Context) Observation) Attributesz[a-zA-Z][-_./a-zA-Z0-9]{0,254}z[\x00-\x7F]{0,63}T)frozenc0eZdZUdZeedzed<dS)_MetricsHistogramAdvisoryNexplicit_bucket_boundaries)__name__ __module__ __qualname__rrfloat__annotations__g/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/opentelemetry/metrics/_internal/instrument.pyrrs,9=$ 6=====rrc"eZdZUdZdZeed<dS)CallbackOptionszOptions for the callback Args: timeout_millis: Timeout for the callback's execution. If the callback does asynchronous work (e.g. HTTP requests), it should respect this timeout. i'timeout_millisN)rrr__doc__r rrrrrrr$s.#NE"""""rr InstrumentT Instrument)boundNc ~eZdZdZe d dedededdfdZededededeeedzffd Z dS) r#z7Abstract class that serves as base for all instruments.nameunit descriptionreturnNcdSNrselfr'r(r)s r__init__zInstrument.__init__;s  rci}t|||d<nd|d<|d}t|||d<nd|d<|d|d<n||d<|S)as Checks the following instrument name, unit and description for compliance with the spec. Returns a dict with keys "name", "unit" and "description", the corresponding values will be the checked strings or `None` if the value is invalid. If valid, the checked strings should be used instead of the original values. Nr'r&r(r)) _name_regex fullmatch _unit_regex)r'r(r)results r_check_name_unit_descriptionz'Instrument._check_name_unit_descriptionDs)+   & & 2!F6NN!F6N <D   & & 2!F6NN!F6N  $&F= ! !$/F= ! rr&r&) rrrr!rstrr/ staticmethoddictr5rrrr#r#8sAA           ^    +.  c3:o    \   rc TeZdZ d dedededdfdZd d Zedd defd ZdS)_ProxyInstrumentr&r'r(r)r*Nc>||_||_||_d|_dSr,)_name_unit _description_real_instrumentr-s rr/z_ProxyInstrument.__init__is(   '48rmeter metrics.Meterc:|||_dS)z;Called when a real meter is set on the creating _ProxyMeterN)_create_real_instrumentr@r.rAs r on_meter_setz_ProxyInstrument.on_meter_setts !% < r?rEs rrDz%_ProxyCounter._create_real_instruments*## J J     rre) rrrrgrrrrdr^rDrrrrurus)-"& CCe C%C4 C  CCCC _       rruc ReZdZdZe ddeezdedzdedzddfdZ dS) UpDownCounterzXAn UpDownCounter is a synchronous `Instrument` which supports increments and decrements.Nr_r`rar*cdS)a/Records an increment or decrement to the counter. Unlike `Counter`, the ``amount`` may be negative, allowing the instrument to track values that go up and down (e.g. number of active requests, queue depth). Args: amount: The amount to add to the counter. May be positive or negative. attributes: Optional set of attributes to associate with the measurement. context: Optional context to associate with the measurement. If not provided, the current context is used. Nrrcs rrdzUpDownCounter.addrHrrerfrrrr|r|sxbb)-"&   e  % 4      ^   rr|c neZdZdZ d dedededdffd Z dd eezd edzd e dzddffd Z xZ S)NoOpUpDownCounterz(No-op implementation of `UpDownCounter`.r&r'r(r)r*NcPt|||dSr[r\rks rr/zNoOpUpDownCounter.__init__rlrr_r`racLt|||Srnrorps rrdzNoOpUpDownCounter.addrqrr6rerrrTs@rrrs22  CCCC C  CCCCCC)-"& KKe K%K4 K  KKKKKKKKKKrrc NeZdZ d deezdedzdedzddfdZdddefd Z dS) _ProxyUpDownCounterNr_r`rar*cP|jr|j|||dSdSr,rwrcs rrdz_ProxyUpDownCounter.addrxrrArBcN||j|j|jSr,)create_up_down_counterr=r>r?rEs rrDz+_ProxyUpDownCounter._create_real_instruments*++ J J     rre) rrrrgrrrrdr|rDrrrrrs)-"& CCe C%C4 C  CCCC _       rrceZdZdZdS)ObservableCounterzAn ObservableCounter is an asynchronous `Instrument` which reports monotonically increasing value(s) when the instrument is being observed. NrWrrrrrsrrc ReZdZdZ d dedeedzdededdf fd ZxZS) NoOpObservableCounterz,No-op implementation of `ObservableCounter`.Nr&r'rKr(r)r*cRt||||dSr[r\rOs rr/zNoOpObservableCounter.__init__ <   #      rrQ rrrr!r7rrRr/rSrTs@rrrs66 15     I&-                 rrceZdZdddefdZdS)_ProxyObservableCounterrArBr*cZ||j|j|j|jSr,)create_observable_counterr=rNr>r?rEs rrDz/_ProxyObservableCounter._create_real_instrument2s1.. J O J      rN)rrrrrDrrrrr/s8 $       rrceZdZdZdS)ObservableUpDownCounteraAn ObservableUpDownCounter is an asynchronous `Instrument` which reports additive value(s) (e.g. the process heap size - it makes sense to report the heap size from multiple processes and sum them up, so we get the total heap usage) when the instrument is being observed. NrWrrrrr=rrc ReZdZdZ d dedeedzdededdf fd ZxZS) NoOpObservableUpDownCounterz2No-op implementation of `ObservableUpDownCounter`.Nr&r'rKr(r)r*cRt||||dSr[r\rOs rr/z$NoOpObservableUpDownCounter.__init__GrrrQrrTs@rrrDs<< 15     I&-                 rrceZdZdddefdZdS)_ProxyObservableUpDownCounterrArBr*cZ||j|j|j|jSr,)!create_observable_up_down_counterr=rNr>r?rEs rrDz5_ProxyObservableUpDownCounter._create_real_instrumentZs166 J O J      rN)rrrrrDrrrrrVs8 $       rrc eZdZdZe ddedededeedzddf d Ze dd e ezd e dzd e dzddfd Z dS) HistogramzHistogram is a synchronous `Instrument` which can be used to report arbitrary values that are likely to be statistically meaningful. It is intended for statistics such as histograms, summaries, and percentile. r&Nr'r(r)#explicit_bucket_boundaries_advisoryr*cdSr,r)r.r'r(r)rs rr/zHistogram.__init__ks  rr_r`racdS)aRecords a measurement. Used to report measurements that are likely to be statistically meaningful, such as request durations, payload sizes, or any value for which a distribution (e.g. percentiles) is useful. Args: amount: The measurement to record. Should be non-negative in most cases; negative values are only meaningful when the histogram is used to track signed deltas. attributes: Optional set of attributes to associate with the measurement. context: Optional context to associate with the measurement. If not provided, the current context is used. Nrrcs rrecordzHistogram.recordurHrr&r&Nre) rrrr!rr7rrr/rgrrrrrrrres FJ       .6e_t-C      ^ )-"&   e  % 4      ^   rrc eZdZdZ ddedededeedzddf fd Z dd eezd e dzd e dzddffd Z xZ S) NoOpHistogramz$No-op implementation of `Histogram`.r&Nr'r(r)rr*cRt||||dS)N)r(r)rr\r.r'r(r)rrPs rr/zNoOpHistogram.__init__s<  #0S      rr_r`racLt|||Srn)rMrrps rrzNoOpHistogram.records! ww~~fW~MMMrrre) rrrr!r7rrr/rgrrrrSrTs@rrrs.. FJ         .6e_t-C         ")-"& NNe N%N4 N  NNNNNNNNNNrrc eZdZ ddedededeedzddf fd Z dd eezd edzd e dzddfd Z d dde fdZ xZ S)_ProxyHistogramr&Nr'r(r)rr*c^t|||||_dSr[)rMr/$_explicit_bucket_boundaries_advisoryrs rr/z_ProxyHistogram.__init__s5 DkBBB / 111rr_r`racP|jr|j|||dSdSr,)r@rrcs rrz_ProxyHistogram.records=   F  ! ( (W E E E E E F FrrArBc\||j|j|j|jS)N)r)create_histogramr=r>r?rrEs rrDz'_ProxyHistogram._create_real_instruments5%% J J  040Y &   rrre)rrrr7rrr/rgrrrrrDrSrTs@rrrsFJ         .6e_t-C         )-"& FFe F%F4 F  FFFF _         rrceZdZdZdS)ObservableGaugezAsynchronous Gauge is an asynchronous `Instrument` which reports non-additive value(s) (e.g. the room temperature - it makes no sense to report the temperature value from multiple rooms and sum them up) when the instrument is being observed. NrWrrrrrrrrc ReZdZdZ d dedeedzdededdf fd ZxZS) NoOpObservableGaugez*No-op implementation of `ObservableGauge`.Nr&r'rKr(r)r*cRt||||dSr[r\rOs rr/zNoOpObservableGauge.__init__rrrQrrTs@rrrs44 15     I&-                 rrceZdZdddefdZdS)_ProxyObservableGaugerArBr*cZ||j|j|j|jSr,)create_observable_gauger=rNr>r?rEs rrDz-_ProxyObservableGauge._create_real_instruments1,, J O J      rN)rrrrrDrrrrrs8 $       rrc ReZdZdZe ddeezdedzdedzddfdZ dS) GaugezdA Gauge is a synchronous `Instrument` which can be used to record non-additive values as they occur.Nr_r`rar*cdS)a&Records the current value of the gauge. The gauge reports the last recorded value when observed. It is intended for non-additive measurements where only the current value matters (e.g. CPU utilisation percentage, room temperature). Args: amount: The current value to record. attributes: Optional set of attributes to associate with the measurement. context: Optional context to associate with the measurement. If not provided, the current context is used. Nrrcs rsetz Gauge.setrHrre) rrrr!rrgrrrrrrrrrsxnn)-"&   e  % 4      ^   rrc neZdZdZ d dedededdffd Z dd eezd edzd e dzddffd Z xZ S) NoOpGaugez"No-op implementation of ``Gauge``.r&r'r(r)r*NcPt|||dSr[r\rks rr/zNoOpGauge.__init__rlrr_r`racLt|||Srn)rMrrps rrz NoOpGauge.setrqrr6re) rrrr!r7r/rgrrrrrSrTs@rrrrsrrc NeZdZ d deezdedzdedzddfdZdddefd Z dS) _ProxyGaugeNr_r`rar*cP|jr|j|||dSdSr,)r@rrcs rrz_ProxyGauge.setrxrrArBcN||j|j|jSr,) create_gauger=r>r?rEs rrDz#_ProxyGauge._create_real_instrument&s*!! J J     rre) rrrrgrrrrrrDrrrrrs)-"& CCe C%C4 C  CCCC _       rr)<abcrrcollections.abcrrrr dataclassesr loggingr rer re_compiletypingr r opentelemetryropentelemetry.contextr+opentelemetry.metrics._internal.observationropentelemetry.util.typesrr_loggerr1r3rrr"rRr#r;rJrVrYr^rirur|rrrrrrrrrrrrrrrrrrrrrs$#######CCCCCCCCCCCC!!!!!!$$$$$$ "!!!!!))))))CCCCCC )H  j:;; j-..  $>>>>>>>> $########gm<888  o  5 56%<=> --------`IIIIIsGK0III2 $ $ $ $ $#3K#@ $ $ $55555*555 C C C C C: C C C     k   (KKKKK'KKK(     $W-w   $     K   0KKKKK KKK(     *=9=   $       -   $       !235F    l     "9   $       !89    $ $ $ $ $ $ $ $ NNNNNNINNN4     &y19   >l     /   $       1         K   0KKKKKKKK(     U      r