jm>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__ZC:\Projects\Muse2API\.venv\Lib\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__8s  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_descriptionAs)+   & & 2!F6NN!F6N <D   & & 2!F6NN!F6N  $&F= ! !$/F= ! rr&r&) rrrr!rstrr/ staticmethoddictr5rrrr#r#5sAA           ^ 3cPTUXZ]`dZdUdPe\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__ds(   '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_setos !% < r?rEs rrDz%_ProxyCounter._create_real_instruments*## J J     rre) rrrrrrrdr^rDrrrrtrts"&"& CCCC4 C  CCCC _       rrtc FeZdZdZe ddedededzddfdZdS) 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{sobb"&"&     4      ^   rr{c beZdZdZ d dedededdffd Z dd ed ed edzddffd Z xZ S)NoOpUpDownCounterz(No-op implementation of `UpDownCounter`.r&r'r(r)r*NcPt|||dSr[r\rjs rr/zNoOpUpDownCounter.__init__rkrr_r`racLt|||Srmrnros rrdzNoOpUpDownCounter.addrprr6rerqrTs@rr~r~s22  CCCC C  CCCCCC"&"& KKKK4 K  KKKKKKKKKKrr~c BeZdZ d dedededzddfdZdddefd ZdS) _ProxyUpDownCounterNr_r`rar*cP|jr|j|||dSdSr,rvrcs rrdz_ProxyUpDownCounter.addrwrrArBcN||j|j|jSr,)create_up_down_counterr=r>r?rEs rrDz+_ProxyUpDownCounter._create_real_instrument s*++ J J     rre) rrrrrrrdr{rDrrrrrs"&"& CCCC4 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_instrument+s/.. J O J      rN)rrrrrDrrrrr*s7 _ AR      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. NrWrrrrr4rrc ReZdZdZ d dedeedzdededdf fd ZxZS) NoOpObservableUpDownCounterz2No-op implementation of `ObservableUpDownCounter`.Nr&r'rKr(r)r*cRt||||dSr[r\rOs rr/z$NoOpObservableUpDownCounter.__init__>rrrQrrTs@rrr;s<< 15     I&-                 rrceZdZdddefdZdS)_ProxyObservableUpDownCounterrArBr*cZ||j|j|j|jSr,)!create_observable_up_down_counterr=rNr>r?rEs rrDz5_ProxyObservableUpDownCounter._create_real_instrumentQs/66 J O J      rN)rrrrrDrrrrrMs7 _ AX      rrc eZdZdZe ddedededeedzddf d Ze dd ed e d 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__`s  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.recordjrHrr&r&Nre) rrrr!rr7rrr/rrrrrrrrZs FJ       .6e_t-C      ^ "&"&     4      ^   rrc zeZdZdZ ddedededeedzddf fd Z dd ed ed 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|||Srm)rMrros rrzNoOpHistogram.records! ww~~fW~MMMrrre) rrrr!r7rrr/rrrrSrTs@rrrs.. FJ         .6e_t-C         ""&"& NNNN4 N  NNNNNNNNNNrrc eZdZ ddedededeedzddf fd Z dd ed ed edzddfd Z d dde fdZ xZ S)_ProxyHistogramr&Nr'r(r)rr*c^t|||||_dSr[)rMr/$_explicit_bucket_boundaries_advisoryrs rr/z_ProxyHistogram.__init__s2 DkBBB4W111rr_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/rrrrrDrSrTs@rrrsFJ XXXX X .6e_t-C X  XXXXXX"&"& FFFF4 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_instruments/,, J O J      rN)rrrrrDrrrrrs6 _       rrc FeZdZdZe ddedededzddfdZdS) 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!rrrrrrrrrrsonn"&"&     4      ^   rrc beZdZdZ d dedededdffd Z dd ed ed edzddffd Z xZ S) NoOpGaugez"No-op implementation of ``Gauge``.r&r'r(r)r*NcPt|||dSr[r\rjs rr/zNoOpGauge.__init__rkrr_r`racLt|||Srm)rMrros rrz NoOpGauge.setrprr6re) rrrr!r7r/rrrrrSrTs@rrrrrrrc BeZdZ d dedededzddfdZdddefd ZdS) _ProxyGaugeNr_r`rar*cP|jr|j|||dSdSr,)r@rrcs rrz_ProxyGauge.setrwrrArBcN||j|j|jSr,) create_gauger=r>r?rEs rrDz#_ProxyGauge._create_real_instruments*!! J J     rre) rrrrrrrrrDrrrrr s"&"& CCCC4 C  CCCC _       rr)<abcrrcollections.abcrrrr dataclassesr loggingr rer re_compiletypingr r opentelemetryropentelemetry.contextr+opentelemetry.metrics._internal.observationropentelemetry.util.typesrr_loggerr1r3rrr"rRr#r;rJrVrYr^rhrtr{r~rrrrrrrrrrrrrrrrrrrrs$#######CCCCCCCCCCCC!!!!!!$$$$$$ "!!!!!))))))CCCCCC )H  j:;; j-..  $>>>>>>>> $########gm<888 o&(== >8T_K`bqswKwAx x ++++++++\IIIIIsGK0III2 $ $ $ $ $#3K#@ $ $ $55555*555 C C C C C: C C C     k   (KKKKK'KKK(     $W-w   $     K   0KKKKK KKK(     *=9=   $       -   $     :;LMO`   l     "9   $       !89    $ $ $ $ $ $ $ $ NNNNNNINNN4     &y19   :l     /   $       1         K   0KKKKKKKK(     U      r