File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/vultr.cpython-310.pyc
Back
o ;j� � @ s� d Z ddlZddlZddlZddlmZmZmZmZm Z ddl m Z ddl m Z mZ ddlmZmZ ddlmZmZmZ ddlmZmZmZmZ dd lm Z m Z m Z m Z m Z m!Z!m"Z" dd l#m$Z$m%Z%m&Z&m'Z' dd l(m)Z) dd l*m+Z+ i d d dddddd��dddddddd��dddddddd��d d d ddd d d��d d d!ddd"d#d��d$d$d%ddd&d'd��d(d(d)d*d+d,d-d��d.d.d/d0d+d,d1d��d2d2d3d4d+d,d5d��d6d6d7ddd"d8d��d9d9d:d;d<d,d=d��d>d>d?d"dd,d@d��dAdAdBdCd+d,dDd��dEdEdFdGdHd,dId��dJdJdKdLdHd,dMd��dNdNdOdddPdQd��dRdRdSdTdHd,dUd��Z,i dVdWdXdYdZd[d\��d]d^d_d`dZd[d\��dadbdcdYdZd[d\��dddedfdYdZd[d\��dgdhdidYdZd[d\��djdkdldYdZd[d\��dmdndodYdpd[d\��dqdrdsd`dpd[d\��dtdudvdYdpd[d\��dwdxdydYdpd[d\��dzd{d|d`d}d[d\��d~dd�dYd}d[d\��d�d�d�dYd}d[d\��d�d�d�dYd�d[d\��d�d�d�dYd�d[d\��d�d�d�dYd�d[d\��d�d�d�dYd�d[d\��d�d�dYd�d[d\�d�d�dYd�d[d\�d�d�dYd�d[d\�d�d�dYd�d[d\�d�d�dYd�d[d\�d�d�dYd�d[d\�d�d�dYd�d[d\�d�d�dYd�d[d\�d�d�dYd�d[d\�d�� �Z-i d�d�d�d d�dEd�d�d�d�d[d�� �d�d�d�d d�d�d�d�d�d�d[d�� �d�d�d�dd�d�d�d�d�d�d[d�� �d�d�d�d d�d�d�d�d�d�d[d�� �d�d�d�d$d�d�d�d�d�d�d[d�� �d�d�d�d.d�d�d�d�d�d�d[d�� �d�d�d�d�d�d�d�d�d�d�d[d�� �d�d�d�dAd�d�d�d�d�d�d[d�� �d�d�d�dd�d�d�d�d�d�d[d�� �d�d�d�d d�d�d�d�d�d�d[d�� �d�d�d�d$d�d�d�d�d�d�d[d�� �d�d�d�d.d�d�d�d�d�d�d[d�� �d�d�d�d d�d�d�d�d�d�d[d�� �djdjd�d d�d�d�d�d�d�d[d�� �d�d�d�dd�d�d�d�d�d�d[d�� �d�d��d dddd�d��dd�d[d�� ��d�d�dd dȐdd�dʐdd�d[d�� ��d�dd.dΐd d�dѐd d�d[d�� �d �d d6�d �d�dddd�d[d�� �d��Z.G �d�d� �d�Z/G �d�d� �de�Z0G �d�d� �d�Z1G �d�d� �de�Z2G �d�d� �d�Z3G �d �d � �d e �Z4G �d �d � �d e4�Z5G �d �d!� �d!e4�Z6dS (" z Vultr Driver � N)�Any�Dict�List�Union�Optional��update_wrapper)�httplib� urlencode)� JsonResponse� ConnectionKey)� LibcloudError�InvalidCredsError�ServiceUnavailableError)�DEFAULT_API_VERSION� VultrNetwork�VultrConnectionV2�VultrNodeSnapshot)�Node�KeyPair�NodeSize� NodeImage� NodeDriver� NodeLocation� StorageVolume)�Provider� NodeState�StorageVolumeState�VolumeSnapshotState)� parse_date)� get_pubkey_openssh_fingerprint�1z New JerseyZUSz North AmericaZNJZEWR)�DCID�name�country� continent�state� regioncode�2ZChicagoZILZORD�3ZDallasZTXZDFW�4ZSeattleZWAZSEA�5z Los Angeles�CAZLAX�6ZAtlantaZGAZATL�7Z Amsterdam�NLZEurope� ZAMS�8ZLondonZGBZLHR�9Z FrankfurtZDEZFRAZ12zSilicon ValleyZSJCZ19ZSydneyZAUZ AustraliaZSYDZ22ZTorontoZYTOZ24ZParisZFRZCDGZ25ZTokyoZJPZAsiaZNRTZ34ZSeoulZKRZICNZ39ZMiamiZFLZMIAZ40Z SingaporeZSGZSGPZ127� z CentOS 6 x64Zx64ZcentosF)�OSIDr# �arch�family�windowsZ147� z CentOS 6 i386Zi386Z167� z CentOS 7 x64Z381i} zCentOS 7 SELinux x64Z362ij z CentOS 8 x64Z401i� zCentOS 8 Stream x64Z215�� zUbuntu 16.04 x64ZubuntuZ216�� zUbuntu 16.04 i386Z270i zUbuntu 18.04 x64Z387i� zUbuntu 20.04 x64Z194�� zDebian 8 i386 (jessie)ZdebianZ244�� zDebian 9 x64 (stretch)Z352i` zDebian 10 x64 (buster)Z230�� zFreeBSD 11 x64ZfreebsdZ327iG zFreeBSD 12 x64Z366in zOpenBSD 6.6 x64ZopenbsdZ394i� zOpenBSD 6.7 x64i� z Fedora CoreOSz fedora-coreosio z Fedora 31 x64Zfedorai� z Fedora 32 x64�| zWindows 2012 R2 x64r7 �� zWindows 2016 x64� ZCustomZiso� ZSnapshot�snapshot� ZBackupZbackup� Z ApplicationZ application) Z391Z367Z389Z124Z240Z159Z164Z180Z186Z201z 1024 MB RAM,25 GB SSD,1.00 TB BWZ1024z1.00z5.00ZSSD) � VPSPLANIDr# � vcpu_count�ram�disk� bandwidthZ bandwidth_gb�price_per_month� plan_typer7 Z202z 2048 MB RAM,55 GB SSD,2.00 TB BWZ2048Z55z2.00z10.00Z203z 4096 MB RAM,80 GB SSD,3.00 TB BWZ4096Z80z3.00Z3072z20.00Z204z!8192 MB RAM,160 GB SSD,4.00 TB BWZ8192Z160z4.00z40.00Z205z"16384 MB RAM,320 GB SSD,5.00 TB BWZ16384Z320Z5120z80.00Z206z"32768 MB RAM,640 GB SSD,6.00 TB BWZ32768Z640z6.00Z6144z160.00Z207z$65536 MB RAM,1280 GB SSD,10.00 TB BWZ16Z65536Z1280Z10240z320.00Z208z$98304 MB RAM,1600 GB SSD,15.00 TB BWZ98304Z1600z15.00Z15360z640.00Z115z"8192 MB RAM,110 GB SSD,10.00 TB BWZ110z60.00Z DEDICATEDZ116z%16384 MB RAM,2x110 GB SSD,20.00 TB BWZ20480z120.00Z117z%24576 MB RAM,3x110 GB SSD,30.00 TB BWZ24576z30.00Z30720z180.00Z118z%32768 MB RAM,4x110 GB SSD,40.00 TB BWZ40960z240.00Z400z 1024 MB RAM,32 GB SSD,1.00 TB BWZ32Z HIGHFREQUENCYz 2048 MB RAM,64 GB SSD,2.00 TB BWZ64z12.00Z402z!4096 MB RAM,128 GB SSD,3.00 TB BWZ128z24.00Z403z!8192 MB RAM,256 GB SSD,4.00 TB BWZ256z48.00Z404z"16384 MB RAM,384 GB SSD,5.00 TB BWZ384z96.00�405z"32768 MB RAM,512 GB SSD,6.00 TB BWZ512z192.00�406z"49152 MB RAM,768 GB SSD,8.00 TB BWZ49152Z768z8.00z256.00)rM rN c @ 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)�selfrS rT � rV �R/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/vultr.py�__init__c 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 sl d }t �jd �D ]&}z � | i |��W S ty/ } z|}t��j� W Y d }~q d }~ww |r4|�d S )NrQ )�rangerT r �timerS )�args�kwargsZlast_exception�_�e��callrU rV rW �wrapperq s ���z&rate_limited.__call__.<locals>.wrapperr )rU r` ra rV r_ rW �__call__g s zrate_limited.__call__N)rP rQ )�__name__� __module__� __qualname__�__doc__rX rb rV rV rV rW rO [ s rO c @ s e Zd Zdd� ZdS )� VultrResponsec C sN | j tjkr | �� }|S | j tjkrt| j��| j tjkr"t| j��t | j��rR ) �statusr �OKZ parse_body� FORBIDDENr �body�SERVICE_UNAVAILABLEr r )rU rk rV rV rW � parse_error� s zVultrResponse.parse_errorN)rc rd re rm rV rV rV rW rg � s rg c @ s e Zd Zdd� Zdd� ZdS )�SSHKeyc C s || _ || _|| _d S rR ��idr# �pub_key)rU rp r# rq rV rV rW rX � s zSSHKey.__init__c C s d| j | j| jf S )Nz$<SSHKey: id=%s, name=%s, pub_key=%s>ro �rU rV rV rW �__repr__� s �zSSHKey.__repr__N)rc rd re rX rs rV rV rV rW rn � s rn 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.comZGET)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)rU �headersrV rV rW �add_default_headers� s z#VultrConnection.add_default_headersc C s t |�S rR )r �rU �datarV rV rW � encode_data� s zVultrConnection.encode_datac C s | � |�S rR ��request)rU �urlrV rV rW �get� s zVultrConnection.getc C s ddi}| j |||dd�S )Nz Content-Typez!application/x-www-form-urlencoded�POST)r~ r{ �methodr� )rU r� r~ r{ rV rV rW �post� s zVultrConnection.postc C s* z | j | j| j vW S ty Y dS w )z� Check whether this call (method + action) must be authenticated. :return: True if ``API-Key`` header required, False otherwise. :rtype: bool T)r� �unauthenticated_endpoints�action�KeyErrorrr rV rV rW rx � s �z VultrConnection.require_api_keyN)rc rd re rf �hostrg Z responseClsr� r| r rO r� r� rx rV rV rV rW rt � s& � rt c @ s e Zd ZdZdd� ZdS )�VultrNodeDriverHelperz! VultrNode helper class. c C s& i }|D ] }||v r|| ||< q|S rR rV )rU � extra_keysr~ �extrarz rV rV rW � handle_extra� s �z"VultrNodeDriverHelper.handle_extraN)rc rd re rf r� rV rV rV rW r� � s r� c s8 e Zd ZejZdZdZddddedf� fdd� Z � Z S )�VultrNodeDriverZVultrzhttps://www.vultr.comNTc s< | t u r|dkr t} n |dkrt} ntd| ��t� �| �S )Nr! r( z)No Vultr driver found for API version: %s)r� �VultrNodeDriverV1�VultrNodeDriverV2�NotImplementedError�super�__new__) �clsrz ZsecretZsecurer� �port� api_version�regionr\ �� __class__rV rW r� � s � zVultrNodeDriver.__new__) rc rd re r ZVULTR�typer# Zwebsiter r� � __classcell__rV rV r� rW r� � s �r� c s� e Zd ZdZeZejejd�Z g d�Z ddddd�Z g d �Z e � e � e � e �� � � fd d �Zd d � Zdd� Zd.dd�Zdd� Zdd� Zdd� Zdd� Zd/d d �Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Z d(d)� Z d*d+� Z d,d-� Z � Z S )0r� z VultrNode node driver. )�pending�active)� enable_ipv6�enable_private_network� auto_backupsZnotify_activate�ddos_protectionZISOIDZSCRIPTIDZ SNAPSHOTID�APPID)�iso_id� script_id� snapshot_id�app_id)�ipxe_chain_url�labelZuserdataZreserved_ip_v4�hostname�tagc s t � j|i |�� t� | _d S rR )r� rX r� �_helper)rU r[ r\ r� rV rW rX s zVultrNodeDriverV1.__init__c C � | � d| j�S )Nz/v1/server/list)�_list_resources�_to_noderr rV rV rW � list_nodes$ � z VultrNodeDriverV1.list_nodesc C r� )z� List all the available SSH keys. :return: Available SSH keys. :rtype: ``list`` of :class:`SSHKey` z/v1/sshkey/list)r� � _to_ssh_keyrr rV rV rW �list_key_pairs' s z VultrNodeDriverV1.list_key_pairsr0 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`` �r# �ssh_keyz/v1/sshkey/create)� connectionr� rh r ri )rU r# � public_key�params�resrV rV rW �create_key_pair/ s z!VultrNodeDriverV1.create_key_pairc C �$ 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�rp r� r� rh r ri )rU �key_pairr� r� rV rV rW �delete_key_pair? s z!VultrNodeDriverV1.delete_key_pairc C r� )Nrw )r� � _to_locationrr rV rV rW �list_locationsL r� z VultrNodeDriverV1.list_locationsc C r� )Nrv )r� �_to_sizerr rV rV rW � list_sizesO r� z VultrNodeDriverV1.list_sizesc C r� )Nru )r� � _to_imagerr rV rV rW � list_imagesR r� z VultrNodeDriverV1.list_imagesNc s |j |j |j |d�}|durd�|�|d< |pi }|�� D ]%\}} || jv rB|| jv r4| r/dnd||< q || jv r>| j| }| ||< q | j�d|�} | jt j krRdS | j d � d } d} t | �D ]#} z| � � }� fd d �|D �d } W | S ty� t�d� Y q_w | 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` )r" rF r4 r� N�,r� Zyes�noz/v1/server/createF�SUBID� c s g | ] }|j � kr|�qS rV �rp )�.0�n�ZsubidrV rW � <listcomp>� s z1VultrNodeDriverV1.create_node.<locals>.<listcomp>r rQ )rp �join�items�EX_CREATE_ATTRIBUTES�EX_CREATE_YES_NO_ATTRIBUTES�EX_CREATE_ID_ATTRIBUTESr� r� rh r ri �objectrY r� � IndexErrorrZ rS )rU r# �size�image�location�ex_ssh_key_idsZex_create_attrr� rz �value�resultZ retry_countZ created_noder] �nodesrV r� rW � create_nodeV s@ 5� � ��z VultrNodeDriverV1.create_nodec C r� )Nr� z/v1/server/rebootr� �rU �noder� r� rV rV rW � reboot_node� � z VultrNodeDriverV1.reboot_nodec C r� )Nr� z/v1/server/destroyr� r� rV rV rW � destroy_node� r� z VultrNodeDriverV1.destroy_nodec s* | j �|�j� t� �}� �fdd�|D �S )Nc s g | ]}�� | ��qS rV rV )r� rz �r~ � tranform_funcrV rW r� � s z5VultrNodeDriverV1._list_resources.<locals>.<listcomp>)r� r� r� �sorted)rU r� r� Z sorted_keyrV r� rW r� � s z!VultrNodeDriverV1._list_resourcesc C s d|v r | j �|d tj�}|tjkr |d dkr tj}ntj}d|v r0|d d ur0|d g}ng }t|d �dkr@|d g}ng }t|d �}g d�}| j� ||�}t �|d �}|rb| � |�} nd } t �|d �}|rs| � |�} nd } t|d |d |||| | ||| d � } | S )Nrh � power_status�running�main_ip� internal_ipr � date_created)r� Zdefault_passwordZpending_chargesZcost_per_monthZcurrent_bandwidth_gbZallowed_bandwidth_gb� netmask_v4� gateway_v4r� Z server_stateZ v6_networksZkvm_urlr� r� r� ZFIREWALLGROUPIDr4 rF r� r� ) rp r# r& � public_ips� private_ipsr� r� r� � created_at�driver)�NODE_STATE_MAPr� r �UNKNOWN�RUNNING�STOPPED�lenr r� r� � VULTR_COMPUTE_INSTANCE_IMAGESr� � VULTR_COMPUTE_INSTANCE_SIZESr� r ) rU r~ r& r� r� r� r� r� Z resolve_datar� r� r� rV rV rW r� � sH � � zVultrNodeDriverV1._to_nodec C s4 g d�}| j �||�}t|d |d |d || d�S )N)r% r& r� Z block_storager' r" r# r$ )rp r# r$ r� r� )r� r� r �rU r~ r� r� rV rV rW r� s �z VultrNodeDriverV1._to_locationc C s� g d�}| j �||�}|�d��� rt|d �|d< t|d �}t|d �}tt|d ��}t|d �}t|d |d |||||| d �S ) N)rG rL Zavailable_locationsrG rH rI rJ rK rF r# )rp r# rH rI rJ �pricer� r� )r� r� r� �isdigit�int�floatr )rU r~ r� r� rH rI rJ r� rV rV rW r� s$ �zVultrNodeDriverV1._to_sizec C s. ddg}| j �||�}t|d |d || d�S )Nr5 r6 r4 r# )rp r# r� r� )r� r� r r� rV rV rW r� ; s zVultrNodeDriverV1._to_imagec C s t |d |d |d d�S )Nr� r# r� ro )rn r} rV rV rW r� @ s z VultrNodeDriverV1._to_ssh_key)r0 )NN)!rc rd re rf rt � connectionClsr �PENDINGr� r� r� r� r� �extend�keysrX r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rV rV r� rW r� � s< � \J r� c / @ sR e Zd ZdZeZejejej ej ej d�Z e je jd�Zejejd�Zd�dedee fdd �Z d�d ed ededee deee deee de e ed f dededee dededee dee dee dee d ed ee d ee d ee d ee d!edef.d"d#�Z d$edefd%d&�Z d$edefd'd(�Z d$edefd)d*�Z!d$edefd+d,�Z"d�dedee fd-d.�Z#dee fd/d0�Z$dee fd1d2�Z%dee& fd3d4�Z'd e(d ede eef de&fd5d6�Z) d�d$ed7e&d8edefd9d:�Z* d�d7e&d8edefd;d<�Z+d7e&defd=d>�Z,dee- fd?d@�Z.dAede-fdBdC�Z/d edDede-fdEdF�Z0dGe-defdHdI�Z1dee fdJdK�Z2d$edefdLdM�Z3d$ed edefdNdO�Z4d$edefdPdQ�Z5d$edefdRdS�Z6d$edefdTdU�Z7dVedefdWdX�Z8dYee defdZd[�Z9dee fd\d]�Z:dee fd^d_�Z;d`ede fdadb�Z< d�d$edcee de fddde�Z=dfe defdgdh�Z>dee? fdidj�Z@ d�dkede eef dcee de?fdldm�ZAdnede?fdodp�ZBdqe?defdrds�ZCdedee fdtdu�ZDdvede&fdwdx�ZEd7e&d e(defdydz�ZFd e eef defd{d|�ZGd}eHeeIf defd~d�ZJd}eHeeIf de&fd�d��ZK d�d�ed�ee defd�d��ZLd}eHeeIf de-fd�d��ZMd}eHeeIf defd�d��ZNd}eHeeIf defd�d��ZOd}eHeeIf defd�d��ZPd}eHeeIf de?fd�d��ZQd}eHeeIf de fd�d��ZR d�d�ed�ed�eeHeeIf deeI fd�d��ZSd S )�r� z" Vultr API v2 NodeDriver. )r� ZhaltedZ rebootingZresizingr� )r� r� )Zcompleter� T�ex_list_bare_metals�returnc �2 � � dd�}� fdd�|D �}|r|� �� 7 }|S )z�List all nodes. :keyword ex_list_bare_metals: Whether to fetch bare metal nodes. :type ex_list_bare_metals: ``bool`` :return: list of node objects :rtype: ``list`` of :class: `Node` � /v2/instancesZ instancesc � g | ]}� � |��qS rV �r� �r� �itemrr rV rW r� f � z0VultrNodeDriverV2.list_nodes.<locals>.<listcomp>)�_paginated_request�ex_list_bare_metal_nodes)rU r r~ r� rV rr rW r� \ s z VultrNodeDriverV2.list_nodesNFr# r� r� r� r� �ex_private_network_ids� ex_snapshot�ex_enable_ipv6� ex_backups� ex_userdata�ex_ddos_protection�ex_enable_private_network�ex_ipxe_chain_url� ex_iso_id� ex_script_id� ex_image_id�ex_activation_email� ex_hostname�ex_tag�ex_firewall_group_id�ex_reserved_ipv4�ex_persistent_pxec C s| ||j |j ||d�}|r|j |d< |r||d< |r.z|j |d< W n ty- ||d< Y nw | r=t�t| d���d�|d< |rC||d< |rI||d< |rO||d < |rU||d < |r[||d < | �|�rz|rf||d < | jjd t � |�dd�}| � |j d �S |r�||d< | r�| |d< | r�| |d< |r�||d< | r�| |d< |r�||d< | r�| du r�dnd|d< | jjdt � |�dd�}| � |j d �S ) a� Create a new node. :param name: The new node's name. :type name: ``str`` :param size: The size to use to create the node. :type size: :class: `NodeSize` :param location: The location to provision the node. :type location: :class: `NodeLocation` :keyword image: The image to use to provision the node. :type image: :class: `NodeImage` :keyword ex_ssh_key_ids: List of SSH keys to install on this node. :type ex_ssh_key_ids: ``list`` of ``str`` :keyword ex_private_network_ids: The network ids to attach to node. This parameter takes precedence over ex_enable_private_network (VPS only) :type ex_private_network_ids: ``list`` of ``str`` :keyword ex_snapshot: The snapshot to use when deploying the node. Mutually exclusive with image, :type ex_snapshot: :class: `VultrNodeSnapshot` or ``str`` :keyword ex_enable_ipv6: Whether to enable IPv6. :type ex_enable_ipv6: ``bool`` :keyword ex_backups: Enable automatic backups for the node. (VPS only) :type ex_backups: ``bool`` :keyword ex_userdata: String containing user data :type ex_userdata: ``str`` :keyword ex_ddos_protection: Enable DDoS protection (VPS only) :type ex_ddos_protection: ``bool`` :keyword ex_enable_private_network: Enable private networking. Mutually exclusive with ex_private_network_ids. (VPS only) :type ex_enable_private_network: ``bool`` :keyword ex_ipxe_chain_url: The URL location of the iPXE chainloader (VPS only) :type ex_ipxe_chain_url: ``str`` :keyword ex_iso_id: The ISO id to use when deploying this node. (VPS only) :type ex_iso_id: ``str`` :keyword ex_script_id: The startup script id to use when deploying this node. :type ex_script_id: ``str`` :keyword ex_image_id: The Application image_id to use when deploying this node. :type ex_image_id: ``str`` :keyword ex_activation_email: Notify by email after deployment. :type ex_activation_email: ``bool`` :keyword ex_hostname: The hostname to use when deploying this node. :type ex_hostname: ``str`` :keyword ex_tag: The user-supplied tag. :type ex_tag: ``str`` :keyword ex_firewall_group_id: The Firewall Group id to attach to this node. (VPS only) :type ex_firewall_group_id: ``str`` :keyword ex_reserved_ipv4: Id of the floating IP to use as the main IP of this node. :type ex_reserved_ipv4: ``str`` :keyword ex_persistent_pxe: Enable persistent PXE (Bare Metal only) :type ex_persistent_pxe: ``bool`` )r� r� �planr� Zactivation_email�os_idZ sshkey_idr� zutf-8Z user_datar� �image_idr� Z reserved_ipv4r� Zpersistent_pxe�/v2/bare-metalsr� �r~ r� Z bare_metalZattach_private_networkr� r� r� r� �firewall_group_idT�enabled�disabledZbackupsr �instance) rp �AttributeError�base64� b64encode�bytes�decode�_is_bare_metalr� r� �json�dumpsr� r� )rU r# r� r� r� r� r r r r r r r r r r r r r r r r r r~ �resprV rV rW r� l sb j� � z VultrNodeDriverV2.create_noder� c C �4 | � |j�r | �|�S | jjd|j dd�}|�� S )z�Reboot the given node. :param node: The node to be rebooted. :type node: :class: `Node` :rtype: ``bool`` z/v2/instances/%s/rebootr� �r� )r+ r� �ex_reboot_bare_metal_noder� r� rp �success�rU r� r. rV rV rW r� � z VultrNodeDriverV2.reboot_nodec C r/ )z�Start the given node. :param node: The node to be started. :type node: :class: `Node` :rtype: ``bool`` z/v2/instances/%s/startr� r0 )r+ r� �ex_start_bare_metal_noder� r� rp r2 r3 rV rV rW � start_node( r4 z VultrNodeDriverV2.start_nodec C s" | � |j�r | �|�S | �|g�S )z�Stop the given node. :param node: The node to be stopped. :type node: :class: `Node` :rtype: ``bool`` )r+ r� �ex_stop_bare_metal_node� ex_stop_nodes)rU r� rV rV rW � stop_node7 s zVultrNodeDriverV2.stop_nodec C r/ )z�Destroy the given node. :param node: The node to be destroyed. :type node: :class: `Node` :rtype: ``bool`` �/v2/instances/%s�DELETEr0 )r+ r� �ex_destroy_bare_metal_noder� r� rp r2 r3 rV rV rW r� D r4 z VultrNodeDriverV2.destroy_nodec r )z�List available node sizes. :keyword ex_list_bare_metals: Whether to fetch bare metal sizes. :type ex_list_bare_metals: ``bool`` :rtype: ``list`` of :class: `NodeSize` z /v2/plansZplansc r rV �r� r rr rV rW r� \ r z0VultrNodeDriverV2.list_sizes.<locals>.<listcomp>)r �ex_list_bare_metal_sizes)rU r r~ ZsizesrV rr rW r� S s z VultrNodeDriverV2.list_sizesc � � � dd�}� fdd�|D �S )zUList available node images. :rtype: ``list`` of :class: `NodeImage` z/v2/os�osc r rV )r� r rr rV rW r� h r z1VultrNodeDriverV2.list_images.<locals>.<listcomp>�r r} rV rr rW r� b � z VultrNodeDriverV2.list_imagesc r? )z[List available node locations. :rtype: ``list`` of :class: `NodeLocation` z /v2/regionsZregionsc r rV )r� r rr rV rW r� p r z4VultrNodeDriverV2.list_locations.<locals>.<listcomp>rA r} rV rr rW r� j rB z VultrNodeDriverV2.list_locationsc r? )zRList storage volumes. :rtype: ``list`` of :class:`StorageVolume` � /v2/blocks�blocksc r rV )� _to_volumer rr rV rW r� x r z2VultrNodeDriverV2.list_volumes.<locals>.<listcomp>rA r} rV rr rW � list_volumesr rB z VultrNodeDriverV2.list_volumesc C s\ ||d�}z|j |d< W n ty ||d< Y nw | jjdt�|�dd�}| �|jd �S )a� Create a new volume. :param size: Size of the volume in gigabytes. Size may range between 10 and 10000. :type size: ``int`` :param name: Name of the volume to be created. :type name: ``str`` :param location: Which data center to create the volume in. :type location: :class:`NodeLocation` or ``str`` :return: The newly created volume. :rtype: :class:`StorageVolume` �r� �size_gbr� rC r� r! �block)rp r& r� r� r, r- rE r� )rU r� r# r� r~ r. rV rV rW � create_volumez s � �z VultrNodeDriverV2.create_volume�volume�ex_livec C s2 |j |d�}| jjd|j t�|�dd�}|�� S )aL Attaches volume to node. :param node: Node to attach volume to. :type node: :class:`Node` :param volume: Volume to attach. :type volume: :class:`StorageVolume` :param ex_live: Attach the volume without restarting the node. :type ex_live: ``bool`` :rytpe: ``bool`` )� instance_id�livez/v2/blocks/%s/attachr� r! )rp r� r� r, r- r2 )rU r� rK rL r~ r. rV rV rW � attach_volume� s ��z VultrNodeDriverV2.attach_volumec C s. d|i}| j jd|j t�|�dd�}|�� S )a Detaches a volume from a node. :param volume: Volume to be detached :type volume: :class:`StorageVolume` :param ex_live: Detach the volume without restarting the node. :type ex_live: ``bool`` :rtype: ``bool`` rN z/v2/blocks/%s/detachr� r! )r� r� rp r, r- r2 )rU rK rL r~ r. rV rV rW � detach_volume� s �z VultrNodeDriverV2.detach_volumec C � | j jd|j dd�}|�� S )z�Destroys a storage volume. :param volume: Volume to be destroyed :type volume: :class:`StorageVolume` :rtype: ``bool`` � /v2/blocks/%sr; r0 �r� r� rp r2 )rU rK r. rV rV rW �destroy_volume� � z VultrNodeDriverV2.destroy_volumec r? )zcList all the available SSH key pair objects. :rtype: ``list`` of :class:`KeyPair` � /v2/ssh-keysZssh_keysc r rV )� _to_key_pairr rr rV rW r� � r z4VultrNodeDriverV2.list_key_pairs.<locals>.<listcomp>rA r} rV rr rW r� � rB z VultrNodeDriverV2.list_key_pairs�key_idc C � | j �d| �}| �|jd �S )z�Retrieve a single key pair. :param key_id: ID of the key pair to retrieve. :type key_id: ``str`` :rtype: :class: `KeyPair` �/v2/ssh-keys/%sr� )r� r� rW r� )rU rX r. rV rV rW � get_key_pair� � z VultrNodeDriverV2.get_key_pair� key_materialc C s2 ||d�}| j jdt�|�dd�}| �|jd �S )z�Import a new public key from string. :param name: Key pair name. :type name: ``str`` :param key_material: Public key material. :type key_material: ``str`` :rtype: :class: `KeyPair` r� rV r� r! r� )r� r� r, r- rW r� )rU r# r] r~ r. rV rV rW �import_key_pair_from_string� s �z-VultrNodeDriverV2.import_key_pair_from_stringr� c C s" | j jd|jd dd�}|�� S )z�Delete existing key pair. :param key_pair: The key pair object to delete. :type key_pair: :class:`.KeyPair` :rtype: ``bool`` rZ rp r; r0 )r� r� r� r2 )rU r� r. rV rV rW r� s z!VultrNodeDriverV2.delete_key_pairc r? )zvList all bare metal nodes. :return: list of node objects :rtype: ``list`` of :class: `Node` r Z bare_metalsc r rV r r rr rV rW r� r z>VultrNodeDriverV2.ex_list_bare_metal_nodes.<locals>.<listcomp>rA r} rV rr rW r � z*VultrNodeDriverV2.ex_list_bare_metal_nodesc C rQ )z�Reboot the given bare metal node. :param node: The bare metal node to be rebooted. :type node: :class: `Node` :rtype: ``bool`` z/v2/bare-metals/%s/rebootr� r0 rS r3 rV rV rW r1 � z+VultrNodeDriverV2.ex_reboot_bare_metal_nodec C s8 d|j i}| jjd|j t�|�dd�}| �|jd �S )z�Change size for the given node, only applicable for VPS nodes. :param node: The node to be resized. :type node: :class: `Node` :param size: The new size. :type size: :class: `NodeSize` r r: �PATCHr! r% )rp r� r� r, r- r� r� )rU r� r� r~ r. rV rV rW �ex_resize_node% s �z VultrNodeDriverV2.ex_resize_nodec C rQ )z�Start the given bare metal node. :param node: The bare metal node to be started. :type node: :class: `Node` :rtype: ``bool`` z/v2/bare-metals/%s/startr� r0 rS r3 rV rV rW r5 4 r` z*VultrNodeDriverV2.ex_start_bare_metal_nodec C rQ )z�Stop the given bare metal node. :param node: The bare metal node to be stopped. :type node: :class: `Node` :rtype: ``bool`` z/v2/bare-metals/%s/haltr� r0 rS r3 rV rV rW r7 @ r` z)VultrNodeDriverV2.ex_stop_bare_metal_nodec C rQ )z�Destroy the given bare metal node. :param node: The bare metal node to be destroyed. :type node: :class: `Node` :rtype: ``bool`` z/v2/bare-metals/%sr; r0 rS r3 rV rV rW r< L r` z,VultrNodeDriverV2.ex_destroy_bare_metal_node�node_idc C rY )z�Retrieve a node object. :param node_id: ID of the node to retrieve. :type snapshot_id: ``str`` :rtype: :class: `Node` r: r% )r� r� r� r� )rU rc r. rV rV rW � ex_get_nodeX r\ z VultrNodeDriverV2.ex_get_noder� c C s2 ddd� |D �i}| j jdt�|�dd�}|�� S )z�Stops all the nodes given. : param nodes: A list of the nodes to stop. : type node: ``list`` of: class `Node` : rtype: ``bool`` Z instance_idsc S s g | ]}|j �qS rV r� )r� r� rV rV rW r� l s z3VultrNodeDriverV2.ex_stop_nodes.<locals>.<listcomp>z/v2/instances/haltr� r! )r� r� r, r- r2 )rU r� r~ r. rV rV rW r8 c s z VultrNodeDriverV2.ex_stop_nodesc r? )zOList bare metal sizes. :rtype: ``list`` of :class: `NodeSize` z/v2/plans-metalZ plans_metalc r rV r= r rr rV rW r� w r z>VultrNodeDriverV2.ex_list_bare_metal_sizes.<locals>.<listcomp>rA r} rV rr rW r> q rB z*VultrNodeDriverV2.ex_list_bare_metal_sizesc r? )zVList node snapshots. :rtype: ``list`` of :class: `VultrNodeSnapshot` � /v2/snapshotsZ snapshotsc r rV )� _to_snapshotr rr rV rW r� r z7VultrNodeDriverV2.ex_list_snapshots.<locals>.<listcomp>rA r} rV rr rW �ex_list_snapshotsy rB z#VultrNodeDriverV2.ex_list_snapshotsr� c C rY )z�Retrieve a snapshot. :param snapshot_id: ID of the snapshot to retrieve. :type snapshot_id: ``str`` :rtype: :class: `VultrNodeSnapshot` �/v2/snapshots/%srC )r� r� rf r� )rU r� r. rV rV rW �ex_get_snapshot� r\ z!VultrNodeDriverV2.ex_get_snapshot� descriptionc C s> d|j i}|r ||d< | jjdt�|�dd�}| �|jd �S )a Create snapshot from a node. :param node: Node to create the snapshot from. :type node: :class: `Node` :keyword description: A description of the snapshot. :type description: ``str`` :rtype: :class: `VultrNodeSnapshot` rM rj re r� r! rC )rp r� r� r, r- rf r� )rU r� rj r~ r. rV rV rW �ex_create_snapshot� s �z$VultrNodeDriverV2.ex_create_snapshotrC c C rQ )z�Delete the given snapshot. :param snapshot: The snapshot to delete. :type node: :class:`VultrNodeSnapshot` :rtype: ``bool`` rh r; r0 rS )rU rC r. rV rV rW �ex_delete_snapshot� rU z$VultrNodeDriverV2.ex_delete_snapshotc r? )zWList all private networks. :rtype: ``list`` of :class: `VultrNetwork` �/v2/private-networksZnetworksc r rV )� _to_networkr rr rV rW r� � r z6VultrNodeDriverV2.ex_list_networks.<locals>.<listcomp>rA r} rV rr rW �ex_list_networks� r_ z"VultrNodeDriverV2.ex_list_networks� cidr_blockc C sz |� d�\}}|t|�d�}z|j|d< W n ty" ||d< Y nw |r)||d< | jjdt�|�dd�}| �|j d �S ) a� Create a private network. :param cidr_block: The CIDR block assigned to the network. :type cidr_block: ``str`` :param location: The location to create the network. :type location: :class: `NodeLocation` or ``str`` :keyword description: A description of the private network. :type description: ``str`` :rtype: :class: `VultrNetwork` �/)� v4_subnet�v4_subnet_maskr� rj rm r� r! �network) �splitr� rp r& r� r� r, r- rn r� )rU rp r� rj ZsubnetZ subnet_maskr~ r. rV rV rW �ex_create_network� s � �z#VultrNodeDriverV2.ex_create_network� network_idc C rY )z�Retrieve a private network. :param network_id: ID of the network to retrieve. :type network_id: ``str`` :rtype: :class: `VultrNetwork` �/v2/private-networks/%srt )r� r� rn r� )rU rw r. rV rV rW �ex_get_network� s z VultrNodeDriverV2.ex_get_networkrt c C rQ )z�Delete a private network. :param network: The network to destroy. :type network: :class: `VultrNetwork` :rtype: ``bool`` rx r; r0 rS )rU rt r. rV rV rW �ex_destroy_network� r` z$VultrNodeDriverV2.ex_destroy_networkc C s | j �d|j �}|jd S )a Get a list of available sizes for the given location. :param location: The location to get available sizes for. :type location: :class: `NodeLocation` :return: A list of available size IDs for the given location. :rtype: ``list`` of ``str`` z/v2/regions/%s/availabilityZavailable_plans)r� r� rp r� )rU r� r. rV rV rW �$ex_list_available_sizes_for_location� s z6VultrNodeDriverV2.ex_list_available_sizes_for_location� volume_idc C rY )z�Retrieve a single volume. :param volume_id: The ID of the volume to fetch. :type volume_id: ``str`` :rtype :class: `StorageVolume` :return: StorageVolume instance on success. rR rI )r� r� rE r� )rU r| r. rV rV rW � ex_get_volume s z VultrNodeDriverV2.ex_get_volumec C s2 |j |d�}| jjd|j t�|�dd�}|�� S )a Resize a volume. :param volume: The volume to resize. :type volume: :class:`StorageVolume` :param size: The new volume size in GBs. Size may range between 10 and 10000. :type size: ``int`` :rtype: ``bool`` rG rR ra r! )r# r� r� rp r, r- r2 )rU rK r� r~ r. rV rV rW �ex_resize_volume s ��z"VultrNodeDriverV2.ex_resize_volumec C s, z|j }W n ty |}Y nw |�d�S )NZvbm)rp r& � startswith)rU r� Zsize_idrV rV rW r+ ( s � z VultrNodeDriverV2._is_bare_metalr~ c C sH |d }|d }|d � � |d � � }|d }t|d �}|d }| �|�}|d |d |d |d |d |d |d |d |d |d |d |d |d� } |rg| �|d �} |d | d< |d | d< d } n/| j|d |d d�} |d | d< |d | d< |d | d< |d | d < |d | d < |d � � } t||| || | ||| |d � S ) Nrp r� r� Z v6_main_ipr r r� r� rH rI r� r� � v6_network�v6_network_sizer� r �featuresr� r@ ) r� rH rI r� r� r� r� r� r r� r� r@ � is_bare_metalrh � cpu_countZ mac_addressr� )� power_staterG Zallowed_bandwidthZ server_statusr" r� ) rp r# r& r� r� r� r� r� r� r� )ru �strr+ �_get_node_stater ) rU r~ �id_r# r� r� r� r� r� r� r& r� rV rV rW r� 0 sZ � �zVultrNodeDriverV2._to_nodec C s| |d }|d }|d }z | j |d }W n ty! tj}Y nw |d |d |d |d |d d �}t|||| ||d �S ) Nrp r� rH rh r� �costr� �attached_to_instance�mount_id)r� r� r� r� r� )rp r# r� r� r& r� )�VOLUME_STATE_MAPr� r r� r )rU r~ r� r# r� r& r� rV rV rW rE b s ��z VultrNodeDriverV2._to_volumer& r� c C sP z| j | }W n ty tj}Y nw |d u r|S |tjkr&|dkr&tj}|S )Nr� )r� r� r r� r� r� )rU r& r� rV rV rW r� s s �z!VultrNodeDriverV2._get_node_statec C sX |d }|d }zt |�}W n ty d }Y nw |d |d d�}t|||| |d�S )Nr# r� rp r� )rp r� )r# r� � fingerprintr� r� )r � RuntimeErrorr )rU r~ r# r� r� r� rV rV rW rW � s" ���z VultrNodeDriverV2._to_key_pairc C s< |d }|d }|d }|d |d d�}t |||| |d�S )Nrp Zcityr$ r% �options)r% �option)rp r# r$ r� r� )r )rU r~ r� r# r$ r� rV rV rW r� � s �z VultrNodeDriverV2._to_locationc C s2 |d }|d }|d |d d�}t ||| |d�S )Nrp r# r5 r6 )r5 r6 )rp r# r� r� )r )rU r~ r� r# r� rV rV rW r� � s �zVultrNodeDriverV2._to_imagec C s� |d }|d }|d }|d }|d }| � |�}|d |d |d |d �}|d u r1|d |d < n|d |d < |d |d < |d |d< t||||||| |d�S )Nrp rH rI rJ Z monthly_cost� locationsr� � disk_count)r� r� r� r� FrG r� Z cpu_modelZ cpu_threads)rp r# rH rI rJ r� r� r� )r+ r ) rU r~ r� rH rI rJ r� r� r� rV rV rW r� � s4 � �zVultrNodeDriverV2._to_sizec C sF |d }d� |d |d �}|d }|d |d d�}t||||d �S ) Nrp z{}/{}rr rs r� rj r� )rj r� )rp rp r� r� )�formatr )rU r~ r� rp r� r� rV rV rW rn � s �z VultrNodeDriverV2._to_networkc C s| |d }|d }|d d d d }z | j |d }W n ty' tj}Y nw |d |d |d d �}t|||||| d �S ) Nrp r� r� i rh rj r r� )rj r r� )rp r� �createdr& r� r� )�SNAPSHOT_STATE_MAPr� r r� r )rU r~ r� r� r� r& r� rV rV rW rf � s �� �z VultrNodeDriverV2._to_snapshotr� rz r� c C s� |dur|ni }| j j||d�j}t|�|g ��}|} |d d d }|rA||d< | j j||d�j}t|�|g ��}|�|� n|S q )a� Perform multiple calls to get the full list of items when the API responses are paginated. :param url: API endpoint :type url: ``str`` :param key: Result object key :type key: ``str`` :param params: Request parameters :type params: ``dict`` :return: ``list`` of API response objects :rtype: ``list`` N)r� T�metaZlinks�nextZcursor)r� r� r� �listr� r� )rU r� rz r� r. r~ ZobjectsZ next_pagerV rV rW r � s �z$VultrNodeDriverV2._paginated_request)T)NNNNFFNFFNNNNFNNNNFrR )Trc rd re rf r r� r r� r� Z REBOOTINGZ RECONFIGURINGr� r� r Z AVAILABLEZCREATINGr� r r� �boolr r r� r� r r r r r r r� r� r6 r9 r� r� r� r� r rF r� rJ rO rP rT r r� r[ r^ r� r r1 rb r5 r7 r< rd r8 r> rg ri rk rl r ro rv ry rz r{ r} r~ r+ r r r� rE r� rW r� r� r� rn rf r rV rV rV rW r� D s| � ������� � � � � � � � ����������� � . �� � �&���� �!��� � ��� � �� �� �% � � 2��� � ! �����r� )7rf r, rZ r' �typingr r r r r � functoolsr Zlibcloud.utils.py3r r Zlibcloud.common.baser r Zlibcloud.common.typesr r r Zlibcloud.common.vultrr r r r Zlibcloud.compute.baser r r r r r r Zlibcloud.compute.typesr r r r Zlibcloud.utils.iso8601r Zlibcloud.utils.publickeyr Z VULTR_COMPUTE_INSTANCE_LOCATIONSr� r� rO rg rn rt r� r� r� r� rV rV rV rW �<module> s� $ �� ������!��)��1��9��A��I��Q��Y��a��i��q��y�� � �� �������� ��$��+��2��9��@��G��N��U��\��c��j��q��y��������� �� 9�� ����%��1��=��I��U��a��m��y�� � �� � �� � �� *� �� 6� �� B� �� O� � � � i' 7 I
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings