ó 6]c@s‚ddlZddlmZddlZddlZddlmZddlmZm Z m Z ddl m Z m Z mZmZddlmZddlmZmZejdkrÉeZejZn d „Zd „Zd „Zd efd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZ defd„ƒYZ!defd„ƒYZ"defd„ƒYZ#dS(iÿÿÿÿN(tLocki(tvalues(tExceptionCountertInprogressTrackertTimer(tMetrictMETRIC_LABEL_NAME_REtMETRIC_NAME_REtRESERVED_METRIC_LABEL_NAME_RE(tREGISTRY(tfloatToGoStringtINFicCstj|||jƒS(N(ttypest MethodTypet __class__(tfunctobj((s8lib/python2.7/site-packages/prometheus_client/metrics.pytcreate_bound_methodscCsºd}|r||d7}n|r4||d7}n||7}|ri|jd|ƒ ri|d|7}n|rŽ|d krŽtd|ƒ‚n|dkr¶|jdƒr¶|d }n|S( Ntt_tinfotstatesets2Metric name is of a type that cannot have a unit: tcountert_totaliúÿÿÿ(RR(tendswitht ValueError(t metric_typetnamet namespacet subsystemtunitt full_name((s8lib/python2.7/site-packages/prometheus_client/metrics.pyt_build_full_names  cCs‡t|ƒ}xt|D]l}tj|ƒs;td|ƒ‚ntj|ƒr]td|ƒ‚n||jkrtd|ƒ‚qqW|S(NsInvalid label metric name: sReserved label metric name: (ttupleRtmatchRRt_reserved_labelnames(tclst labelnamestl((s8lib/python2.7/site-packages/prometheus_client/metrics.pyt_validate_labelnames's  tMetricWrapperBasecBs’eZd ZdZd„Zd„Zd„Zd„Zd„Z dddde d d„Z d„Z d„Z d „Zd „Zd „Zd „ZRS(cCs|j p|jo|jS(N(t _labelnamest _labelvalues(tself((s8lib/python2.7/site-packages/prometheus_client/metrics.pyt_is_observable7scCs|jo|j S(N(R)R*(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyt _is_parent=scCst|j|j|j|jƒS(N(Rt_namet_documentationt_typet_unit(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyt _get_metric@scCs |jƒgS(N(R2(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pytdescribeCscCsM|jƒ}x7|jƒD])\}}}|j|j|||ƒqW|gS(N(R2t_samplest add_sampleR.(R+tmetrictsuffixtlabelstvalue((s8lib/python2.7/site-packages/prometheus_client/metrics.pytcollectFs Rc Csët|j||||ƒ|_t||ƒ|_t|p<dƒ|_i|_||_||_ t j |jƒsˆt d|jƒ‚n|j ƒr¬tƒ|_i|_n|jƒrÅ|jƒn|jsç|rç|j|ƒqçndS(NsInvalid metric name: ((R R0R.R'R)R!R*t_kwargsR/R1RR"RR-Rt_lockt_metricsR,t _metric_inittregister( R+Rt documentationR%RRRtregistryt labelvalues((s8lib/python2.7/site-packages/prometheus_client/metrics.pyt__init__Ls          csq|jstd|ƒ‚n|jrStd|tt|j|jƒƒfƒ‚n|rnˆrntdƒ‚nˆrÀtˆƒt|jƒkržtdƒ‚nt‡fd†|jDƒƒ}n@t|ƒt|jƒkrêtdƒ‚ntd„|Dƒƒ}|jb||j kr\|j |j d|j d |jd |j d ||j|j |“ssIncorrect label countcss|]}t|ƒVqdS(N(RD(RER&((s8lib/python2.7/site-packages/prometheus_client/metrics.pys —sR@R%RRBN(R)RR*tdicttziptsortedR!tlenR<R=RR.R/R1R;(R+RBRF((RFs8lib/python2.7/site-packages/prometheus_client/metrics.pyR8ms2  % "     cGs|jstd|ƒ‚nt|ƒt|jƒkrYtdt|jƒ|fƒ‚ntd„|Dƒƒ}|j|j|=WdQXdS(Ns,No label names were set when constructing %ss+Incorrect label count (expected %d, got %s)css|]}t|ƒVqdS(N(RD(RER&((s8lib/python2.7/site-packages/prometheus_client/metrics.pys «s(R)RRJR!R<R=(R+RB((s8lib/python2.7/site-packages/prometheus_client/metrics.pytremove¤s " cCs$|jƒr|jƒS|jƒSdS(N(R-t_multi_samplest_child_samples(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR4¯s  ccsœ|j|jjƒ}WdQXxv|jƒD]h\}}tt|j|ƒƒ}xA|jƒD]3\}}}|t|t|jƒƒƒ|fVq]Wq,WdS(N( R<R=tcopytitemstlistRHR)R4RG(R+tmetricsR8R6t series_labelsR7t sample_labelsR9((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRLµs  cCstd|ƒ‚dS(Ns*_child_samples() must be implemented by %r(tNotImplementedError(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRM½scCstd|ƒ‚dS(s· 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. s(_metric_init() must be implemented by %rN(RT(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR>ÀsN(((t__name__t __module__tNoneR0R#R,R-R2R3R:R RCR8RKR4RLRMR>(((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR(3s&       7   tCountercBs>eZdZdZd„Zdd„Zed„Zd„ZRS(srA 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 RcCsDtj|j|j|jd|j|jƒ|_tjƒ|_dS(NR( Rt ValueClassR0R.R)R*t_valuettimet_created(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR>ës"icCs/|dkrtdƒ‚n|jj|ƒdS(s&Increment counter by the given amount.is9Counters can only be incremented by non-negative amounts.N(RRZtinc(R+tamount((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR]ðs cCs t||ƒS(sãCount 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. (R(R+t exception((s8lib/python2.7/site-packages/prometheus_client/metrics.pytcount_exceptionsöscCs(di|jjƒfdi|jffS(NRR\(RZtgetR\(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRMÿs( RURVt__doc__R0R>R]t ExceptionR`RM(((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRXÉs    tGaugecBs•eZdZdZedƒZddddeddd„Zd „Z d d „Z d d „Z d „Z d„Z d„Zd„Zd„Zd„ZRS(sÁGauge 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)) tgaugetmintmaxtlivesumtlivealltallRc Cs‚| |_| |jkr+td| ƒ‚ntt|ƒjd|d|d|d|d|d|d|d |ƒ|j|jd Hs!icCs|jj|ƒdS(s$Increment gauge by the given amount.N(RZR](R+R^((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR]NscCs|jj| ƒdS(s$Decrement gauge by the given amount.N(RZR](R+R^((s8lib/python2.7/site-packages/prometheus_client/metrics.pytdecRscCs|jjt|ƒƒdS(sSet gauge to the given value.N(RZtsettfloat(R+R9((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRpVscCs|jtjƒƒdS(s"Set gauge to the current unixtime.N(RpR[(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pytset_to_current_timeZscCs t|ƒS(sØTrack 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. (R(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyttrack_inprogress^scCs t|jƒS(sŒTime a block of code or function, and set the duration in seconds. Can be used as a function decorator or context manager. (RRp(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR[gscs%‡fd†}t||ƒ|_dS(sÇCall 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. csditˆƒƒffS(NR(Rq(R+(tf(s8lib/python2.7/site-packages/prometheus_client/metrics.pytsamplesusN(RRM(R+RtRu((Rts8lib/python2.7/site-packages/prometheus_client/metrics.pyt set_functionnscCsdi|jjƒffS(NR(RZRa(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRMzs(RfRgRhRiRj(N(RURVRbR0t frozensetRmR RWRCR>R]RoRpRrRsR[RvRM(((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRds&$         tSummarycBsAeZdZdZdgZd„Zd„Zd„Zd„ZRS(sûA 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 tsummarytquantilecCsutj|j|j|jd|j|jƒ|_tj|j|j|jd|j|jƒ|_tjƒ|_ dS(Nt_countt_sum( RRYR0R.R)R*R{R|R[R\(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR>Ÿs"1cCs$|jjdƒ|jj|ƒdS(sObserve the given amount.iN(R{R]R|(R+R^((s8lib/python2.7/site-packages/prometheus_client/metrics.pytobserve¥scCs t|jƒS(sTime a block of code or function, and observe the duration in seconds. Can be used as a function decorator or context manager. (RR}(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR[ªscCs=di|jjƒfdi|jjƒfdi|jffS(NR{R|R\(R{RaR|R\(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRM±s( RURVRbR0R#R>R}R[RM(((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRx~s    t HistogramcBs›eZdZdZdgZddddddd d d d d dddefZddddeded„Z d„Z d„Z d„Z d„Z d„ZRS(sA 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`. t histogramtleg{®Gázt?g{®Gáz„?gš™™™™™™?gš™™™™™©?g333333³?gš™™™™™¹?gÐ?gà?gè?gð?g@g@g@g$@Rc Csa|j| ƒtt|ƒjd|d|d|d|d|d|d|d|ƒ| |jd s  1 cCsX|jj|ƒxAt|jƒD]0\}}||kr |j|jdƒPq q WdS(sObserve the given amount.iN(R|R]t enumerateR„R‡(R+R^titbound((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR}s  cCs t|jƒS(sTime a block of code or function, and observe the duration in seconds. Can be used as a function decorator or context manager. (RR}(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR[scCs¾g}d}xWt|jƒD]F\}}||j|jƒ7}|jdit|ƒd6|fƒqW|jdi|fƒ|jdi|jjƒfƒ|jdi|jfƒt|ƒS(NiR†R€R{R|R\( R‰R„R‡RaRƒR R|R\R!(R+RutaccRŠR‹((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRM s'(N(RURVRbR0R#R tDEFAULT_BUCKETSR RWRCR‚R>R}R[RM(((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR~¸s " 3    tInfocBs/eZdZdZd„Zd„Zd„ZRS(s‡Info 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. RcCs+t|jƒ|_tƒ|_i|_dS(N(RpR)t_labelname_setRR<RZ(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR>>s cCsW|jj|jƒƒr4td|j|fƒ‚n|jt|ƒ|_WdQXdS(sSet info metric.s8Overlapping labels for Info metric, metric: %s child: %sN(Rt intersectiontkeysRR)R<RGRZ(R+tval((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRCs  cCs'|jd|jdffSWdQXdS(Nt_infogð?(R<RZ(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRMKs (RURVRbR0R>RRM(((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRŽ,s   tEnumcBsMeZdZdZddddeddd„Zd„Zd„Zd„Z RS( s`Enum 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. RRc Cs™tt|ƒjd|d|d|d|d|d|d|d|ƒ||kretd |fƒ‚n| std |fƒ‚n| |jd <|_dS( NRR@R%RRRRARBs&Overlapping labels for Enum metric: %ss&No states provided for Enum metric: %ststates(RnR”RCRR;t_states( R+RR@R%RRRRARBR•((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRC_s  cCsd|_tƒ|_dS(Ni(RZRR<(R+((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR>zs cCs)|j|jj|ƒ|_WdQXdS(sSet enum metric state.N(R<R–tindexRZ(R+tstate((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR˜~s c Csb|jSgt|jƒD]:\}}di||j6||jkrKdndf^qSWdQXdS(NRii(R<R‰R–R.RZ(R+RŠts((s8lib/python2.7/site-packages/prometheus_client/metrics.pyRMƒs (N( RURVRbR0R RWRCR>R˜RM(((s8lib/python2.7/site-packages/prometheus_client/metrics.pyR”Ps    (i($tsyst threadingRR[R RRtcontext_managersRRRt metrics_coreRRRRRAR tutilsR R t version_infotstrRDR RR R'tobjectR(RXRdRxR~RŽR”(((s8lib/python2.7/site-packages/prometheus_client/metrics.pyts*   "    –=x:t$