Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/openstack/tests/functional/cloud/__pycache__/test_clustering.cpython-39.pyc
Ðазад
a u�hb� � @ sX d Z ddlmZ ddlmZ ddlZddd�Zdd d �Zdd d �ZG d d� dej �Z dS )zf test_clustering ---------------------------------- Functional tests for `shade` clustering methods. � )�content)�baseN� �< c C sh | f i |��| }t � � }||krdt �|� | f i |��}|| }t � � | |k} ||kr| rdS qdS )a� Wait for an OpenStack resource to enter a specified state :param client: An uncalled client resource to be called with resource_args :param client_args: Arguments to be passed to client :param field: Dictionary field to check :param value: Dictionary value to look for :param check_interval: Interval between checks :param timeout: Time in seconds to wait for status to update. :returns: True if correct status was reached :raises: TimeoutException FT��time�sleep) �client� client_args�field�value�check_interval�timeoutZresource_status�start�resource� timed_out� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/openstack/tests/functional/cloud/test_clustering.py�wait_for_status s r c C sT | f i |��}t � � }|sPt �|� | f i |��}t � � | |k}|s|rdS qdS )a� Wait for an OpenStack resource to be created :param client: An uncalled client resource to be called with resource_args :param client_args: Arguments to be passed to client :param name: Name of the resource (for logging) :param check_interval: Interval between checks :param timeout: Time in seconds to wait for status to update. :returns: True if openstack.exceptions.NotFoundException is caught :raises: TimeoutException FTr �r r r r r r r r r r �wait_for_create7 s r c C sT | f i |��}t � � }|rPt �|� | f i |��}t � � | |k}|r|rdS qdS )a� Wait for an OpenStack resource to 404/delete :param client: An uncalled client resource to be called with resource_args :param client_args: Arguments to be passed to client :param name: Name of the resource (for logging) :param check_interval: Interval between checks :param timeout: Time in seconds to wait for status to update. :returns: True if openstack.exceptions.NotFoundException is caught :raises: TimeoutException FTr r r r r �wait_for_deleteR s r c s� e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Z d5d6� Z d<d8d9�Z d:d;� Z � Z S )=�TestClusteringc s t t| ��� | �d� d S )Nz)clustering service not supported by cloud)�superr �setUpZskipTest)�self�� __class__r r r n s zTestClustering.setUpc C s| d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � | � |d |� | � |d |� d S )N� test_profile�m1.tiny�network�private�default�Zflavor�imageZnetworksZsecurity_groups�os.nova.server� �?�� properties�type�version�profile��name�spec�idr- r. ) r � IMAGE_NAME� addDetailr � text_content� user_cloud�create_cluster_profile� addCleanup�cleanup_profile� assertEqual)r � profile_namer. r+ r r r �test_create_profiler s& ���� ��z"TestClustering.test_create_profilec C s� d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � | � |d d |� | � |d d |d � | � |d d |� d S )Nr r r r! r" r# r% r& r' r+ r, r/ �example_clusterr �cluster�r- r+ �desired_capacityr- � profile_idr= ) r r0 r1 r r2 r3 r4 r5 r6 �create_cluster�cleanup_clusterr7 )r r8 r. r+ � cluster_namer= r; r r r �test_create_cluster� s< ���� ����z"TestClustering.test_create_clusterc C s� d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � | j� |d d �}| � |d |d d � d S )Nr r r r! r" r# r% r& r' r+ r, r/ r: r r; r< ) r r0 r1 r r2 r3 r4 r5 r6 r? r@ �get_cluster_by_idr7 )r r8 r. r+ rA r= r; Z cluster_getr r r �test_get_cluster_by_id� s: ���� ��� �z%TestClustering.test_get_cluster_by_idc C sJ d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � | jj |d d dd� t | jj d|d d idd�}| �|� | j� |d d �}| �|d |d d � | �|d d� | �|d |d d � | �|d |d d � d S )Nr r r r! r" r# r% r& r' r+ r, r/ r: r r; r< Znew_cluster_name��new_name� name_or_id�status�ACTIVEr- r> r= )r r0 r1 r r2 r3 r4 r5 r6 r? r@ Zupdate_clusterr rC � assertTruer7 ) r r8 r. r+ rA r= r; �waitZcluster_updater r r �test_update_cluster� sX ���� ����� � � �z"TestClustering.test_update_clusterc C sv d}dddd�dd�ddd �}| � d t�|�� | jj||d �}| �| j|d � | �|d |� | �|d |� d S )N�example_policyr �CHANGE_IN_CAPACITY�Zmin_step�numberr) �CLUSTER_SCALE_IN�Z adjustment�event�senlin.policy.scaling�1.0r' �policyr, r/ r- r. )r1 r r2 r3 �create_cluster_policyr5 �cleanup_policyr7 )r � policy_namer. rV r r r �test_create_cluster_policy" s" ��� �z)TestClustering.test_create_cluster_policyc C s: d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � d}dddd�dd�ddd �}| �dt�|�� | jj ||d �}| �| j |d |d d � | j� |d d �} | j�|d �} | jj| | dd�} | �| � d S ) Nr r r r! r" r# r% r& r' r+ r, r/ r: r r; r< rM r rN rO rQ rR rT rU rV T�� is_enabled)r r0 r1 r r2 r3 r4 r5 r6 r? r@ rW rX rC �get_cluster_policy_by_id�attach_policy_to_clusterrJ ) r r8 r. r+ rA r= r; rY rV �attach_cluster� attach_policy� policy_attachr r r � test_attach_policy_to_cluster= sh ���� ������ � � ���z,TestClustering.test_attach_policy_to_clusterc C s~ d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � d}dddd�dd�ddd �}| �dt�|�� | jj ||d �}| �| j |d |d d � | j� |d d �} | j�|d �} | jj| | dd� t| jj d |d d id d j|d d �g�} | j�| | �} | �| � | �| � d S ) Nr r r r! r" r# r% r& r' r+ r, r/ r: r r; r< rM r rN rO rQ rR rT rU rV Tr[ rG �policies�{policy}�rV )r r0 r1 r r2 r3 r4 r5 r6 r? r@ rW rX rC r] r^ r �format�detach_policy_from_clusterrJ ) r r8 r. r+ rA r= r; rY rV r_ r` rK Z policy_detachr r r � test_detach_policy_from_cluster� sz ���� ������ � � ����� z.TestClustering.test_detach_policy_from_clusterc C s� d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � d}dddd�dd�ddd �}| �dt�|�� | jj ||d �}| �| j |d |d d � | j� |d d �} | j�|d �} | jj| | dd�} | �| � t| jj d |d d id d j|d d �g�} | j�|d d |d �} | �| d |d d � | �| d! |d d" � | �| d# |d �f | �| d$ |d" � | �| � d S )%Nr r r r! r" r# r% r& r' r+ r, r/ r: r r; r< rM r rN rO rQ rR rT rU rV Tr[ rG rc rd re � cluster_idrA r- Z policy_idrY )r r0 r1 r r2 r3 r4 r5 r6 r? r@ rW rX rC r] r^ rJ r rf �get_policy_on_clusterr7 )r r8 r. r+ rA r= r; rY rV r_ r` ra rK Zcluster_policy_getr r r � test_get_policy_on_cluster_by_id� s� ���� ������ � � ��� �� � �z/TestClustering.test_get_policy_on_cluster_by_idc C s� d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � d}dddd�dd�ddd �}| �dt�|�� | jj ||d �}| �| j |d |d d � | j� |d d �} | j�|d �} | jj| | dd� t| jj d |d d id d j|d d �g�} | jj|d d |d d �} d!| gi} | j�|d d �}| �|| � | �| � d S )"Nr r r r! r" r# r% r& r' r+ r, r/ r: r r; r< rM r rN rO rQ rR rT rU rV Tr[ rG rc rd re �rG Zpolicy_name_or_id�cluster_policies)r r0 r1 r r2 r3 r4 r5 r6 r? r@ rW rX rC r] r^ r rf rj Zlist_policies_on_clusterr7 rJ )r r8 r. r+ rA r= r; rY rV r_ r` rK Zcluster_policyZ policy_listrm r r r � test_list_policies_on_cluster6 s� ���� ������ � � ���� � ��z,TestClustering.test_list_policies_on_clusterc C s d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � d}d}| �dt�|�� | jj |||d d dd�} | �| j | d � | � | d |� | � | d |� | � | d |d d � d S )Nr r r r! r" r# r% r& r' r+ r, r/ r: r r; r< �example_receiver�webhook�receiver�CLUSTER_SCALE_OUT�r- � receiver_typeZcluster_name_or_id�actionr- r) ri )r r0 r1 r r2 r3 r4 r5 r6 r? r@ �create_cluster_receiver�cleanup_receiverr7 ) r r8 r. r+ rA r= r; � receiver_namert rq r r r � test_create_cluster_receiver� sJ ���� ��� �z+TestClustering.test_create_cluster_receiverc C s d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � d}d}| �dt�|�� | jj |||d d dd�} | �| j | d � | j� | d �} d| gi} | j�� } | �| | � d S )Nr r r r! r" r# r% r& r' r+ r, r/ r: r r; r< ro rp rq rr rs � receivers)r r0 r1 r r2 r3 r4 r5 r6 r? r@ rv rw �get_cluster_receiver_by_idZlist_cluster_receiversr7 ) r r8 r. r+ rA r= r; rx rt rq Z get_receiverZ receiver_listrz r r r �test_list_cluster_receivers� sP ���� ��� �� z*TestClustering.test_list_cluster_receiversc C sz d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � d}dddd�dd�ddd �}| �dt�|�� | jj ||d �}| �| j |d � | j� |d d �} | j�|d �} | jj| | dd� d } d } | �d t�| �� | jj| | |d d d d � | j�|d d �} | �| � d S )!Nr r r r! r" r# r% r& r' r+ r, r/ r: r r; r< rM r rN rO rQ rR rT rU rV Tr[ ro rp rq rr rs )r r0 r1 r r2 r3 r4 r5 r6 r? r@ rW rX rC r] r^ rv �delete_clusterrJ )r r8 r. r+ rA r= r; rY rV r_ r` rx rt Zcluster_deleter r r �test_delete_cluster sz ���� ������ � ��� � �z"TestClustering.test_delete_clusterc C s� d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � t | jj d|d d idd�}| j� |d d �}| j� � } | �| |g� | �|� d S )Nr r r r! r" r# r% r& r' r+ r, r/ r: r r; r< rG rH rI )r r0 r1 r r2 r3 r4 r5 r6 r? r@ r rC � list_clustersr7 rJ ) r r8 r. r+ rA r= r; rK Z get_clusterZclustersr r r �test_list_clusters^ sF ���� ���� � z!TestClustering.test_list_clustersc C s d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � d}dddd�dd�ddd �}| �dt�|�� | jj ||d �}| �| j |d |d d � | j� |d d �} | j�|d �} | jj| | dd� t| jj d |d d id d j|d d �g�} | j�|d d |d �} | jj| | d d�} | �d!d i� t| jj|d d |d d"�d!d �}| j�|d d |d �}d | d#< d |d#< | �| � | �|| � | �| � | �|� d S )$Nr r r r! r" r# r% r& r' r+ r, r/ r: r r; r< rM r rN rO rQ rR rT rU rV Tr[ rG rc rd re F�enabledrl Zlast_op)r r0 r1 r r2 r3 r4 r5 r6 r? r@ rW rX rC r] r^ r rf rj Zupdate_policy_on_cluster�updaterJ r7 )r r8 r. r+ rA r= r; rY rV r_ r` Z wait_attachZget_old_policy� policy_updateZ wait_updateZget_new_policyr r r � test_update_policy_on_cluster� s� ���� ������ � � ������ ��� z,TestClustering.test_update_policy_on_clusterc C s� d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � t | jj d |d i�}| j� |d �}| j� � }| � ||g� | � |� d S )Nr r r r! r" r# r% r& r' r+ r, r/ rG )r r0 r1 r r2 r3 r4 r5 r6 r �get_cluster_profile_by_idZlist_cluster_profilesr7 rJ )r r8 r. r+ rK Z get_profileZprofilesr r r �test_list_cluster_profiles� s0 ���� �� � z)TestClustering.test_list_cluster_profilesc C s� d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � | j� |d �}d |d< d |d< | � ||� d S )Nr r r r! r" r# r% r& r' r+ r, r/ �ignore� created_at) r r0 r1 r r2 r3 r4 r5 r6 r� r7 )r r8 r. r+ Z profile_getr r r � test_get_cluster_profile_by_id s* ���� ��z-TestClustering.test_get_cluster_profile_by_idc C s� d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � | jj |d d d�}| � |d d |d � | � |d d |d � | � |d d d � d S )Nr r r r! r" r# r% r& r' r+ r, r/ Znew_profile_namerE r. r- ) r r0 r1 r r2 r3 r4 r5 r6 Zupdate_cluster_profiler7 )r r8 r. r+ Zprofile_updater r r �test_update_cluster_profileE s. ���� ���z*TestClustering.test_update_cluster_profilec C sv d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � | j� |d �}| � |� d S ) Nr r r r! r" r# r% r& r' r+ r, r/ ) r r0 r1 r r2 r3 r4 r5 r6 �delete_cluster_profilerJ )r r8 r. r+ Zprofile_deleter r r �test_delete_cluster_profilei s& ���� ��z*TestClustering.test_delete_cluster_profilec C s� d}dddd�dd�ddd �}| � d t�|�� | jj||d �}| �| j|d � | j�|d �}| j�� }d |d d< d |d< | � ||g� d S )NrM r rN rO rQ rR rT rU r' rV r, r/ r� r r� ) r1 r r2 r3 rW r5 rX r] Zlist_cluster_policiesr7 )r rY r. rV � policy_getrc r r r �test_list_cluster_policies� s( ��� � z)TestClustering.test_list_cluster_policiesc C s� d}dddd�dd�ddd �}| � d t�|�� | jj||d �}| �| j|d � | j�|d �}d |d< d |d< | �||� d S )NrM r rN rO rQ rR rT rU r' rV r, r/ r� r� ) r1 r r2 r3 rW r5 rX r] r7 )r rY r. rV r� r r r � test_get_cluster_policy_by_id� s& ��� �z,TestClustering.test_get_cluster_policy_by_idc C s� d}dddd�dd�ddd �}| � d t�|�� | jj||d �}| �| j|d � | jj|d d d�}| �|d d |d � | �|d d |d � | �|d d d � d S )NrM r rN rO rQ rR rT rU r' rV r, r/ Znew_policy_namerE r. r- ) r1 r r2 r3 rW r5 rX Zupdate_cluster_policyr7 )r rY r. rV r� r r r �test_update_cluster_policy� s* ��� ��z)TestClustering.test_update_cluster_policyc C sp d}dddd�dd�ddd �}| � d t�|�� | jj||d �}| �| j|d � | j�|d �}| �|� d S ) NrM r rN rO rQ rR rT rU r' rV r, r/ ) r1 r r2 r3 rW r5 rX �delete_cluster_policyrJ )r rY r. rV Z policy_deleter r r �test_delete_cluster_policy� s& ��� ��z)TestClustering.test_delete_cluster_policyc C s d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � d}d}| �dt�|�� | jj |||d d dd�} | �| j | d � | j� | d �} | �| d | d � d S )Nr r r r! r" r# r% r& r' r+ r, r/ r: r r; r< ro rp rq rr rs )r r0 r1 r r2 r3 r4 r5 r6 r? r@ rv rw r{ r7 ) r r8 r. r+ rA r= r; rx rt rq Z receiver_getr r r � test_get_cluster_receiver_by_id sL ���� ��� ��z.TestClustering.test_get_cluster_receiver_by_idc C sV d}dt jddigdgd�ddd �}| �d t�|�� | jj||d �}| �| j|d � d }d}| �dt�|�� | jj |||d�}| �| j |d d � d}d}| �dt�|�� | jj |||d d dd�} | �| j | d � | jj | d dd�} | �| d d | d � | �| d d | d � | �| d d | d � | �| d d d� d S )Nr r r r! r" r# r% r& r' r+ r, r/ r: r r; r< ro rp rq rr rs Znew_receiver_namerE r) ri r- )r r0 r1 r r2 r3 r4 r5 r6 r? r@ rv rw Zupdate_cluster_receiverr7 ) r r8 r. r+ rA r= r; rx rt rq Zreceiver_updater r r � test_update_cluster_receiverK sZ ���� ��� ����z+TestClustering.test_update_cluster_receiverc C sF t �d� | j�� D ] }||d kr| j�|d � q| j�|� d S )N� r> r/ )r r r3 r r} r� )r r- r; r r r r6 � s z TestClustering.cleanup_profilec C s | j �|� d S �N)r3 r} �r r- r r r r@ � s z TestClustering.cleanup_clusterNc C sZ |d urJ| j �|�}| j �|�}| j �|d �d }|g krJ| j �||� | j �|� d S )Nr/ rc )r3 rC r] rg r� )r r- rA r; rV Z policy_statusr r r rX � s �z TestClustering.cleanup_policyc C s | j �|� d S r� )r3 Zdelete_cluster_receiverr� r r r rw � s z TestClustering.cleanup_receiver)N)!�__name__� __module__� __qualname__r r9 rB rD rL rZ rb rh rk rn ry r| r~ r� r� r� r� r� r� r� r� r� r� r� r� r6 r@ rX rw � __classcell__r r r r r l s: ,+;JR]Y9>X3h&&$ &$! ;A r )r r )r r )r r ) �__doc__Z testtoolsr Zopenstack.tests.functionalr r r r r ZBaseFunctionalTestr r r r r �<module> s �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка