File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/linode.cpython-310.pyc
Back
o ;j\� � @ s$ d Z ddlZddlZddlZddlZddlmZ ddlmZ ddlmZ ddl m Z m Z m Z m Z mZmZmZmZmZ ddlmZmZmZmZmZmZmZmZm Z m Z m Z ddl m Z m!Z!m"Z" dd l#m$Z$ zddl%Z&W n e'yw ddl&Z&Y nw G d d � d e�Z(G d d � d e(�Z)G dd� de(�Z*dS )a� libcloud driver for the Linode(R) API This driver implements all libcloud functionality for the Linode API. Since the API is a bit more fine-grained, create_node abstracts a significant amount of work (and may take a while to run). Linode home page http://www.linode.com/ Linode API documentation http://www.linode.com/api/ Alternate bindings for reference http://github.com/tjfontaine/linode-python Linode(R) is a registered trademark of Linode, LLC. � N)�copy)�datetime)�httplib) �Node�KeyPair�NodeSize� NodeImage� NodeDriver� NodeLocation� StorageVolume�NodeAuthSSHKey�NodeAuthPassword) �API_ROOT�LINODE_PLAN_IDS�DEFAULT_API_VERSION�LINODE_DISK_FILESYSTEMS�LINODE_DISK_FILESYSTEMS_V4� LinodeDisk�LinodeException�LinodeIPAddress�LinodeConnection�LinodeExceptionV4�LinodeConnectionV4)�Provider� NodeState�StorageVolumeState��is_private_subnetc s8 e Zd ZdZdZejZddddedf� fdd� Z � Z S )�LinodeNodeDriverZLinodezhttp://www.linode.com/NTc s< | t u r|dkr t} n |dkrt} ntd| ��t� �| �S )Nz3.0z4.0z*No Linode driver found for API version: %s)r �LinodeNodeDriverV3�LinodeNodeDriverV4�NotImplementedError�super�__new__) �cls�key�secret�secure�host�port� api_version�region�kwargs�� __class__� �S/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/linode.pyr# L s � zLinodeNodeDriver.__new__) �__name__� __module__� __qualname__�nameZwebsiter ZLINODE�typer r# � __classcell__r/ r/ r- r0 r G s �r c @ s e Zd ZdZeZeZeZ dddgiZ d1dd�Z e j e je je je je je j d �Zd d � Zd d � Zdd� Zdd� Zdd� Z d2dd�Zdd� Zdd� Zdd � Zd d � Z d3d d �Z d!d"� Z d#d$� Z d%d&� Z d'd(� Z!d)d*� Z"d3d+d,�Z#d-d.� Z$d/d0� Z%dS )4r a8 libcloud driver for the Linode API Rough mapping of which is which: - list_nodes linode.list - reboot_node linode.reboot - destroy_node linode.delete - create_node linode.create, linode.update, linode.disk.createfromdistribution, linode.disk.create, linode.config.create, linode.ip.addprivate, linode.boot - list_sizes avail.linodeplans - list_images avail.distributions - list_locations avail.datacenters - list_volumes linode.disk.list - destroy_volume linode.disk.delete For more information on the Linode API, be sure to read the reference: http://www.linode.com/api/ � create_node�ssh_key�passwordNTc K s d| _ t�| |� dS )z�Instantiate the driver with the given API key :param key: the API key to use (required) :type key: ``str`` :rtype: ``None`` N)� datacenterr �__init__) �selfr% r& r' r( r) r* r+ r, r/ r/ r0 r; s zLinodeNodeDriverV3.__init__)������r � � � � c C s( ddi}| j jt|d�jd }| �|�S )a~ List all Linodes that the API key can access This call will return all Linodes that the API key in use has access to. If a node is in this list, rebooting will work; however, creation and destruction are a separate grant. :return: List of node objects that the API key can access :rtype: ``list`` of :class:`Node` � api_action� linode.list��paramsr )� connection�requestr �objects� _to_nodes)r< rF �datar/ r/ r0 � list_nodes� s z LinodeNodeDriverV3.list_nodesc C � d|j d�}| jjt|d� dS )z( Boot the given Linode � linode.boot�rC �LinodeIDrE T��idrG rH r �r< �noderF r/ r/ r0 � start_node� � z LinodeNodeDriverV3.start_nodec C rM )z, Shutdown the given Linode zlinode.shutdownrO rE TrQ rS r/ r/ r0 � stop_node� rV z LinodeNodeDriverV3.stop_nodec C rM )a8 Reboot the given Linode Will issue a shutdown job followed by a boot job, using the last booted configuration. In most cases, this will be the only configuration. :param node: the Linode to reboot :type node: :class:`Node` :rtype: ``bool`` z linode.rebootrO rE TrQ rS r/ r/ r0 � reboot_node� s z LinodeNodeDriverV3.reboot_nodec C s" d|j dd�}| jjt|d� dS )a' Destroy the given Linode Will remove the Linode from the account and issue a prorated credit. A grant for removing Linodes from the account is required, otherwise this method will fail. In most cases, all disk images must be removed from a Linode before the Linode can be removed; however, this call explicitly skips those safeguards. There is no going back from this method. :param node: the Linode to destroy :type node: :class:`Node` :rtype: ``bool`` z linode.deleteT)rC rP Z skipChecksrE rQ rS r/ r/ r0 � destroy_node� s �z LinodeNodeDriverV3.destroy_nodeFc ! C s | � |�}|r |j}n | jr| j}ntdd��| �� }|jdd� |D �vr*tdd��| s.dnt| �}|dvr;tdd��d }d }t|t�rH|j}nt|t �rP|j }|sY|sYtdd ��|d urht |�d k rhtdd ��z |smd nt |�}W n t y~ tdd��w |s�|j| nt |�}|| |jkr�tdd��| �� }|jdd� |D �vr�tdd��|r�|}n |jd r�d}nd}ddi}| jjt|d�jd }|dd� |D �vr�tdd��| s�dn| }d ||j|d �}| jjt|d�jd }d |d i} d | d |d!�}| jjt|d� | �rd"| d d#�}| jjt|d� d$| d d%�| d |j�d&| d d'�} | �r2| | d(< | �r9| | d)< |�r@|| d*< |�sPt�t�d+���d,�� � }d-| d |j| d) ||d.�}|�re||d/< | jjt|d�jd }|d0 | d1< d2| d | d* d3|d4�}| jjt|d�jd }|d0 | d5< d6�| d1 | d5 �} d7| d || d( || d8�}| �r�d9|d:< d9|d;< | jjt|d�jd }|d< | d=< d>| d | d= d?�}| jjt|d� d@| d d#�}| jjt|d�jd }| � |�} t | �dAk�r | d } t |dBdC��r|j | jdD< | S d S )Ea Create a new Linode, deploy a Linux distribution, and boot This call abstracts much of the functionality of provisioning a Linode and getting it booted. A global grant to add Linodes to the account is required, as this call will result in a billing charge. Note that there is a safety valve of 5 Linodes per hour, in order to prevent a runaway script from ruining your day. :keyword name: the name to assign the Linode (mandatory) :type name: ``str`` :keyword image: which distribution to deploy on the Linode (mandatory) :type image: :class:`NodeImage` :keyword size: the plan size to create (mandatory) :type size: :class:`NodeSize` :keyword auth: an SSH key or root password (mandatory) :type auth: :class:`NodeAuthSSHKey` or :class:`NodeAuthPassword` :keyword location: which datacenter to create the Linode in :type location: :class:`NodeLocation` :keyword ex_swap: size of the swap partition in MB (128) :type ex_swap: ``int`` :keyword ex_rsize: size of the root partition in MB (plan size - swap). :type ex_rsize: ``int`` :keyword ex_kernel: a kernel ID from avail.kernels (Latest 2.6 Stable). :type ex_kernel: ``str`` :keyword ex_payment: one of 1, 12, or 24; subscription length (1) :type ex_payment: ``int`` :keyword ex_comment: a small comment for the configuration (libcloud) :type ex_comment: ``str`` :keyword ex_private: whether or not to request a private IP (False) :type ex_private: ``bool`` :keyword lconfig: what to call the configuration (generated) :type lconfig: ``str`` :keyword lroot: what to call the root image (generated) :type lroot: ``str`` :keyword lswap: what to call the swap space (generated) :type lswap: ``str`` :return: Node representing the newly-created Linode :rtype: :class:`Node` � z!Need to select a datacenter firstc S � g | ]}|j �qS r/ �rR )�.0�pr/ r/ r0 � <listcomp>@ � z2LinodeNodeDriverV3.create_node.<locals>.<listcomp>z Invalid plan ID -- avail.plans�1)ra Z12Z24z Invalid subscription (1, 12, 24)Nz Need SSH key or root password� zRoot password is too short� zNeed an integer swap sizez Total disk images are too bigc S r[ r/ r\ �r] �dr/ r/ r0 r_ b r` z%Invalid distro -- avail.distributions�64bit� � rC z avail.kernelsrE r c S � g | ]}|d �qS )ZKERNELIDr/ )r] �zr/ r/ r0 r_ q � z Invalid kernel -- avail.kernelsz5Created by Apache libcloud <https://www.libcloud.org>z linode.create)rC Z DatacenterID�PlanIDZ PaymentTermrR rP � linode.update�rC rP �Labelzlinode.ip.addprivaterO z[%s] Configuration Profilez[{}] {} Disk Imagez[%s] Swap Space)�lconfig�lroot�lswaprp rq rr � �asciiz"linode.disk.createfromdistribution)rC rP ZDistributionIDro �SizeZrootPassZ rootSSHKey�DiskIDZ rootimage�linode.disk.create�swap�rC rP ro �Typeru Z swapimagez {},{},,,,,,,zlinode.config.create)rC rP ZKernelIDro ZCommentsZDiskListTZhelper_networkZ helper_distro�ConfigIDZconfigrN )rC rP r{ rD r? Z generatedFr9 ) Z_get_and_check_authrR r: r � list_sizes�str� isinstancer Zpubkeyr r9 �len�int� Exception�disk� list_images�extrarG rH r rI �formatr4 �binascii� b2a_base64�os�urandom�decode�striprJ �getattr)!r< r4 �image�sizeZauth�locationZex_swapZex_rsizeZ ex_kernelZ ex_paymentZ ex_commentZ ex_privaterp rq rr ZchosenZplansZpaymentZssh�rootrx Z imagesize�distrosZkernelrF ZkernelsZcommentsrK Zlinode�labelZdisks�nodesrT r/ r/ r0 r7 � s� G � ��� � �� � � � z LinodeNodeDriverV3.create_nodec C �" d|j |d�}| jjt|d� dS )aX Resizes a Linode from one plan to another Immediately shuts the Linode down, charges/credits the account, and issue a migration to another host server. Requires a size (numeric), which is the desired PlanID available from avail.LinodePlans() After resize is complete the node needs to be booted z linode.resize)rC rP rl rE TrQ )r< rT r� rF r/ r/ r0 �ex_resize_node� s z!LinodeNodeDriverV3.ex_resize_nodec C � | j |d�S �N)rT �rU �r< rT r/ r/ r0 � ex_start_node� � z LinodeNodeDriverV3.ex_start_nodec C r� r� �rW r� r/ r/ r0 � ex_stop_node� r� z LinodeNodeDriverV3.ex_stop_nodec C r� )zRenames a noderm rn rE TrQ )r< rT r4 rF r/ r/ r0 �ex_rename_node s z!LinodeNodeDriverV3.ex_rename_nodec C sp ddi}| j jt|d�jd }g }|D ]"}t|d |d |d |d d |d |d | j jd �}|�|� q|S ) a� List available Linode plans Gets the sizes that can be used for creating a Linode. Since available Linode plans vary per-location, this method can also be passed a location to filter the availability. :keyword location: the facility to retrieve plans in :type location: :class:`NodeLocation` :rtype: ``list`` of :class:`NodeSize` rC zavail.linodeplansrE r �PLANID�LABELZRAMZDISKi ZXFERZPRICE)rR r4 �ramr� � bandwidth�price�driver)rG rH r rI r r� �append)r< r� rF rK Zsizes�obj�nr/ r/ r0 r| s � z LinodeNodeDriverV3.list_sizesc C sd ddi}| j jt|d�jd }g }|D ] }t|d |d | j j|d |d d �d �}|�|� q|S ) z� List available Linux distributions Retrieve all Linux distributions that can be deployed to a Linode. :rtype: ``list`` of :class:`NodeImage` rC zavail.distributionsrE r ZDISTRIBUTIONIDr� ZREQUIRESPVOPSKERNELZIS64BIT)Zpvopsrf �rR r4 r� r� )rG rH r rI r r� r� )r< rF rK r� r� �ir/ r/ r0 r� $ s � z LinodeNodeDriverV3.list_imagesc C s� ddi}| j jt|d�jd }g }|D ]/}d}d|d v r d}nd |d v r)d }n d |d v r2d }nd }|�t|d |d || �� q|S )z� List available facilities for deployment Retrieve all facilities that a Linode can be deployed in. :rtype: ``list`` of :class:`NodeLocation` rC �avail.datacentersrE r NZUSAZLOCATIONZUSZUKZGBZJPz??� DATACENTERID)rG rH r rI r� r )r< rF rK �nl�dc�countryr/ r/ r0 �list_locations9 s z!LinodeNodeDriverV3.list_locationsc C sn |j }ddi}| jjt|d�jd }|D ]}||d kr"|| _ dS qd�dd � |D ��}d| _td d | ��) a� Set the default datacenter for Linode creation Since Linodes must be created in a facility, this function sets the default that :class:`create_node` will use. If a location keyword is not passed to :class:`create_node`, this method must have already been used. :keyword dc: the datacenter to create Linodes in unless specified :type dc: :class:`NodeLocation` :rtype: ``bool`` rC r� rE r r� Nz, c S ri )r� r/ rd r/ r/ r0 r_ g rk z<LinodeNodeDriverV3.linode_set_datacenter.<locals>.<listcomp>� z"Invalid datacenter (use one of %s))rR rG rH r rI r: �joinr )r< r� ZdidrF rK r: Zdcsr/ r/ r0 �linode_set_datacenterQ s �z(LinodeNodeDriverV3.linode_set_datacenterc C sT t |t�s tdd��|jd du rtdd��d|jd |jd�}| jjt|d� d S ) a~ Destroys disk volume for the Linode. Linode id is to be provided as extra["LinodeId"] within :class:`StorageVolume`. It can be retrieved by :meth:`libcloud.compute.drivers.linode.LinodeNodeDriver .ex_list_volumes`. :param volume: Volume to be destroyed :type volume: :class:`StorageVolume` :rtype: ``bool`` r� �Invalid volume instance�LINODEIDNzMissing LinodeIDzlinode.disk.delete�rC rP rv rE T)r~ r r r� rR rG rH r )r< �volumerF r/ r/ r0 �destroy_volumek s �z!LinodeNodeDriverV3.destroy_volumec C s� t |t�s tdd��|jd }| �|�}d}|D ]}||j }q|| } | |k r/tdd| ��|| jvr9tdd��d|j|||d�} | jj t | d �j d } | d }d |j|d �} | jj t | d �j d } | � | �d S ) ab Create disk for the Linode. :keyword size: Size of volume in megabytes (required) :type size: ``int`` :keyword name: Name of the volume to be created :type name: ``str`` :keyword node: Node to attach volume to. :type node: :class:`Node` :keyword fs_type: The formatted type of this disk. Valid types are: ext3, ext4, swap, raw :type fs_type: ``str`` :return: StorageVolume representing the newly-created volume :rtype: :class:`StorageVolume` r� �Invalid node instanceZTOTALHDr z:Volume size too big. Available space %d�Not valid filesystem typerw ry rE rv �linode.disk.listr� ) r~ r r r� �ex_list_volumesr� �_linode_disk_filesystemsrR rG rH r rI � _to_volumes) r< r� r4 rT �fs_typeZ total_spaceZexisting_volumesZ used_spacer� Zavailable_spacerF rK r/ r/ r0 �ex_create_volume� s> �� ��z#LinodeNodeDriverV3.ex_create_volumec C sP t |t�s tdd��d|jd�}|dur||d< | jjt|d�jd }| �|�S ) aN List existing disk volumes for for given Linode. :keyword node: Node to list disk volumes for. (required) :type node: :class:`Node` :keyword disk_id: Id for specific disk volume. (optional) :type disk_id: ``int`` :rtype: ``list`` of :class:`StorageVolume` r� r� r� rO Nrv rE r ) r~ r r rR rG rH r rI r� )r< rT �disk_idrF rK r/ r/ r0 r� � s z"LinodeNodeDriverV3.ex_list_volumesc C sT i }|D ] }|d }t ||d t|d �| jjd� ||< }t|�|_qt|�� �S )a Convert returned JSON volumes into StorageVolume instances :keyword objs: ``list`` of JSON dictionaries representing the StorageVolumes :type objs: ``list`` :return: ``list`` of :class:`StorageVolume`s ZDISKIDr� ZSIZE)rR r4 r� r� )r r� rG r� r r� �list�values)r< �objsZvolumes�oZvidZvolr/ r/ r0 r� � s � z LinodeNodeDriverV3._to_volumesc C sH i }g }|D ]6}|d }t ||d g g | j|d | jjd� ||< }t|�|_| j�|�d��|jd< |�d|d�� qg }t |�gd }t j |� D ]-} d d � | D �} d t � | �d �} | jjt| d�} | �� rot| j�dkrr dS |�| j� qK|D ]"} | D ] } | d }| d dkr�|| jn|| j}|�| d � qq{t|�� �S )z�Convert returned JSON Linodes into Node instances :keyword objs: ``list`` of JSON dictionaries representing the Linodes :type objs: ``list`` :return: ``list`` of :class:`Node`sr� r� ZSTATUS)rR r4 � public_ips� private_ips�stater� ZTOTALRAMr� zlinode.ip.listrO � c S s g | ]}|r|�qS r/ r/ )r] �qr/ r/ r0 r_ rk z0LinodeNodeDriverV3._to_nodes.<locals>.<listcomp>�batch)rC Zapi_requestArrayrE r NZISPUBLICr? Z IPADDRESS)r � LINODE_STATESrG r� r r� �_linode_plan_ids�getr� �iter� itertools� zip_longest�json�dumpsrH r �successr rI �extendr� r� r� r� )r< r� r� r� r� Zlidr� Z ip_answers�argsZ twenty_fiverF �reqZip_list�ip�whichr/ r/ r0 rJ � sB � � � z LinodeNodeDriverV3._to_nodes)NTNNNN) NNNNNNFNNN�N)&r1 r2 r3 �__doc__r � connectionClsr r� r r� Zfeaturesr; r �UNKNOWN�PENDING�RUNNING�STOPPED� REBOOTINGr� rL rU rW rX rY r7 r� r� r� r� r| r� r� r� r� r� r� r� rJ r/ r/ r/ r0 r c sf �� � ~ > r c @ s e Zd ZeZeZejej ej ej ej ej ej ej ejejejej ejd� Zejejejd�Zejejejejd�Zdd� Zdd� Zdd � Zdcd d �Z d d� Z dd� Z dd� Z dd� Z dd� Z!dd� Z"dd� Z#dd � Z$ ddd d �Z%d!d"� Z&d#d$� Z' ded%d&�Z(d'd(� Z)d)d*� Z*dfd+d,�Z+dgd.d/�Z,d0d1� Z-d2d3� Z.d4d5� Z/d6d7� Z0d8d9� Z1d:d;� Z2dhd<d=�Z3d>d?� Z4d@dA� Z5dBdC� Z6didEdF�Z7dGdH� Z8djdIdJ�Z9dKdL� Z:dMdN� Z;dOdP� Z<dQdR� Z=dSdT� Z>dUdV� Z?dWdX� Z@dYdZ� ZAd[d\� ZBd]d^� ZCd_d`� ZDdkdadb�ZEd S )lr ) Zrunning�stoppedZ provisioningZofflineZbootingZ rebootingZ shutting_down�deletingZ migratingZ rebuildingZcloningZ restoring�resizing)�readyz not readyr� )ZcreatingZactiver� Zcontact_supportc � � � dd�}� fdd�|D �S )z� Returns a list of Linodes the API key in use has access to view. :return: List of node objects :rtype: ``list`` of :class:`Node` �/v4/linode/instancesrK c � g | ]}� � |��qS r/ )�_to_node�r] r� �r< r/ r0 r_ L � z1LinodeNodeDriverV4.list_nodes.<locals>.<listcomp>��_paginated_request�r< rK r/ r� r0 rL B s z LinodeNodeDriverV4.list_nodesc r� )za Returns a list of Linode Types : rtype: ``list`` of :class: `NodeSize` z/v4/linode/typesrK c r� r/ )�_to_sizer� r� r/ r0 r_ U r� z1LinodeNodeDriverV4.list_sizes.<locals>.<listcomp>r� r� r/ r� r0 r| N � z LinodeNodeDriverV4.list_sizesc r� )zZ Returns a list of images :rtype: ``list`` of :class:`NodeImage` � /v4/imagesrK c r� r/ )� _to_imager� r� r/ r0 r_ ^ r� z2LinodeNodeDriverV4.list_images.<locals>.<listcomp>r� r� r/ r� r0 r� W r� z LinodeNodeDriverV4.list_images� c C s. ||d�}| j jdt�|�dd�j}| �|�S )a Creates an SSH keypair :param name: The name to be given to the keypair (required). :type name: `str` :keyword public_key: Contents of the public key the the SSH key pair :type public_key: `str` :rtype: :class: `KeyPair` )r� r8 �/v4/profile/sshkeys�POST�rK �method)rG rH r� r� �object� _to_key_pair)r< r4 � public_key�attr�responser/ r/ r0 �create_key_pair` s �� z"LinodeNodeDriverV4.create_key_pairc r� )zx Provide a list of all the SSH keypairs in your account. :rtype: ``list`` of :class: `KeyPair` r� rK c r� r/ )r� r� r� r/ r0 r_ y r� z5LinodeNodeDriverV4.list_key_pairs.<locals>.<listcomp>r� r� r/ r� r0 �list_key_pairsr r� z!LinodeNodeDriverV4.list_key_pairsc r� )zt Lists the Regions available for Linode services :rtype: ``list`` of :class:`NodeLocation` z /v4/regionsrK c r� r/ )� _to_locationr� r� r/ r0 r_ � r� z5LinodeNodeDriverV4.list_locations.<locals>.<listcomp>r� r� r/ r� r0 r� { r� z!LinodeNodeDriverV4.list_locationsc C �4 t |t�s td��| jjd|j dd�}|jtjkS )z�Boots a node the API Key has permission to modify :param node: the node to start :type node: :class:`Node` :rtype: ``bool`` r� z /v4/linode/instances/%s/bootr� �r� � r~ r r rG rH rR �statusr �OK�r< rT r� r/ r/ r0 rU � � z LinodeNodeDriverV4.start_nodec C r� r� r� r� r/ r/ r0 r� � r� z LinodeNodeDriverV4.ex_start_nodec C r )z�Shuts down a a node the API Key has permission to modify. :param node: the Linode to destroy :type node: :class:`Node` :rtype: ``bool`` r� z /v4/linode/instances/%s/shutdownr� r r r r/ r/ r0 rW � � � z LinodeNodeDriverV4.stop_nodec C r� r� r� r� r/ r/ r0 r� � r� z LinodeNodeDriverV4.ex_stop_nodec C r )z�Deletes a node the API Key has permission to `read_write` :param node: the Linode to destroy :type node: :class:`Node` :rtype: ``bool`` r� �/v4/linode/instances/%s�DELETEr r r r/ r/ r0 rY � r z LinodeNodeDriverV4.destroy_nodec C r )z�Reboots a node the API Key has permission to modify. :param node: the Linode to destroy :type node: :class:`Node` :rtype: ``bool`` r� z /v4/linode/instances/%s/rebootr� r r r r/ r/ r0 rX � r z LinodeNodeDriverV4.reboot_nodeNFc C s t |t�s td��t |t�std��|j|j| | d�} | r0dt�t| �d���� d�� � i| d< |durE|du r<td ��|j| d < || d < |durYd } t � | |�sUtd ��|| d< |durct |�| d< |durmt |�| d< |durwt |�| d< | jjdt�| �dd�j}| �|�S )a� Creates a Linode Instance. In order for this request to complete successfully, the user must have the `add_linodes` grant as this call will incur a charge. :param location: which region to create the node in :type location: :class:`NodeLocation` :param size: the plan size to create :type size: :class:`NodeSize` :keyword image: which distribution to deploy on the node :type image: :class:`NodeImage` :keyword name: the name to assign to node. Must start with an alpha character. May only consist of alphanumeric characters, dashes (-), underscores (_) or periods (.). Cannot have two dashes (--), underscores (__) or periods (..) in a row. :type name: ``str`` :keyword root_pass: the root password (required if image is provided) :type root_pass: ``str`` :keyword ex_authorized_keys: a list of public SSH keys :type ex_authorized_keys: ``list`` of ``str`` :keyword ex_authorized_users: a list of usernames. If the usernames have associated SSH keys, the keys will be appended to the root users `authorized_keys` :type ex_authorized_users: ``list`` of ``str`` :keyword ex_tags: list of tags for the node :type ex_tags: ``list`` of ``str`` :keyword ex_backups_enabled: whether to be enrolled in the Linode Backup service (False) :type ex_backups_enabled: ``bool`` :keyword ex_private_ip: whether or not to request a private IP :type ex_private_ip: ``bool`` :keyword ex_userdata: add cloud-config compatible userdata to be processed by cloud-init inside the Linode instance. NOTE: the contents of this string must be base64 encoded before passing it to this function. :type ex_userdata: ``str`` :return: Node representing the newly-created node :rtype: :class:`Node` �Invalid location instancezInvalid size instance)r+ r5 Z private_ipZbackups_enabledZ user_datazutf-8rt �metadataNz.root password required when providing an imager� � root_passz)^[a-zA-Z]((?!--|__|\.\.)[a-zA-Z0-9-_.])+$� Invalid namer� �authorized_keys�authorized_users�tagsr� r� r� )r~ r r r rR r� r� �bytes�encoder� r� �re�matchr� rG rH r� r� r� r� )r< r� r4 r� r� r �ex_authorized_keys�ex_authorized_usersZex_tagsZex_backups_enabledZ ex_private_ipZ ex_userdatar� � valid_namer� r/ r/ r0 r7 � sH N �� �� z LinodeNodeDriverV4.create_nodec C � | j �d| �j}| �|�S )z� Return a Node object based on a node ID. :keyword node_id: Node's ID :type node_id: ``str`` :return: Created node :rtype : :class:`Node` r )rG rH r� r� )r< �node_idr� r/ r/ r0 � ex_get_nodeE � z LinodeNodeDriverV4.ex_get_nodec s6 t |t�s td��� �d|j d�}� fdd�|D �S )z� List disks associated with the node. :param node: Node to list disks. (required) :type node: :class:`Node` :rtype: ``list`` of :class:`LinodeDisk` r� � /v4/linode/instances/%s/disksrK c r� r/ )�_to_diskr� r� r/ r0 r_ ` r� z4LinodeNodeDriverV4.ex_list_disks.<locals>.<listcomp>)r~ r r r� rR )r< rT rK r/ r� r0 � ex_list_disksR s z LinodeNodeDriverV4.ex_list_disksc C s� t |�t|�|| d�} t|t�std��|| jvr td��|dur;t|t�s*td��|du r2td��|j| d< || d< |durEt|�| d < |durOt|�| d < | j j d |j t � | �d d �j } | �| �S )aM Adds a new disk to node :param size: Size of disk in megabytes (required) :type size: ``int`` :param name: Name of the disk to be created (required) :type name: ``str`` :param node: Node to attach disk to (required) :type node: :class:`Node` :param fs_type: The formatted type of this disk. Valid types are: ext3, ext4, swap, raw, initrd :type fs_type: ``str`` :keyword image: Image to deploy the volume from :type image: :class:`NodeImage` :keyword ex_root_pass: root password,required if an image is provided :type ex_root_pass: ``str`` :keyword ex_authorized_keys: a list of SSH keys :type ex_authorized_keys: ``list`` of ``str`` :keyword ex_authorized_users: a list of usernames that will have their SSH keys, if any, automatically appended to the root user's ~/.ssh/authorized_keys file. :type ex_authorized_users: ``list`` of ``str`` :keyword ex_read_only: if true, this disk is read-only :type ex_read_only: ``bool`` :return: LinodeDisk representing the newly-created disk :rtype: :class:`LinodeDisk` )r� r� � filesystemZ read_onlyr� r� N�Invalid image instancez-root_pass is required when deploying an imager� r r r r r� r� )r} r� r~ r r r� r rR r� rG rH r� r� r� r ) r< r� r4 rT r� r� Z ex_root_passr r Z ex_read_onlyr� r� r/ r/ r0 �ex_create_diskb s8 4� �� z!LinodeNodeDriverV4.ex_create_diskc C sd t |t�s td��t |t�std��|j| jd kr td��| jjd�|j |j �dd�}|j t j kS )a Destroys disk for the given node. :param node: The Node the disk is attached to. (required) :type node: :class:`Node` :param disk: LinodeDisk to be destroyed (required) :type disk: :class:`LinodeDisk` :rtype: ``bool`` r� �Invalid disk instancer� z1Node needs to be stopped before disk is destroyedz /v4/linode/instances/{}/disks/{}r r ) r~ r r r r� r� rG rH r� rR r r r )r< rT r� r� r/ r/ r0 �ex_destroy_disk� s � z"LinodeNodeDriverV4.ex_destroy_diskc r� )zYGet all volumes of the account :rtype: `list` of :class: `StorageVolume` � /v4/volumesrK c r� r/ )� _to_volumer� r� r/ r0 r_ � r� z3LinodeNodeDriverV4.list_volumes.<locals>.<listcomp>r� r� r/ r� r0 � list_volumes� s z LinodeNodeDriverV4.list_volumesc C s� d}t �||�s td��|t|�d�}|dur(t|t�s td��t|j�|d< n|r9t|t�s3td��|j|d< ntd ��|durGt|�|d < | j j d t � |�d d �j }| �|�S )a Creates a volume and optionally attaches it to a node. :param name: The name to be given to volume (required). Must start with an alpha character. May only consist of alphanumeric characters, dashes (-), underscores (_) Cannot have two dashes (--), underscores (__) in a row. :type name: `str` :param size: Size in gigabytes (required) :type size: `int` :keyword location: Location to create the node. Required if node is not given. :type location: :class:`NodeLocation` :keyword volume: Node to attach the volume to :type volume: :class:`Node` :keyword tags: tags to apply to volume :type tags: `list` of `str` :rtype: :class: `StorageVolume` z#^[a-zA-Z]((?!--|__)[a-zA-Z0-9-_])+$r )r� r� Nr� � linode_idr r+ z(Region must be provided when node is notr r$ r� r� )r r r r� r~ r rR r r� rG rH r� r� r� r% ) r< r4 r� r� rT r r r� r� r/ r/ r0 � create_volume� s. � �� z LinodeNodeDriverV4.create_volumeTc C s� t |t�s td��t |t�std��|jd dur td��|jd |jd kr+td��t|j�|d�}| jjd |j t � |�d d �j }| � |�S ) a� Attaches a volume to a node. Volume and node must be located in the same region :param node: Node to attach the volume to(required) :type node: :class:`Node` :param volume: Volume to be attached (required) :type volume: :class:`StorageVolume` :keyword persist_across_boots: Whether volume should be attached to node across boots :type persist_across_boots: `bool` :rtype: :class: `StorageVolume` r� r� r' Nz$Volume is already attached to a noder� z*Volume and node must be on the same region)r' �persist_across_bootsz/v4/volumes/%s/attachr� r� ) r~ r r r r� r� rR rG rH r� r� r� r% )r< rT r� r) r� r� r/ r/ r0 � attach_volume s �� z LinodeNodeDriverV4.attach_volumec C sJ t |t�s td��|jd du rtd��| jjd|j dd�}|jtj kS )z�Detaches a volume from a node. :param volume: Volume to be detached (required) :type volume: :class:`StorageVolume` :rtype: ``bool`` r� r' NzVolume is already detachedz/v4/volumes/%s/detachr� r � r~ r r r� rG rH rR r r r �r< r� r� r/ r/ r0 � detach_volume5 s z LinodeNodeDriverV4.detach_volumec C sJ t |t�s td��|jd durtd��| jjd|j dd�}|jtj kS )z�Destroys the volume given. :param volume: Volume to be deleted (required) :type volume: :class:`StorageVolume` :rtype: ``bool`` r� r' Nz1Volume must be detached before it can be deleted.�/v4/volumes/%sr r r+ r, r/ r/ r0 r� F s z!LinodeNodeDriverV4.destroy_volumec C sV t |t�s td��|j|krtd��d|i}| jjd|j t�|�dd�}|j t j kS )a Resizes the volume given. :param volume: Volume to be resized :type volume: :class:`StorageVolume` :param size: new volume size in gigabytes, must be greater than current size :type size: `int` :rtype: ``bool`` r� z Volumes can only be resized upr� z/v4/volumes/%s/resizer� r� ) r~ r r r� rG rH rR r� r� r r r )r< r� r� r� r� r/ r/ r0 �ex_resize_volumeV s � z#LinodeNodeDriverV4.ex_resize_volumec C �D t |t�s td��d|i}| jjd|j t�|�dd�j}| � |�S )z�Clones the volume given :param volume: Volume to be cloned :type volume: :class:`StorageVolume` :param name: new cloned volume name :type name: `str` :rtype: :class:`StorageVolume` r� r� z/v4/volumes/%s/cloner� r� ) r~ r r rG rH rR r� r� r� r% )r< r� r4 r� r� r/ r/ r0 �ex_clone_volumen s �� z"LinodeNodeDriverV4.ex_clone_volumec C r )z� Return a Volume object based on a volume ID. :param volume_id: Volume's id :type volume_id: ``str`` :return: A StorageVolume object for the volume :rtype: :class:`StorageVolume` r. )rG rH r� r% )r< Z volume_idr� r/ r/ r0 � ex_get_volume� r z LinodeNodeDriverV4.ex_get_volumec C s | j jd| dd�}| �|j�S )z� Lookup a Linode image :param image: The name to image to be looked up (required). :type name: `str` :rtype: :class: `NodeImage` � /v4/images/%sZGETr )rG rH r� r� �r< r� r� r/ r/ r0 � get_image� s z LinodeNodeDriverV4.get_imagec C sH t |t�s td��t|j�||d�}| jjdt�|�dd�j }| � |�S )a Creates a private image from a LinodeDisk. Images are limited to three per account. :param disk: LinodeDisk to create the image from (required) :type disk: :class:`LinodeDisk` :keyword name: A name for the image. Defaults to the name of the disk it is being created from if not provided :type name: `str` :keyword description: A description of the image :type description: `str` :return: The newly created NodeImage :rtype: :class:`NodeImage` r" )r� r� � descriptionr� r� r� ) r~ r r r� rR rG rH r� r� r� r� )r< r� r4 r6 r� r� r/ r/ r0 � create_image� s �� z LinodeNodeDriverV4.create_imagec C r )z�Deletes a private image :param image: NodeImage to delete (required) :type image: :class:`NodeImage` :rtype: ``bool`` r r3 r r ) r~ r r rG rH rR r r r r4 r/ r/ r0 � delete_image� r z LinodeNodeDriverV4.delete_imagec r� )ztList IP addresses :return: LinodeIPAddress list :rtype: `list` of :class:`LinodeIPAddress` z/v4/networking/ipsrK c r� r/ �� _to_addressr� r� r/ r0 r_ � r� z8LinodeNodeDriverV4.ex_list_addresses.<locals>.<listcomp>r� r� r/ r� r0 �ex_list_addresses� s z$LinodeNodeDriverV4.ex_list_addressesc C s0 t |t�s td��| j�d|j �j}| �|�S )z�List all IPv4 addresses attached to node :param node: Node to list IP addresses :type node: :class:`Node` :return: LinodeIPAddress list :rtype: `list` of :class:`LinodeIPAddress` r� �/v4/linode/instances/%s/ips)r~ r r rG rH rR r� � _to_addressesr r/ r/ r0 �ex_list_node_addresses� s z)LinodeNodeDriverV4.ex_list_node_addresses�ipv4c C sl t |t�s td��|dkrtd��t|j�dkr td��d|d�}| jjd|j t� |�d d �j }| � |�S ) aZ Allocates a private IPv4 address to node.Only ipv4 is currently supported :param node: Node to attach the IP address :type node: :class:`Node` :keyword address_type: Type of IP address :type address_type: `str` :return: The newly created LinodeIPAddress :rtype: :class:`LinodeIPAddress` r� r? zAddress type not supportedr? z#Nodes can have up to one private IPF)�publicr5 r< r� r� ) r~ r r r r� rG rH rR r� r� r� r: )r< rT Z address_typer� r� r/ r/ r0 �ex_allocate_private_address� s �� z.LinodeNodeDriverV4.ex_allocate_private_addressc C sj t |t�s td��tdd� |D ��std��dd� |D �t|j�d�}| jjdt� |�d d �}|j t j kS ) a� Shares an IP with another node.This can be used to allow one Linode to begin serving requests should another become unresponsive. :param node: Node to share the IP addresses with :type node: :class:`Node` :keyword addresses: List of IP addresses to share :type address_type: `list` of :class: `LinodeIPAddress` :rtype: ``bool`` r� c s s � | ]}t |t�V qd S r� )r~ r �r] �addressr/ r/ r0 � <genexpr> s � z6LinodeNodeDriverV4.ex_share_address.<locals>.<genexpr>zInvalid address instancec S r[ r/ )�inetrB r/ r/ r0 r_ r` z7LinodeNodeDriverV4.ex_share_address.<locals>.<listcomp>)�ipsr' z/v4/networking/ipv4/sharer� r� ) r~ r r �allr� rR rG rH r� r� r r r )r< rT � addressesr� r� r/ r/ r0 �ex_share_address s � � z#LinodeNodeDriverV4.ex_share_addressc C sZ t |t�s td��t |t�std��|j|d�}| jjd|j t�|�dd�}|j t j kS )a� Resizes a node the API Key has read_write permission to a different Type. The following requirements must be met: - The node must not have a pending migration - The account cannot have an outstanding balance - The node must not have more disk allocation than the new size allows :param node: the Linode to resize :type node: :class:`Node` :param size: the size of the new node :type size: :class:`NodeSize` :keyword allow_auto_disk_resize: Automatically resize disks when resizing a node. :type allow_auto_disk_resize: ``bool`` :rtype: ``bool`` r� zInvalid node size)r5 �allow_auto_disk_resizez /v4/linode/instances/%s/resizer� r� ) r~ r r r rR rG rH r� r� r r r )r< rT r� rJ r� r� r/ r/ r0 r� s � z!LinodeNodeDriverV4.ex_resize_nodec C r0 )z�Renames a node :param node: the Linode to resize :type node: :class:`Node` :param name: the node's new name :type name: ``str`` :return: Changed Node :rtype: :class:`Node` r� r� r �PUTr� ) r~ r r rG rH rR r� r� r� r� )r< rT r4 r� r� r/ r/ r0 r� ? s �� z!LinodeNodeDriverV4.ex_rename_nodec C s( d|d i}t |d d |d d | |d�S )NrR r� r8 )r4 Z fingerprintr� Z private_keyr� r� )r �r< rK r� r/ r/ r0 r� V s �z LinodeNodeDriverV4._to_key_pairc C s� |d |d |d |d |d |d |d |d d �}d d � |d D �}d d � |d D �}t |d |d | j|d ||| |d |d | �|d �|d� S )Nr r+ �ipv6� hypervisor�specs�alerts�backups�watchdog_enabled)r r� rM rN rO rP rQ rR c S s g | ]}t |�s|�qS r/ r �r] r� r/ r/ r0 r_ n � z/LinodeNodeDriverV4._to_node.<locals>.<listcomp>r? c S s g | ]}t |�r|�qS r/ r rS r/ r/ r0 r_ o rT rR r� r r5 r� �created) rR r4 r� r� r� r� r� r� Z created_atr� )r r� � _to_datetime)r< rK r� r� r� r/ r/ r0 r� b s. � �zLinodeNodeDriverV4._to_nodec C s t �|d�S )Nz%Y-%m-%dT%H:%M:%S)r �strptime)r< Zstrtimer/ r/ r0 rV } s z LinodeNodeDriverV4._to_datetimec C sh |d |d d |d |d |d |d |d d �}t |d |d |d |d |d |d d | |d�S )N�classr� Zmonthly�addons� successor�transfer�vcpus�gpus)rX Z monthly_pricerY rZ r[ r\ r] rR r� Zmemoryr� Z network_outZhourly)rR r4 r� r� r� r� r� r� )r rL r/ r/ r0 r� � s$ � �zLinodeNodeDriverV4._to_sizec C sT |d |d | � |d �|d |d |d |d |d d �}t|d |d | |d �S ) Nr5 r6 rU � created_by� is_publicr� �eol�vendor)r5 r6 rU r^ r_ r� r` ra rR r� r� )rV r rL r/ r/ r0 r� � s � z LinodeNodeDriverV4._to_imagec C s: |d |d |d d�}t |d |d |d �� | |d�S )Nr � capabilities� resolvers)r rb rc rR r� )rR r4 r� r� r� )r �upperrL r/ r/ r0 r� � s � �z LinodeNodeDriverV4._to_locationc C s^ | � |d �|d |d |d |d | j|d |d d�}tt|d �|d |d | |d �S ) NrU r r+ r' � linode_labelr �filesystem_path)rU r r� r' re r� rf rR r� r� )rR r4 r� r� r� )rV �LINODE_VOLUME_STATESr r} rL r/ r/ r0 r% � s � �z LinodeNodeDriverV4._to_volumec C s. t |d | j|d |d |d |d | d�S )NrR r r� r r� )rR r� r4 r r� r� )r �LINODE_DISK_STATESr� r/ r/ r0 r � s �zLinodeNodeDriverV4._to_diskc C sH |d |d |d |d |d |d d�}t |d |d |d | |d �S ) N�gateway� subnet_mask�prefix�rdnsr' r+ )ri rj rk rl r r+ rC r@ r5 )rE r@ �versionr� r� )r rL r/ r/ r0 r: � s ��z LinodeNodeDriverV4._to_addressc s* |d d |d d }� fdd�|D �S )Nr? r@ Zprivatec r� r/ r9 rB r� r/ r0 r_ � r� z4LinodeNodeDriverV4._to_addresses.<locals>.<listcomp>r/ )r< rK rH r/ r� r0 r= � s z LinodeNodeDriverV4._to_addressesc C s� g }|dur|ni }| j j||d�j}t|�|g ��}t|�dd��}t|�dd��}|�|� t|d |d �D ] } | |d< | j j||d�j}t|�|g ��}|�|� q9|S )a� Perform multiple calls in order to have a full list of elements when the API responses are paginated. :param url: API endpoint :type url: ``str`` :param obj: Result object key :type obj: ``str`` :param params: Request parameters :type params: ``dict`` :return: ``list`` of API response objects :rtype: ``list`` NrE �pager? Zpages)rG rH r� r� r� r� r� �range) r< �urlr� rF rI �retrK Z current_pageZ num_of_pagesrn r/ r/ r0 r� � s z%LinodeNodeDriverV4._paginated_request)r� )NNNNFFN)NNNNF)NNN)T)NN)r? )Fr� )Fr1 r2 r3 r r� r r� r r� r� ZSTARTINGr� ZSTOPPINGr� Z MIGRATINGZUPDATINGZ RECONFIGURINGr� r Z AVAILABLEZCREATINGZDELETINGrh r� rg rL r| r� r� r� r� rU r� rW r� rY rX r7 r r r! r# r& r( r* r- r� r/ r1 r2 r5 r7 r8 r; r> rA rI r� r� r� r� rV r� r� r� r% r r: r= r� r/ r/ r/ r0 r ! s� ��� " �y �V 8# $ r )+r� r� r r� r� r r Zlibcloud.utils.py3r Zlibcloud.compute.baser r r r r r r r r Zlibcloud.common.linoder r r r r r r r r r r Zlibcloud.compute.typesr r r Zlibcloud.utils.networkingr Z simplejsonr� � ImportErrorr r r r/ r/ r/ r0 �<module> s2 ,4 � C
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings