o 3Ih9@sddlmZmZddlmZddlmZddlmZ ddl m Z m Z m Z mZmZmZmZmZmZddlmZddlmZddlmZdd lmZeeZe d Ze d Zed d GdddZ ed d GdddZ!edddZ"ee e!geefe eee!dffZ#GdddeZ$Gdddeee"Z%Gddde%e"Z&Gddde$Z'Gddde$Z(Gdd d e'Z)Gd!d"d"e)Z*Gd#d$d$e%e)e)Z+Gd%d&d&e'Z,Gd'd(d(e,Z-Gd)d*d*e%e,e,Z.Gd+d,d,e(Z/Gd-d.d.e/Z0Gd/d0d0e&e/e/Z1Gd1d2d2e(Z2Gd3d4d4e2Z3Gd5d6d6e&e2e2Z4Gd7d8d8e'Z5Gd9d:d:e5Z6Gd;d<dd>e(Z8Gd?d@d@e8Z9GdAdBdBe&e8e8Z:GdCdDdDe'Z;GdEdFdFe;Zsz(_ProxyInstrument._create_real_instrumentr4)r<r=r(N) rrrr5r-r@rr!r>rrrrr7ys r7c sBeZdZ   d dedeeedededdf fdd ZZS) _ProxyAsynchronousInstrumentNr$r% callbacksr&r'r(cst|||||_dSr*)superr- _callbacksr,r%rBr&r' __class__rrr-s z%_ProxyAsynchronousInstrument.__init__Nr$r$) rrrr5r r CallbackTr- __classcell__rrrFrrAs rAc@eZdZdZdS) Synchronousz*Base class for all synchronous instrumentsNrrrr rrrrrLrLc sJeZdZdZe   d dedeeedededdf fd d Z Z S) Asynchronousz+Base class for all asynchronous instrumentsNr$r%rBr&r'r(cstj|||ddSN)r&r'rCr-rErFrrr-szAsynchronous.__init__rH) rrrr rr5r r rIr-rJrrrFrrOs" rOc @DeZdZdZe  d deeefdee dee ddfddZ dS) CounterzOA Counter is a synchronous `Instrument` which supports non-negative increments.Namount attributescontextr(cCr)r*rr,rTrUrVrrraddr.z Counter.addNN rrrr rrintrr rrrXrrrrrS rSc leZdZdZ  ddedededdffdd Z  dd eeefd e e d e e ddffd d Z Z S) NoOpCounterz"No-op implementation of `Counter`.r$r%r&r'r(Nctj|||ddSrPrQr+rFrrr-zNoOpCounter.__init__rTrUrVctj|||dSN)rUrVrCrXrWrFrrrXzNoOpCounter.addr4rYrrrr r5r-rr[rr rrrXrJrrrFrr^0  r^c @NeZdZ  d deeefdeedeeddfddZ dd de fd d Z dS) _ProxyCounterNrTrUrVr(cC|jr |j|||dSdSr*r;rXrWrrrrXz_ProxyCounter.addr<r=cC||j|j|jSr*)create_counterr8r9r:r?rrrr> z%_ProxyCounter._create_real_instrumentrY) rrrrr[rr rrrXrSr>rrrrrh   rhc @rR) UpDownCounterzXAn UpDownCounter is a synchronous `Instrument` which supports increments and decrements.NrTrUrVr(cCr)r*rrWrrrrXr.zUpDownCounter.addrYrZrrrrrpr\rpc r])NoOpUpDownCounterz(No-op implementation of `UpDownCounter`.r$r%r&r'r(Ncr_rPrQr+rFrrr-r`zNoOpUpDownCounter.__init__rTrUrVcrarbrcrWrFrrrXrdzNoOpUpDownCounter.addr4rYrerrrFrrqrfrqc @rg) _ProxyUpDownCounterNrTrUrVr(cCrir*rjrWrrrrXrkz_ProxyUpDownCounter.addr<r=cCrlr*)create_up_down_counterr8r9r:r?rrrr>rnz+_ProxyUpDownCounter._create_real_instrumentrY) rrrrr[rr rrrXrpr>rrrrrrrorrc@rK)ObservableCounterzAn ObservableCounter is an asynchronous `Instrument` which reports monotonically increasing value(s) when the instrument is being observed. NrMrrrrrtrNrtc FeZdZdZ   d dedeeedededdf fd d ZZ S) NoOpObservableCounterz,No-op implementation of `ObservableCounter`.Nr$r%rBr&r'r(ctj||||ddSrPrQrErFrrr-  zNoOpObservableCounter.__init__rH rrrr r5r r rIr-rJrrrFrrv  rvc@eZdZdddefddZdS)_ProxyObservableCounterr<r=r(cC||j|j|j|jSr*)create_observable_counterr8rDr9r:r?rrrr>1 z/_ProxyObservableCounter._create_real_instrumentN)rrrrtr>rrrrr|.s r|c@rK)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. NrMrrrrr<rNrc ru) NoOpObservableUpDownCounterz2No-op implementation of `ObservableUpDownCounter`.Nr$r%rBr&r'r(crwrPrQrErFrrr-Frxz$NoOpObservableUpDownCounter.__init__rHryrrrFrrCrzrc@r{)_ProxyObservableUpDownCounterr<r=r(cCr}r*)!create_observable_up_down_counterr8rDr9r:r?rrrr>Yrz5_ProxyObservableUpDownCounter._create_real_instrumentN)rrrrr>rrrrrU rc @sveZdZdZe   ddedededeeeddf d d Z e  dd e e efd ee d ee ddfddZdS) 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(cCr)r*rr,r%r&r'rrrrr-jszHistogram.__init__rTrUrVcCr)r*rrWrrrrecordtr.zHistogram.recordr$r$NrY)rrrr rr5r r rr-rr[rrrrrrrrds:    rc szeZdZdZ   ddedededeeeddf fd d Z  dd e e efd ee d ee ddffdd Z ZS) NoOpHistogramz$No-op implementation of `Histogram`.r$Nr%r&r'rr(crw)N)r&r'rrQrrFrrr-rxzNoOpHistogram.__init__rTrUrVcrarb)rCrrWrFrrrrdzNoOpHistogram.recordrrY)rrrr r5r r rr-rr[rrrrJrrrFrr~s6  rc seZdZ   ddedededeeeddf fdd Z  dd ee efd ee d ee ddfd dZ ddde fddZZS)_ProxyHistogramr$Nr%r&r'rr(cstj|||d||_dSrP)rCr-$_explicit_bucket_boundaries_advisoryrrFrrr-sz_ProxyHistogram.__init__rTrUrVcCrir*)r;rrWrrrrrkz_ProxyHistogram.recordr<r=cCs|j|j|j|j|jdS)N)r)create_histogramr8r9r:rr?rrrr>s z'_ProxyHistogram._create_real_instrumentrrY)rrrr5r r rr-rr[rrrrr>rJrrrFrrs6    rc@rK)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. NrMrrrrrrNrc ru) NoOpObservableGaugez*No-op implementation of `ObservableGauge`.Nr$r%rBr&r'r(crwrPrQrErFrrr-rxzNoOpObservableGauge.__init__rHryrrrFrrrzrc@r{)_ProxyObservableGauger<r=r(cCr}r*)create_observable_gauger8rDr9r:r?rrrr>rz-_ProxyObservableGauge._create_real_instrumentN)rrrrr>rrrrrrrc @rR) GaugezdA Gauge is a synchronous `Instrument` which can be used to record non-additive values as they occur.NrTrUrVr(cCr)r*rrWrrrsetr.z Gauge.setrY) rrrr rrr[rr rrrrrrrrr\rc r]) NoOpGaugez"No-op implementation of ``Gauge``.r$r%r&r'r(Ncr_rPrQr+rFrrr-r`zNoOpGauge.__init__rTrUrVcrarb)rCrrWrFrrrrdz NoOpGauge.setr4rY)rrrr r5r-rr[rr rrrrJrrrFrrrfrc @rg) _ProxyGaugeNrTrUrVr(cCrir*)r;rrWrrrrrkz_ProxyGauge.setr<r=cCrlr*) create_gauger8r9r:r?rrrr> rnz#_ProxyGauge._create_real_instrumentrY) rrrrr[rr rrrrr>rrrrrs   r)>abcrr dataclassesrloggingrrer re_compiletypingrrr r r r r rr opentelemetryropentelemetry.contextr+opentelemetry.metrics._internal.observationropentelemetry.util.typesrr_loggerr/r1rrr!rIr"r7rArLrOrSr^rhrprqrrrtrvr|rrrrrrrrrrrrrrrrsv   ,    0