Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/gig_g8.cpython-39.pyc
Ðазад
a q�h�U � @ s� d Z ddlZddlmZmZmZ ddlmZmZ ddlmZm Z ddl m Z m Z ddl mZ ddlmZ G d d � d e�ZG d d � d e�ZG d d� de�ZG dd� de�Zedkr�ddlZe�� dS )z GiG G8 Driver � N)� NodeImage�NodeSize�Node)� NodeDriver� UuidMixin)� StorageVolume�NodeAuthSSHKey)�Provider� NodeState)� G8Connection)� BaseHTTPErrorc @ s e Zd ZdS )�G8ProvisionErrorN)�__name__� __module__� __qualname__� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/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 �destroy+ 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 7 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' @ s � zG8Network.cidrc C s | j �| �S r )r � list_nodesr r r r r, L s zG8Network.list_nodesc C s | j �| �S r )r �ex_destroy_networkr r r r r O s zG8Network.destroyc C s | j �| �S r )r �ex_list_portforwardsr r r r �list_portforwardsR s zG8Network.list_portforwards�tcpc C s | j �| ||||�S r )r �ex_create_portforward)r �noder r r r r r �create_portforwardU s �z G8Network.create_portforward)N)r0 ) r r r �__doc__r �propertyr' r, r r/ r3 r r r r r! / s �r! c s� e Zd ZdZejejejejejej ej ejej ej ejej ejejejejejejejejejejejejejejejd�ZdZdZejZeZ� fdd�Zdd� ZdId d �Zed d � �Z dJdd�Z dd� Z dd� Z dKdd�Z dd� Z!dd � Z"d d � Z#dLd d!�Z$d"d#� Z%d$d%� Z&d&d'� Z'd(d)� Z(dMd*d+�Z)d,d-� Z*d.d/� Z+d0d1� Z,d2d3� Z-dNd5d6�Z.d7d8� Z/d9d:� Z0d;d<� Z1d=d>� Z2d?d@� Z3dAdB� Z4dCdD� Z5dEdF� Z6dGdH� Z7� Z8S )O� G8NodeDriverz GiG G8 node driver )ZVIRTUALZHALTED�RUNNINGZ DESTROYEDZDELETED�PAUSED�ERRORZ DEPLOYING�STOPPINGZMOVINGZ RESTORING�STARTINGZPAUSINGZRESUMINGZ RESETTINGZDELETINGZ DESTROYINGZ ADDING_DISKZATTACHING_DISKZDETACHING_DISKZ ATTACHING_NICZDETTACHING_NICZ DELETING_DISKZCHANGING_DISK_LIMITSZCLONINGZRESIZINGZCREATING_TEMPLATEzGiG G8 Node Providerzhttps://gig.techc s. |� d�| _tt| �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�superr6 r � _account_id�_location_data)r Zuser_idr= Zapi_url�� __class__r r r � s zG8NodeDriver.__init__c C s d| j iS )N�url)r? 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 )rB r+ r r r r � _location� s zG8NodeDriver._locationFc C s� |t |j�t |j�|d�} |p i }|r6t |j�| d< n|d | d< |d | d< d|v rb|d | d< d|v rv|d | d< d |v r�|d | d < d |v r�|d | d < n|jd | d < |�r*t|t��r*| �di �} | �dg �} d} | D ]} | d dkr�| } �qq�ddd�} | �| � | �dg �}|�|j� n |�rFd�t |��}t |��| � d| �}| j dd|id�}| � ||�}|�r�| � |�}||jd< |j|jd< |S ) aA 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: Descripton 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�vcpus� 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�rP �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�size�authZex_create_attrZ ex_expose_sshrP rV rX rY �user�keys�errorr[ �machiner2 �portr r r � create_node� sX 3� � zG8NodeDriver.create_nodec C sP |� � }g }d |d�}|D ]0}|�|j� |j|jkr|jdkr|j|d< q|S )N)r2 r � r2 )r/ ra r r r" r )r rh r2 �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 r�||v rP|d7 }q>z,|�||d� ||j d< |j|j d< W q�W q6 ty� } z"|jd kr�|�|� � W Y d }~q6d }~0 0 q6td ��|S ) z� Create portforward for ssh purposed :param node: Node to expose ssh for :type node: ``Node`` :rtype: ``int`` r r2 i� i� � rr r] r^ i� Nz Failed to create portforward)r& rw r3 r% r �codera r )r r2 r Zportsrt ZsshportZendport�er r r rf s* 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 assing 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# �locationrc z/cloudspaces/creater( r) )r+ rA rQ � _to_network)r r# Zprivate_networkrc �userinforP Z networkidr r r r �ex_create_network3 s � �z G8NodeDriver.ex_create_networkc C s | � ddt|j�i� dS )Nz/cloudspaces/deleter) T�r+ r r" �r r r r r r- N s �z G8NodeDriver.ex_destroy_networkc C s* t j|_| �ddt|j�i� t j|_dS )z& Stop virtual machine z/machines/stopr[ T)r r: �stater+ r r" �STOPPED�r r2 r r r � stop_nodeT s zG8NodeDriver.stop_nodec C s: | � ddt|j�i�}g }|D ]}|�| �||�� q |S )Nz/portforwarding/listr) )r+ r r" ra �_to_port_forward)r r rH rs rv r r r r. ^ s �z!G8NodeDriver.ex_list_portforwardsr0 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 r2 r r r rP r r r r1 g 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 portforwardrP r r r r s s � z"G8NodeDriver.ex_delete_portforwardc C s* t j|_| �ddt|j�i� t j|_dS )z' Start virtual machine z/machines/startr[ T)r r; r� r+ r r" r7 r� r r r � start_node| s 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+ rA ra 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� )rQ r+ �extend�_to_size)r r� �sizesrj r r r � list_sizes� s zG8NodeDriver.list_sizesc C s� dd� }|r|g}n| � � }g }|D ]f}| jdd|jid�}|�� }|D ]@}| �||�} ||| �} | r~| j| jd< |j| jd< |�| � qHq$|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 )Nrr )r r" r )rs r2 rv r r r � _get_ssh_port� s z.G8NodeDriver.list_nodes.<locals>._get_ssh_portz/machines/listr) r\ r] r^ ) r� r+ r" r/ re r r& r% ra ) r rh r� r� �nodesr Z nodes_listrs �nodedatar2 Z sshforwardr r r r, � s$ � zG8NodeDriver.list_nodesc C s* t j|_| �ddt|j�i� t j|_dS )zX Reboot node returns True as if the reboot had been successful. z/machines/rebootr[ T)r � REBOOTINGr� r+ r r" r7 r� r r r � reboot_node� s zG8NodeDriver.reboot_nodec C s | � ddt|j�i� dS )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+ rA ra � _to_image)r Zimagesrg r r r � list_images� s �zG8NodeDriver.list_imagesc C s> g }| � dd| ji�D ]"}|d dvr(q|�| �|�� q|S )Nz /disks/listr~ �status)ZASSIGNED�CREATED)r+ rA ra � _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: Descripton 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)rj r# rc rR r� r~ z /disks/createz /disks/get�diskId)rQ rA r+ r� )r rj r# ri Z ex_disk_typerP r� r� r r r � create_volume� s � zG8NodeDriver.create_volumec C s | � ddt|j�i� dS )Nz /disks/deleter� Tr� )r �volumer r r �destroy_volume s zG8NodeDriver.destroy_volumec C s& t |j�t |j�d�}| �d|� dS )N�r[ r� z/machines/attachDiskT�r r" r+ �r r2 r� rP r r r � attach_volume s � zG8NodeDriver.attach_volumec C s& t |j�t |j�d�}| �d|� dS )Nr� z/machines/detachDiskTr� r� r r r � detach_volume s � zG8NodeDriver.detach_volumec C s6 |d |� d�d�}tt|d �|d |d | |d�S )Nrc r[ )rc r r" ZsizeMaxr# )r" rj r# r r& )�getr �str)r rH r& r r r r� s �zG8NodeDriver._to_volumec C s� | j �|d tj�}g }g }|�dg �}|s8|�dg �}|D ]8}|d dkrf|�|d �d�d � q<|�|d � q<d |i}|�d g �D ] } | d |d < | d |d < q�tt|d �|d | ||||d�S )Nr� �nicsZ interfacesrc ZPUBLICZ ipAddressr< r r Zaccounts�password�login�usernamer" r# )r" r# r � public_ips� private_ipsr� r& )�NODE_STATE_MAPr� r �UNKNOWNra �splitr r� ) r r� rh r� r� r� r� Znicr& �accountr r r re s$ �zG8NodeDriver._to_nodec C s t t|d �|d d |d | �S )Nr" r# Zexternalnetworkip)r! r� r� r r r r� 6 s �zG8NodeDriver._to_networkc C s. |d |d d�}t t|d �|d | |d�S )NZ bootDiskSizerS )rW Z min_memoryr" r# )r" r# r r& )r r� )r rg r& r r r r� ; s ��zG8NodeDriver._to_imagec C sL g }|d D ]:}|� tt|d �|d |d || d|d iddd�� q |S )N�disksr" r# rS rT r )r" r# �ramr� r r& � bandwidthZprice)ra r r� )r rj r� r� r r r r� C s � zG8NodeDriver._to_sizec C s& t |t|d �|d |d |d | �S )Nr[ r� r� r )r r� )r rH rh r r r r� M s �z G8NodeDriver._to_port_forward)N)NNNF)r{ r| )r0 )N)r� )9r r r r4 r ZPENDINGr� r7 Z TERMINATEDr8 r9 r: Z MIGRATINGr; r� Z RECONFIGURINGr� r# Zwebsiter ZGIG_G8rc r Z connectionClsr rF r+ r5 rQ rq rw rf r� r- r� r. r1 r r� r� r� r, r� r� r� r� r� r� r� r� r� re r� r� r� r� � __classcell__r r rC r r6 [ s� � � c " � � r6 �__main__)r4 rM Zlibcloud.compute.baser r r r r r r Zlibcloud.compute.typesr r Zlibcloud.common.gig_g8r Zlibcloud.common.exceptionsr � Exceptionr r r! r6 r �doctest�testmodr r r r �<module> s" , |
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка