File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/onapp.cpython-310.pyc
Back
o ;jL: � @ s� d dl Z d dlmZ d dlmZ d dlmZmZmZm Z d dl m Z d dl m Z dgZ di d d ed ��d d ed ��d d ed ��d d ed ��dded ��dded ��dded ��dded ��dded ��dded ��dded ��dded ��dded ��dded ��dded ��dded ��dded ��i dded ��d d ed ��d d ed ��d d ed ��d d ed ��d d ed ��d!d!ed ��d"d"ed ��d#d#ed ��d$d$ed ��d%d%ed ��d&d&ed ��d'd'ed ��d(d(ed ��d)d)ed ��d*d*ed ��d+d+ed ���i d,d,ed ��d-d-ed ��d.d.ed ��d/d/ed ��d0d0ed ��d1d1ed ��d2d2ed ��d3d3ed ��d4d4ed ��d5d5ed ��d6d6ed ��d7d7ed ��d8d8ed ��d9d9ed ��d:d:ed ��d;d;ed ��d<d<ed ���d=d=ed �i�iZG d>d� de �ZdS )?� N)�httplib)�OnAppConnection)�Node�KeyPair� NodeImage� NodeDriver)�is_private_subnet)�Provider�OnAppNodeDriver�nodeZadd_to_marketplace)�key_name�transform_funcZ admin_note�allow_resize_without_reboot�allowed_hot_migrate� allowed_swapZbootedZbuiltZ cpu_priority� cpu_sharesZ cpu_socketsZ cpu_threadsZ cpu_units�cpus� created_atZcustomer_network_idZ deleted_atZedge_server_typeZenable_autoscaleZenable_monitisZfirewall_notrack�hostnameZ hypervisor_id�idZinitial_root_passwordZ initial_root_password_encryptedZ local_remote_access_ip_addressZlocal_remote_access_port�locked�memory� min_disk_sizeZmonthly_bandwidth_usedZnote�operating_system�operating_system_distroZ preferred_hvsZprice_per_hourZprice_per_hour_powered_offZ recovery_modeZremote_access_passwordZservice_password�stateZstorage_server_typeZstrict_virtual_machine_idZsupport_incremental_backupsZ suspended� template_idZtemplate_labelZtotal_disk_size� updated_at�user_idZvipZxen_idc @ s� e Zd ZdZeZejZdZ dZ d!dd�Z d"dd �Z d d � Z d d � Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zed d � �Zed d � �Zd S )#r z! Base OnApp node driver. ZOnAppzhttp://onapp.com/� c K sp t ||||||||| | | �d�d� } | �tjd i | ��� t�d| i�} | jjd| ddidd�}| � |j d �S ) z� Add a VS :param kwargs: All keyword arguments to create a VS :type kwargs: ``dict`` :rtype: :class:`OnAppNode` � rate_limit) �labelr r r r r Zprimary_disk_sizeZswap_disk_sizeZ required_virtual_machine_buildZ required_ip_address_assignmentr �virtual_machine�/virtual_machines.json� Content-type�application/json�POST��data�headers�methodN� ) �dict�get�updater �_create_args_to_params�json�dumps� connection�request�_to_node�object)�self�nameZ ex_memoryZex_cpusZ ex_cpu_sharesZ ex_hostnameZex_template_idZex_primary_disk_sizeZex_swap_disk_sizeZ!ex_required_virtual_machine_buildZ!ex_required_ip_address_assignment�kwargs� server_paramsr( �responser+ r+ �R/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/onapp.py� create_node� s, ��zOnAppNodeDriver.create_noder c C s. ||d�}dj |jd�}| jj||dd� dS )a� Delete a VS :param node: OnApp node :type node: :class: `OnAppNode` :param convert_last_backup: set 1 to convert the last VS's backup to template, otherwise set 0 :type convert_last_backup: ``int`` :param destroy_all_backups: set 1 to destroy all existing backups of this VS, otherwise set 0 :type destroy_all_backups: ``int`` )Zconvert_last_backupZdestroy_all_backupsz#/virtual_machines/{identifier}.json)� identifier�DELETE)�paramsr* T)�formatr r2 r3 )r6 r Zex_convert_last_backupZex_destroy_all_backupsr9 �actionr+ r+ r; � destroy_node� s �z OnAppNodeDriver.destroy_nodec C �4 | j �d�}g }|jD ] }|�| �|d �� q |S )zM List all VS :rtype: ``list`` of :class:`OnAppNode` r# r" )r2 r3 r5 �appendr4 )r6 r: ZnodesZvmr+ r+ r; � list_nodes� � zOnAppNodeDriver.list_nodesc C rC )zQ List all images :rtype: ``list`` of :class:`NodeImage` z/templates.jsonZimage_template)r2 r3 r5 rD � _to_image)r6 r: Z templates�templater+ r+ r; � list_images� rF zOnAppNodeDriver.list_imagesc C sN | j �d�jd d }| j �d| �}g }|jD ] }|�| �|d �� q|S )zq List all the available key pair objects. :rtype: ``list`` of :class:`.KeyPair` objects � /profile.json�userr �/users/%s/ssh_keys.json�ssh_key)r2 r3 r5 rD � _to_key_pair)r6 r r: Zssh_keysrM r+ r+ r; �list_key_pairs� s z OnAppNodeDriver.list_key_pairsc C s: | j �d�jd d }| j �d�||��}| �|jd �S )z� Retrieve a single key pair. :param name: ID of the key pair to retrieve. :type name: ``str`` :rtype: :class:`.KeyPair` object rJ rK r z/users/{}/ssh_keys/{}.jsonrM )r2 r3 r5 r@ rN )r6 r7 r r: r+ r+ r; � get_key_pair� s z OnAppNodeDriver.get_key_pairc C sP t �d|i�}| j�d�jd d }| jjd| |ddidd �}| �|jd �S ) a Import a new public key from string. :param name: Key pair name (unused). :type name: ``str`` :param key_material: Public key material. :type key_material: ``str`` :rtype: :class:`.KeyPair` object �keyrJ rK r rL r$ r% r& r' rM )r0 r1 r2 r3 r5 rN )r6 r7 Z key_materialr( r r: r+ r+ r; �import_key_pair_from_string s �z+OnAppNodeDriver.import_key_pair_from_stringc C s& |j }| jjd| dd�}|jtjkS )z� Delete an existing key pair. :param key_pair: Key pair object. :type key_pair: :class:`.KeyPair` :return: True on success :rtype: ``bool`` z/settings/ssh_keys/%s.jsonr> )r* )r7 r2 r3 �statusr � NO_CONTENT)r6 rQ Zkey_idr: r+ r+ r; �delete_key_pair s z OnAppNodeDriver.delete_key_pairc C s. |d |d d�}t |d d |d d | |d�S )Nr r )r r r rQ )r7 Z fingerprintZ public_keyZ private_key�driver�extra)r )r6 r( rW r+ r+ r; rN 0 s �z OnAppNodeDriver._to_key_pairc C sT |d |d |d |d |d |d |d |d |d d � }t |d |d | |d �S )Nr r �operating_system_archr r r r �min_memory_sizer ) Z distributionr rX r r r r rY r r r! )r r7 rV rW )r )r6 rH rW r+ r+ r; rG ; s � zOnAppNodeDriver._to_imagec C sz |d }|d }g }g }|d D ]}|d d }t |�r"|�|� q|�|� qt�|td �}t|||d ||| |d�S ) Nr= r! Z ip_addresses� ip_address�addressr r )rW )r rD r �_get_extra_dict� RESOURCE_EXTRA_ATTRIBUTES_MAPr ) r6 r( r= r7 Z private_ipsZ public_ips�ipr[ rW r+ r+ r; r4 I s zOnAppNodeDriver._to_nodec C sD i }|� � D ]\}}|d }| �|d �}|r||�nd||< q|S )aV Extract attributes from the element based on rules provided in the mapping dictionary. :param response: The JSON response to parse the values from. :type response: ``dict`` :param mapping: Dictionary with the extra layout :type mapping: ``dict`` :rtype: ``dict`` r r N)�itemsr- )r: �mappingrW Z attribute�valuesr �valuer+ r+ r; r\ X s z OnAppNodeDriver._get_extra_dictc K s8 g d�}i }|D ]}| � |�}|r|||dd� < q|S )z� Extract server params from keyword args to create a VS :param kwargs: keyword args :return: ``dict`` )Zex_cpu_socketsZex_cpu_threadsZex_enable_autoscaleZ ex_data_store_group_primary_idZex_data_store_group_swap_idZex_hypervisor_group_idZex_hypervisor_idZex_initial_root_passwordZex_noteZex_primary_disk_min_iopsZex_primary_network_idZex_primary_network_group_idZ ex_recipe_idsZ ex_required_automatic_backup�#ex_required_virtual_machine_startuprc Zex_selected_ip_address_idZex_swap_disk_min_iopsZex_type_of_formatZex_custom_recipe_variablesZex_licensing_keyZex_licensing_server_idZex_licensing_type� N)r- )r8 r? r9 �prb r+ r+ r; r/ n s �z&OnAppNodeDriver._create_args_to_paramsN)r r )r r )�__name__� __module__� __qualname__�__doc__r Z connectionClsr ZONAPP�typer7 Zwebsiter< rB rE rI rO rP rR rU rN rG r4 � staticmethodr\ r/ r+ r+ r+ r; r � s. � 0 )r0 Zlibcloud.utils.py3r Zlibcloud.common.onappr Zlibcloud.compute.baser r r r Zlibcloud.utils.networkingr Zlibcloud.compute.providersr �__all__�bool�str�int�list�floatr] r r+ r+ r+ r; �<module> s@ �� ��� �� � � � � � � � � � ��� � � � � � !� "� #�$��(��,��0�� 4� 5� 6�7�� ;� <�=�� A� B�C�� G�H�� L� M�N��R��V�� Z� [� \� ]� ^� _� `� a��g
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings