관리-도구
편집 파일: values.cpython-38.pyc
U .?�f� � @ sZ d dl Z d dlmZ d dlZddlmZmZ G dd� d�Ze jfdd�Z d d � Z e � Z dS ) � N��Lock� )�mmap_key� MmapedDictc @ sF e Zd ZdZdZdd� Zdd� Zddd �Zd d � Zd d � Z dd� Z dS )� MutexValuez A float protected by a mutex.Fc K s d| _ d | _t� | _d S �Ng )�_value� _exemplarr �_lock)�self�typ� metric_name�name� labelnames� labelvalues� help_text�kwargs� r �F/opt/hc_python/lib/python3.8/site-packages/prometheus_client/values.py�__init__ s zMutexValue.__init__c C s$ | j � | j|7 _W 5 Q R X d S �N�r r �r �amountr r r �inc s zMutexValue.incNc C s | j � || _W 5 Q R X d S r r �r �value� timestampr r r �set s zMutexValue.setc C s | j � || _W 5 Q R X d S r �r r �r Zexemplarr r r � set_exemplar s zMutexValue.set_exemplarc C s$ | j � | jW 5 Q R � S Q R X d S r r �r r r r �get s zMutexValue.getc C s$ | j � | jW 5 Q R � S Q R X d S r r r# r r r � get_exemplar" s zMutexValue.get_exemplar)N) �__name__� __module__� __qualname__�__doc__� _multiprocessr r r r" r$ r% r r r r r s r c s6 i � g �d�� i�t � �G � ����fdd�d�}|S )a8 Returns a MmapedValue class based on a process_identifier function. The 'process_identifier' function MUST comply with this simple rule: when called in simultaneously running processes it MUST return distinct values. Using a different function than the default 'os.getpid' is at your own risk. r c sz e Zd ZdZdZd��fdd� Z� �fdd�Z� ���fdd �Z�fd d �Zd�fd d� Z dd� Z �fdd�Z dd� Z d S )z&MultiProcessValue.<locals>.MmapedValuezAA float protected by a mutex backed by a per-process mmaped file.T� c sr |||||||f| _ dtjkrDdtjkrDtjd tjd< t�dt� � � | �� | �� ��| � W 5 Q R X d S )N�prometheus_multiproc_dir�PROMETHEUS_MULTIPROC_DIRzpprometheus_multiproc_dir variable has been deprecated in favor of the upper case naming PROMETHEUS_MULTIPROC_DIR) �_params�os�environ�warnings�warn�DeprecationWarning�"_MmapedValue__check_for_pid_change�_MmapedValue__reset�append) r r r r r r r �multiprocess_moder )�lock�valuesr r r < s z/MultiProcessValue.<locals>.MmapedValue.__init__c s� | j \}}}}}}}|dkr*|d | }n|}|� krdtj�tj�d�d�|�d ��} t| �� |< � | | _t |||||�| _ | j� | j �\| _ | _ d S )NZgauge�_r- z{}_{}.dbr )r. r/ �path�joinr0 r$ �formatr �_filer �_keyZ read_valuer � _timestamp) r r r r r r r r7 Z file_prefix�filename)�files�pidr r Z__resetG s � z.MultiProcessValue.<locals>.MmapedValue.__resetc sN �� }�d |krJ|�d< � � � D ] }|�� q"� �� �D ] }|�� q<d S )Nr )r9 �close�clearr5 )r Z actual_pid�fr )rB rC �process_identifierr9 r r Z__check_for_pid_changeW s z=MultiProcessValue.<locals>.MmapedValue.__check_for_pid_changec sF � �8 | � � | j|7 _d| _| j�| j| j| j� W 5 Q R X d S r �r4 r r@ r> � write_valuer? r �r8 r r r b s z*MultiProcessValue.<locals>.MmapedValue.incNc sB � �4 | � � || _|pd| _| j�| j| j| j� W 5 Q R X d S r rH r rJ r r r i s z*MultiProcessValue.<locals>.MmapedValue.setc S s d S r r r! r r r r" p s z3MultiProcessValue.<locals>.MmapedValue.set_exemplarc s* � � | � � | jW 5 Q R � S Q R X d S r )r4 r r# rJ r r r$ t s z*MultiProcessValue.<locals>.MmapedValue.getc S s d S r r r# r r r r% y s z3MultiProcessValue.<locals>.MmapedValue.get_exemplar)r+ )N) r& r' r( r) r* r r5 r4 r r r" r$ r% r �rB r8 rC rG r9 r r � MmapedValue7 s rL r )rG rL r rK r �MultiProcessValue' s FrM c C s" dt jksdt jkrt� S tS d S )Nr, r- )r/ r0 rM r r r r r �get_value_class� s rN ) r/ � threadingr r1 Z mmap_dictr r r �getpidrM rN Z ValueClassr r r r �<module> s Y