File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/gig_g8.cpython-310.pyc
Back
o ;jS � @ s� d Z ddlZddlmZmZmZmZmZmZm Z ddl m Z ddl m Z mZ ddlmZ G dd� de�ZG d d � d e�ZG d d � d e�ZG d d� de�ZedkrZddlZe�� dS dS )z GiG G8 Driver � N)�Node�NodeSize� NodeImage� UuidMixin� NodeDriver� StorageVolume�NodeAuthSSHKey)� G8Connection)�Provider� NodeState)� BaseHTTPErrorc @ s e Zd ZdS )�G8ProvisionErrorN)�__name__� __module__� __qualname__� r r �S/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/gig_g8.pyr $ s r c @ s e Zd Zdd� Zdd� ZdS )� G8PortForwardc C s: || _ || _t|�| _t|�| _|| _|| _t�| � d S �N) �node_id�network�int� publicport� privateport�protocol�driverr �__init__)�selfr r r r r r r r r r ) s zG8PortForward.__init__c C s | j �| � d S r )r �ex_delete_portforward�r r r r �destroy2 s zG8PortForward.destroyN)r r r r r r r r r r ( s r c @ sH e Zd ZdZddd�Zedd� �Zdd� Zd d � Zd d � Z ddd�Z dS )� G8NetworkzH G8 Network object class. This class maps to a cloudspace Nc C s2 || _ || _|| _|| _|| _|| _t�| � d S r )�id�name�_cidrr �publicipaddress�extrar r )r r" r# �cidrr% r r& r r r r > s zG8Network.__init__c C s. | j du r| j�dd| ji�}|d | _ | j S )zh Cidr is not part of the list result we will lazily fetch it with a get request N�/cloudspaces/get� cloudspaceId�privatenetwork)r$ r � _api_requestr" )r Z networkdatar r r r' G s zG8Network.cidrc C � | j �| �S r )r � list_nodesr r r r r- R � zG8Network.list_nodesc C r, r )r �ex_destroy_networkr r r r r U r. zG8Network.destroyc C r, r )r �ex_list_portforwardsr r r r �list_portforwardsX r. zG8Network.list_portforwards�tcpc C s | j �| ||||�S r )r �ex_create_portforward)r �noder r r r r r �create_portforward[ s z G8Network.create_portforwardr �r2 ) r r r �__doc__r �propertyr' r- r r1 r5 r r r r r! 6 s r! c s� e Zd ZdZi dej�dej�dej�dej�dej�dej �dej �d ej�d ej �d ej �d ej�d ej �dej�dej�dej�dej�dej�ejejejejejejejejejejd� �ZdZdZejZeZ� fdd�Zdd� ZdZdd �Zed d � �Z d[d d!�Z d"d#� Z d$d%� Z d\d(d)�Z d*d+� Z!d,d-� Z"d.d/� Z#d]d1d2�Z$d3d4� Z%d5d6� Z&d7d8� Z'd9d:� Z(dZd;d<�Z)d=d>� Z*d?d@� Z+dAdB� Z,dCdD� Z-d^dFdG�Z.dHdI� Z/dJdK� Z0dLdM� Z1dNdO� Z2dPdQ� Z3dRdS� Z4dTdU� Z5dVdW� Z6dXdY� Z7� Z8S )_� G8NodeDriverz GiG G8 node driver ZVIRTUALZHALTED�RUNNINGZ DESTROYEDZDELETED�PAUSED�ERRORZ DEPLOYING�STOPPINGZMOVINGZ RESTORING�STARTINGZPAUSINGZRESUMINGZ RESETTINGZDELETINGZ DESTROYING) Z ADDING_DISKZATTACHING_DISKZDETACHING_DISKZ ATTACHING_NICZDETTACHING_NICZ DELETING_DISKZCHANGING_DISK_LIMITSZCLONINGZRESIZINGZCREATING_TEMPLATEzGiG G8 Node Providerzhttps://gig.techc s* |� d�| _t� j|d� || _d| _dS )a :param key: Token to use for api (jwt) :type key: ``str`` :param user_id: Id of the account to connect to (accountId) :type user_id: ``int`` :param api_url: G8 api url :type api_url: ``str`` :rtype: ``None`` �/)�keyN)�rstrip�_apiurl�superr � _account_id�_location_data)r Zuser_idr@ Zapi_url�� __class__r r r � s zG8NodeDriver.__init__c C s d| j iS )N�url)rB r r r r �_ex_connection_class_kwargs� s z(G8NodeDriver._ex_connection_class_kwargsNc C s | j j|�d�t�|�dd�jS )Nr? �POST)�data�method)� connection�request�lstrip�json�dumps�object)r Zendpoint�paramsr r r r+ � s ��zG8NodeDriver._api_requestc C s | j d u r | �d�d | _ | j S )Nz/locations/listr )rE r+ r r r r � _location� s zG8NodeDriver._locationFc C s� |t |j�t |j�|d�} |pi }|rt |j�| d< n |d | d< |d | d< d|v r1|d | d< d|v r;|d | d< d |v rE|d | d < d |v rP|d | d < n|jd | d < |r�t|t�r�| �di �} | �dg �} d} | D ] } | d dkrz| } n qnddd�} | �| � | �dg �}|�|j� n |r�d�t |��}t |��| � d| �}| j dd|id�}| � ||�}|r�| � |�}||jd< |j|jd< |S ) aB Create a node. The `ex_create_attr` parameter can include the following dictionary key and value pairs: * `memory`: ``int`` Memory in MiB (only used if size is None and vcpus is passed * `vcpus`: ``int`` Amount of vcpus (only used if size is None and memory is passed) * `disk_size`: ``int`` Size of bootdisk defaults to minimumsize of the image * `user_data`: ``str`` for cloud-config data * `private_ip`: ``str`` Private Ip inside network * `data_disks`: ``list(int)`` Extra data disks to assign to vm list of disk sizes in GiB :param name: the name to assign the vm :type name: ``str`` :param size: the plan size to create mutual exclusive with `memory` `vcpus` :type size: :class:`NodeSize` :param image: which distribution to deploy on the vm :type image: :class:`NodeImage` :param network: G8 Network to place vm in :type size: :class:`G8Network` :param ex_description: Description of vm :type size: : ``str`` :param auth: an SSH key :type auth: :class:`NodeAuthSSHKey` :param ex_create_attr: A dictionary of optional attributes for vm creation :type ex_create_attr: ``dict`` :param ex_expose_ssh: Create portforward for ssh port :type ex_expose_ssh: int :return: The newly created node. :rtype: :class:`Node` )r# ZimageIdr) � descriptionZsizeId�memory�vcpusZ user_data�userdataZ data_disksZ datadisksZ private_ipZ privateIpZ disk_sizeZdisksize� min_disk_size�usersNr# �rootz /bin/bash)r# �shellzssh-authorized-keysz Auth type {} is not implementedz/machines/createz /machines/get� machineId�rS �ssh_port�ssh_ip)r r" r& � isinstancer � setdefault�appendZpubkey�format�type�NotImplementedErrorr+ �_to_node�ex_expose_ssh_noder% )r r# �image� ex_network�ex_description�sizeZauthZex_create_attrZ ex_expose_sshrS rX rZ r[ �user�keys�errorr] �machiner4 �portr r r � create_node� sV <� � zG8NodeDriver.create_nodec C sP |� � }g }d |d�}|D ]}|�|j� |j|jkr%|jdkr%|j|d< q |S )N)r4 r � r4 )r1 rc r r r" r )r rj r4 �forwards� usedports�result�forwardr r r �_find_ssh_ports s �z G8NodeDriver._find_ssh_portsc C s� |j d }| �||�}|d r|d S |d }d}d}||k rX||v r+|d7 }||v s#z|�||d� ||j d< |j|j d< W |S tyW } z |jd krR|�|� � d }~ww td ��) z� Create portforward for ssh purposed :param node: Node to expose ssh for :type node: ``Node`` :rtype: ``int`` r r4 i� i� � rs r_ r` i� Nz Failed to create portforward)r& rx r5 r% r �coderc r )r r4 r Zportsru ZsshportZendport�er r r rh s0 � � ��z G8NodeDriver.ex_expose_ssh_node�192.168.103.0/24�vgwc C sN | � d�}| j||d || jd |d�}| � d|�}| � dd|i�}| �|�S )aM Create network also known as cloudspace :param name: the name to assign to the network :type name: ``str`` :param private_network: subnet used as private network :type private_network: ``str`` :param type: type of the gateway vgw or routeros :type type: ``str`` z ../system/usermanager/whoamir# � locationCode)� accountIdr* �accessr# �locationre z/cloudspaces/creater( r) )r+ rD rT � _to_network)r r# Zprivate_networkre �userinforS Z networkidr r r r �ex_create_network@ s � z G8NodeDriver.ex_create_networkc C � | � ddt|j�i� dS )Nz/cloudspaces/deleter) T�r+ r r" �r r r r r r/ [ � z G8NodeDriver.ex_destroy_networkc C �* t j|_| �ddt|j�i� t j|_dS )z& Stop virtual machine z/machines/stopr] T)r r= �stater+ r r" �STOPPED�r r4 r r r � stop_node` � zG8NodeDriver.stop_nodec C s: | � ddt|j�i�}g }|D ] }|�| �||�� q|S )Nz/portforwarding/listr) )r+ r r" rc �_to_port_forward)r r rK rt rw r r r r0 j s z!G8NodeDriver.ex_list_portforwardsr2 c C s8 t |j�t |j�|||j|d�}| �d|� | �||�S )N)r) r] � localPort� publicPort�publicIpr z/portforwarding/create)r r" r% r+ r� )r r r4 r r r rS r r r r3 r s � z"G8NodeDriver.ex_create_portforwardc C s. t |jj�|jj|j|jd�}| �d|� dS )N)r) r� r� �protoz /portforwarding/deleteByPortT)r r r" r% r r r+ )r Z portforwardrS r r r r s � z"G8NodeDriver.ex_delete_portforwardc C r� )z' Start virtual machine z/machines/startr] T)r r> r� r+ r r" r: r� r r r � start_node� r� zG8NodeDriver.start_nodec C s6 g }| � d�D ]}|d | jkr|�| �|�� q|S )z� Return the list of networks. :return: A list of network objects. :rtype: ``list`` of :class:`G8Network` z/cloudspaces/listr )r+ rD rc r� )r �networksr r r r �ex_list_networks� s �z G8NodeDriver.ex_list_networksc C s8 | j d }g }| �dd|i�D ] }|�| �|�� q|S )zN Returns a list of node sizes as a cloud provider might have r~ z /sizes/listr� )rT r+ �extend�_to_size)r r� �sizesrl r r r � list_sizes� s zG8NodeDriver.list_sizesc C s� dd� }|r |g}n| � � }g }|D ]3}| jdd|jid�}|�� }|D ] }| �||�} ||| �} | r?| j| jd< |j| jd< |�| � q$q|S )z{ List the nodes known to a particular driver; There are two default nodes created at the beginning c S s, | D ]}|j |jkr|jdkr| S qd S )Nrs )r r" r )rt r4 rw r r r � _get_ssh_port� s ��z.G8NodeDriver.list_nodes.<locals>._get_ssh_portz/machines/listr) r^ r_ r` ) r� r+ r" r1 rg r r& r% rc ) r rj r� r� Znodesr Z nodes_listrt �nodedatar4 Z sshforwardr r r r- � s" �zG8NodeDriver.list_nodesc C r� )zX Reboot node returns True as if the reboot had been successful. z/machines/rebootr] T)r � REBOOTINGr� r+ r r" r: r� r r r � reboot_node� s zG8NodeDriver.reboot_nodec C r� )z Destroy node z/machines/deleter] Tr� r� r r r � destroy_node� s zG8NodeDriver.destroy_nodec C s0 g }| � dd| ji�D ] }|�| �|�� q |S )z} Returns a list of images as a cloud provider might have @inherits: :class:`NodeDriver.list_images` z /images/listr )r+ rD rc � _to_image)r Zimagesri r r r � list_images� s zG8NodeDriver.list_imagesc C s> g }| � dd| ji�D ]}|d dvrq |�| �|�� q |S )Nz /disks/listr �status)ZASSIGNED�CREATED)r+ rD rc � _to_volume)r Zvolumes�diskr r r � list_volumes� s zG8NodeDriver.list_volumes�Dc C s@ ||||| j d | jd�}| �d|�}| �dd|i�}| �|�S )a� Create volume :param size: Size of the volume to create in GiB :type size: ``int`` :param name: Name of the volume :type name: ``str`` :param description: Description of the volume :type description: ``str`` :param disk_type: Type of the disk depending on the G8 D for datadisk is always available :type disk_type: ``str`` :rtype: class:`StorageVolume` �gid)rl r# re rU r� r z /disks/createz /disks/get�diskId)rT rD r+ r� )r rl r# rk Z ex_disk_typerS r� r� r r r � create_volume� s � zG8NodeDriver.create_volumec C r� )Nz /disks/deleter� Tr� )r �volumer r r �destroy_volume r� zG8NodeDriver.destroy_volumec C �& t |j�t |j�d�}| �d|� dS )N�r] r� z/machines/attachDiskT�r r" r+ �r r4 r� rS r r r � attach_volume � zG8NodeDriver.attach_volumec C r� )Nr� z/machines/detachDiskTr� r� r r r � detach_volume r� zG8NodeDriver.detach_volumec C s6 |d |� d�d�}tt|d �|d |d | |d�S )Nre r] )re r r" ZsizeMaxr# )r" rl r# r r& )�getr �str)r rK r& r r r r� % s �zG8NodeDriver._to_volumec C s� | j �|d tj�}g }g }|�dg �}|s |�dg �}|D ] }|d dkr3|�|d �d�d � q |�|d � q d |i}|�d g �D ]} | d |d < | d |d < qEtt|d �|d | ||||d�S )Nr� �nicsZ interfacesre ZPUBLICZ ipAddressr? r r Zaccounts�passwordZlogin�usernamer" r# )r" r# r � public_ips� private_ipsr� r& )�NODE_STATE_MAPr� r �UNKNOWNrc �splitr r� ) r r� rj r� r� r� r� Znicr& Zaccountr r r rg 0 s. �zG8NodeDriver._to_nodec C s t t|d �|d d |d | �S )Nr" r# Zexternalnetworkip)r! r� r� r r r r� L s �zG8NodeDriver._to_networkc C s. |d |d d�}t t|d �|d | |d�S )NZ bootDiskSizerV )rY Z min_memoryr" r# )r" r# r r& )r r� )r ri r& r r r r� V s � zG8NodeDriver._to_imagec C sL g }|d D ] }|� tt|d �|d |d || d|d iddd�� q|S )NZdisksr" r# rV rW r )r" r# Zramr� r r& Z bandwidthZprice)rc r r� )r rl r� r� r r r r� ^ s �� zG8NodeDriver._to_sizec C s& t |t|d �|d |d |d | �S )Nr] r� r� r )r r� )r rK rj r r r r� p s �z G8NodeDriver._to_port_forwardr )NNNF)r| r} r6 )r� )9r r r r7 r ZPENDINGr� r: Z TERMINATEDr; r< r= Z MIGRATINGr> r� Z RECONFIGURINGr� r# Zwebsiter ZGIG_G8re r Z connectionClsr rI r+ r8 rT rr rx rh r� r/ r� r0 r3 r r� r� r� r- r� r� r� r� r� r� r� r� r� rg r� r� r� r� � __classcell__r r rF r r9 _ s� ������� � � � � ������� �l " r9 �__main__)r7 rP Zlibcloud.compute.baser r r r r r r Zlibcloud.common.gig_g8r Zlibcloud.compute.typesr r Zlibcloud.common.exceptionsr � Exceptionr r r! r9 r ZdoctestZtestmodr r r r �<module> s$ $ ) ! �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings