o Y۷i8B@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;Zrrrr=z(_ProxyInstrument._create_real_instrumentr3)r;r<r(N) rrrr4r-r?rr!r=rrrrr6ys r6c sBeZdZ   d dedeeedededdf fdd ZZS) _ProxyAsynchronousInstrumentNr$r% callbacksr&r'r(cst|||||_dSr*)superr- _callbacksr,r%rCr&r' __class__rrr-s z%_ProxyAsynchronousInstrument.__init__Nr$r$) rrrr4r r CallbackTr- __classcell__rrrGrrBs rBc@eZdZdZdS) Synchronousz*Base class for all synchronous instrumentsNrrrr rrrrrMrMc sJeZdZdZe   d dedeeedededdf fd d Z Z S) Asynchronousz+Base class for all asynchronous instrumentsNr$r%rCr&r'r(cstj|||ddSN)r&r'rDr-rFrGrrr-szAsynchronous.__init__rI) rrrr rr4r r rJr-rKrrrGrrPs" rPc @DeZdZdZe  d deeefdee dee ddfddZ dS) CounterzOA Counter is a synchronous `Instrument` which supports non-negative increments.Namount attributescontextr(cCr@)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,rUrVrWrrraddrAz Counter.addNN rrrr rrintrr rrrYrrrrrT rTc 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|||ddSrQrRr+rGrrr-zNoOpCounter.__init__rUrVrWctj|||dSN)rVrWrDrYrXrGrrrYzNoOpCounter.addr3rZrrrr r4r-rr\rr rrrYrKrrrGrr_0  r_c @NeZdZ  d deeefdeedeeddfddZ dd de fd d Z dS) _ProxyCounterNrUrVrWr(cC|jr |j|||dSdSr*r:rYrXrrrrYz_ProxyCounter.addr;r<cC||j|j|jSr*)create_counterr7r8r9r>rrrr= z%_ProxyCounter._create_real_instrumentrZ) rrrrr\rr rrrYrTr=rrrrri   ric @rS) UpDownCounterzXAn UpDownCounter is a synchronous `Instrument` which supports increments and decrements.NrUrVrWr(cCr@)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. NrrXrrrrYrAzUpDownCounter.addrZr[rrrrrqr]rqc r^)NoOpUpDownCounterz(No-op implementation of `UpDownCounter`.r$r%r&r'r(Ncr`rQrRr+rGrrr-razNoOpUpDownCounter.__init__rUrVrWcrbrcrdrXrGrrrY rezNoOpUpDownCounter.addr3rZrfrrrGrrrrgrrc @rh) _ProxyUpDownCounterNrUrVrWr(cCrjr*rkrXrrrrYrlz_ProxyUpDownCounter.addr;r<cCrmr*)create_up_down_counterr7r8r9r>rrrr= roz+_ProxyUpDownCounter._create_real_instrumentrZ) rrrrr\rr rrrYrqr=rrrrrsrprsc@rL)ObservableCounterzAn ObservableCounter is an asynchronous `Instrument` which reports monotonically increasing value(s) when the instrument is being observed. NrNrrrrru(rOruc FeZdZdZ   d dedeeedededdf fd d ZZ S) NoOpObservableCounterz,No-op implementation of `ObservableCounter`.Nr$r%rCr&r'r(ctj||||ddSrQrRrFrGrrr-1  zNoOpObservableCounter.__init__rI rrrr r4r r rJr-rKrrrGrrw.  rwc@eZdZdddefddZdS)_ProxyObservableCounterr;r<r(cC||j|j|j|jSr*)create_observable_counterr7rEr8r9r>rrrr=C z/_ProxyObservableCounter._create_real_instrumentN)rrrrur=rrrrr}@s r}c@rL)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. NrNrrrrrNrOrc rv) NoOpObservableUpDownCounterz2No-op implementation of `ObservableUpDownCounter`.Nr$r%rCr&r'r(crxrQrRrFrGrrr-Xryz$NoOpObservableUpDownCounter.__init__rIrzrrrGrrUr{rc@r|)_ProxyObservableUpDownCounterr;r<r(cCr~r*)!create_observable_up_down_counterr7rEr8r9r>rrrr=krz5_ProxyObservableUpDownCounter._create_real_instrumentN)rrrrr=rrrrrg 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-|szHistogram.__init__rUrVrWcCr@)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. NrrXrrrrecordrAzHistogram.recordr$r$NrZ)rrrr rr4r r rr-rr\rrrrrrrrvs:    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(crx)N)r&r'rrRrrGrrr-ryzNoOpHistogram.__init__rUrVrWcrbrc)rDrrXrGrrrrezNoOpHistogram.recordrrZ)rrrr r4r r rr-rr\rrrrKrrrGrrs6  rc seZdZ   ddedededeeeddf fdd Z  dd ee efd ee d ee ddfd dZ ddde fddZZS)_ProxyHistogramr$Nr%r&r'rr(cstj|||d||_dSrQ)rDr-$_explicit_bucket_boundaries_advisoryrrGrrr-sz_ProxyHistogram.__init__rUrVrWcCrjr*)r:rrXrrrrrlz_ProxyHistogram.recordr;r<cCs|j|j|j|j|jdS)N)r)create_histogramr7r8r9rr>rrrr=s z'_ProxyHistogram._create_real_instrumentrrZ)rrrr4r r rr-rr\rrrrr=rKrrrGrrs6    rc@rL)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. NrNrrrrrrOrc rv) NoOpObservableGaugez*No-op implementation of `ObservableGauge`.Nr$r%rCr&r'r(crxrQrRrFrGrrr-ryzNoOpObservableGauge.__init__rIrzrrrGrrr{rc@r|)_ProxyObservableGauger;r<r(cCr~r*)create_observable_gauger7rEr8r9r>rrrr=rz-_ProxyObservableGauge._create_real_instrumentN)rrrrr=rrrrrrrc @rS) GaugezdA Gauge is a synchronous `Instrument` which can be used to record non-additive values as they occur.NrUrVrWr(cCr@)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. NrrXrrrsetrAz Gauge.setrZ) rrrr rrr\rr rrrrrrrrr]rc r^) NoOpGaugez"No-op implementation of ``Gauge``.r$r%r&r'r(Ncr`rQrRr+rGrrr-razNoOpGauge.__init__rUrVrWcrbrc)rDrrXrGrrr!rez NoOpGauge.setr3rZ)rrrr r4r-rr\rr rrrrKrrrGrrrgrc @rh) _ProxyGaugeNrUrVrWr(cCrjr*)r:rrXrrrr.rlz_ProxyGauge.setr;r<cCrmr*) create_gauger7r8r9r>rrrr=7roz#_ProxyGauge._create_real_instrumentrZ) rrrrr\rr rrrrr=rrrrr*s   r)>abcrr dataclassesrloggingrrer re_compiletypingrrr r r r r rr opentelemetryropentelemetry.contextr+opentelemetry.metrics._internal.observationropentelemetry.util.typesrr_loggerr.r0rrr!rJr"r6rBrMrPrTr_rirqrrrsrurwr}rrrrrrrrrrrrrrrrsv   ,    0   '