g3ddlmZmZddlmZddlmZddlmZ ddl m Z m Z m Z mZmZmZmZmZmZddlmZddlmZddlmZdd lmZeeZe d Ze d Zed GddZ eddZ!ee e geefe eee dffZ"GddeZ#Gddeee!Z$Gdde$e!Z%Gdde#Z&Gdde#Z'Gdde&Z(Gdd 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/Gd-d.e%e.e.Z0Gd/d0e'Z1Gd1d2e1Z2Gd3d4e%e1e1Z3Gd5d6e&Z4Gd7d8e4Z5Gd9d:e$e4e4Z6Gd;de7Z8Gd?d@e%e7e7Z9GdAdBe&Z:GdCdDe:Z;GdEdFe$e:e:Zr?rEs r!rDz%_ProxyCounter._create_real_instruments%##DJJ Dr?rEs r!rDz+_ProxyUpDownCounter._create_real_instruments*++ JJ D$5$5  r rd) rrrrrfrr rrrcr{rDrr r!rrs`,0%) Cc5j!CZ(C'" C  C _  r rceZdZdZy)ObservableCounterzAn ObservableCounter is an asynchronous `Instrument` which reports monotonically increasing value(s) when the instrument is being observed. NrVrr r!rr sr rc LeZdZdZ d dedeeedededdf fd ZxZ S) NoOpObservableCounterz,No-op implementation of `ObservableCounter`.Nr&rJr'r(r)c,t|||||yrZr[rNs r!r.zNoOpObservableCounter.__init__ ytMr rP rrrrr8r rrQr.rRrSs@r!rrs\6 48 NNHY/0N N  N  NNr rceZdZdddefdZy)_ProxyObservableCounterrArBr)cz|j|j|j|j|jSr+)create_observable_counterr=rMr>r?rEs r!rDz/_ProxyObservableCounter._create_real_instruments2.. JJT5F5F  r N)rrrrrDrr r!rrs $  r rceZdZdZy)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. NrVrr r!rr'r rc LeZdZdZ d dedeeedededdf fd ZxZ S) NoOpObservableUpDownCounterz2No-op implementation of `ObservableUpDownCounter`.Nr&rJr'r(r)c,t|||||yrZr[rNs r!r.z$NoOpObservableUpDownCounter.__init__1rr rPrrSs@r!rr.s\< 48 NNHY/0N N  N  NNr rceZdZdddefdZy)_ProxyObservableUpDownCounterrArBr)cz|j|j|j|j|jSr+)!create_observable_up_down_counterr=rMr>r?rEs r!rDz5_ProxyObservableUpDownCounter._create_real_instrument?s266 JJT5F5F  r N)rrrrrDrr r!rr;s $  r rc NeZdZdZe ddeeefdee dee ddfdZ 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`r)cyr+rrbs r!recordzHistogram.recordMr/r rd) rrrrrrrfrr rrrrr r!rrGs\ ,0%)  c5j! Z( '"     r rc reZdZdZ d dedededdffd Z d deeefd e e d e e ddffd Z xZ S) NoOpHistogramz$No-op implementation of `Histogram`.r&r'r(r)Nc*t||||yrZr[rjs r!r.zNoOpHistogram.__init__Zrkr r^r_r`c(t||||Srm)rLrros r!rzNoOpHistogram.recordbs w~fW~MMr r7rd)rrrrr8r.rrfrr rrrrRrSs@r!rrWs.  CCC C  C,0%) Nc5j!NZ(N'" N  NNr rc PeZdZ d deeefdeedeeddfdZ ddde fd Z y) _ProxyHistogramNr^r_r`r)cX|jr|jj|||yyr+)r@rrbs r!rz_ProxyHistogram.recordls*   ! ! ( (W E !r rArBcd|j|j|j|jSr+)create_histogramr=r>r?rEs r!rDz'_ProxyHistogram._create_real_instrumentus*%% JJ D$5$5  r rd) rrrrrfrr rrrrrDrr r!rrks`,0%) Fc5j!FZ(F'" F  F _  r rceZdZdZy)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. NrVrr r!rr{rr rc LeZdZdZ d dedeeedededdf fd ZxZ S) NoOpObservableGaugez*No-op implementation of `ObservableGauge`.Nr&rJr'r(r)c,t|||||yrZr[rNs r!r.zNoOpObservableGauge.__init__rr rPrrSs@r!rrs\4 48 NNHY/0N N  N  NNr rceZdZdddefdZy)_ProxyObservableGaugerArBr)cz|j|j|j|j|jSr+)create_observable_gauger=rMr>r?rEs r!rDz-_ProxyObservableGauge._create_real_instruments2,, JJT5F5F  r N)rrrrrDrr r!rrs $  r rc NeZdZdZe ddeeefdee dee ddfdZ y) GaugezdA Gauge is a synchronous `Instrument` which can be used to record non-additive values as they occur.Nr^r_r`r)cyr+rrbs r!setz Gauge.setr/r rd) rrrrrrrfrr rrrrr r!rrsXn,0%)  c5j! Z( '"     r rc reZdZdZ d dedededdffd Z d deeefd e e d e e ddffd Z xZ S) NoOpGaugez"No-op implementation of ``Gauge``.r&r'r(r)Nc*t||||yrZr[rjs r!r.zNoOpGauge.__init__rkr r^r_r`c(t||||Srm)rLrros r!rz NoOpGauge.setrpr r7rd)rrrrr8r.rrfrr rrrrRrSs@r!rrrrr rc PeZdZ d deeefdeedeeddfdZ ddde fd Z y) _ProxyGaugeNr^r_r`r)cX|jr|jj|||yyr+)r@rrbs r!rz_ProxyGauge.setrwr rArBcd|j|j|j|jSr+) create_gauger=r>r?rEs r!rDz#_ProxyGauge._create_real_instruments%!!$**djj$:K:KLLr rd) rrrrrfrr rrrrrDrr r!rrsc,0%) Cc5j!CZ(C'" C  CM_MMr r)=abcrr dataclassesrloggingrrer re_compiletypingrr r r r r rrr opentelemetryropentelemetry.contextr+opentelemetry.metrics._internal.observationropentelemetry.util.typesrr_loggerr2r4rr"rQr#r;rIrUrXr]rhrtr{r~rrrrrrrrrrrrrrrrrr r!rsP$$!$   ")C/ H :; -.  $###m<8  o  5 56 h{#_d:;=  --`IsGK0I2 $#3K#@ $5*5 C: C  k  K'K( O$W-w O  K  K K(  *=9=    N- N  !235F l N"9 N   !89     NIN(  &y19  l N/ N   1    K  KK(MU Mr