:jk?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__/home/mcse/projects/srt_converter/srt-converter-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__;s 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_descriptionDs)+   & 2!F6N!F6N <D   & 2!F6N!F6N  $&F= ! %0F= ! rr0r0) rrrr!rstrr. staticmethoddictr5rrrr#r#8sA            +.  c3:o   rc LeZdZ d dedededdfdZd d Zedddefd Zy) _ProxyInstrumentr&r'r(r)Nc<||_||_||_d|_yr+)_name_unit _description_real_instrumentr,s rr.z_ProxyInstrument.__init__is"   '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_setts !% < r?rEs rrDz%_ProxyCounter._create_real_instruments,## JJ JJ     rre) rrrrgrrrrdr^rDrrrrurusZ)-"& Ce C%C4 C  C _  rruc JeZdZdZe ddeezdedzdedzddfdZ y) 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|sRb)-"&  e  % 4     rr|c neZdZdZ d dedededdffd Z d deezd edzd e dzddffd Z xZ S)NoOpUpDownCounterz(No-op implementation of `UpDownCounter`.r&r'r(r)Nc*t||||yr[r\rks rr.zNoOpUpDownCounter.__init__rlrr_r`rac(t||||Srnrorps rrdzNoOpUpDownCounter.addrqrr6rerrrTs@rrrs2  CCC C  C)-"& Ke K%K4 K  KKrrc LeZdZ d deezdedzdedzddfdZdddefd Z y) _ProxyUpDownCounterNr_r`rar)cX|jr|jj|||yyr+rwrcs rrdz_ProxyUpDownCounter.addrxrrArBcd|j|j|j|jSr+)create_up_down_counterr=r>r?rEs rrDz+_ProxyUpDownCounter._create_real_instruments,++ JJ JJ     rre) rrrrgrrrrdr|rDrrrrrsZ)-"& Ce C%C4 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_instrument2s5.. JJ OO JJ      rN)rrrrrDrrrrr/s $  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. NrWrrrrr=rrc LeZdZdZ d dedeedzdededdf fd ZxZS) NoOpObservableUpDownCounterz2No-op implementation of `ObservableUpDownCounter`.Nr&rKr'r(r)c,t|||||yr[r\rOs rr.z$NoOpObservableUpDownCounter.__init__GrrrQrrTs@rrrDsU< 15    I&-         rrceZdZdddefdZy)_ProxyObservableUpDownCounterrArBr)cz|j|j|j|j|jSr+)!create_observable_up_down_counterr=rNr>r?rEs rrDz5_ProxyObservableUpDownCounter._create_real_instrumentZs566 JJ OO JJ      rN)rrrrrDrrrrrVs $  rrc eZdZdZe d dedededeedzddf dZe dd e ezd e dzd 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__ks 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.recordurHrr0r0Nre) rrrr!rr7rrr.rgrrrrrrrres FJ      .6e_t-C     )-"&  e  % 4     rrc eZdZdZ d dedededeedzddf fd Z dd eezd e dzd 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||||Srn)rMrrps rrzNoOpHistogram.records w~fW~MMrrre) rrrr!r7rrr.rgrrrrSrTs@rrrs. FJ        .6e_t-C    ")-"& Ne N%N4 N  NNrrc eZdZ ddedededeedzddf fd Z ddeezd edzd e dzddfd Z d d de fdZ xZ S)_ProxyHistogramNr&r'r(rr)c8t||||||_yr[)rMr.$_explicit_bucket_boundaries_advisoryrs rr.z_ProxyHistogram.__init__s$ DkB / 1rr_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.rgrrrrrDrSrTs@rrrsFJ        .6e_t-C    )-"& Fe F%F4 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_instruments5,, JJ OO JJ      rN)rrrrrDrrrrrs $  rrc JeZdZdZe ddeezdedzdedzddfdZ y) 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!rrgrrrrrrrrrsRn)-"&  e  % 4     rrc neZdZdZ d dedededdffd Z d deezd edzd e dzddffd Z xZ S) NoOpGaugez"No-op implementation of ``Gauge``.r&r'r(r)Nc*t||||yr[r\rks rr.zNoOpGauge.__init__rlrr_r`rac(t||||Srn)rMrrps rrz NoOpGauge.setrqrr6re) rrrr!r7r.rgrrrrrSrTs@rrrrsrrc LeZdZ d deezdedzdedzddfdZdddefd Z y) _ProxyGaugeNr_r`rar)cX|jr|jj|||yyr+)r@rrcs rrz_ProxyGauge.setrxrrArBcd|j|j|j|jSr+) create_gauger=r>r?rEs rrDz#_ProxyGauge._create_real_instrument&s,!! JJ JJ     rre) rrrrgrrrrrrDrrrrrsZ)-"& Ce C%C4 C  C _  rr)<abcrrcollections.abcrrrr dataclassesr loggingr rer re_compiletypingr r opentelemetryropentelemetry.contextr+opentelemetry.metrics._internal.observationropentelemetry.util.typesrr_loggerr1r3rrr"rRr#r;rJrVrYr^rirur|rrrrrrrrrrrrrrrrrrrrrsb$CC!$ ")C H :; -.  $>>> $###m<8  o  5 56%<=> --`IsGK0I2 $#3K#@ $5*5 C: C k (K'K( $W-w $ K 0K K( *=9= $   - $   !235F  l "9 $   !89  $ $ NNIN4 &y19 >l / $   1   K 0KK( U  r