?( 3Ņ Z d dl Z d dlmZ ddlmZ G d de Z ed ZdS ) N)Lock )Metricc R e Zd ZdZddZd Zd Zd Zd Zd Z d
Z
d Z d Z dd
Z
dS )CollectorRegistryzMetric collector registry.
Collectors must have a no-argument method 'collect' that returns a list of
Metric objects. The returned metrics should be consistent with the Prometheus
exposition formats.
FNc i | _ i | _ || _ t | _ i | _ | | d S N)_collector_to_names_names_to_collectors_auto_describer _lock _target_infoset_target_info)self
auto_describe target_infos l/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/prometheus_client/registry.py__init__zCollectorRegistry.__init__ sG #% $&! +VV
[))))) c 8 | j 5 | | }t | j | }|r"t d | |D ] }|| j |<
|| j |< ddd dS # 1 swxY w Y dS )z Add a collector to the registry.z/Duplicated timeseries in CollectorRegistry: {0}N)r
_get_namessetr intersection
ValueErrorformatr
)r collectornames
duplicatesnames r registerzCollectorRegistry.register s
Z 8 8OOI..E T 677DDUKKJ
% ELL"$ $% % %
<
<2;)$//27D $Y / 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8s A:BBBc | j 5 | j | D ]
}| j |= | j |= ddd dS # 1 swxY w Y dS )z%Remove a collector from the registry.N)r
r
r )r r r s r
unregisterz CollectorRegistry.unregister$ s
Z 4 4 0;
4
4-d33(3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4s !6::c d} |j }n# t $ r Y nw xY w|s| j r|j }|sg S g }ddgg dg dg ddgd} | D ]>}| |j d g D ] }| |j |z ?|S )
z/Get names of timeseries the collector produces.N_total_created) _sum_countr% )_bucketr' r( r% )r) _gsum_gcount_info)countersummary histogramgaugehistograminfor& )describeAttributeErrorr collectgettypeappendr )r r desc_funcresult
type_suffixesmetricsuffixs r r z CollectorRegistry._get_names+ s !*II D *T 0 *!)I I *-999BBB = = = I
ikk 4 4F'++FK">>
4
4
fkF 23333
4
s
c # K d}d}| j 5 t j | j }| j r| }ddd n # 1 swxY w Y |r|V |D ] }| D ]}|V dS )z3Yields metrics from the collectors in the registry.N)r
copyr
r _target_info_metricr4 )r
collectorstir r; s r r4 zCollectorRegistry.collectG s
Z 0 0 4#;<z9CollectorRegistry.restricted_registry..k s" FFF!
1
r c e Zd Z fdZdS )ACollectorRegistry.restricted_registry..RestrictedRegistryc S r rD )r metricss r r4 zICollectorRegistry.restricted_registry..RestrictedRegistry.collectr s r N)__name__
__module__ __qualname__r4 )rK s r RestrictedRegistryrI q s.
r rO )r r
r r7 r? remover addr4 samplesr r
documentationr6 object)
r r r@ r r r; rR mrO rK s
` @r restricted_registryz%CollectorRegistry.restricted_registryU s E
UU
Z D D %%$*;%t 7 7 9 9::: ]+++
D
D4444 NN4#W-W-W$%^___;?)-88"
C)--mTBBB &D ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' 's AA++A/2A/c R | j 5 | j cd d d S # 1 swxY w Y d S r )r
r )r s r get_target_infoz!CollectorRegistry.get_target_info st
Z % %$ % % % % % % % % % % % % % % % % % %s c ` t ddd }| d| j d |S )NtargetzTarget metadatar1 r r )r
add_sampler )r rU s r r? z%CollectorRegistry._target_info_metric s2 8 . 7 7 ]D$5q999r c |i }| D ]-}|j D ]#}|j |k r|j |k r |j c c S $.dS )z~Returns the sample value, or None if not found.
This is inefficient, and intended only for use in unittests.
N)r4 rR r rY value)r r rY r; rF s r get_sample_valuez"CollectorRegistry.get_sample_value si
>Fllnn # #F^
#
#6T>>ah&&8&8 7NNNNN
# tr )FNr )rL rM rN __doc__r r r" r r4 rV r r[ r? ra rD r r r r s * * * * 8 8 84 4 4 8 $ $ $D' ' '% % %
r r T)r )r> threadingr metrics_corer rT r REGISTRYrD r r rf s~ N N N N N N N Nb 4 0 0 0r