h`kSSKrSSKJr SSKrSSKrSSKJrJrJrJ r J r J r J r J r JrJrJrJr SSKrSSKJr SSKJrJrJr SSKJr SSKJrJrJr SS KJ r J!r! SS K"J#r#J$r$ SS K%J&r&J'r'J(r( \"S S S9r)\"S\S\4S9r*Sr+S\,4Sjr-\-"5q.Sr/Sr0"SS \5r1"SS\15r2"SS\15r3"SS\15r4"SS\15r5"SS \15r6"S!S"\15r7g)#N)Lock) AnyCallableDictIterableListLiteralOptionalSequenceTupleTypeTypeVarUnion)values)ExceptionCounterInprogressTrackerTimer)Metric) CollectorCollectorRegistryREGISTRY)ExemplarSample)floatToGoStringINF)_validate_exemplar_validate_labelnames_validate_metric_nameTMetricWrapperBase)boundF.c6U(d [S5eSnU(aXRS-- nU(aXSS-- nXQ- nUS:XaURS5(aUSSnU(a!URSU-5(dUSU-- nU(aUS;a[SU-5eU$) NzMetric name should not be empty_counter_totali)infostatesetz2Metric name is of a type that cannot have a unit: ) ValueErrorendswith) metric_typename namespace subsystemunit full_names lC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\prometheus_client/metrics.py_build_full_namer4s :;;I_$ _$  IiI$6$6x$@$@crN  I&&sTz22S4Z  33MPYYZZ returncd[RRSS5R5S;$)N!PROMETHEUS_DISABLE_CREATED_SERIESFalse)true1t)osenvirongetlowerr5r3_get_use_createdrB,s' ::>>=w G M M OWi iir5cSqg)zJDisable exporting _created metrics on counters, histograms, and summaries.FN _use_createdrAr5r3disable_created_metricsrF3s Lr5cSqg)zIEnable exporting _created metrics on counters, histograms, and summaries.TNrDrAr5r3enable_created_metricsrH9s Lr5cl\rSrSr%Sr\\\S'Sr\ \\S'Sr Sr Sr S r S \\4S jrS \\4S jrS \4S jrS \4SjrSSSS\S4S\S\S\S\\S\S\S\S\\S\\ \S S4SjjrS\S\S\S \4SjrS\S S4SjrS$SjrS \\4SjrS \\4S jrS \\4S!jrS"r S#r!g)%r!?N_typerA_reserved_labelnamescpUR(+=(d UR=(a UR$N _labelnames _labelvaluesselfs r3_is_observable MetricWrapperBase._is_observableCs)###O(8(8(NT=N=NOr5cpUR5(d![S[UR5-5eg)Nz!%s metric is missing label values)rTr+strrKrRs r3_raise_if_not_observable*MetricWrapperBase._raise_if_not_observableIs1""$$@3tzz?RS S%r5cJUR=(a UR(+$rNrOrRs r3 _is_parentMetricWrapperBase._is_parentPs9(9(9$99r5cn[URURURUR5$rN)r_name_documentationrK_unitrRs r3 _get_metricMetricWrapperBase._get_metricSs%djj$"5"5tzz4::NNr5r6c$UR5/$rN)rarRs r3describeMetricWrapperBase.describeVs  "##r5c UR5nUR5H(up#pEpgURURU-X4XVU5 M* U/$rN)ra_samples add_sampler^)rSmetricsuffixlabelsvalue timestampexemplarnative_histogram_values r3collectMetricWrapperBase.collectYsQ!!#RVR_R_Ra NFEh   djj616)Wm nSbxr5c8URSUR3$)N:)rKr^rRs r3__str__MetricWrapperBase.__str___s**Qtzzl++r5cj[U5nURSURSURS3$)N.())type __module____name__r^)rSr-s r3__repr__MetricWrapperBase.__repr__bs64j (();+?+?*@$**QOOr5r%rSr. documentation labelnamesr/r0r1registryrQc [URXXV5Ul[X5Ul[ U=(d S5Ul0UlX lX`l [UR5 UR5(a[5Ul 0UlUR5(aUR!5 UR (dU(aUR#U5 ggg)NrA)r4rKr^rrPtuplerQ_kwargsr_r`rr[r_lock_metricsrT _metric_initregister) rSr.rrr/r0r1rrQs r3__init__MetricWrapperBase.__init__fs&djj$9S /A!,"4"5') + djj) ??  DJ46DM         !!$'!r5 labelvalues labelkwargsc x^UR(d[SU-5eUR(aB[SRU[ [ URUR5555eU(aT(a [S5eT(aM[ T5[ UR5:wa [S5e[U4SjUR55nO?[U5[UR5:wa [S5e[SU55nUR XR;aWUR"UR4URURURUS.URD6URU'URUsS S S 5 $!,(df  g =f) aReturn the child for the given labelset. All metrics can have labels, allowing grouping of related time series. Taking a counter as an example: from prometheus_client import Counter c = Counter('my_requests_total', 'HTTP Failures', ['method', 'endpoint']) c.labels('get', '/').inc() c.labels('post', '/submit').inc() Labels can also be provided as keyword arguments: from prometheus_client import Counter c = Counter('my_requests_total', 'HTTP Failures', ['method', 'endpoint']) c.labels(method='get', endpoint='/').inc() c.labels(method='post', endpoint='/submit').inc() See the best practices on [naming](http://prometheus.io/docs/practices/naming/) and [labels](http://prometheus.io/docs/practices/instrumentation/#use-labels). ,No label names were set when constructing %sz@{} already has labels set ({}); can not chain calls to .labels()z"Can't pass both *args and **kwargszIncorrect label namesc3@># UHn[TU5v M g7frNrW).0lrs r3 +MetricWrapperBase.labels..sN=MKN 3 3=MszIncorrect label countc38# UHn[U5v M g7frNrrrs r3rrs< 1A )rrr1rQN)rPr+rQformatdictzipsortedrlenrr __class__r^r_r`r)rSrrs `r3rkMetricWrapperBase.labelss[.KdRS S   _ffS))4+<+<=>  ;AB B k"fT-=-=&>> !899NT=M=MNNK;3t'7'7#88 !899< <.s8KqCFFKr) r=r>warningswarn UserWarningrPr+rrrr)rSrs r3removeMetricWrapperBase.removes % 37QUWU_U_7_ MMX KdRS S8 { s4#3#34 4JcRVRbRbNcepMqqr r8K88 ZZmm+MM+.ZZs C-- C;cS[R;dS[R;a[R"S[5 UR  0UlSSS5 g!,(df  g=f)z$Remove all labelsets from the metricrrzBClearing labels has not been implemented in multi-process mode yetN)r=r>rrrrrrRs r3clearMetricWrapperBase.clearsI % 37QUWU_U_7_ MMT ZZDMZZs A!! A/clUR5(aUR5$UR5$rN)r[_multi_samples_child_samplesrRs r3rgMetricWrapperBase._sampless- ??  &&( (&&( (r5c ## UR URR5nSSS5 WR5Hrup#[ [ UR U55nUR5H:upVpxp[U[U[ UR55-5XxX5v M< Mt g!,(df  N=f7frN) rrcopyitemslistrrPrgrr) rSmetricsrkri series_labelsrj sample_labelsrlrmrnros r3r MetricWrapperBase._multi_sampless ZZmm((*G%mmoNF T%5%5v!>?M]c]l]l]nYuVT-$}?R?R?T:U*U%VX]jrLL^o.Zs C B9BC 9 CC c[SU-5e)Nz*_child_samples() must be implemented by %rNotImplementedErrorrRs r3r MetricWrapperBase._child_sampless!"NQU"UVVr5c[SU-5e)z Initialize the metric object as a child, i.e. when it has labels (if any) set. This is factored as a separate function to allow for deferred initialization. z(_metric_init() must be implemented by %rrrRs r3rMetricWrapperBase._metric_inits ""Lt"STTr5)r_rrPrQrrr^r`r6N)"r|r{ __qualname____firstlineno__rKr rW__annotations__rLr rTrXr[rarrrdrprtr}rr rrrrkrrrrgrrr__static_attributes__rAr5r3r!r!?ssE8C=*,(3-,P T:O$(6*$&) ,,P#P.0"$"$9A9=(q(( #(&c]( (  (  ($$56( ( 6((@5.Q5.c5.#5.!5.n/3/4/")(6*) L 0LW 0WUr5c\rSrSrSrSrSSjrSS\S\\ \ \ 4SS4S jjr SS jr \ 4S \\\\\\S 44S\4S jjrS\\4SjrSrg)CounteraA Counter tracks counts of events or running totals. Example use cases for Counters: - Number of requests processed - Number of items that were inserted into a queue - Total amount of data that a system has processed Counters can only go up (and be reset when the process restarts). If your use case can go down, you should use a Gauge instead. An example for a Counter: from prometheus_client import Counter c = Counter('my_failures_total', 'Description of counter') c.inc() # Increment by 1 c.inc(1.6) # Increment by given value There are utilities to count exceptions raised: @c.count_exceptions() def f(): pass with c.count_exceptions(): pass # Count only one type of exception with c.count_exceptions(ValueError): pass You can also reset the counter to zero in case your logical "process" restarts without restarting the actual python process. c.reset() r'r6Nc[R"URURURS-URUR UR 5Ul[R"5Ul g)Nr() r ValueClassrKr^rPrQr__valuetime_createdrRs r3rCounter._metric_initsS'' DJJ X@UW[WgWg(,(9(94;N;NP   r5amountrncUR5 US:a [S5eURRU5 U(aD[ U5 URR [ X![R"555 gg)z&Increment counter by the given amount.rz9Counters can only be incremented by non-negative amounts.N)rXr+rincr set_exemplarrr)rSrrns r3r Counter.incs` %%' A:XY Y   x ( KK $ $Xh %L M r5cnURRS5 [R"5Ulg)zqReset the counter to zero. Use this when a logical process restarts without restarting the actual python process.rN)rsetrrrRs r3reset Counter.reset(s   r5 exception.c8UR5 [X5$)zCount exceptions in a block of code or function. Can be used as a function decorator or context manager. Increments the counter when an exception of the given type is raised up out of the code. )rXr)rSrs r3count_exceptionsCounter.count_exceptions-s %%'00r5c[S0URR5SURR55n[(aU[S0UR SS54$U4$)Nr(r)rrr? get_exemplarrEr)rSsamples r3rCounter._child_samples7s\"dkkoo&7t{{?W?W?YZ <z2t}}dDA yr5)rrr)rN)r|r{rr__doc__rKrfloatr rrWrr Exceptionrr BaseExceptionr rrrrrrrAr5r3rrs$J E$ N%NxS#X/GNSWN$ ir1%]0CU4P]K^`cKcEd0d*e1wG1 0r5rcF^\rSrSrSrSr\"S5r\"S5rSSSS\ SS 4S \ S \ S \ \ S \ S\ S\ S\ \ S\ \\ S\S4U4SjjjrS"SjrS#S\SS4SjjrS#S\SS4SjjrS\SS4SjrS"SjrS\4SjrS\4SjrS\/\4SS4SjrS\ \4S jrS!rU=r $)$GaugeiAaEGauge metric, to report instantaneous values. Examples of Gauges include: - Inprogress requests - Number of items in a queue - Free memory - Total memory - Temperature Gauges can go both up and down. from prometheus_client import Gauge g = Gauge('my_inprogress_requests', 'Description of gauge') g.inc() # Increment by 1 g.dec(10) # Decrement by given value g.set(4.2) # Set to a given value There are utilities for common use cases: g.set_to_current_time() # Set to current unixtime # Increment when entered, decrement when exited. @g.track_inprogress() def f(): pass with g.track_inprogress(): pass A Gauge can also take its value from a callback: d = Gauge('data_objects', 'Number of objects') my_dict = {} d.set_function(lambda: len(my_dict)) gauge) allliveallminliveminmaxlivemaxsumlivesum mostrecentlivemostrecent)rrrAr%Nrr.rrr/r0r1rrQmultiprocess_modec >XlXR;a[SU -5e[T U]UUUUUUUUS9 URUR S'URUR ;Ulg)NzInvalid multiprocess mode: r.rrr/r0r1rrQr)_multiprocess_mode_MULTIPROC_MODESr+superrr_MOST_RECENT_MODES_is_most_recent) rSr.rrr/r0r1rrQrrs r3rGauge.__init__js#4 $9$9 9:=NNO O '!%  -1,C,C ()#66$:Q:QQr5r6c [R"URURURURUR UR URS9Ulg)N)r) rrrKr^rPrQr_rrrRs r3rGauge._metric_initsH'' JJ DJJ0@0@$BSBS   43J3J  r5rcUR(a [S5eUR5 URR U5 g)z$Increment gauge by the given amount.z-inc must not be used with the mostrecent modeNr RuntimeErrorrXrrrSrs r3r Gauge.incs3   NO O %%' r5cUR(a [S5eUR5 URR U*5 g)z$Decrement gauge by the given amount.z-dec must not be used with the mostrecent modeNrrs r3dec Gauge.decs5   NO O %%'  r5rlcUR5 UR(a7URR[ U5[ R "5S9 gURR[ U55 g)zSet gauge to the given value.)rmN)rXrrrrr)rSrls r3r Gauge.setsI %%'    KKOOE%LDIIKO @ KKOOE%L )r5cLUR[R"55 g)z"Set gauge to the current unixtime.N)rrrRs r3set_to_current_timeGauge.set_to_current_times r5c8UR5 [U5$)zTrack inprogress blocks of code or functions. Can be used as a function decorator or context manager. Increments the gauge when the code is entered, and decrements when it is exited. )rXrrRs r3track_inprogressGauge.track_inprogresss %%' &&r5c[US5$)z|Time a block of code or function, and set the duration in seconds. Can be used as a function decorator or context manager. rrrRs r3r Gauge.times T5!!r5fc^UR5 S[S[[4U4Sjjn[R "X 5Ulg)zCall the provided function to return the Gauge value. The function must return a float, and may be called from multiple threads. All other methods of the Gauge become NOOPs. r&r6c@>[S0[T"55SS54$Nr%)rr)r&r s r3samples#Gauge.set_function..sampless2r5:tT:<  %%' =u =&!1 =$..w=r5cR[S0URR5SS54$r)rrr?rRs r3rGauge._child_sampless#r2t{{0$=??r5)rrrrr)r)!r|r{rrrrK frozensetrrrrWrr rr r rrrrrrrrrrrrrrrr __classcell__rs@r3rrAsd#H E "JK"#CD .0"$"$9A9=W\RR #R&c]R R  R  R$$56R ( 6R%,-S%TRR6  %  !%!!**4*'"3'"e" >hr5y1 >d >@ 0@@r5rc`\rSrSrSrSrS/rS SjrS\SS4S jr S\ 4S jr S\ \ 4S jrS rg)SummaryiaA Summary tracks the size and number of events. Example use cases for Summaries: - Response latency - Request size Example for a Summary: from prometheus_client import Summary s = Summary('request_size_bytes', 'Request size (bytes)') s.observe(512) # Observe 512 (bytes) Example for a Summary using time: from prometheus_client import Summary REQUEST_TIME = Summary('response_latency_seconds', 'Response latency (seconds)') @REQUEST_TIME.time() def create_response(request): '''A dummy function''' time.sleep(1) Example for using the same Summary object as a context manager: with REQUEST_TIME.time(): pass # Logic to be timed summaryquantiler6Nc[R"URURURS-URUR UR 5Ul[R"URURURS-URUR UR 5Ul[R"5Ul g)N_count_sum) rrrKr^rPrQr_r r!rrrRs r3rSummary._metric_inits'' DJJ X@UW[WgWg(,(9(94;N;NP %%djj$**djj6>QSWScSceievevx|yLyLM   r5rcUR5 URRS5 URRU5 ga.Observe the given amount. The amount is usually positive or zero. Negative values are accepted but prevent current versions of Prometheus from properly detecting counter resets in the sum of observations. See https://prometheus.io/docs/practices/histograms/#count-and-sum-of-observations for details. rN)rXr rr!rs r3observeSummary.observes0 %%'  fr5c[US5$zTime a block of code or function, and observe the duration in seconds. Can be used as a function decorator or context manager. r%r rRs r3r Summary.time T9%%r5c [S0URR5SS5[S0URR5SS5/n[(a(UR [S0UR SS55 [U5$)Nr r!r)rr r?r!rEappendrr)rSrs r3rSummary._child_samplessl 8R!2D$ ? 62tyy}}d ;  < NN6*b$--tL MW~r5)r rr!r)r|r{rrrrKrLrrr%rrrrrrrAr5r3rrsK: E&<$ e  &e& 0r5rc2^\rSrSrSrSrS/rSSSSS S S S S SSSSS\4rSSSS\ S\4S\ S\ S\ \ S\ S\ S\ S\ \ S\ \\ S\\\\ 44U4SjjjrS \\\\ 4S!S4S"jrS*S#jrS+S$\S%\ \\ \ 4S!S4S&jjrS!\4S'jrS!\ \4S(jrS)rU=r$), HistogramiaA Histogram tracks the size and number of events in buckets. You can use Histograms for aggregatable calculation of quantiles. Example use cases: - Response latency - Request size Example for a Histogram: from prometheus_client import Histogram h = Histogram('request_size_bytes', 'Request size (bytes)') h.observe(512) # Observe 512 (bytes) Example for a Histogram using time: from prometheus_client import Histogram REQUEST_TIME = Histogram('response_latency_seconds', 'Response latency (seconds)') @REQUEST_TIME.time() def create_response(request): '''A dummy function''' time.sleep(1) Example of using the same Histogram object as a context manager: with REQUEST_TIME.time(): pass # Logic to be timed The default buckets are intended to cover a typical web/rpc request from milliseconds to seconds. They can be overridden by passing `buckets` keyword argument to `Histogram`. histogramleg{Gzt?g{Gz?g?g?g333333?g?g?g?g??g@g@g@g$@rAr%Nr.rrr/r0r1rrQbucketsc l>URU 5 [T U] UUUUUUUUS9 XRS'g)Nrr3)_prepare_bucketsrrr) rSr.rrr/r0r1rrQr3rs r3rHistogram.__init__5sK g& '!%  #* Yr5source_bucketsr6c UVs/sHn[U5PM nnU[U5:wa [S5eU(a"US[:waUR [5 [ U5S:a [S5eX0lgs snf)NzBuckets not in sorted orderzMust have at least two buckets)rrr+rr,r _upper_bounds)rSr7br3s r3r5Histogram._prepare_bucketsMsq%34^58^4 fWo %:; ; wr{c) NN3  w >$5sBc 4/Ul[R"5UlURS-n[R "UR URURS-URURUR5Ul URHynURR[R "UR URURS-UUR[U54-UR55 M{ g)N)r1r!_bucket)_bucketsrrrPrrrKr^rQr_r!r;r,r)rSbucket_labelnamesr<s r3rHistogram._metric_initYs13    ,,w6%%djj$**djj6>QSWScSceievevx|yLyLM ##A MM !2!2   Y&!!!_Q%7$99## "% $r5rrnc zUR5 URRU5 [UR5Hwup4X::dM UR URS5 U(aF[ U5 UR UR[X![R"555 g gr$) rXr!r enumerater;r@rrrr)rSrrnir"s r3r%Histogram.observehs %%' f!$"4"45HA a $$Q'&x0MM!$11(8TYY[2YZ 6r5c[US5$r(r rRs r3rHistogram.time|r*r5c V/nSn[UR5Hhup4X RUR5- nUR [ SS[ U50USURUR555 Mj UR [ S0USS55 URSS:a6UR [ S0URR5SS55 [(a(UR [ S0URSS55 [U5$)Ngr?r1r rr!r) rDr;r@r?r,rrrr!rErr)rSraccrEr"s r3rHistogram._child_sampless!$"4"45HA ==#'') )C NN6)dOE4J-KSRVX\XeXefgXhXuXuXwx y6 vhCt<=   a A % NN6&"diimmotTJ K < NN6*b$--tL MW~r5)r@rr!r;rrN)r|r{rrrrKrLrDEFAULT_BUCKETSrrWrr rr rrrr5rrr%rrrrrrrs@r3r/r/sG!D E 6S$T2sBS#sTWY]_bcO .0"$"$9A9=8G** #*&c]* *  *  *$$56* ( 6*#5#45**0 %xeSj8I/J %t % exS#X/GSW(&e&  0  r5r/cR\rSrSrSrSrSrS\\\4SS4Sjr S\ \ 4S jr S r g) InfoiaVInfo metric, key-value pairs. Examples of Info include: - Build information - Version information - Potential target metadata Example usage: from prometheus_client import Info i = Info('my_build', 'Description of info') i.info({'version': '1.2.3', 'buildhost': 'foo@bar'}) Info metrics do not work in multiprocess mode. r)cd[UR5Ul[5Ul0UlgrN)rrP_labelname_setrrrrRs r3rInfo._metric_inits%!$"2"23V  r5valr6NcvURRUR55(a%[SR UR U55e[ SUR555(a [S5eUR [U5Ul SSS5 g!,(df  g=f)zSet info metric.z8Overlapping labels for Info metric, metric: {} child: {}c3(# UHoSLv M g7frNrA)rrEs r3rInfo.info..s/,QDy,szLabel value cannot be NoneN) rP intersectionkeysr+rrPanyrrrr)rSrRs r3r) Info.infos    + +CHHJ 7 7W^^  #'( ( /#**,/ / /9: : ZZs)DKZZs B** B8cUR [SURSSS54sSSS5 $!,(df  g=f)N_infor2)rrrrRs r3rInfo._child_sampless* ZZ7DKKdDACZZs1 ?)rPrr)r|r{rrrrKrrrWr)rrrrrAr5r3rNrNsA E $S#X$4$D 0Dr5rNc^\rSrSrSrSrSSSS\SS4S\S\S \\S \S \S \S \ \ S\ \\S\ \\4U4Sjjjr SSjr S\SS4Sjr S\\4SjrSrU=r$)Enumia9Enum metric, which of a set of states is true. Example usage: from prometheus_client import Enum e = Enum('task_state', 'Description of enum', states=['starting', 'running', 'stopped']) e.state('running') The first listed state will be the default. Enum metrics do not work in multiprocess mode. r*rAr%Nr.rrr/r0r1rrQstatesc >[T U]UUUUUUUUS9 X;a[SU35eU (d[SU35eU =URS'Ulg)Nrz$Overlapping labels for Enum metric: z$No states provided for Enum metric: r_)rrr+r_states) rSr.rrr/r0r1rrQr_rs r3r Enum.__init__su '!%    CD6JK KCD6JK K066 Xr5r6c0SUl[5Ulg)Nr)rrrrRs r3rEnum._metric_inits V r5statecUR5 UR URRU5UlSSS5 g!,(df  g=f)zSet enum metric state.N)rXrraindexr)rSres r3re Enum.states5 %%' ZZ,,,,U3DKZZs !A Ac UR [UR5VVs/sH1up[SURU0XR :XaSOSSS5PM3 snnsSSS5 $s snnf!,(df  g=f)Nr%rr)rrDrarr^r)rSrEss r3rEnum._child_samplessk ZZT\\*+ArDJJ?kk1AAq$PTU*ZZsA18A+A1+A11 A?)rrarr)r|r{rrrrKrrWr r rrrrerrrrrrs@r3r^r^s  E .0"$"$9A9=3777 #7&c]7 7  7  7$$567 ( 67"(3-077643444  0r5r^)8r= threadingrrrtypingrrrrrr r r r r rrrr%rcontext_managersrrr metrics_corerrrrrrrrutilsrr validationrrrr r#r4boolrBrErFrHr!rrrr/rNr^rAr5r3rss  HH <<%' C*+ CxS)*&j$j !   oU oUdMM`D@ D@NCCL@!@F#D #DL: :r5