File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/gandi.cpython-310.pyc
Back
o ;jdc � @ s� d Z ddlmZ ddlmZmZmZmZmZ ddlm Z m Z m Z m Z m Z mZmZ ddlmZmZ ejejejejejejejejd�ZdZdd d d d d d�ddd ddd d�dddddd d�ddddd d d�d �ZG d d � d ee �Zd S )!z Gandi driver for compute � )�datetime)�Disk� IPAddress�GandiException�BaseGandiDriver�NetworkInterface)�Node�KeyPair�NodeSize� NodeImage� NodeDriver� NodeLocation� StorageVolume)�Provider� NodeState)�runningZhaltedZpaused�lockedZ being_created�invalidZlegally_lockedZdeletedg{�G�z�?�smallzSmall instance� � � i ( )�id�name�cpu�memory�disk� bandwidth�mediumzMedium instancei � �largezLarge instance� i �2 �x-largezExtra Large instance� i �d )r r r r# c s� e Zd ZdZdZdZdZdZej Z i Z � fdd�Z dd � Z d d � Zd d � Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Z ! ddd"d#�Zd$d%� Zded&d'�Zd(d)� Z d*d+� Z ded,d-�Z ded.d/�Z d0d1� Z d2d3� Z!d4d5� Z"d6d7� Z#dfd8d9�Z$ded:d;�Z%d<d=� Z&d>d?� Z'd@dA� Z(dBdC� Z)dDdE� Z*dFdG� Z+dHdI� Z,dJdK� Z-dLdM� Z.dNdO� Z/dPdQ� Z0dRdS� Z1dedTdU�Z2dfdVdW�Z3dXdY� Z4dZd[� Z5d\d]� Z6d^d_� Z7d`da� Z8dbdc� Z9� Z:S )g�GandiNodeDriverz Gandi node driver Zgandiz Gandi.netzhttp://www.gandi.net/ZFRc s t � j|i |�� dS )z9 @inherits: :class:`NodeDriver.__init__` N)�super�__init__)�self�args�kwargs�� __class__� �R/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/gandi.pyr( f s zGandiNodeDriver.__init__c C sB z| j �d| t|��}|jW S ty } ztd|��d }~ww )Nzhosting.%s.infoi� )� connection�request�int�object� Exceptionr )r) �typer �obj�er. r. r/ �_resource_infol s ��z GandiNodeDriver._resource_infoc C � | � d|�S )N�vm�r8 �r) r r. r. r/ � _node_infos � zGandiNodeDriver._node_infoc C r9 )Nr r; r< r. r. r/ � _volume_infov r> z GandiNodeDriver._volume_infoc C sN t |d |d t�|d tj�|�dg �g | |�d�|�d�|�d�d�d �S ) Nr �hostname�state�ips� ai_active� datacenter_id� description)rC rD rE )r r rA Z public_ipsZ private_ips�driver�extra)r �NODE_STATE_MAP�getr �UNKNOWN)r) r: r. r. r/ �_to_nodez s ��zGandiNodeDriver._to_nodec � � fdd�|D �S )Nc � g | ]}� � |��qS r. )rK )�.0�v�r) r. r/ � <listcomp>� � z-GandiNodeDriver._to_nodes.<locals>.<listcomp>r. )r) �vmsr. rP r/ � _to_nodes� � zGandiNodeDriver._to_nodesc C s. d|d i}t |d |d t|d �| |d�S )N� can_snapshotr r �size)r r rW rF rG )r r2 )r) r rG r. r. r/ � _to_volume� s �zGandiNodeDriver._to_volumec rL )Nc rM r. )rX )rN �drP r. r/ rQ � rR z/GandiNodeDriver._to_volumes.<locals>.<listcomp>r. )r) Zdisksr. rP r/ � _to_volumes� rU zGandiNodeDriver._to_volumesc C sx | j �d�j}| j �d�j}|D ]$}g |d< |D ]}|d d |d kr3|�dd�}|r3|d �|� qq| �|�}|S ) z� Return a list of nodes in the current zone or all zones. :return: List of Node objects :rtype: ``list`` of :class:`Node` zhosting.vm.list�hosting.ip.listrB � ifaces_idr �iface_id�ipN)r0 r1 r3 rI �appendrT )r) rS rB r: r^ Znodesr. r. r/ � list_nodes� s �� zGandiNodeDriver.list_nodesc C st | j �dt|��j}| j �d�j}g |d< |D ]}|d d |d kr2|�dd�}|r2|d �|� q| �|�}|S ) z� Return a Node object based on a node id. :param name: The ID of the node :type name: ``int`` :return: A Node object for the node :rtype: :class:`Node` zhosting.vm.infor[ rB r\ r r] r^ N)r0 r1 r2 r3 rI r_ rK )r) �node_idr: rB r^ �noder. r. r/ � ex_get_node� s � zGandiNodeDriver.ex_get_nodec C sH | j �dt|j��}| �|jd � | �t|j��}|d dkr"dS dS )z� Reboot a node. :param node: Node to be rebooted :type node: :class:`Node` :return: True if successful, False if not :rtype: ``bool`` zhosting.vm.rebootr rA r TF)r0 r1 r2 r �_wait_operationr3 r= )r) rb �opr: r. r. r/ � reboot_node� s zGandiNodeDriver.reboot_nodec C sr | � |j�}|d dkr#| j�dt|j��}| �|jd �s#tdd��| j�dt|j��}| �|jd �r7dS d S ) z� Destroy a node. :param node: Node object to destroy :type node: :class:`Node` :return: True if successful :rtype: ``bool`` rA r zhosting.vm.stopr i� zvm.stop failedzhosting.vm.deleteTF)r= r r0 r1 r2 rd r3 r )r) rb r: Zop_stopre r. r. r/ � destroy_node� s z GandiNodeDriver.destroy_nodec K s t d��)z[ deploy_node is not implemented for gandi driver :rtype: ``bool`` z,deploy_node not implemented for gandi driver)�NotImplementedError)r) r+ r. r. r/ � deploy_node� s zGandiNodeDriver.deploy_nodeNr$ c C sd |pg }|s |s t dd��|rt|t�rt|j�} nt dd��|s+t|t�s+t dd��dd� |D �} t�|j�} | r>| d nt|j�} t|j�} | d | d �}| |t|j�| t|j �|d �}|rj|rj|� ||d �� | rp| |d< | j � d||| �j \}}}| �|d �r�| �|d �}|�d�}t|�dkr�|d �d�}t|�dkr�|d d |d< | �|�S dS )a Create a new Gandi node :keyword name: String with a name for this new node (required) :type name: ``str`` :keyword image: OS Image to boot on node. (required) :type image: :class:`NodeImage` :keyword location: Which data center to create a node in. If empty, undefined behavior will be selected. (optional) :type location: :class:`NodeLocation` :keyword size: The size of resources allocated to this node. (required) :type size: :class:`NodeSize` :keyword login: user name to create for login on machine (required) :type login: ``str`` :keyword password: password for user that'll be created (required) :type password: ``str`` :keyword inet_family: version of ip to use, default 4 (optional) :type inet_family: ``int`` :keyword keypairs: IDs of keypairs or Keypairs object :type keypairs: list of ``int`` or :class:`.KeyPair` :rtype: :class:`Node` i� zCLogin and password or ssh keypair must be defined for node creation� z+location must be a subclass of NodeLocationi� z#size must be a subclass of NodeSizec S s$ g | ]}t |t�r |n|jd �qS )r )� isinstancer2 rG �rN �kr. r. r/ rQ + s $ z/GandiNodeDriver.create_node.<locals>.<listcomp>r zdisk_%s)rD r )rD r@ r �coresr Z ip_version)�login�password�keyszhosting.vm.create_fromr �vm_id�ifacesr rB r^ N)r rk r r2 r r �INSTANCE_TYPESrI �ramr �updater0 r1 r3 rd r= �lenrK )r) r rW Zimage�locationro rp Z inet_familyZkeypairsZdc_idZ keypair_ids�instancern Z src_disk_idZ disk_specZvm_specZop_diskZop_ifaceZop_vmrb rs rB r. r. r/ � create_node� sR *� � �� zGandiNodeDriver.create_nodec C s t |d |d | jjd�S )N�disk_idZlabel)r r rF )r r0 rF )r) Zimgr. r. r/ � _to_imageW s zGandiNodeDriver._to_imagec s` z |r dt |j�i}ni }� j�d|�}� fdd�|jD �W S ty/ } ztd|��d}~ww )a Return a list of image objects. :keyword location: Which data center to filter a images in. :type location: :class:`NodeLocation` :return: List of GCENodeImage objects :rtype: ``list`` of :class:`GCENodeImage` rD zhosting.image.listc rM r. )r| �rN �irP r. r/ rQ j rR z/GandiNodeDriver.list_images.<locals>.<listcomp>i� N)r2 r r0 r1 r3 r4 r )r) rx Z filteringZimagesr7 r. rP r/ � list_imagesZ s ��zGandiNodeDriver.list_imagesc C s6 t |d| |d |d |d | jdd�| | jjd�S )Nz%s coresr r r �1�Zsize_id�r r ru r r ZpricerF �r Z_get_size_pricer0 rF )r) r rW r. r. r/ �_to_sizen s �zGandiNodeDriver._to_sizec C s: t |d |d |d |d |d | j|d d�| jjd�S )Nr r r r r r� r� r� )r) ry r. r. r/ �_instance_type_to_sizey s �z&GandiNodeDriver._instance_type_to_sizec s � fdd�t �� D �S )Nc s g | ] \}}� � |��qS r. )r� )rN r ry rP r. r/ rQ � s z6GandiNodeDriver.list_instance_type.<locals>.<listcomp>)rt �items)r) rx r. rP r/ �list_instance_type� s z"GandiNodeDriver.list_instance_typec C s� | j �d�j}|�d�r| �|�S |d d }|d dkr dS |d }|d }t|d �}g }|d d k r7|S td |d �D ]/}t|i} d } dD ]} || | || krWd} qH|| | | | < qH| rm|} |�| � | | �� q>|S )a! Return a list of sizes (machineTypes) in a zone. :keyword location: Which data center to filter a sizes in. :type location: :class:`NodeLocation` or ``None`` :return: List of NodeSize objects :rtype: ``list`` of :class:`NodeSize` zhosting.account.infoZrating_enabledZ resourcesZ available�sharesr NZshare_definitionrn g �?Zserversr T)r r r F) r0 r1 r3 rI r� r2 �ranger r_ r� ) r) rx ZaccountZ available_resZ share_defZavailable_coresZmax_corer� r~ �shareZshare_is_availablerm Znb_corer. r. r/ � list_sizes� s0 �zGandiNodeDriver.list_sizesc C s t |d |d |d | d�S )Nr Zdc_code�country)r r r� rF )r )r) �locr. r. r/ �_to_loc� s zGandiNodeDriver._to_locc s � j �d�}� fdd�|jD �S )z� Return a list of locations (datacenters). :return: List of NodeLocation objects :rtype: ``list`` of :class:`NodeLocation` zhosting.datacenter.listc rM r. )r� )rN r� rP r. r/ rQ � rR z2GandiNodeDriver.list_locations.<locals>.<listcomp>)r0 r1 r3 �r) �resr. rP r/ �list_locations� s z GandiNodeDriver.list_locationsc C � | j �di �}| �|j�S )z� Return a list of volumes. :return: A list of volume objects. :rtype: ``list`` of :class:`StorageVolume` �hosting.disk.list)r0 r1 rZ r3 r� r. r. r/ � list_volumes� s z GandiNodeDriver.list_volumesc C s | j �d|�}| �|j�S )z� Return a Volume object based on a volume ID. :param volume_id: The ID of the volume :type volume_id: ``int`` :return: A StorageVolume object for the volume :rtype: :class:`StorageVolume` zhosting.disk.info)r0 r1 rX r3 )r) Z volume_idr� r. r. r/ � ex_get_volume� s z GandiNodeDriver.ex_get_volumec C sn |t |�t |j�d�}|r| j�d|t |j��}n| j�d|�}| �|jd �r5| �|jd �}| �|�S dS )a Create a volume (disk). :param size: Size of volume to create (in GB). :type size: ``int`` :param name: Name of volume to create :type name: ``str`` :keyword location: Location (zone) to create the volume in :type location: :class:`NodeLocation` or ``None`` :keyword snapshot: Snapshot to create image from :type snapshot: :class:`Snapshot` :return: Storage Volume object :rtype: :class:`StorageVolume` )r rW rD �hosting.disk.create_fromzhosting.disk.creater r{ N)r2 r r0 r1 rd r3 r? rX )r) rW r rx �snapshotZ disk_paramre r r. r. r/ � create_volume� s � z GandiNodeDriver.create_volumec C s4 | j �dt|j�t|j��}| �|jd �rdS dS )a} Attach a volume to a node. :param node: The node to attach the volume to :type node: :class:`Node` :param volume: The volume to attach. :type volume: :class:`StorageVolume` :keyword device: Not used in this cloud. :type device: ``None`` :return: True if successful :rtype: ``bool`` �hosting.vm.disk_attachr TF�r0 r1 r2 r rd r3 )r) rb �volumeZdevicere r. r. r/ � attach_volume� s z GandiNodeDriver.attach_volumec C �4 | j �dt|j�t|j��}| �|jd �rdS dS )a Detaches a volume from a node. :param node: Node which should be used :type node: :class:`Node` :param volume: Volume to be detached :type volume: :class:`StorageVolume` :rtype: ``bool`` �hosting.vm.disk_detachr TFr� )r) rb r� re r. r. r/ � detach_volume � z GandiNodeDriver.detach_volumec C s, | j �dt|j��}| �|jd �rdS dS )z� Destroy a volume. :param volume: Volume object to destroy :type volume: :class:`StorageVolume` :return: True if successful :rtype: ``bool`` zhosting.disk.deleter TFr� )r) r� re r. r. r/ �destroy_volume s z GandiNodeDriver.destroy_volumec C s� g }|� dg �D ]%}t|d t� |d tj�|d | jj|� d�d|d id�}|�|� qt|d t� |d tj�d | jj||� d�d |d id �S ) NrB r rA r^ �version�reverse)r� rG rr r )Z mac_addressrF rB ra rG ) rI r rH r rJ r0 rF r_ r )r) �ifacerB r^ Znew_ipr. r. r/ � _to_iface+ s( � �zGandiNodeDriver._to_ifacec rL )Nc rM r. )r� r} rP r. r/ rQ B rR z.GandiNodeDriver._to_ifaces.<locals>.<listcomp>r. )r) rs r. rP r/ � _to_ifacesA rU zGandiNodeDriver._to_ifacesc sJ | j �d�j}| j �d�j}|D ]� tt� fdd�|��� d< q| �|�S )zx Specific method to list network interfaces :rtype: ``list`` of :class:`GandiNetworkInterface` zhosting.iface.listr[ c s | d � d kS )Nr] r r. )r~ �r� r. r/ �<lambda>M s z4GandiNodeDriver.ex_list_interfaces.<locals>.<lambda>rB )r0 r1 r3 �list�filterr� )r) rs rB r. r� r/ �ex_list_interfacesD s z"GandiNodeDriver.ex_list_interfacesc C s> t |d t�|d tj�|d | jj|d d|d id�}|S )Nr rA r rW rV )r rA r rF rW rG )r rH rI r rJ r0 rF )r) �elementr r. r. r/ �_to_diskP s �zGandiNodeDriver._to_diskc rL )Nc rM r. )r� )rN �elrP r. r/ rQ \ rR z-GandiNodeDriver._to_disks.<locals>.<listcomp>r. )r) �elementsr. rP r/ � _to_disks[ rU zGandiNodeDriver._to_disksc C r� )zb Specific method to list all disk :rtype: ``list`` of :class:`GandiDisk` r� )r0 r1 r� r3 r� r. r. r/ � ex_list_disks^ s z GandiNodeDriver.ex_list_disksc C r� )a Specific method to attach a disk to a node :param node: Node which should be used :type node: :class:`Node` :param disk: Disk which should be used :type disk: :class:`GandiDisk` :rtype: ``bool`` r� r TFr� �r) rb r re r. r. r/ �ex_node_attach_diskg r� z#GandiNodeDriver.ex_node_attach_diskc C r� )a Specific method to detach a disk from a node :param node: Node which should be used :type node: :class:`Node` :param disk: Disk which should be used :type disk: :class:`GandiDisk` :rtype: ``bool`` r� r TFr� r� r. r. r/ �ex_node_detach_diskx r� z#GandiNodeDriver.ex_node_detach_diskc C r� )a6 Specific method to attach an interface to a node :param node: Node which should be used :type node: :class:`Node` :param iface: Network interface which should be used :type iface: :class:`GandiNetworkInterface` :rtype: ``bool`` zhosting.vm.iface_attachr TFr� �r) rb r� re r. r. r/ �ex_node_attach_interface� r� z(GandiNodeDriver.ex_node_attach_interfacec C r� )a8 Specific method to detach an interface from a node :param node: Node which should be used :type node: :class:`Node` :param iface: Network interface which should be used :type iface: :class:`GandiNetworkInterface` :rtype: ``bool`` zhosting.vm.iface_detachr TFr� r� r. r. r/ �ex_node_detach_interface� r� z(GandiNodeDriver.ex_node_detach_interfacec C sj |j �d�stdd|j ��|st�� �d�}d| }| j�d|dd�t |j��}| � |j d �r3d S d S ) a Specific method to make a snapshot of a disk :param disk: Disk which should be used :type disk: :class:`GandiDisk` :param name: Name which should be used :type name: ``str`` :rtype: ``bool`` rV rj zDisk %s can't snapshotz%Y%m%dzsnap_%sr� r� )r r5 r TF) rG rI r r r �today�strftimer0 r1 r2 rd r3 )r) r r �suffixre r. r. r/ �ex_snapshot_disk� s �z GandiNodeDriver.ex_snapshot_diskc C sV i }|r |� d|i� |r|� d|i� | j�dt|j�|�}| �|jd �r)dS dS )a� Specific method to update size or name of a disk WARNING: if a server is attached it'll be rebooted :param disk: Disk which should be used :type disk: :class:`GandiDisk` :param new_size: New size :type new_size: ``int`` :param new_name: New name :type new_name: ``str`` :rtype: ``bool`` rW r zhosting.disk.updater TF)rv r0 r1 r2 r rd r3 )r) r Znew_size�new_name�paramsre r. r. r/ �ex_update_disk� s z GandiNodeDriver.ex_update_diskc C s8 t |d |d |�dd �|�dd �| d|d id�}|S )Nr � fingerprint�valueZ privatekeyr )r r� Z public_keyZ private_keyrF rG )r rI )r) �data�key_pairr. r. r/ � _to_key_pair� s �z GandiNodeDriver._to_key_pairc rL )Nc rM r. )r� rl rP r. r/ rQ � rR z1GandiNodeDriver._to_key_pairs.<locals>.<listcomp>r. )r) r� r. rP r/ � _to_key_pairs� rU z GandiNodeDriver._to_key_pairsc C s | j �d�j}| �|�S )z� List registered key pairs. :return: A list of key par objects. :rtype: ``list`` of :class:`libcloud.compute.base.KeyPair` �hosting.ssh.list)r0 r1 r3 r� )r) �kpsr. r. r/ �list_key_pairs� s z GandiNodeDriver.list_key_pairsc C s& d|i}| j �d|�j}| �|d �S )z� Retrieve a single key pair. :param name: Name of the key pair to retrieve. :type name: ``str`` :rtype: :class:`.KeyPair` r r� r �r0 r1 r3 r� )r) r Z filter_paramsr� r. r. r/ � get_key_pair� s z GandiNodeDriver.get_key_pairc C s$ ||d�}| j �d|�j}| �|�S )a Create a new key pair object. :param name: Key pair name. :type name: ``str`` :param key_material: Public key material. :type key_material: ``str`` :return: Imported key pair object. :rtype: :class:`.KeyPair` )r r� zhosting.ssh.creater� )r) r Z key_materialr� Zkpr. r. r/ �import_key_pair_from_string s z+GandiNodeDriver.import_key_pair_from_stringc C s, t |t�r|n|jd }| j�d|�j}|S )z� Delete an existing key pair. :param key_pair: Key pair object or ID. :type key_pair: :class.KeyPair` or ``int`` :return: True of False based on success of Keypair deletion :rtype: ``bool`` r zhosting.ssh.delete)rk r2 rG r0 r1 r3 )r) r� Zkey_id�successr. r. r/ �delete_key_pair s z GandiNodeDriver.delete_key_pair)NNNr$ N)N)NN);�__name__� __module__� __qualname__�__doc__Zapi_nameZ friendly_nameZwebsiter� r ZGANDIr5 Zfeaturesr( r8 r= r? rK rT rX rZ r` rc rf rg ri rz r| r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� � __classcell__r. r. r, r/ r& X sv �f * ! r& N)r� r Zlibcloud.common.gandir r r r r Zlibcloud.compute.baser r r r r r r Zlibcloud.compute.typesr r ZRUNNINGZ TERMINATEDZPENDINGrJ rH ZNODE_PRICE_HOURLY_USDrt r& r. r. r. r/ �<module> sZ $ � � � � ��$
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings