o #fx,@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__rrf/home/ubuntu/dev/venv/lib/python3.10/site-packages/mysql/opentelemetry/metrics/_internal/instrument.pyr-s r InstrumentT Instrument)boundNc @s^eZdZdZe  d dedededdfdd Zededededeee effd d Z dS) rz7Abstract class that serves as base for all instruments.nameunit descriptionreturnNcCdSNrselfr"r#r$rrr__init__CszInstrument.__init__cCspi}t|dur||d<nd|d<|durd}t|dur$||d<nd|d<|dur2d|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#r$) _name_regex fullmatch _unit_regex)r"r#r$resultrrr_check_name_unit_descriptionLs  z'Instrument._check_name_unit_descriptionr!r!) rrrrrstrr* staticmethodrr r/rrrrr@s0 c @sLeZdZ  ddedededdfddZdd d Zed d defd dZdS)_ProxyInstrumentr!r"r#r$r%NcCs||_||_||_d|_dSr')_name_unit _description_real_instrumentr(rrrr*qs z_ProxyInstrument.__init__meter metrics.MetercCs|||_dS)z;Called when a real meter is set on the creating _ProxyMeterN)_create_real_instrumentr7r)r8rrr on_meter_set|sz_ProxyInstrument.on_meter_setcCsdS)z:Create an instance of the real instrument. Implement this.Nrr;rrrr:sz(_ProxyInstrument._create_real_instrumentr0)r8r9r%N) rrrr1r*r<rrr:rrrrr3ps r3c sBeZdZ   d dedeeedededdf fdd ZZS) _ProxyAsynchronousInstrumentNr!r" callbacksr#r$r%cst|||||_dSr')superr* _callbacksr)r"r>r#r$ __class__rrr*s z%_ProxyAsynchronousInstrument.__init__Nr!r!) rrrr1r r CallbackTr* __classcell__rrrBrr=s r=c@eZdZdZdS) Synchronousz*Base class for all synchronous instrumentsNrrrrrrrrrHrHc sJeZdZdZe   d dedeeedededdf fd d Z Z S) Asynchronousz+Base class for all asynchronous instrumentsNr!r"r>r#r$r%cstj|||ddSN)r#r$r?r*rArBrrr*szAsynchronous.__init__rD) rrrrrr1r r rEr*rFrrrBrrKs" rKc@:eZdZdZe ddeeefdee ddfddZ dS) CounterzOA Counter is a synchronous `Instrument` which supports non-negative increments.Namount attributesr%cCr&r'rr)rPrQrrraddz Counter.addr' rrrrrrintrr rrSrrrrrO rOc beZdZdZ  ddedededdffdd Z dd eeefd e e ddffd d Z Z S) NoOpCounterz"No-op implementation of `Counter`.r!r"r#r$r%Nctj|||ddSrLrMr(rBrrr*zNoOpCounter.__init__rPrQctj||dSN)rQr?rSrRrBrrrSzNoOpCounter.addr0r' rrrrr1r*rrVrr rrSrFrrrBrrY*  rYc@DeZdZ d deeefdeeddfddZddde fd d Z dS) _ProxyCounterNrPrQr%cC|jr |j||dSdSr'r7rSrRrrrrSz_ProxyCounter.addr8r9cC||j|j|jSr')create_counterr4r5r6r;rrrr:z%_ProxyCounter._create_real_instrumentr') rrrrrVrr rrSrOr:rrrrrc  rcc@rN) UpDownCounterzXAn UpDownCounter is a synchronous `Instrument` which supports increments and decrements.NrPrQr%cCr&r'rrRrrrrSrTzUpDownCounter.addr'rUrrrrrkrWrkc rX)NoOpUpDownCounterz(No-op implementation of `UpDownCounter`.r!r"r#r$r%NcrZrLrMr(rBrrr*r[zNoOpUpDownCounter.__init__rPrQcr\r]r^rRrBrrrSr_zNoOpUpDownCounter.addr0r'r`rrrBrrlrarlc@rb) _ProxyUpDownCounterNrPrQr%cCrdr'rerRrrrrSrfz_ProxyUpDownCounter.addr8r9cCrgr')create_up_down_counterr4r5r6r;rrrr:riz+_ProxyUpDownCounter._create_real_instrumentr') rrrrrVrr rrSrkr:rrrrrmrjrmc@rG)ObservableCounterzAn ObservableCounter is an asynchronous `Instrument` which reports monotonically increasing value(s) when the instrument is being observed. NrIrrrrrorJroc FeZdZdZ   d dedeeedededdf fd d ZZ S) NoOpObservableCounterz,No-op implementation of `ObservableCounter`.Nr!r"r>r#r$r%ctj||||ddSrLrMrArBrrr*zNoOpObservableCounter.__init__rD rrrrr1r r rEr*rFrrrBrrq  rqc@eZdZdddefddZdS)_ProxyObservableCounterr8r9r%cC||j|j|j|jSr')create_observable_counterr4r@r5r6r;rrrr:z/_ProxyObservableCounter._create_real_instrumentN)rrrror:rrrrrwsrwc@rG)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. NrIrrrrr{rJr{c rp) NoOpObservableUpDownCounterz2No-op implementation of `ObservableUpDownCounter`.Nr!r"r>r#r$r%crrrLrMrArBrrr*%rsz$NoOpObservableUpDownCounter.__init__rDrtrrrBrr|"rur|c@rv)_ProxyObservableUpDownCounterr8r9r%cCrxr')!create_observable_up_down_counterr4r@r5r6r;rrrr:3sz5_ProxyObservableUpDownCounter._create_real_instrumentN)rrrr{r:rrrrr}/s r}c@rN) 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. NrPrQr%cCr&r'rrRrrrrecordArTzHistogram.recordr') rrrrrrrVrr rrrrrrr;s rc rX) NoOpHistogramz$No-op implementation of `Histogram`.r!r"r#r$r%NcrZrLrMr(rBrrr*Mr[zNoOpHistogram.__init__rPrQcr\r])r?rrRrBrrrUr_zNoOpHistogram.recordr0r') rrrrr1r*rrVrr rrrFrrrBrrJrarc@rb) _ProxyHistogramNrPrQr%cCrdr')r7rrRrrrr^rfz_ProxyHistogram.recordr8r9cCrgr')create_histogramr4r5r6r;rrrr:friz'_ProxyHistogram._create_real_instrumentr') rrrrrVrr rrrr:rrrrr]rjrc@rG)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. NrIrrrrrjrJrc rp) NoOpObservableGaugez*No-op implementation of `ObservableGauge`.Nr!r"r>r#r$r%crrrLrMrArBrrr*trszNoOpObservableGauge.__init__rDrtrrrBrrqrurc@rv)_ProxyObservableGauger8r9r%cCrxr')create_observable_gauger4r@r5r6r;rrrr:rzz-_ProxyObservableGauge._create_real_instrumentN)rrrrr:rrrrr~sr)8abcrr dataclassesrloggingrrer re_compiletypingrrr r r r r rrmysql.opentelemetryr1mysql.opentelemetry.metrics._internal.observationrmysql.opentelemetry.util.typesrr_loggerr+r-rrrErr3r=rHrKrOrYrcrkrlrmrorqrwr{r|r}rrrrrrrrrrsd   ,   0