Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/openstack/tests/unit/__pycache__/test_stats.cpython-39.pyc
Ðазад
a u�h $ � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl m Z G dd� dej �ZG dd� de j�ZG dd� de j�ZdS ) � N)�basec @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� StatsdFixturec C s| d| _ tj| jd�| _d| j_t�tjtj�| _ | j � d� | j � � d | _ t �� \| _| _g | _| j�� | �| j� d S )NT)�target)� r � )�running� threading�Thread�run�thread�daemon�socket�AF_INET� SOCK_DGRAM�sock�bind� getsockname�port�os�pipe� wake_read� wake_write�stats�startZ addCleanup�_cleanup��self� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/openstack/tests/unit/test_stats.py�_setUp! s zStatsdFixture._setUpc C s� | j r�t�� }|�| jtj� |�| jtj� |�� }|D ]L\}}|| j�� krv| j�d�}|sf d S | j � |d � || jkr: d S q:q d S )Ni r ) r �select�poll�registerr �POLLINr �fileno�recvfromr �append)r r! �ret�fd�event�datar r r r - s zStatsdFixture.runc C s" d| _ t�| jd� | j�� d S )NFs 1 )r r �writer r �joinr r r r r < s zStatsdFixture._cleanupN)�__name__� __module__� __qualname__r r r r r r r r s r c sX e Zd Z� fdd�Zdd� Zddd�Zddd �Zd d � Zd d � Zdd� Z dd� Z � Z S )� TestStatsc s� t � | _| �| j� | �t�dd�� | �t�dt| jj��� | �d| jj� t t | �� � t � � | _| j| jj_| �| j� d S )NZ STATSD_HOSTz 127.0.0.1Z STATSD_PORTZstatsd_content)r �statsd� useFixture�fixturesZEnvironmentVariable�strr Zadd_info_on_exceptionr �superr0 �setUp�prometheus_clientZCollectorRegistry� _registry�cloud�configZ_collector_registryZaddOnException�_add_prometheus_samplesr �� __class__r r r6 D s �� zTestStats.setUpc C sH g }| j �� D ]}|jD ]}|�|� qq| �dtj�t� |��� d S )NZprometheus_samples) r8 Zcollect�samplesr& Z addDetail� testtools�contentZ text_content�pprint�pformat)r �exc_infor> Zmetric�sr r r r; W s �z!TestStats._add_prometheus_samplesNc C s� | � | j� |r | �|d� t�� }t�� |d k r�tj�dd� | jjD ��}|D ]x}|�d�\}}||krR|du rz dS |�d�\} } || kr�qR|r�|dkr�t |�t | �kr� dS || krR dS qR dS qRt� d � q$t d | ��dS ) a Check statsd output Check statsd return values. A ``value`` should specify a ``kind``, however a ``kind`` may be specified without a ``value`` for a generic match. Leave both empy to just check for key presence. :arg str key: The statsd key :arg str value: The expected value of the metric ``key`` :arg str kind: The expected type of the metric ``key`` For example - ``c`` counter - ``g`` gauge - ``ms`` timing - ``s`` set Nr c S s g | ]}|� d ��d��qS )zutf-8� )�decode�split)�.0rD r r r � <listcomp>� � z2TestStats.assert_reported_stat.<locals>.<listcomp>�:T�|�msg�������?z"Key %s not found in reported stats) ZassertIsNotNoner1 ZassertNotEqual�time� itertools�chain� from_iterabler rG �float�sleep� Exception) r �key�value�kindr r �stat�k�vZs_valueZs_kindr r r �assert_reported_stat` s4 � z TestStats.assert_reported_statc C s | j �||�}| �||� d S �N)r8 Zget_sample_value� assertEqual)r �namerV �labelsZ sample_valuer r r �assert_prometheus_stat� s z TestStats.assert_prometheus_statc C sl | j dddd�}| �td|ddg id�g� | j�� | �� | jdd d d � | �d d td|ddd�� d S �N�identity�projects�v3�� service_type�resourceZbase_url_append�GET�� ��method�uri� status_code�jsonz#openstack.api.identity.GET.projects�1�c�rV rW � openstack_http_requests_totalr �200�rf Zendpointrk rm )� get_mock_url� register_uris�dictr9 Z list_projects� assert_callsr[ r` �r Zmock_urir r r �test_list_projects� s, ��� ���z TestStats.test_list_projectsc C sr | j dddd�}| �td|ddg id�g� t| jj�� � | �� | jdd d d � | � d d td|ddd�� d S ra ) ru rv rw �listr9 rb rc rx r[ r` ry r r r � test_projects� s, ������zTestStats.test_projectsc C sl d}| � | �� td|ddg id�g� t| jj�� � | �� | jdddd � | � d d td |dd d�� d S )Nz/https://compute.example.com/v2.1/servers/detailrh ri �serversrj z(openstack.api.compute.GET.servers.detailro rp rq rr r �computers rt ) rv Z get_nova_discovery_mock_dictrw r{ r9 r~ r} rx r[ r` ry r r r � test_servers� s( �����zTestStats.test_serversc C sd d}| � td|ddg id�g� | jj�d� | �� | jddd d � | �d d td |ddd�� d S )Nz(https://compute.example.com/v2.1/serversrh ri r} rj z/serversz!openstack.api.compute.GET.serversro rp rq rr r r~ rs rt )rv rw r9 r~ �getrx r[ r` ry r r r �test_servers_no_detail� s& �����z TestStats.test_servers_no_detail)NN)N) r- r. r/ r6 r; r[ r` rz r| r r� � __classcell__r r r< r r0 B s @ r0 c s$ e Zd Z� fdd�Zdd� Z� ZS )� TestNoStatsc s& t t| ��� t� | _| �| j� d S r\ )r5 r� r6 r r1 r2 r r< r r r6 � s zTestNoStats.setUpc C sb | j dddd�}| �td|ddg id�g� d | jj_t| jj�� � | �� | � g | j j � d S )Nrb rc rd re rh ri rj ) ru rv rw r9 rb Z_statsd_clientr{ rc rx r] r1 r ry r r r � test_no_stats s ��� zTestNoStats.test_no_stats)r- r. r/ r6 r� r� r r r< r r� � s r� )rO r rA r rN r r r3 r7 Ztesttools.contentr? Zopenstack.tests.unitr ZFixturer ZTestCaser0 r� r r r r �<module> s " 8
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка