Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/vultr.cpython-39.pyc
Ðазад
a q�h4 � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddlmZm Z ddl m Z m Z ddl mZ dd l mZ dd l mZ dd lmZ dd lmZmZmZmZ G d d� d�ZG dd� de �ZG dd� de�ZG dd� de�ZG dd� de�Z dS )z Vultr Driver � N��update_wrapper)�httplib�� urlencode)� ConnectionKey� JsonResponse)�Provider� NodeState)�InvalidCredsError)� LibcloudError)�ServiceUnavailableError)� NodeDriver)�Node� NodeImage�NodeSize� NodeLocationc @ s" e Zd ZdZd dd�Zdd� ZdS ) � rate_limitedz� Decorator for retrying Vultr calls that are rate-limited. :param int sleep: Seconds to sleep after being rate-limited. :param int retries: Number of retries. � �?� c C s || _ || _d S �N)�sleep�retries)�selfr r � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/vultr.py�__init__* s zrate_limited.__init__c s � �fdd�}t |� � |S )z� Run ``call`` method until it's not rate-limited. The method is invoked while it returns 503 Service Unavailable or the allowed number of retries is reached. :param callable call: Method to be decorated. c sn d }t �jd �D ]N}z� | i |��W S ty^ } z |}t��j� W Y d }~qd }~0 0 q|rj|�d S )Nr )�ranger r �timer )�args�kwargsZlast_exception�i�e��callr r r �wrapper8 s $z&rate_limited.__call__.<locals>.wrapperr )r r$ r% r r# r �__call__. s zrate_limited.__call__N)r r )�__name__� __module__� __qualname__�__doc__r r& r r r r r " s r c @ s e Zd Zdd� ZdS )� VultrResponsec C sV | j tjkr| �� }|S | j tjkr0t| j��n"| j tjkrHt| j��n t | j��d S r ) �statusr �OKZ parse_body� FORBIDDENr �body�SERVICE_UNAVAILABLEr r )r r/ r r r � parse_errorJ s zVultrResponse.parse_errorN)r' r( r) r1 r r r r r+ I s r+ c @ s e Zd Zdd� Zdd� ZdS )�SSHKeyc C s || _ || _|| _d S r ��id�name�pub_key)r r4 r5 r6 r r r r W s zSSHKey.__init__c C s d| j | j| jf S )Nz$<SSHKey: id=%s, name=%s, pub_key=%s>r3 �r r r r �__repr__\ s �zSSHKey.__repr__N)r' r( r) r r8 r r r r r2 V s r2 c @ sn e Zd ZdZdZeZdgdgdgdgdgdgdgd�Zdd� Zdd� Z e � d d � �Z e � d d � �Z d d� Z dS )�VultrConnectionz0 Connection class for the Vultr driver. z api.vultr.com�GET)z /v1/app/list� /v1/os/list�/v1/plans/listz/v1/plans/list_vc2z/v1/plans/list_vdc2z/v1/regions/availability�/v1/regions/listc C s | � � r|�d| ji� |S )zj Adds ``API-Key`` default header. :return: Updated headers. :rtype: dict zAPI-Key)�require_api_key�update�key)r �headersr r r �add_default_headersr s z#VultrConnection.add_default_headersc C s t |�S r r �r �datar r r � encode_data~ s zVultrConnection.encode_datac C s | � |�S r ��request)r �urlr r r �get� s zVultrConnection.getc C s ddi}| j |||dd�S )Nz Content-Typez!application/x-www-form-urlencoded�POST)rD rA �methodrF )r rH rD rA r r r �post� s zVultrConnection.postc C s. z| j | j| j vW S ty( Y dS 0 dS )z� Check whether this call (method + action) must be authenticated. :return: True if ``API-Key`` header required, False otherwise. :rtype: bool TN)rK �unauthenticated_endpoints�action�KeyErrorr7 r r r r> � s � z VultrConnection.require_api_keyN)r' r( r) r* �hostr+ Z responseClsrM rB rE r rI rL r> r r r r r9 a s$ � r9 c @ s� e Zd ZdZeZejZdZ dZ e j e j d�Zg d�Zdddd d �Zg d �Ze�e� e�e�� � d d � Zdd� Zd.dd�Zdd� Zdd� Zdd� Zdd� Zd/d d �Zd d � Z d d!� Z d"d#� Z d$d%� Z d&d'� Z d(d)� Z!d*d+� Z"d,d-� Z#dS )0�VultrNodeDriverz VultrNode node driver. ZVultrzhttps://www.vultr.com)�pendingZactive)Z enable_ipv6Zenable_private_networkZ auto_backupsZnotify_activateZddos_protectionZISOIDZSCRIPTIDZ SNAPSHOTIDZAPPID)Ziso_idZ script_idZ snapshot_idZapp_id)Zipxe_chain_url�labelZuserdataZreserved_ip_v4�hostname�tagc C s | � d| j�S )Nz/v1/server/list)�_list_resources�_to_noder7 r r r � list_nodes� s zVultrNodeDriver.list_nodesc C s | � d| j�S )z� List all the available SSH keys. :return: Available SSH keys. :rtype: ``list`` of :class:`SSHKey` z/v1/sshkey/list)rV � _to_ssh_keyr7 r r r �list_key_pairs� s z VultrNodeDriver.list_key_pairs� c C s$ ||d�}| j �d|�}|jtjkS )a Create a new SSH key. :param name: Name of the new SSH key :type name: ``str`` :key public_key: Public part of the new SSH key :type name: ``str`` :return: True on success :rtype: ``bool`` )r5 �ssh_keyz/v1/sshkey/create)� connectionrL r, r r- )r r5 Z public_key�params�resr r r �create_key_pair� s z VultrNodeDriver.create_key_pairc C s$ d|j i}| j�d|�}|jtjkS )z� Delete an SSH key. :param key_pair: The SSH key to delete :type key_pair: :class:`SSHKey` :return: True on success :rtype: ``bool`` �SSHKEYIDz/v1/sshkey/destroy�r4 r] rL r, r r- )r Zkey_pairr^ r_ r r r �delete_key_pair� s z VultrNodeDriver.delete_key_pairc C s | � d| j�S )Nr= )rV � _to_locationr7 r r r �list_locations� s z VultrNodeDriver.list_locationsc C s | � d| j�S )Nr< )rV �_to_sizer7 r r r � list_sizes� s zVultrNodeDriver.list_sizesc C s | � d| j�S )Nr; )rV � _to_imager7 r r r � list_images� s zVultrNodeDriver.list_imagesNc s |j |j |j |d�}|dur*d�|�|d< |p0i }|�� D ]J\}} || jv r:|| jv rh| r^dnd||< q:|| jv r|| j| }| ||< q:| j�d|�} | jt j kr�dS | j d � d } d} t | �D ]L} z"| � � }� fd d �|D �d } W n t�y t�d� Y q�0 �q q�| S )a� Create a node :param name: Name for the new node :type name: ``str`` :param size: Size of the new node :type size: :class:`NodeSize` :param image: Image for the new node :type image: :class:`NodeImage` :param location: Location of the new node :type location: :class:`NodeLocation` :param ex_ssh_key_ids: IDs of the SSH keys to initialize :type ex_sshkeyid: ``list`` of ``str`` :param ex_create_attr: Extra attributes for node creation :type ex_create_attr: ``dict`` The `ex_create_attr` parameter can include the following dictionary key and value pairs: * `ipxe_chain_url`: ``str`` for specifying URL to boot via IPXE * `iso_id`: ``str`` the ID of a specific ISO to mount, only meaningful with the `Custom` `NodeImage` * `script_id`: ``int`` ID of a startup script to execute on boot, only meaningful when the `NodeImage` is not `Custom` * 'snapshot_id`: ``str`` Snapshot ID to restore for the initial installation, only meaningful with the `Snapshot` `NodeImage` * `enable_ipv6`: ``bool`` Whether an IPv6 subnet should be assigned * `enable_private_network`: ``bool`` Whether private networking support should be added * `label`: ``str`` Text label to be shown in the control panel * `auto_backups`: ``bool`` Whether automatic backups should be enabled * `app_id`: ``int`` App ID to launch if launching an application, only meaningful when the `NodeImage` is `Application` * `userdata`: ``str`` Base64 encoded cloud-init user-data * `notify_activate`: ``bool`` Whether an activation email should be sent when the server is ready * `ddos_protection`: ``bool`` Whether DDOS protection should be enabled * `reserved_ip_v4`: ``str`` IP address of the floating IP to use as the main IP of this server * `hostname`: ``str`` The hostname to assign to this server * `tag`: ``str`` The tag to assign to this server :return: The newly created node. :rtype: :class:`Node` )�DCID� VPSPLANID�OSIDrS N�,ra �yes�noz/v1/server/createF�SUBID� c s g | ]}|j � kr|�qS r )r4 )�.0�n�Zsubidr r � <listcomp>= � z/VultrNodeDriver.create_node.<locals>.<listcomp>r r )r4 �join�items�EX_CREATE_ATTRIBUTES�EX_CREATE_YES_NO_ATTRIBUTES�EX_CREATE_ID_ATTRIBUTESr] rL r, r r- �objectr rX � IndexErrorr r )r r5 �size�image�locationZex_ssh_key_idsZex_create_attrr^ r@ �value�resultZ retry_countZ created_noder! �nodesr rt r � create_node� s6 5� zVultrNodeDriver.create_nodec C s$ d|j i}| j�d|�}|jtjkS )Nrp z/v1/server/rebootrb �r �noder^ r_ r r r � reboot_nodeE s zVultrNodeDriver.reboot_nodec C s$ d|j i}| j�d|�}|jtjkS )Nrp z/v1/server/destroyrb r� r r r � destroy_nodeK s z VultrNodeDriver.destroy_nodec s* | j �|�j� t� �}� �fdd�|D �S )Nc s g | ]}�� | ��qS r r )rr r@ �rD � tranform_funcr r ru T rv z3VultrNodeDriver._list_resources.<locals>.<listcomp>)r] rI r| �sorted)r rH r� Z sorted_keyr r� r rV Q s z VultrNodeDriver._list_resourcesc C s� d|v r:| j �|d tj�}|tjkr@|d dkr@tj}ntj}d|v r`|d d ur`|d g}ng }g }i }|D ]}||v rp|| ||< qpt|d |d ||d || d�}|S )Nr, Z power_status�runningZmain_iprp rS )r4 r5 �state� public_ipsZ private_ips�extra�driver)�NODE_STATE_MAPrI r �UNKNOWN�RUNNINGZSTOPPEDr )r rD r� r� Z extra_keysr� r@ r� r r r rW V s( � �zVultrNodeDriver._to_nodec C s t |d |d |d | d�S )Nrj r5 �country)r4 r5 r� r� )r rC r r r rd p s �z VultrNodeDriver._to_locationc C sl t |d �|d |d d�}t |d �}t |d �}t|d �}t|d �}t|d |d |||||| d �S ) N� vcpu_count� plan_type�available_locations)r� r� r� �ram�disk� bandwidthZprice_per_monthrk r5 )r4 r5 r� r� r� �pricer� r� )�int�floatr )r rD r� r� r� r� r� r r r rf t s � �zVultrNodeDriver._to_sizec C s* |d |d d�}t |d |d || d�S )N�arch�family)r� r� rl r5 )r4 r5 r� r� )r )r rD r� r r r rh � s �zVultrNodeDriver._to_imagec C s t |d |d |d d�S )Nra r5 r\ r3 )r2 rC r r r rY � s �zVultrNodeDriver._to_ssh_key)r[ )NN)$r' r( r) r* r9 Z connectionClsr ZVULTR�typer5 Zwebsiter ZPENDINGr� r� rz r{ ry �extend�keysrX rZ r` rc re rg ri r� r� r� rV rW rd rf rh rY r r r r rQ � sF �� � YrQ ) r* r � functoolsr Zlibcloud.utils.py3r r Zlibcloud.common.baser r Zlibcloud.compute.typesr r Zlibcloud.common.typesr r r Zlibcloud.compute.baser r r r r r r+ r| r2 r9 rQ r r r r �<module> s ' 8
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка