`Qjm>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;y)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)frozenc(eZdZUdZeedzed<y)_MetricsHistogramAdvisoryNexplicit_bucket_boundaries)__name__ __module__ __qualname__rrfloat__annotations__o/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/opentelemetry/metrics/_internal/instrument.pyrrs9=$ 6=rrc eZdZUdZdZeed<y)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 jeZdZdZe d dedededdfdZededededeeedzffdZ y) r#z7Abstract class that serves as base for all instruments.nameunit descriptionreturnNcyNrselfr&r'r(s r__init__zInstrument.__init__8s rci}tj|||d<nd|d<|d}tj|||d<nd|d<|d|d<|S||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() _name_regex fullmatch _unit_regex)r&r'r(results r_check_name_unit_descriptionz'Instrument._check_name_unit_descriptionAs)+   & 2!F6N!F6N <D   & 2!F6N!F6N  $&F= ! %0F= ! rr0r0) rrrr!rstrr. staticmethoddictr5rrrr#r#5sA         3cPTUXZ]`dZdUdPerc LeZdZ d dedededdfdZd d Zedddefd Zy) _ProxyInstrumentr&r'r(r)Nc<||_||_||_d|_yr+)_name_unit _description_real_instrumentr,s rr.z_ProxyInstrument.__init__ds"   '48rmeter metrics.Meterc0|j||_y)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 !% < eZdZdZe ddedededzddfdZy) CounterzOA Counter is a synchronous `Instrument` which supports non-negative increments.Namount attributescontextr)cy)akRecords an increment to the counter. Args: amount: The amount to increment the counter by. Must be non-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. Nrr-r_r`ras raddz Counter.addrHrNN rrrr!rrrrrdrrrr^r^sIY"&"&      4      rr^c beZdZdZ d dedededdffd Z d ded ed edzddffd Z xZ S) NoOpCounterz"No-op implementation of `Counter`.r&r'r(r)Nc*t||||yr[r\r-r&r'r(rPs rr.zNoOpCounter.__init__ DkBrr_r`rac(t||||SN)r`rarMrdr-r_r`rarPs rrdzNoOpCounter.add w{6j'{JJrr6re rrrr!r7r.rrrrdrSrTs@rrhrh,  CCC C  C"&"& KKK4 K  KKrrhc @eZdZ d dedededzddfdZdddefd Zy) _ProxyCounterNr_r`rar)cX|jr|jj|||yyr+r@rdrcs rrdz_ProxyCounter.add*   ! ! % %fj' B !rrArBcd|j|j|j|jSr+)create_counterr=r>r?rEs rrDz%_ProxyCounter._create_real_instruments,## JJ JJ     rre) rrrrrrrdr^rDrrrrtrtsQ"&"& CCC4 C  C _  rrtc >eZdZdZe ddedededzddfdZy) UpDownCounterzXAn UpDownCounter is a synchronous `Instrument` which supports increments and decrements.Nr_r`rar)cy)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{sIb"&"&    4     rr{c beZdZdZ d dedededdffd Z d ded ed edzddffd Z xZ S)NoOpUpDownCounterz(No-op implementation of `UpDownCounter`.r&r'r(r)Nc*t||||yr[r\rjs rr.zNoOpUpDownCounter.__init__rkrr_r`rac(t||||Srmrnros rrdzNoOpUpDownCounter.addrprr6rerqrTs@rr~r~s2  CCC C  C"&"& KKK4 K  KKrr~c @eZdZ d dedededzddfdZdddefd Zy) _ProxyUpDownCounterNr_r`rar)cX|jr|jj|||yyr+rvrcs rrdz_ProxyUpDownCounter.addrwrrArBcd|j|j|j|jSr+)create_up_down_counterr=r>r?rEs rrDz+_ProxyUpDownCounter._create_real_instrument s,++ JJ JJ     rre) rrrrrrrdr{rDrrrrrsQ"&"& CCC4 C  C _  rrceZdZdZy)ObservableCounterzAn ObservableCounter is an asynchronous `Instrument` which reports monotonically increasing value(s) when the instrument is being observed. NrWrrrrrsrrc LeZdZdZ d dedeedzdededdf fd ZxZS) NoOpObservableCounterz,No-op implementation of `ObservableCounter`.Nr&rKr'r(r)c,t|||||yr[r\rOs rr.zNoOpObservableCounter.__init__#   #  rrQ rrrr!r7rrRr.rSrTs@rrrsU6 15    I&-         rrceZdZdddefdZy)_ProxyObservableCounterrArBr)cz|j|j|j|j|jSr+)create_observable_counterr=rNr>r?rEs rrDz/_ProxyObservableCounter._create_real_instrument+s3.. JJ OO JJ      rN)rrrrrDrrrrr*s _ AR rrceZdZdZy)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 LeZdZdZ d dedeedzdededdf fd ZxZS) NoOpObservableUpDownCounterz2No-op implementation of `ObservableUpDownCounter`.Nr&rKr'r(r)c,t|||||yr[r\rOs rr.z$NoOpObservableUpDownCounter.__init__>rrrQrrTs@rrr;sU< 15    I&-         rrceZdZdddefdZy)_ProxyObservableUpDownCounterrArBr)cz|j|j|j|j|jSr+)!create_observable_up_down_counterr=rNr>r?rEs rrDz5_ProxyObservableUpDownCounter._create_real_instrumentQs366 JJ OO JJ      rN)rrrrrDrrrrrMs _ AX rrc xeZdZdZe d dedededeedzddf dZe dd ed e d e dzddfd Z y) 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. Nr&r'r(#explicit_bucket_boundaries_advisoryr)cyr+r)r-r&r'r(rs rr.zHistogram.__init__`s rr_r`racy)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.recordjrHrr0r0Nre) rrrr!rr7rrr.rrrrrrrrZs FJ      .6e_t-C     "&"&    4     rrc teZdZdZ d dedededeedzddf fd Z dd ed ed e dzddffd Z xZ S) NoOpHistogramz$No-op implementation of `Histogram`.Nr&r'r(rr)c,t|||||y)N)r'r(rr\r-r&r'r(rrPs rr.zNoOpHistogram.__init__s#  #0S  rr_r`rac(t||||Srm)rMrros rrzNoOpHistogram.records w~fW~MMrrre) rrrr!r7rrr.rrrrSrTs@rrrs. FJ        .6e_t-C    ""&"& NNN4 N  NNrrc |eZdZ ddedededeedzddf fd Z dded ed edzddfd Z d d de fdZ xZ S)_ProxyHistogramNr&r'r(rr)c8t||||||_yr[)rMr.$_explicit_bucket_boundaries_advisoryrs rr.z_ProxyHistogram.__init__s! DkB4W1rr_r`racX|jr|jj|||yyr+)r@rrcs rrz_ProxyHistogram.records*   ! ! ( (W E !rrArBc||j|j|j|j|jS)N)r)create_histogramr=r>r?rrEs rrDz'_ProxyHistogram._create_real_instruments:%% JJ JJ   040Y0Y &  rrre) rrrr7rrr.rrrrrDrSrTs@rrrsFJ XXX X .6e_t-C X  X"&"& FFF4 F  F _  rrceZdZdZy)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 LeZdZdZ d dedeedzdededdf fd ZxZS) NoOpObservableGaugez*No-op implementation of `ObservableGauge`.Nr&rKr'r(r)c,t|||||yr[r\rOs rr.zNoOpObservableGauge.__init__rrrQrrTs@rrrsU4 15    I&-         rrceZdZdddefdZy)_ProxyObservableGaugerArBr)cz|j|j|j|j|jSr+)create_observable_gauger=rNr>r?rEs rrDz-_ProxyObservableGauge._create_real_instruments3,, JJ OO JJ      rN)rrrrrDrrrrrs _  rrc >eZdZdZe ddedededzddfdZy) GaugezdA Gauge is a synchronous `Instrument` which can be used to record non-additive values as they occur.Nr_r`rar)cy)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!rrrrrrrrrrsIn"&"&    4     rrc beZdZdZ d dedededdffd Z d ded ed edzddffd Z xZ S) NoOpGaugez"No-op implementation of ``Gauge``.r&r'r(r)Nc*t||||yr[r\rjs rr.zNoOpGauge.__init__rkrr_r`rac(t||||Srm)rMrros rrz NoOpGauge.setrprr6re) rrrr!r7r.rrrrrSrTs@rrrrrrrc @eZdZ d dedededzddfdZdddefd Zy) _ProxyGaugeNr_r`rar)cX|jr|jj|||yyr+)r@rrcs rrz_ProxyGauge.setrwrrArBcd|j|j|j|jSr+) create_gauger=r>r?rEs rrDz#_ProxyGauge._create_real_instruments,!! JJ JJ     rre) rrrrrrrrrDrrrrr sQ"&"& CCC4 C  C _  rr)<abcrrcollections.abcrrrr dataclassesr loggingr rer re_compiletypingr r opentelemetryropentelemetry.contextr+opentelemetry.metrics._internal.observationropentelemetry.util.typesrr_loggerr1r3rrr"rRr#r;rJrVrYr^rhrtr{r~rrrrrrrrrrrrrrrrrrrrs]$CC!$ ")C H :; -.  $>>> $###m<8 o&(== >8T_K`bqswKwAx x ++\IsGK0I2 $#3K#@ $5*5 C: C k (K'K( $W-w $ K 0K K( *=9= $   - $ :;LMO` l "9 $   !89  $ $ NNIN4 &y19 :l / $   1   K 0KK( U  r