U 4Jex,@sddlmZmZddlmZddlmZddlmZ ddl m Z m Z m Z mZmZmZmZmZmZddlmZddlmZddlmZeeZe d Ze d Zed d Gd ddZedddZee egeefe eeedffZ GdddeZ!GdddeeeZ"Gddde"eZ#Gddde!Z$Gddde!Z%Gddde$Z&Gddde&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,Z-Gd,d-d-e#e,e,Z.Gd.d/d/e%Z/Gd0d1d1e/Z0Gd2d3d3e#e/e/Z1Gd4d5d5e$Z2Gd6d7d7e2Z3Gd8d9d9e"e2e2Z4Gd:d;d;e%Z5Gdd?d?e#e5e5Z7dS)@)ABCabstractmethod) dataclass) getLogger)compile) CallableDict GeneratorGenericIterableOptionalSequenceTypeVarUnion)metrics) Observation) Attributesz[a-zA-Z][-_.a-zA-Z0-9]{0,62}z[\x00-\x7F]{0,63}T)frozenc@seZdZUdZdZeed<dS)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)__name__ __module__ __qualname____doc__rfloat__annotations__rrT/tmp/pip-unpacked-wheel-7_167w8m/mysql/opentelemetry/metrics/_internal/instrument.pyr-s r InstrumentT Instrument)boundNc@sNeZdZdZed eeeddddZeeeeeee efdddZ dS) rz7Abstract class that serves as base for all instruments.Nnameunit descriptionreturncCsdSNrselfr#r$r%rrr__init__CszInstrument.__init__cCsni}t|dk r||d<nd|d<|dkr0d}t|dk rH||d<nd|d<|dkrbd|d<n||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$r%) _name_regex fullmatch _unit_regex)r#r$r%resultrrr_check_name_unit_descriptionLs   z'Instrument._check_name_unit_description)r!r!) rrrrrstrr* staticmethodrr r/rrrrr@s c@sFeZdZd eeeddddZddddd Zededd d ZdS) _ProxyInstrumentr!Nr"cCs||_||_||_d|_dSr')_name_unit _description_real_instrumentr(rrrr*qsz_ProxyInstrument.__init__ metrics.Metermeterr&cCs|||_dS)z;Called when a real meter is set on the creating _ProxyMeterN)_create_real_instrumentr6r)r9rrr on_meter_set|sz_ProxyInstrument.on_meter_setcCsdS)z:Create an instance of the real instrument. Implement this.Nrr;rrrr:sz(_ProxyInstrument._create_real_instrument)r!r!) rrrr0r*r<rrr:rrrrr2ps r2cs4eZdZdeeeeeeddfdd ZZS)_ProxyAsynchronousInstrumentNr!r# callbacksr$r%r&cst|||||_dSr')superr* _callbacksr)r#r?r$r% __class__rrr*sz%_ProxyAsynchronousInstrument.__init__)Nr!r!) rrrr0r r CallbackTr* __classcell__rrrCrr=s r=c@seZdZdZdS) Synchronousz*Base class for all synchronous instrumentsNrrrrrrrrrGsrGcs<eZdZdZedeeeeeeddfdd Z Z S) Asynchronousz+Base class for all asynchronous instrumentsNr!r>cstj|||ddSN)r$r%r@r*rBrCrrr*szAsynchronous.__init__)Nr!r!) rrrrrr0r r rEr*rFrrrCrrIs rIc@s4eZdZdZedeeefee ddddZ dS)CounterzOA Counter is a synchronous `Instrument` which supports non-negative increments.Namount attributesr&cCsdSr'rr)rNrOrrraddsz Counter.add)N rrrrrrintrr rrQrrrrrLs rLcsReZdZdZd eeeddfdd Zd eeefe e ddfdd Z Z S) NoOpCounterz"No-op implementation of `Counter`.r!Nr"cstj|||ddSrJrKr(rCrrr*szNoOpCounter.__init__rMcstj||dSN)rOr@rQrPrCrrrQszNoOpCounter.add)r!r!)N rrrrr0r*rrSrr rrQrFrrrCrrTs  rTc@s<eZdZd eeefeeddddZde dddZ dS) _ProxyCounterNrMcCs|jr|j||dSr'r6rQrPrrrrQsz_ProxyCounter.addr7r8cCs||j|j|jSr')Zcreate_counterr3r4r5r;rrrr:sz%_ProxyCounter._create_real_instrument)N) rrrrrSrr rrQrLr:rrrrrXs  rXc@s4eZdZdZedeeefee ddddZ dS) UpDownCounterzXAn UpDownCounter is a synchronous `Instrument` which supports increments and decrements.NrMcCsdSr'rrPrrrrQszUpDownCounter.add)NrRrrrrrZs rZcsReZdZdZd eeeddfdd Zd eeefe e ddfdd Z Z S) NoOpUpDownCounterz(No-op implementation of `UpDownCounter`.r!Nr"cstj|||ddSrJrKr(rCrrr*szNoOpUpDownCounter.__init__rMcstj||dSrUrVrPrCrrrQszNoOpUpDownCounter.add)r!r!)NrWrrrCrr[s  r[c@s<eZdZd eeefeeddddZde dddZ dS) _ProxyUpDownCounterNrMcCs|jr|j||dSr'rYrPrrrrQsz_ProxyUpDownCounter.addr7r8cCs||j|j|jSr')Zcreate_up_down_counterr3r4r5r;rrrr:sz+_ProxyUpDownCounter._create_real_instrument)N) rrrrrSrr rrQrZr:rrrrr\s  r\c@seZdZdZdS)ObservableCounterzAn ObservableCounter is an asynchronous `Instrument` which reports monotonically increasing value(s) when the instrument is being observed. NrHrrrrr]sr]cs8eZdZdZdeeeeeeddfdd ZZ S)NoOpObservableCounterz,No-op implementation of `ObservableCounter`.Nr!r>cstj||||ddSrJrKrBrCrrr*szNoOpObservableCounter.__init__)Nr!r! rrrrr0r r rEr*rFrrrCrr^s r^c@seZdZdedddZdS)_ProxyObservableCounterr7r8cCs||j|j|j|jSr')Zcreate_observable_counterr3rAr4r5r;rrrr:s z/_ProxyObservableCounter._create_real_instrumentN)rrrr]r:rrrrr`sr`c@seZdZdZdS)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. NrHrrrrrasracs8eZdZdZdeeeeeeddfdd ZZ S)NoOpObservableUpDownCounterz2No-op implementation of `ObservableUpDownCounter`.Nr!r>cstj||||ddSrJrKrBrCrrr*%sz$NoOpObservableUpDownCounter.__init__)Nr!r!r_rrrCrrb"s rbc@seZdZdedddZdS)_ProxyObservableUpDownCounterr7r8cCs||j|j|j|jSr')Z!create_observable_up_down_counterr3rAr4r5r;rrrr:3s z5_ProxyObservableUpDownCounter._create_real_instrumentN)rrrrar:rrrrrc/srcc@s4eZdZdZedeeefee ddddZ dS) 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. NrMcCsdSr'rrPrrrrecordAszHistogram.record)N) rrrrrrrSrr rrerrrrrd;s rdcsReZdZdZd eeeddfdd Zd eeefe e ddfdd Z Z S) NoOpHistogramz$No-op implementation of `Histogram`.r!Nr"cstj|||ddSrJrKr(rCrrr*MszNoOpHistogram.__init__rMcstj||dSrU)r@rerPrCrrreUszNoOpHistogram.record)r!r!)N) rrrrr0r*rrSrr rrerFrrrCrrfJs  rfc@s<eZdZd eeefeeddddZde dddZ dS) _ProxyHistogramNrMcCs|jr|j||dSr')r6rerPrrrre^sz_ProxyHistogram.recordr7r8cCs||j|j|jSr')Zcreate_histogramr3r4r5r;rrrr:fsz'_ProxyHistogram._create_real_instrument)N) rrrrrSrr rrerdr:rrrrrg]s  rgc@seZdZdZdS)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. NrHrrrrrhjsrhcs8eZdZdZdeeeeeeddfdd ZZ S)NoOpObservableGaugez*No-op implementation of `ObservableGauge`.Nr!r>cstj||||ddSrJrKrBrCrrr*tszNoOpObservableGauge.__init__)Nr!r!r_rrrCrriqs ric@seZdZdedddZdS)_ProxyObservableGauger7r8cCs||j|j|j|jSr')Zcreate_observable_gauger3rAr4r5r;rrrr:s z-_ProxyObservableGauge._create_real_instrumentN)rrrrhr:rrrrrj~srj)8abcrrZ dataclassesrloggingrrerZ re_compiletypingrrr r r r r rrZmysql.opentelemetryrZ1mysql.opentelemetry.metrics._internal.observationrZmysql.opentelemetry.util.typesrrZ_loggerr+r-rrrErr2r=rGrIrLrTrXrZr[r\r]r^r`rarbrcrdrfrgrhrirjrrrrsd   ,    0