File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/openstack.cpython-310.pyc
Back
o ;j+� � @ s� d Z ddlZddlZddlmZ ddlmZmZmZm Z m Z m Z ddl m Z ddlmZmZmZmZmZmZmZmZmZmZ ddlmZmZm Z m Z m Z m Z ddl m!Z! dd l"m#Z#m$Z$m%Z%m&Z& dd l'm(Z( dd l)m*Z* zddl+Z,W n e-y ddl,Z,Y nw g d �Z.d Z/dZ0dZ1G dd� de&�Z2G dd� de&�Z3G dd� de&�Z4G dd� de&�Z5G dd� de&�Z6G dd� de&�Z7G d d � d ee%�Z8G d d � d e�Z9G d d!� d!e#�Z:G d"d#� d#e2�Z;G d$d%� d%e8�Z<G d&d'� d'�Z=G d(d)� d)�Z>G d*d+� d+e#�Z?G d,d-� d-�Z@G d.d/� d/�ZAG d0d1� d1�ZBG d2d3� d3�ZCG d4d5� d5e2�ZDG d6d7� d7e8�ZEG d8d9� d9e2�ZFG d:d;� d;e3�ZGG d<d=� d=e4�ZHG d>d?� d?e5�ZIG d@dA� dAe6�ZJG dBdC� dCe7�ZKG dDdE� dEe�ZLG dFdG� dGeE�ZMG dHdI� dI�ZNG dJdK� dK�ZOG dLdM� dM�ZPG dNdO� dO�ZQG dPdQ� dQeQ�ZRG dRdS� dS�ZSG dTdU� dU�ZTG dVdW� dW�ZUG dXdY� dYe�ZVG dZd[� d[�ZWG d\d]� d]�ZXG d^d_� d_�ZYG d`da� da�ZZG dbdc� dc�Z[dS )dz OpenStack driver � N)�get_size_price)�ET�b�next�httplib�parse_qs�urlparse)�findall) �Node�KeyPair�NodeSize� NodeImage� UuidMixin� NodeDriver� NodeLocation� StorageVolume�VolumeSnapshot�NodeImageMember)�Type�Provider� NodeState� LibcloudError�StorageVolumeState�VolumeSnapshotState)� parse_date)�OpenStackResponse�OpenStackException�OpenStackDriverMixin�OpenStackBaseConnection)�is_public_subnet)� BaseHTTPError)�OpenStack_1_0_Response�OpenStack_1_0_Connection�OpenStack_1_0_NodeDriver�OpenStack_1_0_SharedIpGroup� OpenStack_1_0_NodeIpAddresses�OpenStack_1_1_Response�OpenStack_1_1_Connection�OpenStack_1_1_NodeDriver� OpenStack_1_1_FloatingIpPool�OpenStack_2_FloatingIpPool� OpenStack_1_1_FloatingIpAddress� OpenStack_2_FloatingIpAddress� OpenStack_2_PortInterfaceState�OpenStack_2_PortInterface�OpenStackNodeDriverzhttp://www.w3.org/2005/Atom�1.1i� c @ � e Zd ZdZdZdZdS )�OpenStackComputeConnection�computeZnova� RegionOneN��__name__� __module__� __qualname__Z service_type� service_nameZservice_region� r: r: �V/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/openstack.pyr2 V s r2 c @ r1 )�OpenStackImageConnection�imageZglancer4 Nr5 r: r: r: r; r< ] � r< c @ r1 )�OpenStackNetworkConnection�networkZneutronr4 Nr5 r: r: r: r; r? c r> r? c @ r1 )�OpenStackVolumeV2ConnectionZvolumev2Zcinderv2r4 Nr5 r: r: r: r; rA i r> rA c @ r1 )�OpenStackVolumeV3ConnectionZvolumev3Zcinderv3r4 Nr5 r: r: r: r; rB o r> rB c @ r1 )� OpenStackReservationConnectionZ reservationZblazarr4 Nr5 r: r: r: r; rC u r> rC c s� e Zd ZdZdZdZdZi dej�dej�dej �dej �d ej �d ej �d ej�d ej�d ej �dej�dej�dej �dej�dej �dej�dej�dej�ejejd��Zejejejejejejejejejejejd� Zejejejejejejd�Z dddde f� fdd � Z � fd d �Z e dKd d ��Z!d!d"� Z"d#d$� Z#d%d&� Z$d'd(� Z%d)d*� Z&dLd,d-�Z'dMd.d/�Z(d0d1� Z)dNd3d4�Z*dKd5d6�Z+d7d8� Z,d9d:� Z-dOd;d<�Z.d=d>� Z/dKd?d@�Z0dAdB� Z1dCdD� Z2dEdF� Z3dGdH� Z4dIdJ� Z5� Z6S )Pr/ zB Base OpenStack node driver. Should not be used directly. Z openstackZ OpenStackzhttp://openstack.org/�BUILDZREBUILD�ACTIVE� SUSPENDEDZSHUTOFF�DELETEDZ QUEUE_RESIZEZ PREP_RESIZEZ VERIFY_RESIZEZPASSWORDZRESCUEZREBOOTZRESIZEZ HARD_REBOOTZSHARE_IPZSHARE_IP_NO_CONFIGZ DELETE_IP)�ERROR�UNKNOWN) �creating� availableZ attachingzin-use�deleting�errorZerror_deletingz backing-upzrestoring-backup�error_restoringZerror_extending)rJ rK rL rM Z restoringrN NTc sJ | t u r |dkr t} n|dkrt} n |dv rt} ntd| ��t� �| �S )Nz1.0r0 )z2.0z2.1z2.2z/No OpenStackNodeDriver found for API version %s)r/ r# r( �OpenStack_2_NodeDriver�NotImplementedError�super�__new__)�cls�keyZsecretZsecure�host�port� api_version�kwargs�� __class__r: r; rR � s � zOpenStackNodeDriver.__new__c s( t j| fi |�� t� j|i |�� d S �N)r �__init__rQ ��self�argsrX rY r: r; r\ � � z OpenStackNodeDriver.__init__c C s� |pi }t � }d} |j| |d�}|j�|t � �}|�|� |j�d| t � �}dd� |D �} | rF| d } t�| d �} |�t| d �� n ||iS |d 7 }|tkr\t d | tf d ��q ) 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 connection: The API connection to use to perform the request :type connection: ``obj`` :param params: Any request parameters :type params: ``dict`` :return: ``list`` of API response objects :rtype: ``list`` r T��paramsz%s_linksc S s g | ] }|d dkr|�qS )�relr r: )�.0�nr: r: r; � <listcomp>� s z:OpenStackNodeDriver._paginated_request.<locals>.<listcomp>�href� � ��Pagination limit reached for %s, the limit is %d. This might indicate that your API is returning a looping next target for pagination!N) �list�request�object�get�extendr �updater �PAGINATION_LIMITr ) �url�obj� connectionrb ZobjectsZ loop_count�data�values�linksZ next_linksZ next_link�queryr: r: r; �_paginated_request� s0 ����z&OpenStackNodeDriver._paginated_requestc C sz d}g }|r;||�}|j �|g �pg }|�|� |j �dd�}||kr& |S |tkr3td|tf d��|}|d7 }|s|S )a� Perform multiple calls and retrieve all the elements for a paginated response. This method utilizes "next" attribute in the response object. It also includes an infinite loop protection (if the "next" value matches the current path, it will abort). :param request_method: Method to call which will send the request and return a response. This method will get passed in "path" as a first argument. :param response_key: Key in the response object dictionary which contains actual objects we are interested in. r r Nrj ri )rm rn ro rq r ) r^ �path�request_method� response_keyZiteration_count�result�response�itemsZ next_pathr: r: r; �_paginated_request_next s* ����z+OpenStackNodeDriver._paginated_request_nextc C s, d|j }| jj|dd�}|jtjtjfv S )N� /servers/%s�DELETE��method)�idrt rl �statusr � NO_CONTENT�ACCEPTED)r^ �node�uri�respr: r: r; � destroy_node0 s z OpenStackNodeDriver.destroy_nodec C � | j |dd�S )N�HARD�� reboot_type�� _reboot_node�r^ r� r: r: r; � reboot_node: s z OpenStackNodeDriver.reboot_nodec C � | � |d�S )Nzos-start��_post_simple_node_actionr� r: r: r; � start_node> � z OpenStackNodeDriver.start_nodec C r� )Nzos-stopr� r� r: r: r; � stop_nodeB r� z OpenStackNodeDriver.stop_nodeFc C s( i }|rddi}| � | jjd|d�j�S )� List the nodes in a tenant :param ex_all_tenants: List nodes for all the tenants. Note: Your user must have admin privileges for this functionality to work. :type ex_all_tenants: ``bool`` � all_tenantsri �/servers/detailra )� _to_nodesrt rl rm �r^ Zex_all_tenantsrb r: r: r; � list_nodesF s z OpenStackNodeDriver.list_nodesc C sZ |||d|id�}|r||d< |r||d< |r |j |d< | jjddd|id �}| �|j�S ) a< Create a new volume. :param size: Size of volume in gigabytes (required) :type size: ``int`` :param name: Name of the volume to be created :type name: ``str`` :param location: Which data center to create a volume in. If empty, undefined behavior will be selected. (optional) :type location: :class:`.NodeLocation` :param snapshot: Snapshot from which to create the new volume. (optional) :type snapshot: :class:`.VolumeSnapshot` :param ex_volume_type: What kind of volume to create. (optional) :type ex_volume_type: ``str`` :return: The newly created volume. :rtype: :class:`StorageVolume` �contents)� display_name�display_description�size�metadata� volume_type�availability_zone� snapshot_id� /os-volumes�POST�volume�r� ru )r� rt rl � _to_volumerm )r^ r� �name�location�snapshot�ex_volume_typer� r� r: r: r; � create_volumeV s � z!OpenStackNodeDriver.create_volumec C s | j jd|j dd��� S )N�/os-volumes/%sr� r� �rt rl r� �success�r^ r� r: r: r; �destroy_volume� s z"OpenStackNodeDriver.destroy_volume�autoc C s4 |dkrd }| j jd|j dd|j|d�id��� S )Nr� z!/servers/%s/os-volume_attachmentsr� ZvolumeAttachment)�volumeId�devicer� r� )r^ r� r� r� r: r: r; � attach_volume� s ��z!OpenStackNodeDriver.attach_volumec C s� g }|j d D ]9}|r|jtd |�d�|�d�f�v r@| jjd|�d�p'|d |d f dd�}|�� s@|�|�d�p>|d � q|rNtdd � |� d | ��d S ) N� attachments�serverIdZ server_idz$/servers/%s/os-volume_attachments/%sr� r� r� z*detach_volume failed for nodes with id: %sz, �� T) �extrar� �filterrn rt rl r� �appendr �join)r^ r� Zex_nodeZ failed_nodes� attachmentr~ r: r: r; � detach_volume� s. ���� � �z!OpenStackNodeDriver.detach_volumec C � | � | j�d�j�S )Nr� )� _to_volumesrt rl rm �r^ r: r: r; � list_volumes� � z OpenStackNodeDriver.list_volumesc C � | � | j�d| �j�S )Nr� )r� rt rl rm �r^ r� r: r: r; � ex_get_volume� s z!OpenStackNodeDriver.ex_get_volumec C s | � | j�d�j|�S )z� Lists all active images @inherits: :class:`NodeDriver.list_images` :param ex_only_active: True if list only active (optional) :type ex_only_active: ``bool`` z/images/detail)� _to_imagesrt rl rm )r^ r� �ex_only_activer: r: r; � list_images� s z OpenStackNodeDriver.list_imagesc C � | � | j�d�|��jd �S )z� Get an image based on an image_id @inherits: :class:`NodeDriver.get_image` :param image_id: Image identifier :type image_id: ``str`` :return: A NodeImage object :rtype: :class:`NodeImage` � /images/{}r= �� _to_imagert rl �formatrm �r^ �image_idr: r: r; � get_image� s �z OpenStackNodeDriver.get_imagec C r� )Nz/flavors/detail)� _to_sizesrt rl rm )r^ r� r: r: r; � list_sizes� r� z OpenStackNodeDriver.list_sizesc C s t ddd| �gS )Nr � )r r� r: r: r; �list_locations� � z"OpenStackNodeDriver.list_locationsc C s | � � S r[ )Zopenstack_connection_kwargsr� r: r: r; �_ex_connection_class_kwargs� s z/OpenStackNodeDriver._ex_connection_class_kwargsc C sn t |t�r|j}d| }z | jj|dd�}W n ty0 } z|jtjkr+W Y d}~dS � d}~ww | � |j �S )z� Lists details of the specified server. :param node_id: ID of the node which should be used :type node_id: ``str`` :rtype: :class:`Node` r� �GETr� N) � isinstancer r� rt rl r �coder � NOT_FOUND�_to_node_from_objrm )r^ �node_idr� r� �er: r: r; �ex_get_node_details� s �� z'OpenStackNodeDriver.ex_get_node_detailsc C r� )z� Soft reboots the specified server :param node: node :type node: :class:`Node` :rtype: ``bool`` �SOFTr� r� r� r: r: r; �ex_soft_reboot_node� � z'OpenStackNodeDriver.ex_soft_reboot_nodec C r� )z� Hard reboots the specified server :param node: node :type node: :class:`Node` :rtype: ``bool`` r� r� r� r� r: r: r; �ex_hard_reboot_node r� z'OpenStackNodeDriver.ex_hard_reboot_noder[ �F�NNN)r� �NT)7r6 r7 r8 �__doc__�api_namer� Zwebsiter �PENDINGZRUNNINGrF ZSTOPPED� TERMINATEDZ REBOOTINGZ RECONFIGURINGrH rI �NODE_STATE_MAPr �CREATINGZ AVAILABLEZ ATTACHINGZINUSE�DELETINGZBACKUP�VOLUME_STATE_MAPr Z RESTORING�SNAPSHOT_STATE_MAP�DEFAULT_API_VERSIONrR r\ � staticmethodry r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� � __classcell__r: r: rY r; r/ { s� �������� � � � � �������� � 10 / r/ c s2 e Zd ZdZ d� fdd� Zdd� Z� ZS )�OpenStackNodeSizez� NodeSize class for the OpenStack.org driver. Following the example of OpenNebula.org driver and following guidelines: https://issues.apache.org/jira/browse/LIBCLOUD-119 Nc s6 t � j|||||||d� || _| | _| | _| | _d S )N)r� r� �ram�disk� bandwidth�price�driver)rQ r\ �vcpus�ephemeral_disk�swapr� ) r^ r� r� r� r� r� r� r� r� r r r� rY r: r; r\ s � zOpenStackNodeSize.__init__c C s* d| j | j| j| j| j| j| jj| jf S )Nzg<OpenStackNodeSize: id=%s, name=%s, ram=%s, disk=%s, bandwidth=%s, price=%s, driver=%s, vcpus=%s, ...>)r� r� r� r� r� r� r� r� r� r: r: r; �__repr__4 s ��zOpenStackNodeSize.__repr__�NNNN)r6 r7 r8 r� r\ r r� r: r: rY r; r� s � r� c � e Zd Z� fdd�Z� ZS )r! c � t | _t� j|i |�� d S r[ )r# � node_driverrQ r\ r] rY r: r; r\ E � z OpenStack_1_0_Response.__init__�r6 r7 r8 r\ r� r: r: rY r; r! D � r! c @ s e Zd ZeZdZdZdZdS )r" z application/xml; charset=UTF-8zapplication/xmlz/http://docs.rackspacecloud.com/servers/api/v1.0N)r6 r7 r8 r! � responseCls�default_content_type� accept_format� XML_NAMESPACEr: r: r: r; r" L s r" c sJ e Zd ZdZeZejZddgiZ � fdd�Z dd� Z dd � Z dJd d �Z dKd d�Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � ZdLd d �ZdMd d!�Zd"d#� ZdNd%d&�Zd'd(� Zd)d*� Zd+d,� Z d-d.� Z dOd0d1�Z d2d3� Z d4d5� Z d6d7� Z!d8d9� Z"d:d;� Z#d<d=� Z$d>d?� Z%dPd@dA�Z&dBdC� Z'dDdE� Z(dFdG� Z)dHdI� Z*� Z+S )Qr# z� OpenStack node driver. Extra node attributes: - password: root password, available after create. - hostId: represents the host your cloud server runs on - imageId: id of image - flavorId: id of flavor � create_node�generates_passwordc s2 t |�dd ��| _| jj| _t� j|i |�� d S �N�ex_force_api_version)�str�pop�_ex_force_api_version� connectionClsr rQ r\ r] rY r: r; r\ c s z!OpenStack_1_0_NodeDriver.__init__c C s@ g }t |d| j�D ]}|r|�d�dkrq |�| �|�� q |S )Nr= r� rE )r r rn r� r� )r^ rm r� �imagesr= r: r: r; r� h s z#OpenStack_1_0_NodeDriver._to_imagesc C sZ t |�d�|�d�| jj|�d�|�d�|�d�|�d�|�d�|�d�|�d �d �d �S ) Nr� r� �updated�createdr� r� �progress�minDisk�minRam)r r r� r� r r r �r� r� r� r� )r rn rt r� )r^ �elementr: r: r; r� q s ��z"OpenStack_1_0_NodeDriver._to_imageNc C s~ d|j }|s |j}| j|d�}|d ur||d< t�d|�}| jj|dt�|�d�}|jt j kr9|d ur9||j d< |jt j kS )Nr� ��xmlnsr� � adminPass�server�PUTr� �password) r� r� r r �Elementrt rl �tostringr� r r� r� )r^ r� r� r# r� �body� server_elmr� r: r: r; �_change_password_or_name� s z1OpenStack_1_0_NodeDriver._change_password_or_namec C s� | j |t|j�t|j�d�}|rt�d� |r||d< t�d|�} | �|p&i �} | r/| �| � | � |p4i �} | r=| �| � | j j ddt� | �d�} | � | j�S )a Create a new node @inherits: :class:`NodeDriver.create_node` :keyword ex_metadata: Key/Value metadata to associate with a node :type ex_metadata: ``dict`` :keyword ex_files: File Path => File contents to create on the node :type ex_files: ``dict`` :keyword ex_shared_ip_group_id: The server is launched into that shared IP group :type ex_shared_ip_group_id: ``str`` )r r� �imageId�flavorIdzKex_shared_ip_group argument is deprecated. Please use ex_shared_ip_group_id�sharedIpGroupIdr! �/serversr� r� )r r r� �warnings�warnr r$ �_metadata_to_xmlr� � _files_to_xmlrt rl r% �_to_noderm ) r^ r� r� r= � ex_metadata�ex_filesZex_shared_ip_groupZex_shared_ip_group_idZ attributesr' � metadata_elmZ files_elmr� r: r: r; r � s( �� z$OpenStack_1_0_NodeDriver.create_nodec C � | j ||d�S )a� Sets the Node's root password. This will reboot the instance to complete the operation. :class:`Node.extra['password']` will be set to the new value if the operation was successful. :param node: node to set password :type node: :class:`Node` :param password: new password. :type password: ``str`` :rtype: ``bool`` )r# �r( )r^ r� r# r: r: r; �ex_set_password� s z(OpenStack_1_0_NodeDriver.ex_set_passwordc C r5 )a Sets the Node's name. This will reboot the instance to complete the operation. :param node: node to set name :type node: :class:`Node` :param name: new name :type name: ``str`` :rtype: ``bool`` �r� r6 �r^ r� r� r: r: r; �ex_set_server_name� s z+OpenStack_1_0_NodeDriver.ex_set_server_namec C sD t �d| jt|j�d��}| jjd|j dt �|�d�}|jt j kS )a Change an existing server flavor / scale the server up or down. :param node: node to resize. :type node: :class:`Node` :param size: new size. :type size: :class:`NodeSize` :rtype: ``bool`` �resize)r r* �/servers/%s/actionr� r� ) r r$ r r r� rt rl r% r� r r� )r^ r� r� �elmr� r: r: r; �ex_resize_node� s � z'OpenStack_1_0_NodeDriver.ex_resize_nodec C r5 )z� NOTE: This method is here for backward compatibility reasons. You should use ``ex_resize_node`` instead. )r� r� )r> )r^ r� r� r: r: r; � ex_resize s z"OpenStack_1_0_NodeDriver.ex_resizec C �< t �dd| ji�}| jjd|j dt �|�d�}|jtj kS )a� Confirm a resize request which is currently in progress. If a resize request is not explicitly confirmed or reverted it's automatically confirmed after 24 hours. For more info refer to the API documentation: http://goo.gl/zjFI1 :param node: node for which the resize request will be confirmed. :type node: :class:`Node` :rtype: ``bool`` � confirmResizer r< r� r� � r r$ r rt rl r� r% r� r r� �r^ r� r= r� r: r: r; �ex_confirm_resize s �� z*OpenStack_1_0_NodeDriver.ex_confirm_resizec C r@ )a� Revert a resize request which is currently in progress. All resizes are automatically confirmed after 24 hours if they have not already been confirmed explicitly or reverted. For more info refer to the API documentation: http://goo.gl/AizBu :param node: node for which the resize request will be reverted. :type node: :class:`Node` :rtype: ``bool`` � revertResizer r< r� r� rB rC r: r: r; �ex_revert_resize# s � z)OpenStack_1_0_NodeDriver.ex_revert_resizec C s\ t |t�r|j}t |t�r|j}t�d| j|d��}| jjd| dt� |�d�}|j t j kS )a Rebuilds the specified server. :param node_id: ID of the node which should be used :type node_id: ``str`` :param image_id: ID of the image which should be used :type image_id: ``str`` :rtype: ``bool`` �rebuild)r r) r< r� r� ) r� r r� r r r$ r rt rl r% r� r r� )r^ r� r� r= r� r: r: r; � ex_rebuild7 s � z#OpenStack_1_0_NodeDriver.ex_rebuildc C s^ t |t�r|j}t�d| j|d��}|r t�|dd|i� | jjddt� |�d�}| � |j �S )a Creates a shared IP group. :param group_name: group name which should be used :type group_name: ``str`` :param node_id: ID of the node which should be used :type node_id: ``str`` :rtype: ``bool`` � sharedIpGroupr r! r� �/shared_ip_groupsr� r� ) r� r r� r r$ r � SubElementrt rl r% �_to_shared_ip_grouprm )r^ Z group_namer� Z group_elmr� r: r: r; �ex_create_ip_groupQ s � z+OpenStack_1_0_NodeDriver.ex_create_ip_groupFc s> |rdnd}� j j|dd�}t|jd� j�}� fdd�|D �S )a Lists IDs and names for shared IP groups. If details lists all details for shared IP groups. :param details: True if details is required :type details: ``bool`` :rtype: ``list`` of :class:`OpenStack_1_0_SharedIpGroup` z/shared_ip_groups/detailrJ r� r� rI c � g | ]}� � |��qS r: )rL �rd �elr� r: r; rf x � z>OpenStack_1_0_NodeDriver.ex_list_ip_groups.<locals>.<listcomp>)rt rl r rm r )r^ �detailsr� r� �groupsr: r� r; �ex_list_ip_groupsk s z*OpenStack_1_0_NodeDriver.ex_list_ip_groupsc C s$ d| }| j j|dd�}|jtjkS )z� Deletes the specified shared IP group. :param group_id: group id which should be used :type group_id: ``str`` :rtype: ``bool`` z/shared_ip_groups/%sr� r� )rt rl r� r r� )r^ �group_idr� r� r: r: r; �ex_delete_ip_groupz s z+OpenStack_1_0_NodeDriver.ex_delete_ip_groupTc C sd t |t�r|j}|r d}nd}t�d| j||d��}d�||�}| jj|dt� |�d�}|j t j kS )a� Shares an IP address to the specified server. :param group_id: group id which should be used :type group_id: ``str`` :param node_id: ID of the node which should be used :type node_id: ``str`` :param ip: ip which should be used :type ip: ``str`` :param configure_node: configure node :type configure_node: ``bool`` :rtype: ``bool`` �true�falseZshareIp)r r+ ZconfigureServer�/servers/{}/ips/public/{}r" r� ) r� r r� r r$ r r� rt rl r% r� r r� ) r^ rU r� �ipZconfigure_nodeZ str_configurer= r� r� r: r: r; � ex_share_ip� s �� z$OpenStack_1_0_NodeDriver.ex_share_ipc C s8 t |t�r|j}d�||�}| jj|dd�}|jtjkS )a Removes a shared IP address from the specified server. :param node_id: ID of the node which should be used :type node_id: ``str`` :param ip: ip which should be used :type ip: ``str`` :rtype: ``bool`` rY r� r� ) r� r r� r� rt rl r� r r� )r^ r� rZ r� r� r: r: r; � ex_unshare_ip� s z&OpenStack_1_0_NodeDriver.ex_unshare_ipc C s4 t |t�r|j}d| }| jj|dd�}| �|j�S )z� List all server addresses. :param node_id: ID of the node which should be used :type node_id: ``str`` :rtype: :class:`OpenStack_1_0_NodeIpAddresses` z/servers/%s/ipsr� r� )r� r r� rt rl �_to_ip_addressesrm )r^ r� r� r� r: r: r; �ex_list_ip_addresses� s z-OpenStack_1_0_NodeDriver.ex_list_ip_addressesc C sL |sd S t �d�}t|�� �D ]\}}t �|ddt|�i�}t|�|_q|S )Nr� �metarT )r r$ rk r rK r �text)r^ r� r4 �k�vZmeta_elmr: r: r; r/ � s z)OpenStack_1_0_NodeDriver._metadata_to_xmlc C sX |sd S t �d�}t|�� �D ]\}}t �|ddt|�i�}t�t|��� d�|_ q|S )N� personality�filerz �ascii) r r$ rk r rK r �base64� b64encoder �decoder` )r^ �filesZpersonality_elmra rb Zfile_elmr: r: r; r0 � s z&OpenStack_1_0_NodeDriver._files_to_xmlr� c C s | � |dd|fg�}|jtjkS )N�reboot�type�� _node_actionr� r r� �r^ r� r� r� r: r: r; r� � s z%OpenStack_1_0_NodeDriver._reboot_nodec C sZ t |t�r d�dd� |dd � D ��}d�|d | j|�}d|j }| jj|d|d �}|S ) N� c S s g | ] }d � |d |d ��qS )z{}="{}"r ri )r� )rd �itemr: r: r; rf � s z9OpenStack_1_0_NodeDriver._node_action.<locals>.<listcomp>ri z<{} xmlns="{}" {}/>r r< r� r� )r� rk r� r� r r� rt rl )r^ r� r& �attrr� r� r: r: r; rm � s z%OpenStack_1_0_NodeDriver._node_actionc � t |d� j�}� fdd�|D �S )Nr! c rN r: �r1 rO r� r: r; rf � rQ z6OpenStack_1_0_NodeDriver._to_nodes.<locals>.<listcomp>�r r )r^ rm Z node_elementsr: r� r; r� � � z"OpenStack_1_0_NodeDriver._to_nodesc C s | � t|d| j�d �S )Nr! r )r1 r r �r^ rs r: r: r; r� � � z*OpenStack_1_0_NodeDriver._to_node_from_objc C s� dd� }dd� }|t |d| j��}|t |d| j��}|t |d| j��}t|�d�|�d �| j�|�d �tj�||| jj|�d �|�d �|�d �|�d�d| jj | jj |�d�f | j� � |d�d�}|S )Nc S s dd� | D �S )Nc S � g | ]}|� d ��qS ��addr�rn �rd rZ r: r: r; rf rQ zFOpenStack_1_0_NodeDriver._to_node.<locals>.get_ips.<locals>.<listcomp>r: �rP r: r: r; �get_ips � z2OpenStack_1_0_NodeDriver._to_node.<locals>.get_ipsc S s" i }| D ] }|j ||�d�< q|S )NrT )r` rn )rP �dr_ r: r: r; � get_meta_dict s z8OpenStack_1_0_NodeDriver._to_node.<locals>.get_meta_dictzaddresses/public/ipzaddresses/private/ipz metadata/metar� r� r� r �hostIdr) r* zhttps://%s%s/servers/%s)r# r� r) r* r� r9 r� )r� r� �state� public_ips� private_ipsr� r� ) r r r rn r� r rI rt r� rU Z request_path�get_service_name)r^ rP r~ r� Z public_ipZ private_ipr� re r: r: r; r1 � s0 ���z!OpenStack_1_0_NodeDriver._to_nodec rr )N�flavorc rN r: ��_to_sizerO r� r: r; rf $ rQ z6OpenStack_1_0_NodeDriver._to_sizes.<locals>.<listcomp>rt )r^ rm �elementsr: r� r; r� " ru z"OpenStack_1_0_NodeDriver._to_sizesc C sn |� dd �r t|� d��nd }t|� d�|� d�t|� d��t|� d��|d |� d�| �|� d��| jjd� S )Nr� r� r� r� r� � extra_specs) r� r� r� r� r� r� r� r� r� )rn �intr� �_get_size_pricert r� )r^ rP r� r: r: r; r� & s �z!OpenStack_1_0_NodeDriver._to_sizec sj dd� � dd� }| j �d�j}� fdd�t|d| j�D �}i }t|d | j�D ] }|�||�� q&||d �S ) a' Extra call to get account's limits, such as rates (for example amount of POST requests per day) and absolute limits like total amount of available RAM to be used by servers. :return: dict with keys 'rate' and 'absolute' :rtype: ``dict`` c S s* i }t | �� �D ] }|d ||d < q|S )Nri r )rk r )rP �raterp r: r: r; �_to_rateA s z4OpenStack_1_0_NodeDriver.ex_limits.<locals>._to_ratec S s | � d�| � d�iS )Nr� �valuer{ r} r: r: r; � _to_absoluteH � z8OpenStack_1_0_NodeDriver.ex_limits.<locals>._to_absolutez/limitsc s g | ]}� |��qS r: r: rO �r� r: r; rf L � z6OpenStack_1_0_NodeDriver.ex_limits.<locals>.<listcomp>z rate/limitzabsolute/limit)r� �absolute)rt rl rm r r rp )r^ r� Zlimitsr� r� rp r: r� r; � ex_limits6 s z"OpenStack_1_0_NodeDriver.ex_limitsc C s8 t �d| j||jd��}| �| jjddt �|�d�j�S )a. Create an image for node. @inherits: :class:`NodeDriver.create_image` :param node: node to use as a base for image :type node: :class:`Node` :param name: name for new image :type name: ``str`` :rtype: :class:`NodeImage` r= )r r� r� z/imagesr� r� ) r r$ r r� r� rt rl r% rm )r^ r� r� � descriptionrj Z image_elmr: r: r; � create_imageS s ��z%OpenStack_1_0_NodeDriver.create_imagec C s& d|j }| jj|dd�}|jtjkS )z�Delete an image for node. @inherits: :class:`NodeDriver.delete_image` :param image: the image to be deleted :type image: :class:`NodeImage` :rtype: ``bool`` z /images/%sr� r� )r� rt rl r� r r� )r^ r= r� r� r: r: r; � delete_imagei s z%OpenStack_1_0_NodeDriver.delete_imagec C sN t |d| j�}|rdd� t |d d| j�D �}nd }t|�d�|�d�|d�S ) N�serversc S rx �r� r{ )rd �sr: r: r; rf z rQ z@OpenStack_1_0_NodeDriver._to_shared_ip_group.<locals>.<listcomp>r r! r� r� )r� r� r� )r r r$ rn )r^ rP Z servers_elr� r: r: r; rL w s z,OpenStack_1_0_NodeDriver._to_shared_ip_groupc C sV dd� t t |d| j�d d| j�D �}dd� t t |d| j�d d| j�D �}t||�S )Nc S rx ry r{ r| r: r: r; rf � � ��z=OpenStack_1_0_NodeDriver._to_ip_addresses.<locals>.<listcomp>�publicr rZ c S rx ry r{ r| r: r: r; rf � r� Zprivate)r r r% )r^ rP r� r� r: r: r; r] s ���� z)OpenStack_1_0_NodeDriver._to_ip_addressesc C �( z t d| j|d�W S ty Y dS w �Nr3 )Z driver_typeZ driver_name�size_idg �r r� �KeyError�r^ r� r: r: r; r� � s �z(OpenStack_1_0_NodeDriver._get_size_price�NNr r[ r� )T�r� r� ),r6 r7 r8 r� r" r r � OPENSTACKrk �featuresr\ r� r� r( r r7 r: r> r? rD rF rH rM rT rV r[ r\ r^ r/ r0 r� rm r� r� r1 r� r� r� r� r� rL r] r� r� r: r: rY r; r# S sT �9 ) # r# c @ s e Zd ZdZddd�ZdS )r$ z Shared IP group info. Nc C s t |�| _|| _|| _d S r[ )r r� r� r� )r^ r� r� r� r: r: r; r\ � s z$OpenStack_1_0_SharedIpGroup.__init__r[ �r6 r7 r8 r� r\ r: r: r: r; r$ � s r$ c @ s e Zd ZdZdd� ZdS )r% z< List of public and private IP addresses of a Node. c C � || _ || _d S r[ )�public_addresses�private_addresses)r^ r� r� r: r: r; r\ � � z&OpenStack_1_0_NodeIpAddresses.__init__Nr� r: r: r: r; r% � s r% c r )r& c r r[ )r( r rQ r\ r] rY r: r; r\ � r z OpenStack_1_1_Response.__init__r r: r: rY r; r& � r r& c @ �" e Zd ZdZddd�Zdd� ZdS )�OpenStackNetworkz A Virtual Network. Nc C �* t |�| _|| _|| _|| _|pi | _d S r[ )r r� r� �cidrr� r� )r^ r� r� r� r� r� r: r: r; r\ � � zOpenStackNetwork.__init__c C � d� | j| j| j�S )Nz.<OpenStackNetwork id="{}" name="{}" cidr="{}">�r� r� r� r� r� r: r: r; r � � �zOpenStackNetwork.__repr__r[ �r6 r7 r8 r� r\ r r: r: r: r; r� � � r� c @ r� )�OpenStackSecurityGroupz A Security Group. Nc C s6 || _ || _|| _|| _|| _|pg | _|pi | _dS )a Constructor. :keyword id: Group id. :type id: ``str`` :keyword tenant_id: Owner of the security group. :type tenant_id: ``str`` :keyword name: Human-readable name for the security group. Might not be unique. :type name: ``str`` :keyword description: Human-readable description of a security group. :type description: ``str`` :keyword rules: Rules associated with this group. :type rules: ``list`` of :class:`OpenStackSecurityGroupRule` :keyword extra: Extra attributes associated with this group. :type extra: ``dict`` N)r� � tenant_idr� r� r� �rulesr� )r^ r� r� r� r� r� r� r� r: r: r; r\ � s z OpenStackSecurityGroup.__init__c C s d� | j| j| j| j�S )NzJ<OpenStackSecurityGroup id={} tenant_id={} name={} description={}>)r� r� r� r� r� r� r: r: r; r � s �z OpenStackSecurityGroup.__repr__r� r� r: r: r: r; r� � s !r� c @ s, e Zd ZdZ ddd�Zdd� ZdS )�OpenStackSecurityGroupRulez% A Rule of a Security Group. Nc C s� || _ || _|| _|| _|| _|| _d| _i | _d| _|du r#|| _n|| d�| _| dur;| dv r5| | _nt dd|��| | _ | pAi | _ dS )a Constructor. :keyword id: Rule id. :type id: ``str`` :keyword parent_group_id: ID of the parent security group. :type parent_group_id: ``str`` :keyword ip_protocol: IP Protocol (icmp, tcp, udp, etc). :type ip_protocol: ``str`` :keyword from_port: Port at start of range. :type from_port: ``int`` :keyword to_port: Port at end of range. :type to_port: ``int`` :keyword ip_range: CIDR for address range. :type ip_range: ``str`` :keyword group: Name of a source security group to apply to rule. :type group: ``str`` :keyword tenant_id: Owner of the security group. :type tenant_id: ``str`` :keyword direction: Security group Direction (ingress or egress). :type direction: ``str`` :keyword extra: Extra attributes associated with this rule. :type extra: ``dict`` r� �ingressN)r� r� )r� Zegressz<Security group direction incorrect value: ingress or egress.r� ) r� �parent_group_id� ip_protocol� from_port�to_portr� �ip_range�group� directionr r� r� ) r^ r� r� r� r� r� r� r� r� r� r� r� r: r: r; r\ � s, / �z#OpenStackSecurityGroupRule.__init__c C � d| j | j| j| j| jf S )Nzl<OpenStackSecurityGroupRule id=%s parent_group_id=%s ip_protocol=%s from_port=%s to_port=%s>)r� r� r� r� r� r� r: r: r; r C s ���z#OpenStackSecurityGroupRule.__repr__)NNNNNr� r: r: r: r; r� � s � Lr� c @ r� )�OpenStackKeyPairz A KeyPair. Nc C s, || _ || _|| _|| _|| _|pi | _dS )a Constructor. :keyword name: Name of the KeyPair. :type name: ``str`` :keyword fingerprint: Fingerprint of the KeyPair :type fingerprint: ``str`` :keyword public_key: Public key in OpenSSH format. :type public_key: ``str`` :keyword private_key: Private key in PEM format. :type private_key: ``str`` :keyword extra: Extra attributes associated with this KeyPair. :type extra: ``dict`` N)r� � fingerprint� public_key� private_keyr� r� )r^ r� r� r� r� r� r� r: r: r; r\ V s zOpenStackKeyPair.__init__c C r� )Nz;<OpenStackKeyPair name={} fingerprint={} public_key={} ...>)r� r� r� r� r� r: r: r; r p r� zOpenStackKeyPair.__repr__r� r� r: r: r: r; r� Q s r� c @ � e Zd ZeZdZdZdd� ZdS )r' �application/json� application/json; charset=UTF-8c C � t �|�S r[ ��json�dumps�r^ ru r: r: r; � encode_data} � z$OpenStack_1_1_Connection.encode_dataN�r6 r7 r8 r& r r r r� r: r: r: r; r' x � r' c sB e Zd ZdZeZejZddgiZ dZ � fdd�Z d�dd �Z d d � Z d d � Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd�d d �Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd�d)d*�Z d+d,� Z d-d.� Z d/d0� Z d1d2� Z d3d4� Z!d5d6� Z"d7d8� Z#d9d:� Z$d;d<� Z%d=d>� Z&d�d?d@�Z'dAdB� Z(dCdD� Z)dEdF� Z*d�dHdI�Z+dJdK� Z,d�dMdN�Z-dOdP� Z.dQdR� Z/dSdT� Z0dUdV� Z1dWdX� Z2dYdZ� Z3d[d\� Z4d]d^� Z5d_d`� Z6 d�dadb�Z7dcdd� Z8dedf� Z9dgdh� Z:didj� Z;dkdl� Z<dmdn� Z=dodp� Z>dqdr� Z?dsdt� Z@dudv� ZAdwdx� ZBdydz� ZCd{d|� ZDd}d~� ZEdd�� ZFd�d�� ZGd�d�� ZHd�d�� ZId�d�� ZJd�d�� ZKd�d�� ZLd�d�� ZMd�d�� ZNd�d�d��ZOd�d�� ZPd�d�� ZQd�d�d��ZRd�d�� ZSd�d�� ZTd�d�� ZUd�d�� ZVd�d�� ZWd�d�� ZXd�d�� ZYd�d�� ZZd�d�d��Z[d�d�� Z\d�d�� Z]d�d�� Z^d�d�� Z_d�d�� Z`d�d�� Zad�d�� Zbd�d�� Zcd�d�� Zdd�d�� Zed�d�� Zf� ZgS )�r( � OpenStack node driver. r r z /os-networksc s( t |�dd ��| _t� j|i |�� d S r )r r r rQ r\ r] rY r: r; r\ � r` z!OpenStack_1_1_NodeDriver.__init__Nc C s� |pi }| pi } | p g } |pg }| j d||||||||| | | | |d�}d|i}|r-||d< | jjdd|d�}|jd }| j�d|d �}|jd }|�d d�|d < | �|�S ) a= Create a new node @inherits: :class:`NodeDriver.create_node` :keyword ex_keyname: The name of the key pair :type ex_keyname: ``str`` :keyword ex_userdata: String containing user data see https://help.ubuntu.com/community/CloudInit :type ex_userdata: ``str`` :keyword ex_config_drive: Enable config drive see http://docs.openstack.org/grizzly/openstack-compute/admin/content/config-drive.html :type ex_config_drive: ``bool`` :keyword ex_security_groups: List of security groups to assign to the node :type ex_security_groups: ``list`` of :class:`OpenStackSecurityGroup` :keyword ex_metadata: Key/Value metadata to associate with a node :type ex_metadata: ``dict`` :keyword ex_files: File Path => File contents to create on the node :type ex_files: ``dict`` :keyword networks: The server is launched into a set of Networks. :type networks: ``list`` of :class:`OpenStackNetwork` :keyword ex_disk_config: Name of the disk configuration. Can be either ``AUTO`` or ``MANUAL``. :type ex_disk_config: ``str`` :keyword ex_config_drive: If True enables metadata injection in a server through a configuration drive. :type ex_config_drive: ``bool`` :keyword ex_admin_pass: The root password for the node :type ex_admin_pass: ``str`` :keyword ex_availability_zone: Nova availability zone for the node :type ex_availability_zone: ``str`` :keyword ex_blockdevicemappings: Enables fine grained control of the block device mapping for an instance. :type ex_blockdevicemappings: ``dict`` :keyword ex_os_scheduler_hints: The dictionary of data to send to the scheduler. :type ex_os_scheduler_hints: ``dict`` N)r� r� r� r= � ex_keyname� ex_userdata�ex_config_drive�ex_security_groupsr2 r3 �networks�ex_disk_config�ex_availability_zone�ex_blockdevicemappingsr! zos:scheduler_hintsr, r� r� r� r� r )�_create_args_to_paramsrt rl rm rn r1 )r^ r� r� r= r� r� r� r� r2 r3 r� r� � ex_admin_passr� r� Zex_os_scheduler_hints� server_paramsru r� Zcreate_responseZ server_respZ server_objectr: r: r; r � s: I� z$OpenStack_1_1_NodeDriver.create_nodec C s: g }|d D ]}|r|� d�dkrq|�| �|�� q|S )Nr r� rE )rn r� r� )r^ rs r� r r= r: r: r; r� s z#OpenStack_1_1_NodeDriver._to_imagesc C s� |� di �}|� d�p|d }|� d�p|d }|� d�}|d u r&|� d�}|� d�}|d u r4|� d �}t|d |d | t|� d �|||d |� d�|� d�|� d�|� d�|� d�|� d �||d� d�S )Nr! � updated_atr � created_atr �min_ramr �min_diskr r� r� � visibilityr� r r� �os_type� os_distro� os_version) r� r r r� r r� r� r� r� r� r r r )rn r �dict)r^ Z api_imager! r r r� r� r: r: r; r� s8 ��z"OpenStack_1_1_NodeDriver._to_imagec C s@ |d }|� d�}t|d |d |d || t|� d�|d�d�S ) Nr� r� � member_idr� r� �schema)r� r )r� r� r� r r� r� )rn r r� )r^ Zapi_image_memberr r r: r: r; �_to_image_member+ s ��z)OpenStack_1_1_NodeDriver._to_image_memberc � |d }� fdd�|D �S )Nr� c rN r: rs )rd r! r� r: r; rf < rQ z6OpenStack_1_1_NodeDriver._to_nodes.<locals>.<listcomp>r: )r^ rs r� r: r� r; r� : � z"OpenStack_1_1_NodeDriver._to_nodesc r� )N�volumesc rN r: )r� )rd r� r� r: r; rf @ rQ z8OpenStack_1_1_NodeDriver._to_volumes.<locals>.<listcomp>r: )r^ rs r� r: r� r; r� > r� z$OpenStack_1_1_NodeDriver._to_volumesc r� )N� snapshotsc rN r: )� _to_snapshot�rd r� r� r: r; rf D rQ z:OpenStack_1_1_NodeDriver._to_snapshots.<locals>.<listcomp>r: )r^ rs r� r: r� r; � _to_snapshotsB r� z&OpenStack_1_1_NodeDriver._to_snapshotsc r� )N�flavorsc rN r: r� )rd r� r� r: r; rf H rQ z6OpenStack_1_1_NodeDriver._to_sizes.<locals>.<listcomp>r: )r^ rs r� r: r� r; r� F r� z"OpenStack_1_1_NodeDriver._to_sizesc K s� |� d�|� di �p i d�}|� dd �r | �|� d��|d< |� dd �r*|d |d< |� dd �r6|d |d < |� d d �rJt�t|d ���d �|d < |� d d �rV|d |d< |� dd �rdt|d �|d< |� dd �rp|d |d< |� dd �r�|d p{g }dd� |D �}||d< |� dd �r�g |d< |d p�g D ]}|j}|d �d|i� q�|� dd �r�|d |d< |� dd �r�|� d�|d< n|j|d< |� dd �r�|� d�j |d< n |r�|j � d d �nd |d< |� d d �r�|� d �j |d < |S |j � d �|d < |S )!Nr� r2 )r� r� r3 rc r� r� r� �key_namer� re Z user_datar� �OS-DCF:diskConfigr� � config_driver� r r� c S s g | ]}d |j i�qS )Zuuidr� �rd r@ r: r: r; rf g rQ zCOpenStack_1_1_NodeDriver._create_args_to_params.<locals>.<listcomp>r� �security_groupsr� Zblock_device_mapping_v2r= �imageRefr) r� r� � flavorRefr* ) rn �_files_to_personalityrf rg r rh r r� r� r� r� )r^ r� rX r� r� �security_groupr� r: r: r; r� J sN � �z/OpenStack_1_1_NodeDriver._create_args_to_paramsc C s< g }t |�� �D ]\}}|�|t�t|���� d�� q|S )N)rz r� )rk r r� rf rg r rh )r^ ri �rvra rb r: r: r; r� � s z.OpenStack_1_1_NodeDriver._files_to_personalityr� c C s | j |d|d�}|jtjkS )Nrj )rk rl rn r: r: r; r� � s z%OpenStack_1_1_NodeDriver._reboot_nodec C s& | j |d|d�}||jd< |jtjkS )a Changes the administrator password for a specified server. :param node: Node to rebuild. :type node: :class:`Node` :param password: The administrator password. :type password: ``str`` :rtype: ``bool`` ZchangePassword�r r# )rm r� r� r r� �r^ r� r# r� r: r: r; r7 � s z(OpenStack_1_1_NodeDriver.ex_set_passwordc K s6 | j |fd|i|��}| j|dfi |��}|jtjkS )a� Rebuild a Node. :param node: Node to rebuild. :type node: :class:`Node` :param image: New image to use. :type image: :class:`NodeImage` :keyword ex_metadata: Key/Value metadata to associate with a node :type ex_metadata: ``dict`` :keyword ex_files: File Path => File contents to create on the node :type ex_files: ``dict`` :keyword ex_keyname: Name of existing public key to inject into instance :type ex_keyname: ``str`` :keyword ex_userdata: String containing user data see https://help.ubuntu.com/community/CloudInit :type ex_userdata: ``str`` :keyword ex_security_groups: List of security groups to assign to the node :type ex_security_groups: ``list`` of :class:`OpenStackSecurityGroup` :keyword ex_disk_config: Name of the disk configuration. Can be either ``AUTO`` or ``MANUAL``. :type ex_disk_config: ``str`` :keyword ex_config_drive: If True enables metadata injection in a server through a configuration drive. :type ex_config_drive: ``bool`` :rtype: ``bool`` r= rG )r� rm r� r r� )r^ r� r= rX r� r� r: r: r; rH � s ) z#OpenStack_1_1_NodeDriver.ex_rebuildc C s* d|j i}| j|dfi |��}|jtjkS )z� Change a node size. :param node: Node to resize. :type node: :class:`Node` :type size: :class:`NodeSize` :param size: New size to use. :rtype: ``bool`` r� r; )r� rm r� r r� )r^ r� r� r� r� r: r: r; r? � � z"OpenStack_1_1_NodeDriver.ex_resizec C � | � |d�}|jtjkS )z� Confirms a pending resize action. :param node: Node to resize. :type node: :class:`Node` :rtype: ``bool`` rA )rm r� r r� �r^ r� r� r: r: r; rD � � z*OpenStack_1_1_NodeDriver.ex_confirm_resizec C r )z� Cancels and reverts a pending resize action. :param node: Node to resize. :type node: :class:`Node` :rtype: ``bool`` rE rl r r: r: r; rF � r z)OpenStack_1_1_NodeDriver.ex_revert_resizec C sD i }|r||d< | j |dfd|i|��}| �|jd �}| j|d�S )aS Creates a new image. :param node: Node :type node: :class:`Node` :param name: The name for the new image. :type name: ``str`` :param metadata: Key and value pairs for metadata. :type metadata: ``dict`` :rtype: :class:`NodeImage` r� Z createImager� r� )r� )rm �_extract_image_id_from_url�headersr� )r^ r� r� r� Zoptional_paramsr� r� r: r: r; r� � s z%OpenStack_1_1_NodeDriver.create_imagec C r5 )z� Sets the Node's name. :param node: Node :type node: :class:`Node` :param name: The name of the server. :type name: ``str`` :rtype: :class:`Node` r8 )� _update_noder9 r: r: r; r: s z+OpenStack_1_1_NodeDriver.ex_set_server_namec C s | j jd�|j�dd�jd S )z� Get a Node's metadata. :param node: Node :type node: :class:`Node` :return: Key/Value metadata associated with node. :rtype: ``dict`` �/servers/{}/metadatar� r� r� �rt rl r� r� rm r� r: r: r; �ex_get_metadata s ��z(OpenStack_1_1_NodeDriver.ex_get_metadatac C s$ | j jd�|j�dd|id�jd S )z� Sets the Node's metadata. :param node: Node :type node: :class:`Node` :param metadata: Key/Value metadata to associate with a node :type metadata: ``dict`` :rtype: ``dict`` r r" r� r� r )r^ r� r� r: r: r; �ex_set_metadata( s ��z(OpenStack_1_1_NodeDriver.ex_set_metadatac K s0 | j |fi |��}d|d i}| j|fi |��S )a� Update the Node's editable attributes. The OpenStack API currently supports editing name and IPv4/IPv6 access addresses. The driver currently only supports updating the node name. :param node: Node :type node: :class:`Node` :keyword name: New name for the server :type name: ``str`` :rtype: :class:`Node` r� )r� r )r^ r� � node_updatesZpotential_dataZupdatesr: r: r; �ex_update_node: s z'OpenStack_1_1_NodeDriver.ex_update_nodec r� )Nr� c rN r: �� _to_networkr� r� r: r; rf O rQ z9OpenStack_1_1_NodeDriver._to_networks.<locals>.<listcomp>r: �r^ rs r� r: r� r; � _to_networksM r� z%OpenStack_1_1_NodeDriver._to_networksc C s t |d |d |�dd �| d�S )Nr� �labelr� )r� r� r� r� )r� rn rv r: r: r; r Q s �z$OpenStack_1_1_NodeDriver._to_networkc C � | j �| j�j}| �|�S �zs Get a list of Networks that are available. :rtype: ``list`` of :class:`OpenStackNetwork` )rt rl �_networks_url_prefixrm r �r^ r~ r: r: r; �ex_list_networksV � z)OpenStack_1_1_NodeDriver.ex_list_networksc C �, dj | j|d�}| j�|�j}| �|d �S �z� Retrieve the Network with the given ID :param networkId: ID of the network :type networkId: ``str`` :rtype :class:`OpenStackNetwork` z"{networks_url_prefix}/{network_id})Znetworks_url_prefix� network_idr@ )r� r rt rl rm r �r^ r Z request_urlr~ r: r: r; �ex_get_network_ � �z'OpenStack_1_1_NodeDriver.ex_get_networkc C s2 d||d�i}| j j| jd|d�j}| �|d �S )z� Create a new Network :param name: Name of network which should be used :type name: ``str`` :param cidr: cidr of network which should be used :type cidr: ``str`` :rtype: :class:`OpenStackNetwork` r@ )r� r r� r� )rt rl r rm r )r^ r� r� ru r~ r: r: r; �ex_create_networkn s ��z*OpenStack_1_1_NodeDriver.ex_create_networkc C �. | j jd�| j|j�dd�}|jtjtjfv S �z� Delete a Network :param network: Network which should be used :type network: :class:`OpenStackNetwork` :rtype: ``bool`` �{}/{}r� r� ) rt rl r� r r� r� r r� r� �r^ r@ r� r: r: r; �ex_delete_network� � �z*OpenStack_1_1_NodeDriver.ex_delete_networkc C s* dd|ii}| j jd|j d|d�j}|S )aF Get console output :param node: node :type node: :class:`Node` :param length: Optional number of lines to fetch from the console log :type length: ``int`` :return: Dictionary with the output :rtype: ``dict`` zos-getConsoleOutput�lengthr< r� r� )rt rl r� rm )r^ r� r& ru r� r: r: r; �ex_get_console_output� s ��z.OpenStack_1_1_NodeDriver.ex_get_console_outputc C r� )N� /os-snapshots)r� rt rl rm r� r: r: r; �ex_list_snapshots� r� z*OpenStack_1_1_NodeDriver.ex_list_snapshotsc C r� )N�/os-snapshots/%s)r� rt rl rm )r^ � snapshotIdr: r: r; �ex_get_snapshot� rw z(OpenStack_1_1_NodeDriver.ex_get_snapshotc s � fdd�| � � D �S )Nc s g | ] }|j d � jkr|�qS )� volume_id)r� r� r� �r� r: r; rf � s �zBOpenStack_1_1_NodeDriver.list_volume_snapshots.<locals>.<listcomp>)r) r� r: r. r; �list_volume_snapshots� s �z.OpenStack_1_1_NodeDriver.list_volume_snapshotsTc C sR d|j |d�i}|dur||d d< |dur ||d d< | �| jjdd|d�j�S ) �g Create snapshot from volume :param volume: Instance of `StorageVolume` :type volume: `StorageVolume` :param name: Name of snapshot (optional) :type name: `str` | `NoneType` :param ex_description: Description of the snapshot (optional) :type ex_description: `str` | `NoneType` :param ex_force: Specifies if we create a snapshot that is not in state `available`. For example `in-use`. Defaults to True. (optional) :type ex_force: `bool` :rtype: :class:`VolumeSnapshot` r� �r- �forceNr� r� r( r� r� )r� r� rt rl rm �r^ r� r� �ex_description�ex_forceru r: r: r; �create_volume_snapshot� s �z/OpenStack_1_1_NodeDriver.create_volume_snapshotc C �" | j jd|j dd�}|jtjkS )Nr* r� r� �rt rl r� r� r r� �r^ r� r� r: r: r; �destroy_volume_snapshot� s z0OpenStack_1_1_NodeDriver.destroy_volume_snapshotFc C s t �d� | j||||d�S )a� Create a snapshot based off of a volume. :param volume: volume :type volume: :class:`StorageVolume` :keyword name: New name for the volume snapshot :type name: ``str`` :keyword description: Description of the snapshot (optional) :type description: ``str`` :keyword force: Whether to force creation (optional) :type force: ``bool`` :rtype: :class:`VolumeSnapshot` zMThis method has been deprecated in favor of the create_volume_snapshot method)r4 r5 )r- r. r6 )r^ r� r� r� r2 r: r: r; �ex_create_snapshot� s �z+OpenStack_1_1_NodeDriver.ex_create_snapshotc C s t �d� | �|�S )z� Delete a VolumeSnapshot :param snapshot: snapshot :type snapshot: :class:`VolumeSnapshot` :rtype: ``bool`` zNThis method has been deprecated in favor of the destroy_volume_snapshot method)r- r. r: )r^ r� r: r: r; �ex_delete_snapshot� s � z+OpenStack_1_1_NodeDriver.ex_delete_snapshotc s � fdd�|D �S )Nc rN r: )�_to_security_group_rule)rd �security_group_ruler� r: r; rf � rQ zEOpenStack_1_1_NodeDriver._to_security_group_rules.<locals>.<listcomp>r: rv r: r� r; �_to_security_group_rules� s z1OpenStack_1_1_NodeDriver._to_security_group_rulesc C sx d } }}|d i kr|d � dd �}n|d � dd �}|d � dd �}t|d |d |d |d |d | |||d � S ) Nr� r� r� r� r� r� r� r� r� r� ) r� r� r� r� r� r� r� r� r� �rn r� )r^ rs r� r� r� r: r: r; r= � s �z0OpenStack_1_1_NodeDriver._to_security_group_rulec r� )Nr� c rN r: )�_to_security_group)rd r� r� r: r; rf rQ z@OpenStack_1_1_NodeDriver._to_security_groups.<locals>.<listcomp>r: )r^ rs r� r: r� r; �_to_security_groups r� z,OpenStack_1_1_NodeDriver._to_security_groupsc C sB | � |�d|�dg ���}t|d |d |d |�dd�|| d�S ) N�security_group_rulesr� r� r� r� r� r� )r� r� r� r� r� r� )r? rn r� )r^ rs r� r: r: r; rA s �z+OpenStack_1_1_NodeDriver._to_security_groupc C r� )�� Get a list of Security Groups that are available. :rtype: ``list`` of :class:`OpenStackSecurityGroup` �/os-security-groups)rB rt rl rm r� r: r: r; �ex_list_security_groups � z0OpenStack_1_1_NodeDriver.ex_list_security_groupsc C s | � | j�d|j �j�S )z{ Get Security Groups of the specified server. :rtype: ``list`` of :class:`OpenStackSecurityGroup` z /servers/%s/os-security-groups)rB rt rl r� rm r� r: r: r; �ex_get_node_security_groups( s �z4OpenStack_1_1_NodeDriver.ex_get_node_security_groupsc C �( | � | jjddd||d�id�jd �S )� Create a new Security Group :param name: Name of the new Security Group :type name: ``str`` :param description: Description of the new Security Group :type description: ``str`` :rtype: :class:`OpenStackSecurityGroup` rE r� r� �r� r� r� )rA rt rl rm �r^ r� r� r: r: r; �ex_create_security_group2 � ���z1OpenStack_1_1_NodeDriver.ex_create_security_groupc C �( | j jd|j dd�}|jtjtjfv S )�� Delete a Security Group. :param security_group: Security Group should be deleted :type security_group: :class:`OpenStackSecurityGroup` :rtype: ``bool`` z/os-security-groups/%sr� r� �rt rl r� r� r r� r� �r^ r� r� r: r: r; �ex_delete_security_groupF s �z1OpenStack_1_1_NodeDriver.ex_delete_security_groupc C sH d}t |�tkr |j}| �| jjddd||||||jd�id�jd �S )�l Create a new Rule in a Security Group :param security_group: Security Group in which to add the rule :type security_group: :class:`OpenStackSecurityGroup` :param ip_protocol: Protocol to which this rule applies Examples: tcp, udp, ... :type ip_protocol: ``str`` :param from_port: First port of the port range :type from_port: ``int`` :param to_port: Last port of the port range :type to_port: ``int`` :param cidr: CIDR notation of the source IP range for this rule :type cidr: ``str`` :param source_security_group: Existing Security Group to use as the source (instead of CIDR) :type source_security_group: L{OpenStackSecurityGroup :rtype: :class:`OpenStackSecurityGroupRule` Nz/os-security-group-rulesr� r> )r� r� r� r� rU r� r� )rk r� r� r= rt rl rm �r^ r� r� r� r� r� Zsource_security_groupZsource_security_group_idr: r: r; � ex_create_security_group_ruleT s( " ��� ��z6OpenStack_1_1_NodeDriver.ex_create_security_group_rulec C r7 )�� Delete a Rule from a Security Group. :param rule: Rule should be deleted :type rule: :class:`OpenStackSecurityGroupRule` :rtype: ``bool`` z/os-security-group-rules/%sr� r� r8 �r^ Zruler� r: r: r; � ex_delete_security_group_rule� � z6OpenStack_1_1_NodeDriver.ex_delete_security_group_rulec s |d }� fdd�|D �}|S )NZkeypairsc s g | ] }� � |d ��qS )�keypair)� _to_key_pair)rd �key_pairr� r: r; rf � s z:OpenStack_1_1_NodeDriver._to_key_pairs.<locals>.<listcomp>r: )r^ rs � key_pairsr: r� r; � _to_key_pairs� s z&OpenStack_1_1_NodeDriver._to_key_pairsc C s* t |d |d |d |�dd �| d�}|S )Nr� r� r� r� )r� r� r� r� r� )r rn )r^ rs r] r: r: r; r\ � s �z%OpenStack_1_1_NodeDriver._to_key_pairc C s | j �d�}| �|j�}|S )N� /os-keypairs)rt rl r_ rm )r^ r~ r^ r: r: r; �list_key_pairs� s z'OpenStack_1_1_NodeDriver.list_key_pairsc C s4 | j �d|i� | j �d| �}| �|jd �}|S )NZ key_pair_name�/os-keypairs/%sr[ )rt Z set_contextrl r\ rm )r^ r� r~ r] r: r: r; � get_key_pair� s z%OpenStack_1_1_NodeDriver.get_key_pairc C s2 dd|ii}| j jdd|d�}| �|jd �}|S )Nr[ r� r` r� r� �rt rl r\ rm )r^ r� ru r~ r] r: r: r; �create_key_pair� s z(OpenStack_1_1_NodeDriver.create_key_pairc C s4 d||d�i}| j jdd|d�}| �|jd �}|S )Nr[ )r� r� r` r� r� rd )r^ r� � key_materialru r~ r] r: r: r; �import_key_pair_from_string� s z4OpenStack_1_1_NodeDriver.import_key_pair_from_stringc C r7 )�� Delete a KeyPair. :param keypair: KeyPair to delete :type keypair: :class:`OpenStackKeyPair` :rtype: ``bool`` rb r� r� )rt rl r� r� r r� )r^ r] r~ r: r: r; �delete_key_pair� rZ z(OpenStack_1_1_NodeDriver.delete_key_pairc C s t �d� | �� S )zs Get a list of KeyPairs that are available. :rtype: ``list`` of :class:`OpenStackKeyPair` zAThis method has been deprecated in favor of list_key_pairs method)r- r. ra r� r: r: r; �ex_list_keypairs� s z)OpenStack_1_1_NodeDriver.ex_list_keypairsc C � t �d� | j|d�S )z� Create a new KeyPair :param name: Name of the new KeyPair :type name: ``str`` :rtype: :class:`OpenStackKeyPair` zBThis method has been deprecated in favor of create_key_pair methodr8 )r- r. re )r^ r� r: r: r; �ex_create_keypair� � z*OpenStack_1_1_NodeDriver.ex_create_keypairc C � t �d� | j||d�S )a Import a KeyPair from a file :param name: Name of the new KeyPair :type name: ``str`` :param keyfile: Path to the public key file (in OpenSSH format) :type keyfile: ``str`` :rtype: :class:`OpenStackKeyPair` zLThis method has been deprecated in favor of import_key_pair_from_file method)r� Z key_file_path)r- r. Zimport_key_pair_from_file)r^ r� �keyfiler: r: r; �ex_import_keypair� � �z*OpenStack_1_1_NodeDriver.ex_import_keypairc C rn )a Import a KeyPair from a string :param name: Name of the new KeyPair :type name: ``str`` :param key_material: Public key (in OpenSSH format) :type key_material: ``str`` :rtype: :class:`OpenStackKeyPair` zNThis method has been deprecated in favor of import_key_pair_from_string method)r� rf )r- r. rg )r^ r� rf r: r: r; � ex_import_keypair_from_string� rq z6OpenStack_1_1_NodeDriver.ex_import_keypair_from_stringc C rk )rh zBThis method has been deprecated in favor of delete_key_pair method)r] )r- r. ri )r^ r[ r: r: r; �ex_delete_keypair rm z*OpenStack_1_1_NodeDriver.ex_delete_keypairc C r� )z� Get a NodeSize :param size_id: ID of the size which should be used :type size_id: ``str`` :rtype: :class:`NodeSize` z /flavors/{}r� )r� rt rl r� rm r� r: r: r; � ex_get_size s �z$OpenStack_1_1_NodeDriver.ex_get_sizec C s | j �d�|��jd S )z� Get the extra_specs field of a NodeSize :param size_id: ID of the size which should be used :type size_id: ``str`` :rtype: `dict` z/flavors/{}/os-extra_specsr� )rt rl r� rm r� r: r: r; �ex_get_size_extra_specs s �z0OpenStack_1_1_NodeDriver.ex_get_size_extra_specsc C r� )z� Get a NodeImage @inherits: :class:`NodeDriver.get_image` :param image_id: ID of the image which should be used :type image_id: ``str`` :rtype: :class:`NodeImage` r� r= r� r� r: r: r; r� , s �z"OpenStack_1_1_NodeDriver.get_imagec C s$ | j jd�|j�dd�}|jtjkS )z� Delete a NodeImage @inherits: :class:`NodeDriver.delete_image` :param image: image witch should be used :type image: :class:`NodeImage` :rtype: ``bool`` r� r� r� )rt rl r� r� r� r r� )r^ r= r� r: r: r; r� ; s z%OpenStack_1_1_NodeDriver.delete_imagec K s& |pd }| j jd�|j�d||id�S )Nz/servers/{}/actionr� r� )rt rl r� r� )r^ r� �actionrb r: r: r; rm I s �z%OpenStack_1_1_NodeDriver._node_actionc K s* | � | jjd�|j�dd|id�jd �S )z� Updates the editable attributes of a server, which currently include its name and IPv4/IPv6 access addresses. z /servers/{}r" r! r� )r1 rt rl r� r� rm )r^ r� r r: r: r; r O s ���z%OpenStack_1_1_NodeDriver._update_nodec C s | � |d �S )Nr! rs rv r: r: r; r� Z r z*OpenStack_1_1_NodeDriver._to_node_from_objc C s� ddg}g g }}|d � � D ]F\}}|D ]?}|d }d} zt|�} W n# tyF |�dd �} ||v r7d} n | dkr>d} n| d krDd} Y nw | rO|�|� q|�|� qq|�d d �} | rd| �d d �nd } |�d d�} |�d �}t|d �}t|d |d | j�|d tj �|||| t d8i d|d �d|d �d|�d��d|�dd ��d|�d��p:|d �d|�dd ��d| �d|�d i ��d d ��d |�d d ��d t d d � |d! D ���d"| j � � �d#|d# �d$|�d%d ��d|d �d&|d& �d'|�d'd ��d(|�d)d ��d | �d*|�d+��d,|�d-|�d.d ��d/|�d0d ��d1|�d2d ��d3|�d3d ��d4|�d4��d5|�d6���d7�S �d|�dd ��d| �d|�d i ��d d ��d |�d d ��d t d d � |d! D ���d"| j � � �d#|d# �d$|�d%d ��d|d �d&|d& �d'|�d'd ��d(|�d)d ��d | �d*|�d+��d,|�d-|�d.d ��d/|�d0d ��d1|�d2d ��d3|�d3d ��d4|�d4��d5|�d6���d7�S )9Nr� Zinternet� addressesrz FzOS-EXT-IPS:typeTZfloating�fixedr= r� r� z$os-extended-volumes:volumes_attachedr r� r� r� Z access_ipZ accessIPv4Z access_ipv6Z accessIPv6ZtenantIdr� ZuserId�user_idr) r* r� Zflavor_detailsr� c s s$ � | ] }|d dkr|d V qdS )rc r^ rg Nr: )rd �linkr: r: r; � <genexpr>� s �" z4OpenStack_1_1_NodeDriver._to_node.<locals>.<genexpr>rw r9 r� r# r r r� Z disk_configr� r� zOS-EXT-AZ:availability_zone�volumes_attachedZ task_statezOS-EXT-STS:task_stateZvm_statezOS-EXT-STS:vm_stateZ power_statezOS-EXT-STS:power_stater Zfault�hypervisor_hostnamez#OS-EXT-SRV-ATTR:hypervisor_hostname)r� r� r� r� r� r� r� r� r: )r r � Exceptionrn r� r r r� r rI r� r rt r� )r^ �api_nodeZpublic_networks_labelsr� r� r rv r� rZ Z is_public_ipZexplicit_ip_typer= r� r� r| r r: r: r; r1 ] s �� � �� � �� � � � � � �� ��� � �� �� � � � � � ��� � � � � � �� ��� � �� �� � � � � � ��z!OpenStack_1_1_NodeDriver._to_nodec C s� d|v r|d }| j �|d tj�}t|d |�d|�d��|d || |�d|�d��d d � |d D �|�dd �|�d |�d ��|�d|�d��|�d|�d��|�dd �|�d|�d��d�d�S )Nr� r� r� � displayNamer� r� �displayDescriptionr� c S s g | ]}|r|�qS r: r: )rd Zattr: r: r; rf � r� z7OpenStack_1_1_NodeDriver._to_volume.<locals>.<listcomp>r� r� r+ r� ZavailabilityZoner� Z volumeTyper� r� � createdAt)r� r� r� r� r� r� r� r� )r� r� r� r� r� r� )r� rn r rI r )r^ r r� r: r: r; r� � s& ��z#OpenStack_1_1_NodeDriver._to_volumec C s� d|v r|d }|� d|� dd ��}|� d|� d|� dd ���}|� d|� dd ��}|� d |� d |� d d ���}|� d d �}|||||d �}| j� |tj�}zt|�} W n ty_ d } Y nw t|d | |d || ||d�} | S )Nr� 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� )rn r� r rI r � ValueErrorr ) r^ ru r- r� r� r� r� r� r� Z created_dtr� r: r: r; r� � s@ � � �� z%OpenStack_1_1_NodeDriver._to_snapshotc C sp |s | � t|d ��}|�di �}|�dd �|d< t|d |d |d |d |d |�d d �|d |||| d � S ) Nr� z!OS-FLV-WITH-EXT-SPECS:extra_specszOS-FLV-DISABLED:disabled�disabledr� r� r� r� zOS-FLV-EXT-DATA:ephemeralr ) r� r� r� r� r� r r r� r� r� r� )r� r rn r� )r^ Z api_flavorr� r� r� r: r: r; r� � s" �z!OpenStack_1_1_NodeDriver._to_sizec C r� r� r� r� r: r: r; r� s � �z(OpenStack_1_1_NodeDriver._get_size_pricec C s t � |�j}|�d�d }|S )N�/���)r rz �split)r^ Zlocation_headerrz r� r: r: r; r s z3OpenStack_1_1_NodeDriver._extract_image_id_from_urlc C s@ |r | j |d|d�}n| � |d�}t�|j�d }||jd< |S )z� Rescue a node :param node: node :type node: :class:`Node` :param password: password :type password: ``str`` :rtype: :class:`Node` Zrescuer� r r# )rm r� �loadsr& r� r r: r: r; � ex_rescue s z"OpenStack_1_1_NodeDriver.ex_rescuec C r )z� Unrescue a node :param node: node :type node: :class:`Node` :rtype: ``bool`` Zunrescuerl r r: r: r; � ex_unrescue' r z$OpenStack_1_1_NodeDriver.ex_unrescuec r� )NZfloating_ip_poolsc rN r: ��_to_floating_ip_pool�rd �poolr� r: r; rf 5 rQ zBOpenStack_1_1_NodeDriver._to_floating_ip_pools.<locals>.<listcomp>r: �r^ rs Z pool_elementsr: r� r; �_to_floating_ip_pools3 r� z.OpenStack_1_1_NodeDriver._to_floating_ip_poolsc C s t |d | j�S )Nr� )r) rt rv r: r: r; r� 7 r� z-OpenStack_1_1_NodeDriver._to_floating_ip_poolc C r� )zu List available floating IP pools :rtype: ``list`` of :class:`OpenStack_1_1_FloatingIpPool` z/os-floating-ip-pools)r� rt rl rm r� r: r: r; �ex_list_floating_ip_pools: rG z2OpenStack_1_1_NodeDriver.ex_list_floating_ip_poolsc r� )N� floating_ipsc rN r: ��_to_floating_ipr| r� r: r; rf D rQ z=OpenStack_1_1_NodeDriver._to_floating_ips.<locals>.<listcomp>r: �r^ rs Z ip_elementsr: r� r; �_to_floating_ipsB r� z)OpenStack_1_1_NodeDriver._to_floating_ipsc C s t |d |d d |d | d�S �Nr� rZ Z instance_id�r� � ip_addressr� r� r� )r+ rv r: r: r; r� F s �z(OpenStack_1_1_NodeDriver._to_floating_ipc C r� )zi List floating IPs :rtype: ``list`` of :class:`OpenStack_1_1_FloatingIpAddress` �/os-floating-ips�r� rt rl rm r� r: r: r; �ex_list_floating_ipsO rG z-OpenStack_1_1_NodeDriver.ex_list_floating_ipsc C �$ | � � D ] }|j|kr| S qdS )z� Get specified floating IP :param ip: floating IP to get :type ip: ``str`` :rtype: :class:`OpenStack_1_1_FloatingIpAddress` N)r� r� �r^ rZ � floating_ipr: r: r; �ex_get_floating_ipW � �z+OpenStack_1_1_NodeDriver.ex_get_floating_ipc C sR |durd|ini }| j jdd|d�}|jd }|d }|d }t||dd| d �S ) a) Create new floating IP. The ip_pool attribute is optional only if your infrastructure has only one IP pool available. :param ip_pool: name of the floating IP pool :type ip_pool: ``str`` :rtype: :class:`OpenStack_1_1_FloatingIpAddress` Nr� r� r� r� r� r� rZ r� )rt rl rm r+ )r^ �ip_poolru r� r� r� r: r: r; �ex_create_floating_ipe s �z.OpenStack_1_1_NodeDriver.ex_create_floating_ipc C rO )z� Delete specified floating IP :param ip: floating IP to remove :type ip: :class:`OpenStack_1_1_FloatingIpAddress` :rtype: ``bool`` �/os-floating-ips/%sr� r� rQ �r^ rZ r� r: r: r; �ex_delete_floating_ipy � z.OpenStack_1_1_NodeDriver.ex_delete_floating_ipc C �D t |d�r|jn|}dd|ii}| jjd|j d|d�}|jtjkS )a Attach the floating IP to the node :param node: node :type node: :class:`Node` :param ip: floating IP to attach :type ip: ``str`` or :class:`OpenStack_1_1_FloatingIpAddress` :rtype: ``bool`` r� Z addFloatingIp�addressr< r� r� ��hasattrr� rt rl r� r� r r� �r^ r� rZ r� ru r� r: r: r; � ex_attach_floating_ip_to_node� � z6OpenStack_1_1_NodeDriver.ex_attach_floating_ip_to_nodec C r� )� Detach the floating IP from the node :param node: node :type node: :class:`Node` :param ip: floating IP to remove :type ip: ``str`` or :class:`OpenStack_1_1_FloatingIpAddress` :rtype: ``bool`` r� ZremoveFloatingIpr� r< r� r� r� r� r: r: r; � ex_detach_floating_ip_from_node� r� z8OpenStack_1_1_NodeDriver.ex_detach_floating_ip_from_nodec C s |j d S )a, Return the metadata associated with the node. :param node: Node instance :type node: :class:`Node` :return: A dictionary or other mapping of strings to strings, associating tag names with tag values. :type tags: ``dict`` r� )r� r� r: r: r; �ex_get_metadata_for_node� s z1OpenStack_1_1_NodeDriver.ex_get_metadata_for_nodec C r� )N�pauser� r� r: r: r; � ex_pause_node� � z&OpenStack_1_1_NodeDriver.ex_pause_nodec C r� )NZunpauser� r� r: r: r; �ex_unpause_node� r� z(OpenStack_1_1_NodeDriver.ex_unpause_nodec C � | j |d�S �N)r� )r� r� r: r: r; � ex_start_node� � z&OpenStack_1_1_NodeDriver.ex_start_nodec C r� r� )r� r� r: r: r; � ex_stop_node� r� z%OpenStack_1_1_NodeDriver.ex_stop_nodec C r� )NZsuspendr� r� r: r: r; �ex_suspend_node� r� z(OpenStack_1_1_NodeDriver.ex_suspend_nodec C r� )NZresumer� r� r: r: r; �ex_resume_node� r� z'OpenStack_1_1_NodeDriver.ex_resume_nodec C s0 dj |jd�}| jj|d|did�}|jtjkS )z�Post a simple, data-less action to the OS node action endpoint :param `Node` node: :param str action: the action to call :return `bool`: a boolean that indicates success z/servers/{node_id}/action)r� r� Nr� )r� r� rt rl r� r r� )r^ r� rv r� r� r: r: r; r� � s z1OpenStack_1_1_NodeDriver._post_simple_node_action) NNNNNNNNNNNNNr� r[ �NNT)NFr� )hr6 r7 r8 r� r' r r r� rk r� r r\ r r� r� r� r� r� r� r� r� r� r� r7 rH r? rD rF r� r: r r r r r r r r r$ r' r) r, r/ r6 r: r; r< r? r= rB rA rF rH rM rS rV rY r_ r\ ra rc re rg ri rj rl rp rr rs rt ru r� r� rm r r� r1 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: rY r; r( � s� �p ": - �7 P ' r( c @ r� )�OpenStack_2_Connectionr� r� c C r� r[ r� r� r: r: r; r� � r� z"OpenStack_2_Connection.encode_dataNr� r: r: r: r; r� � r� r� c @ r� )�OpenStack_2_ImageConnectionr� r� c C r� r[ r� r� r: r: r; r� � r� z'OpenStack_2_ImageConnection.encode_dataNr� r: r: r: r; r� � r� r� c @ r� )� OpenStack_2_NetworkConnectionr� r� c C r� r[ r� r� r: r: r; r� � r� z)OpenStack_2_NetworkConnection.encode_dataNr� r: r: r: r; r� � r� r� c @ r� )� OpenStack_2_VolumeV2Connectionr� r� c C r� r[ r� r� r: r: r; r� � r� z*OpenStack_2_VolumeV2Connection.encode_dataNr� r: r: r: r; r� � r� r� c @ r� )� OpenStack_2_VolumeV3Connectionr� r� c C r� r[ r� r� r: r: r; r� r� z*OpenStack_2_VolumeV3Connection.encode_dataNr� r: r: r: r; r� � r� r� c @ r� )�!OpenStack_2_ReservationConnectionr� r� c C r� r[ r� r� r: r: r; r� r� z-OpenStack_2_ReservationConnection.encode_dataNr� r: r: r: r; r� r� r� c @ s e Zd ZdZdZdZdZdZdS )r- z; Standard states of OpenStack_2_PortInterfaceState �buildZactiveZdown�unknownN)r6 r7 r8 r� rD rE �DOWNrI r: r: r: r; r- s r- c s` e Zd ZdZeZeZdZe Z dZ e Z eZdZdZdZeZdZejZddgiZdZdZe j e j e j e j d�Z!� fdd �Z"d d � Z#d�d d�Z$dd� Z%d�dd�Z&dd� Z'dd� Z(dd� Z)dd� Z*d d � Z+d d � Z,d d!� Z-d"d#� Z.d$d%� Z/d&d'� Z0d(d)� Z1d*d+� Z2d,d-� Z3d.d/� Z4 0 1 d�d2d3�Z5d4d5� Z6 d�d6d7�Z7d8d9� Z8d:d;� Z9d<d=� Z:d>d?� Z;d�d@dA�Z<dBdC� Z= d�dDdE�Z>dFdG� Z?dHdI� Z@dJdK� ZAdLdM� ZB d�dNdO�ZCdPdQ� ZDdRdS� ZEd�dTdU�ZFdVdW� ZGdXdY� ZHdZd[� ZId\d]� ZJd^d_� ZK d�d`da�ZLdbdc� ZMddde� ZNdfdg� ZOdhdi� ZPdjdk� ZQdldm� ZRdndo� ZSdpdq� ZT d�drds�ZUdtdu� ZVd�dvdw�ZWdxdy� ZXdzd{� ZYd|d}� ZZd~d� Z[d�d�� Z\d�d�d��Z]d�d�� Z^d�d�� Z_d�d�� Z`d�d�� Zad�d�� Zbd�d�� Zcd�d�� Zdd�d�� Zeg fd�d��Zfd�d�� Zgd�d�� Zhd�d�� Zid�d�� Zjd�d�� Zkd�d�� Zld�d�� Zmd�d�d��Znd�d�� Zod�d�� Zpd�d�� Zqd�d�� Zrd�d�� Zsd�d�� Ztd�d�� Zu� ZvS )�rO r� Nr r z/v2.0/networksz /v2.0/subnets)rD rE r� rI c s� | j }t|�dd ��| _d|vrd|d< |�d�}|s |�d�r*t|�d|��|d< | j| _ t� j|i |�� | j| _ |sB|�d�rLt|�d|��|d< | j | _ t� j|i |�� | j| _ | j | _ t� j|i |�� | j| _ |su|�d�rt|�d|��|d< | j| _ t� j|i |�� | j| _|s�|�d�r�t|�d|��|d< | j| _ t� j|i |�� | j| _|| _|r�| j|d< nd|v r�|d= || _ t� j|i |�� d S ) Nr Zex_force_auth_versionz 3.x_passwordZex_force_base_urlZex_force_image_urlZex_force_volume_urlZex_force_network_urlZex_force_reservation_url)r r r r rn �image_connectionClsrQ r\ rt �image_connection�volumev3_connectionCls�volumev3_connection�volumev2_connectionCls�volumev2_connection�network_connectionCls�network_connection�reservation_connectionCls�reservation_connectionZ_ex_force_base_url)r^ r_ rX Zoriginal_connectionClsZoriginal_ex_force_base_urlrY r: r; r\ Z sV � � � � z OpenStack_2_NodeDriver.__init__c C s |� d�}|� d�}t|d | j� |� d�tj�|| tdi 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|� dd ��d|� dd ��d|� dd ��d|� d��d|� dd ��d|� d��d|��d�S )Nr� r� r� r� �admin_state_up�allowed_address_pairsZbinding_vnic_typezbinding:vnic_typeZbinding_host_idzbinding:host_id� device_idr� � device_owner� fixed_ips� mac_addressr� r � project_id�port_security_enabledZrevision_numberr� �tagsr� r )r� r� r r� r� r: )rn r. �PORT_INTERFACE_MAPr- rI r� )r^ r r r r: r: r; �_to_port� s^ � � � � � � � � � � � � � � � � � ���z OpenStack_2_NodeDriver._to_portFc C s* i }|rddi}| � | jdd| j|d��S )r� r� ri r� r� ra )r� ry rt r� r: r: r; r� � s �z!OpenStack_2_NodeDriver.list_nodesc C s | � | j�d�|��j�S )a Get a NodeImage using the V2 Glance API @inherits: :class:`OpenStack_1_1_NodeDriver.get_image` :param image_id: ID of the image which should be used :type image_id: ``str`` :rtype: :class:`NodeImage` � /v2/images/{})r� r� rl r� rm r� r: r: r; r� � s �z OpenStack_2_NodeDriver.get_imageTc C sR |durt d��|st d��| jd| jjdd�}g }|D ] }|�| �|�� q |S )a� Lists all active images using the V2 Glance API @inherits: :class:`NodeDriver.list_images` :param location: Which data center to list the images in. If empty, undefined behavior will be selected. (optional) :type location: :class:`.NodeLocation` :param ex_only_active: True if list only active (optional) :type ex_only_active: ``bool`` NzHlocation in list_images is not implemented in the OpenStack_2_NodeDriverzNex_only_active in list_images is not implemented in the OpenStack_2_NodeDriverz /v2/imagesr )rz r{ r| )rP r� r� rl r� r� )r^ r� r� r} r rp r: r: r; r� � s" ���z"OpenStack_2_NodeDriver.list_imagesc C s* | j jd�|�ddid|d�}| �|j�S )a� Patch a NodeImage. Can be used to set visibility :param image_id: ID of the image which should be used :type image_id: ``str`` :param data: The data to PATCH, either a dict or a list for example: [ {'op': 'replace', 'path': '/visibility', 'value': 'shared'} ] :type data: ``dict|list`` :rtype: :class:`NodeImage` r� z Content-typez,application/openstack-images-v2.1-json-patch�PATCH)r r� ru )r� rl r� r� rm )r^ r� ru r~ r: r: r; �ex_update_image� s � z&OpenStack_2_NodeDriver.ex_update_imagec C s: | j �d�|��}g }|jd D ] }|�| �|�� q|S )a8 List all members of an image. See https://developer.openstack.org/api-ref/image/v2/index.html#sharing :param image_id: ID of the image of which the members should be listed :type image_id: ``str`` :rtype: ``list`` of :class:`NodeImageMember` z/v2/images/{}/members�members)r� rl r� rm r� r� )r^ r� r~ Z image_membersZ image_memberr: r: r; �ex_list_image_members s z,OpenStack_2_NodeDriver.ex_list_image_membersc C s* d|i}| j jd| d|d�}| �|j�S )a� Give a project access to an image. The image should have visibility status 'shared'. Note that this is not an idempotent operation. If this action is attempted using a tenant that is already in the image members group the API will throw a Conflict (409). See the 'create-image-member' section on https://developer.openstack.org/api-ref/image/v2/index.html :param str image_id: The ID of the image to share with the specified tenant :param str member_id: The ID of the project / tenant (the image member) Note that this is the Keystone project ID and not the project name, so something like e2151b1fe02d4a8a2d1f5fc331522c0a :return None: :param image_id: ID of the image to share :type image_id: ``str`` :param project: ID of the project to give access to the image :type image_id: ``str`` :rtype: ``list`` of :class:`NodeImageMember` �memberz/v2/images/%s/membersr� r� )r� rl r� rm �r^ r� r� ru r~ r: r: r; �ex_create_image_member$ s � z-OpenStack_2_NodeDriver.ex_create_image_memberc C s | j �d�||��}| �|j�S )aG Get a member of an image by id :param image_id: ID of the image of which the member should be listed :type image_id: ``str`` :param member_id: ID of the member to list :type image_id: ``str`` :rtype: ``list`` of :class:`NodeImageMember` �/v2/images/{}/members/{}�r� rl r� r� rm )r^ r� r� r~ r: r: r; �ex_get_image_memberE s � z*OpenStack_2_NodeDriver.ex_get_image_memberc C s. ddi}| j jd�||�d|d�}| �|j�S )a� Accept a pending image as a member. This call is idempotent unlike ex_create_image_member, you can accept the same image many times. :param image_id: ID of the image to accept :type image_id: ``str`` :param project: ID of the project to accept the image as :type image_id: ``str`` :rtype: ``bool`` r� Zacceptedr� r" r� r� r� r: r: r; �ex_accept_image_memberW s � z-OpenStack_2_NodeDriver.ex_accept_image_memberc r� )Nr� c rN r: r r� r� r: r; rf n rQ z7OpenStack_2_NodeDriver._to_networks.<locals>.<listcomp>r: r r: r� r; r l r� z#OpenStack_2_NodeDriver._to_networksc C s� i }|� dd �r|� d�|d< |� dd �r |� d�|d< |� dd �r)|� d�|d< |� dd �d ur8|� d�|d< |� dd �d urG|� d�|d< t|d |d d | |d�S ) N�router:external�subnetsr� Z is_defaultr� r� r� )r� r� r� r� r� )rn r� �r^ rs r� r: r: r; r p s z"OpenStack_2_NodeDriver._to_networkc C r r )r� rl r rm r r r: r: r; r ~ r z'OpenStack_2_NodeDriver.ex_list_networksc C r r )r� r r� rl rm r r r: r: r; r � r z%OpenStack_2_NodeDriver.ex_get_networkc K sN dd|ii}|� � D ] \}}||d |< q | jj| jd|d�j}| �|d �S )z� Create a new Network :param name: Name of network which should be used :type name: ``str`` :rtype: :class:`OpenStackNetwork` r@ r� r� r� )r r� rl r rm r )r^ r� rX ru rT r� r~ r: r: r; r � s ��z(OpenStack_2_NodeDriver.ex_create_networkc C r r! ) r� rl r� r r� r� r r� r� r# r: r: r; r$ � r% z(OpenStack_2_NodeDriver.ex_delete_networkc r� )Nr� c rN r: )� _to_subnet)rd �subnetr� r: r; rf � rQ z6OpenStack_2_NodeDriver._to_subnets.<locals>.<listcomp>r: )r^ rs r� r: r� r; � _to_subnets� r� z"OpenStack_2_NodeDriver._to_subnetsc C s\ i }|� dd �r|� d�|d< |� dd �r |� d�|d< t|d |d |d |d | |d�S )Nr� r� r� r� r� r )r� r� r� r r� r� )rn �OpenStack_2_SubNetr� r: r: r; r� � s �z!OpenStack_2_NodeDriver._to_subnetc C r )zs Get a list of Subnet that are available. :rtype: ``list`` of :class:`OpenStack_2_SubNet` )r� rl �_subnets_url_prefixrm r� r r: r: r; �ex_list_subnets� r z&OpenStack_2_NodeDriver.ex_list_subnetsrh r� c C sN d||j ||pd|p d|pg |pg d�i}| jj| jd|d�j} | �| d �S )a Create a new Subnet :param name: Name of subnet which should be used :type name: ``str`` :param network: Parent network of the subnet :type network: ``OpenStackNetwork`` :param cidr: cidr of network which should be used :type cidr: ``str`` :param ip_version: ip_version of subnet which should be used :type ip_version: ``int`` :param description: Description for the resource. :type description: ``str`` :param dns_nameservers: List of dns name servers. :type dns_nameservers: ``list`` of ``str`` :param host_routes: Additional routes for the subnet. :type host_routes: ``list`` of ``str`` :rtype: :class:`OpenStack_2_SubNet` r� r� )r� r � ip_versionr� r� �dns_nameservers� host_routesr� r� )r� r� rl r� rm r� ) r^ r� r@ r� r� r� r� r� ru r~ r: r: r; �ex_create_subnet� s %�� ��z'OpenStack_2_NodeDriver.ex_create_subnetc C r )z� Delete a Subnet :param subnet: Subnet which should be deleted :type subnet: :class:`OpenStack_2_SubNet` :rtype: ``bool`` r" r� r� ) r� rl r� r� r� r� r r� r� )r^ r� r� r: r: r; �ex_delete_subnet r% z'OpenStack_2_NodeDriver.ex_delete_subnetc C s� di i}|dur||d d< |dur||d d< |dur"||d d< |dur,||d d< | j jd�| j|j�d|d �j}| �|d �S ) aY Update data of an existing SubNet :param subnet: Subnet which should be updated :type subnet: :class:`OpenStack_2_SubNet` :param name: Name of subnet which should be used :type name: ``str`` :param description: Description for the resource. :type description: ``str`` :param dns_nameservers: List of dns name servers. :type dns_nameservers: ``list`` of ``str`` :param host_routes: Additional routes for the subnet. :type host_routes: ``list`` of ``str`` :rtype: :class:`OpenStack_2_SubNet` r� Nr� r� r� r� r" r" r� )r� rl r� r� r� rm r� )r^ r� r� r� r� r� ru r~ r: r: r; �ex_update_subnet s ��z'OpenStack_2_NodeDriver.ex_update_subnetc s& � � dd� j�}� fdd�|d D �S )z� List all OpenStack_2_PortInterfaces https://developer.openstack.org/api-ref/network/v2/#list-ports :rtype: ``list`` of :class:`OpenStack_2_PortInterface` � /v2.0/ports�portsc rN r: )r� )rd rV r� r: r; rf G rQ z8OpenStack_2_NodeDriver.ex_list_ports.<locals>.<listcomp>)ry r� r r: r� r; � ex_list_ports> s z$OpenStack_2_NodeDriver.ex_list_portsc C s | j jd|j dd�}|�� S )a Delete an OpenStack_2_PortInterface https://developer.openstack.org/api-ref/network/v2/#delete-port :param port: port interface to remove :type port: :class:`OpenStack_2_PortInterface` :rtype: ``bool`` z/v2.0/ports/%sr� r� )r� rl r� r� )r^ rV r~ r: r: r; �ex_delete_portI s z%OpenStack_2_NodeDriver.ex_delete_portc C s | j jd�|j|j�dd��� S )a Detaches an OpenStack_2_PortInterface interface from a Node. :param node: node :type node: :class:`Node` :param port: port interface to detach :type port: :class:`OpenStack_2_PortInterface` :rtype: ``bool`` z/servers/{}/os-interface/{}r� r� )rt rl r� r� r� )r^ r� rV r: r: r; �ex_detach_port_interfaceW s ��z/OpenStack_2_NodeDriver.ex_detach_port_interfacec C s, dd|j ii}| jjd�|j �d|d��� S )a Attaches an OpenStack_2_PortInterface to a Node. :param node: node :type node: :class:`Node` :param port: port interface to attach :type port: :class:`OpenStack_2_PortInterface` :rtype: ``bool`` ZinterfaceAttachment�port_idz/servers/{}/os-interfacer� r� )r� rt rl r� r� )r^ r� rV ru r: r: r; �ex_attach_port_interfacef s ��z/OpenStack_2_NodeDriver.ex_attach_port_interfacec C s> d|pd||pd|j d�i}| jjdd|d�}| �|jd �S )aw Creates a new OpenStack_2_PortInterface :param network: ID of the network where the newly created port should be attached to :type network: :class:`OpenStackNetwork` :param description: Description of the port :type description: str :param admin_state_up: The administrative state of the resource, which is up or down :type admin_state_up: bool :param name: Human-readable name of the resource :type name: str :rtype: :class:`OpenStack_2_PortInterface` rV r� )r� r� r� r r� r� r� )r� r� rl r� rm )r^ r@ r� r� r� ru r~ r: r: r; �ex_create_portw s ��z%OpenStack_2_NodeDriver.ex_create_portc C s& | j jd�|�dd�}| �|jd �S )z� Retrieve the OpenStack_2_PortInterface with the given ID :param port_interface_id: ID of the requested port :type port_interface_id: str :return: :class:`OpenStack_2_PortInterface` �/v2.0/ports/{}r� r� rV )r� rl r� r� rm )r^ Zport_interface_idr~ r: r: r; � ex_get_port� s �z"OpenStack_2_NodeDriver.ex_get_portc C s� di i} |dur|| d d< |dur|| d d< |dur"|| d d< |dur,|| d d< |dur6|| d d< |dur@|| d d< |durJ|| d d < | j jd �|j�d | d �} | �| jd �S ) a0 Update a OpenStack_2_PortInterface :param port: port interface to update :type port: :class:`OpenStack_2_PortInterface` :param description: Description of the port :type description: ``str`` :param admin_state_up: The administrative state of the resource, which is up or down :type admin_state_up: ``bool`` :param name: Human-readable name of the resource :type name: ``str`` :param port_security_enabled: The port security status :type port_security_enabled: ``bool`` :param qos_policy_id: QoS policy associated with the port :type qos_policy_id: ``str`` :param security_groups: The IDs of security groups applied :type security_groups: ``list`` of ``str`` :param allowed_address_pairs: IP and MAC address that the port can use when sending packets if port_security_enabled is true :type allowed_address_pairs: ``list`` of ``dict`` containing ip_address and mac_address; mac_address is optional, taken from the port if not specified :rtype: :class:`OpenStack_2_PortInterface` rV Nr� r� r� r� � qos_policy_idr� r� r� r" r� )r� rl r� r� r� rm ) r^ rV r� r� r� r� r r� r� ru r~ r: r: r; �ex_update_port� s& - �z%OpenStack_2_NodeDriver.ex_update_portc C sL | j jd|j dd�}g }|jd D ]}|�d�|d< |�| �|�� q|S )z� Get the list of OpenStack_2_PortInterface interfaces from a Node. :param node: node :type node: :class:`Node` :rtype: ``list`` of :class:`OpenStack_2_PortInterface` z/servers/%s/os-interfacer� r� ZinterfaceAttachmentsr� r� )rt rl r� rm r r� r� )r^ r� r~ r� rV r: r: r; �ex_get_node_ports� s z(OpenStack_2_NodeDriver.ex_get_node_portsc C sF | j s z | j�� | j| _ W | j S ty | j| _ Y | j S w | j S )z> Get the correct Volume connection (v3 or v2) )�volume_connectionr� Zget_service_catalogr r� r� r: r: r; �_get_volume_connection� s � �z-OpenStack_2_NodeDriver._get_volume_connectionc C � | � | �dd| �� ��S )zo Get a list of Volumes that are available. :rtype: ``list`` of :class:`StorageVolume` z/volumes/detailr� )r� ry r r� r: r: r; r� � �z#OpenStack_2_NodeDriver.list_volumesc C s | � | �� �d| �j�S )z� Retrieve the StorageVolume with the given ID :param volumeId: ID of the volume :type volumeId: ``string`` :return: :class:`StorageVolume` � /volumes/%s)r� r rl rm r� r: r: r; r� s �z$OpenStack_2_NodeDriver.ex_get_volumec C sh |||d|id�}|r||d< |r||d< |r||d< |r"|j |d< | �� jddd |id �}| �|j�S ) a� Create a new volume. :param size: Size of volume in gigabytes (required) :type size: ``int`` :param name: Name of the volume to be created :type name: ``str`` :param location: Which data center to create a volume in. If empty, undefined behavior will be selected. (optional) :type location: :class:`.NodeLocation` :param snapshot: Snapshot from which to create the new volume. (optional) :type snapshot: :class:`.VolumeSnapshot` :param ex_volume_type: What kind of volume to create. (optional) :type ex_volume_type: ``str`` :param ex_image_ref: The image to create the volume from when creating a bootable volume (optional) :type ex_image_ref: ``str`` :return: The newly created volume. :rtype: :class:`StorageVolume` r� )r� r� r� r� r� r� r� r� z/volumesr� r� r� )r� r rl r� rm ) r^ r� r� r� r� r� Z ex_image_refr� r� r: r: r; r� s" '� � z$OpenStack_2_NodeDriver.create_volumec C s | � � jd|j dd��� S )z� Delete a Volume. :param volume: Volume to be deleted :type volume: :class:`StorageVolume` :rtype: ``bool`` r r� r� )r rl r� r� r� r: r: r; r� X s ��z%OpenStack_2_NodeDriver.destroy_volumec C r )zq Get a list of Snapshot that are available. :rtype: ``list`` of :class:`VolumeSnapshot` z/snapshots/detailr� )r� ry r r� r: r: r; r) g r z(OpenStack_2_NodeDriver.ex_list_snapshotsc C sT d|j |d�i}|dur||d d< |dur ||d d< | �| �� jdd|d�j�S ) r0 r� r1 Nr� r� z /snapshotsr� r� )r� r� r rl rm r3 r: r: r; r6 q s �z-OpenStack_2_NodeDriver.create_volume_snapshotc C s* | � � jd|j dd�}|jtjtjfv S )z� Delete a Volume Snapshot. :param snapshot: Snapshot to be deleted :type snapshot: :class:`VolumeSnapshot` :rtype: ``bool`` z /snapshots/%sr� r� )r rl r� r� r r� r� r9 r: r: r; r: � s z.OpenStack_2_NodeDriver.destroy_volume_snapshotc C r� )rD �/v2.0/security-groups)rB r� rl rm r� r: r: r; rF � s �z.OpenStack_2_NodeDriver.ex_list_security_groupsc C rI )rJ r r� r� rK r� )rA r� rl rm rL r: r: r; rM � rN z/OpenStack_2_NodeDriver.ex_create_security_groupc C r7 )rP z/v2.0/security-groups/%sr� r� �r� rl r� r� r r� rR r: r: r; rS � � � z/OpenStack_2_NodeDriver.ex_delete_security_groupc C s� d } } }}d } } }} d|v rD|d i kr#|d � dd �}n|d � dd �}|d � dd �}|d }|d }|d }|d }n"|� d d �}|� d d �}|� dd �}|d }|d }|d }|d }t|d ||||| |||| d� S )Nr� r� r� r� r� r� r� r� r� �remote_ip_prefix�remote_group_id�security_group_id�port_range_min�port_range_max�protocolr� ) r� r� r� r� r� r� r� r� r� r� r@ ) r^ rs r� r� r� Z parent_idr r� r� r� r: r: r; r= � s< �z.OpenStack_2_NodeDriver._to_security_group_rulec C sJ d}t |�tkr |j}| �| jjdddd||||||jd�id�jd �S )rT Nz/v2.0/security-group-rulesr� r> r� )r� r r r r r r r� )rk r� r� r= r� rl rm rU r: r: r; rV � s* " �����z4OpenStack_2_NodeDriver.ex_create_security_group_rulec C r7 )rW z /v2.0/security-group-rules/%sr� r� r rX r: r: r; rY ' r z4OpenStack_2_NodeDriver.ex_delete_security_group_rulec C s* d|j i}| j|dfi |��}|jtjkS )a9 Remove a Security Group from a node. :param security_group: Security Group to remove from node. :type security_group: :class:`OpenStackSecurityGroup` :param node: Node to remove the Security Group. :type node: :class:`Node` :rtype: ``bool`` r� ZremoveSecurityGroup)r� rm r� r r� )r^ r� r� r� r� r: r: r; �"ex_remove_security_group_from_node5 r z9OpenStack_2_NodeDriver.ex_remove_security_group_from_nodec C s t |d |d | j�S )Nr� r� )r* r� rv r: r: r; r� E s z+OpenStack_2_NodeDriver._to_floating_ip_poolc r� )Nr� c rN r: r� r� r� r: r; rf J rQ z@OpenStack_2_NodeDriver._to_floating_ip_pools.<locals>.<listcomp>r: r� r: r� r; r� H r� z,OpenStack_2_NodeDriver._to_floating_ip_poolsc C r� )zs List available floating IP pools :rtype: ``list`` of :class:`OpenStack_2_FloatingIpPool` z9/v2.0/networks?router:external=True&fields=id&fields=name)r� r� rl rm r� r: r: r; r� L s ��z0OpenStack_2_NodeDriver.ex_list_floating_ip_poolsc r� )N�routersc rN r: )� _to_router)rd �routerr� r: r; rf Z rQ z6OpenStack_2_NodeDriver._to_routers.<locals>.<listcomp>r: )r^ rs r r: r� r; � _to_routersX r� z"OpenStack_2_NodeDriver._to_routersc C s: i }|d |d< |d |d< t |d |d |d | |d�S )N�external_gateway_infoZroutesr� r� r� )r� r� r� r� r� )�OpenStack_2_Routerr� r: r: r; r \ s �z!OpenStack_2_NodeDriver._to_routerc C s | j �d�j}| �|�S )zt Get a list of Routers that are available. :rtype: ``list`` of :class:`OpenStack_2_Router` � /v2.0/routers)r� rl rm r r r: r: r; �ex_list_routersh s z&OpenStack_2_NodeDriver.ex_list_routersc C sJ d|pd|pd|d�i}|r||d d< | j jdd|d�j}| �|d �S )a0 Create a new Router :param name: Name of router which should be used :type name: ``str`` :param description: Description of the port :type description: ``str`` :param admin_state_up: The administrative state of the resource, which is up or down :type admin_state_up: ``bool`` :param external_gateway_info: The external gateway information :type external_gateway_info: ``dict`` :rtype: :class:`OpenStack_2_Router` r r� )r� r� r� r r r� r� )r� rl rm r )r^ r� r� r� r ru r~ r: r: r; �ex_create_routerq s �� z'OpenStack_2_NodeDriver.ex_create_routerc C s, | j jd�d|j�dd�}|jtjtjfv S )z� Delete a Router :param router: Router which should be deleted :type router: :class:`OpenStack_2_Router` :rtype: ``bool`` r" r r� r� )r� rl r� r� r� r r� r� )r^ r r� r: r: r; �ex_delete_router� s �z'OpenStack_2_NodeDriver.ex_delete_routerc C sZ i }|r |j |d< n|r|j |d< ntdd| ��| jjd�d|j |�d|d�}|jtjkS ) a� Add/Remove interface to router :param router: Router to add/remove the interface :type router: :class:`OpenStack_2_Router` :param op: Operation to perform: 'add' or 'remove' :type op: ``str`` :param subnet: Subnet object to be added to the router :type subnet: :class:`OpenStack_2_SubNet` :param port: Port object to be added to the router :type port: :class:`OpenStack_2_PortInterface` :rtype: ``bool`` Z subnet_idr� z3Error in router interface: port or subnet are None.r� z{}/{}/{}_router_interfacer r" r� )r� r r� rl r� r� r �OK)r^ r �opr� rV ru r� r: r: r; �_manage_router_interface� s �� z/OpenStack_2_NodeDriver._manage_router_interfacec C � | j |d|d�S )a Add port to a router :param router: Router to add the port :type router: :class:`OpenStack_2_Router` :param port: Port object to be added to the router :type port: :class:`OpenStack_2_PortInterface` :rtype: ``bool`` �add�rV �r �r^ r rV r: r: r; �ex_add_router_port� � z)OpenStack_2_NodeDriver.ex_add_router_portc C r )a Remove port from a router :param router: Router to remove the port :type router: :class:`OpenStack_2_Router` :param port: Port object to be added to the router :type port: :class:`OpenStack_2_PortInterface` :rtype: ``bool`` �remover" r# r$ r: r: r; �ex_del_router_port� r& z)OpenStack_2_NodeDriver.ex_del_router_portc C r )a Add subnet to a router :param router: Router to add the subnet :type router: :class:`OpenStack_2_Router` :param subnet: Subnet object to be added to the router :type subnet: :class:`OpenStack_2_SubNet` :rtype: ``bool`` r! �r� r# �r^ r r� r: r: r; �ex_add_router_subnet� r& z+OpenStack_2_NodeDriver.ex_add_router_subnetc C r )a Remove subnet to a router :param router: Router to remove the subnet :type router: :class:`OpenStack_2_Router` :param subnet: Subnet object to be added to the router :type subnet: :class:`OpenStack_2_SubNet` :rtype: ``bool`` r' r) r# r* r: r: r; �ex_del_router_subnet� r& z+OpenStack_2_NodeDriver.ex_del_router_subnetc C s� t di 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|�dd ��d|�dd ��d|�dd ��d| jj��}|S )Nr� �cores� instancesr^ �metadata_itemsr� � server_groups�server_group_membersr� r� r� rC r� �injected_file_content_bytes�injected_file_path_bytes�injected_filesr� r: )�OpenStack_2_QuotaSetrn rt r� �r^ rs �resr: r: r; � _to_quota_set� sH �������� � � � � � � � ��z$OpenStack_2_NodeDriver._to_quota_setc C s0 d| }|r |d| 7 }| � | j�|�jd �S )aR Get the quota for a project or a project and a user. :param tenant_id: The UUID of the tenant in a multi-tenancy cloud :type tenant_id: ``str`` :param user_id: ID of user to list the quotas for. :type user_id: ``str`` :rtype: :class:`OpenStack_2_QuotaSet` z/os-quota-sets/%s/detailz ?user_id=%s� quota_set)r8 rt rl rm )r^ r� ry rr r: r: r; �ex_get_quota_set s z'OpenStack_2_NodeDriver.ex_get_quota_setc C s\ t |d |d |d |d |�dd �|�dd �|�dd �|�dd �|�d d �| jjd � }|S ) N� floatingipr@ rV � rbac_policyr r� r> r� � subnetpool) r; r@ rV r< r r� r> r� r= r� )�OpenStack_2_NetworkQuotarn rt r� r6 r: r: r; �_to_network_quota# s � z(OpenStack_2_NodeDriver._to_network_quotac C s d| }| � | j�|�jd �S )z� Get the network quotas for a project :param project_id: The ID of the project. :type project_id: ``str`` :rtype: :class:`OpenStack_2_NetworkQuota` z /v2.0/quotas/%s/details.jsonZquota)r? r� rl rm �r^ r� rr r: r: r; �ex_get_network_quotas3 s z,OpenStack_2_NodeDriver.ex_get_network_quotasc C sN t |�dd �|�dd �|�dd �|�dd �|�dd �|�dd �| jjd�}|S )N�backup_gigabytes� gigabytes�per_volume_gigabytes�backupsr� r� )rB rC rD rE r� r� r� )�OpenStack_2_VolumeQuotarn rt r� r6 r: r: r; �_to_volume_quota? s � z'OpenStack_2_NodeDriver._to_volume_quotac C s" d| }| � | �� �|�jd �S )z� Get the volume quotas for a project :param project_id: The ID of the project. :type project_id: ``str`` :rtype: :class:`OpenStack_2_VolumeQuota` z /os-quota-sets/%s?usage=Truer9 )rG r rl rm r@ r: r: r; �ex_get_volume_quotasL s z+OpenStack_2_NodeDriver.ex_get_volume_quotasc C r� )zb List Server Groups :rtype: ``list`` of :class:`OpenStack_2_ServerGroup` �/os-server-groups)�_to_server_groupsrt rl rm r� r: r: r; �ex_list_server_groupsX rG z,OpenStack_2_NodeDriver.ex_list_server_groupsc r� )Nr0 c rN r: )�_to_server_group)rd Zsgr� r: r; rf b rQ z<OpenStack_2_NodeDriver._to_server_groups.<locals>.<listcomp>r: )r^ rs Z sg_elementsr: r� r; rJ ` r� z(OpenStack_2_NodeDriver._to_server_groupsc C s^ d }d|v r |d }nd|v r|d r|d d }t |d |d ||�d�|�d�| jjd�S ) N�policy�policiesr r� r� r� r� �r� r� rM r� r� r� )�OpenStack_2_ServerGrouprn rt r� )r^ rs rM r: r: r; rL d s �z'OpenStack_2_NodeDriver._to_server_groupc C s | � | j�d| �jd �S )zT Get Server Group :rtype: :class:`OpenStack_2_ServerGroup` �/os-server-groups/%s� server_group)rL rt rl rm )r^ Zserver_group_idr: r: r; �ex_get_server_groups s �z*OpenStack_2_NodeDriver.ex_get_server_groupc C s� d|i}|r ||d< z||d< | j jddd|id�j}W n ty9 |d= |g|d< | j jddd|id�j}Y nw | �|d �S ) a Add a Server Group :param name: Server Group Name. :type name: ``str`` :param policy: Server Group policy. :type policy: ``str`` :param rules: Server Group rules. :type rules: ``list`` :rtype: ``bool`` r� r� rM rI r� rR r� rN )rt rl rm r rL )r^ r� rM r� ru r~ r: r: r; �ex_add_server_group} s( �� ���z*OpenStack_2_NodeDriver.ex_add_server_groupc C rO )z� Delete a Server Group :param server_group: Server Group which should be deleted :type server_group: :class:`OpenStack_2_ServerGroup` :rtype: ``bool`` rQ r� r� rQ )r^ rR r� r: r: r; �ex_del_server_group� r� z*OpenStack_2_NodeDriver.ex_del_server_groupc r� )N� floatingipsc rN r: r� r| r� r: r; rf � rQ z;OpenStack_2_NodeDriver._to_floating_ips.<locals>.<listcomp>r: r� r: r� r; r� � r� z'OpenStack_2_NodeDriver._to_floating_ipsc C sJ i }|� d�|d< |� d�|d< |� d�|d< t|d |d d d | |d�S )N� port_detailsr� �floating_network_idr� �floating_ip_address�r� r� r� r� r� r� )rn r, r� r: r: r; r� � s �z&OpenStack_2_NodeDriver._to_floating_ipc C r� )zf List floating IPs :rtype: ``list`` of :class:`OpenStack_2_FloatingIpAddress` �/v2.0/floatingips�r� r� rl rm r� r: r: r; r� � s z+OpenStack_2_NodeDriver.ex_list_floating_ipsc C s( | � | j�d| �j�}|r|d S dS )z� Get specified floating IP from the pool :param ip: floating IP to get :type ip: ``str`` :rtype: :class:`OpenStack_2_FloatingIpAddress` z(/v2.0/floatingips?floating_ip_address=%sr Nr\ )r^ rZ r� r: r: r; r� � s ��z)OpenStack_2_NodeDriver.ex_get_floating_ipc C s6 | � � D ]}|r||jks||jkr|�� S qdS )a+ Create new floating IP. The ip_pool attribute is optional only if your infrastructure has only one IP pool available. :param ip_pool: name or id of the floating IP pool :type ip_pool: ``str`` :rtype: :class:`OpenStack_2_FloatingIpAddress` N)r� r� r� �create_floating_ip)r^ r� r� r: r: r; r� � s ��z,OpenStack_2_NodeDriver.ex_create_floating_ipc C rO )z� Delete specified floating IP :param ip: floating IP to remove :type ip: :class:`OpenStack_2_FloatingIpAddress` :rtype: ``bool`` �/v2.0/floatingips/%sr� r� )r� rl r� r� r r� r� r� r: r: r; r� � s z,OpenStack_2_NodeDriver.ex_delete_floating_ipc C s� d}t |d�r |j}n| �� D ] }|�|�}|r|j}q|s dS |s.| �|�}|r.|d j}|rE| jjd| ddd|iid �}|jtj kS dS ) a� Attach the floating IP to the node :param node: node :type node: :class:`Node` :param ip: floating IP to attach :type ip: ``str`` or :class:`OpenStack_1_1_FloatingIpAddress` :param port_id: Optional node port ID to attach the floating IP :type port_id: ``str`` :rtype: ``bool`` Nr� Fr r^ r" r; r� r� ) r� r� r� �get_floating_ipr r� rl r� r r ) r^ r� rZ r� �ip_idr� �fipr� r� r: r: r; r� � s, � � z4OpenStack_2_NodeDriver.ex_attach_floating_ip_to_nodec C sj d}t |d�r |j}n| �� D ] }|�|�}|r|j}q|s dS | jjd| ddddiid�}|jtjkS ) r� Nr� Fr^ r" r; r� r� ) r� r� r� r_ r� rl r� r r )r^ r� rZ r` r� ra r� r: r: r; r� s � � z6OpenStack_2_NodeDriver.ex_detach_floating_ip_from_nodec C r� )zU List leases :rtype: ``list`` of :class:`OpenStack_2_Lease` z/leases)� _to_leasesr� rl rm r� r: r: r; �ex_list_leases. rG z%OpenStack_2_NodeDriver.ex_list_leasesc r� )NZleasesc rN r: )� _to_lease)rd Zleaser� r: r; rf 8 rQ z5OpenStack_2_NodeDriver._to_leases.<locals>.<listcomp>r: )r^ rs Zlease_elementsr: r� r; rb 6 r� z!OpenStack_2_NodeDriver._to_leasesc C s2 t |d |d |d |d |d |d | jjd�S )Nr� r� Z start_dateZend_dater� � reservations�r� r� �start�endr� re r� )�OpenStack_2_Leaser� r� rv r: r: r; rd : s �z OpenStack_2_NodeDriver._to_leasec C r� )zT List leases :rtype: ``list`` of :class:`OpenStack_2_Host` z /os-hosts)� _to_hostsr� rl rm r� r: r: r; � ex_list_hostsE rG z$OpenStack_2_NodeDriver.ex_list_hostsc r� )N�hostsc rN r: )�_to_host)rd rU r� r: r; rf O rQ z4OpenStack_2_NodeDriver._to_hosts.<locals>.<listcomp>r: )r^ rs Z host_elementsr: r� r; rj M r� z OpenStack_2_NodeDriver._to_hostsc C s, t |d |d |d |d |d |d d�S )Nr� r} r� � memory_mb�local_gbr9 �r� r} r� rn ro r9 )�OpenStack_2_Hostrv r: r: r; rm Q s �z OpenStack_2_NodeDriver._to_hostr� r� )rh r� NNr )NTN)NNNNNNNr� r� )r� TNr[ )wr6 r7 r8 r� r� r r� r� r� r� r� r� r� r� r� r� r� r� r r� r� r� r r� rk r� r r� r- rD rE r� rI 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 r� r� r� r� r) r6 r: rF rM rS r= rV rY r r� r� r� r r r r r r r% r( r+ r, r8 r: r? rA rG rH rK rJ rL rS rT rU r� r� r� r� r� r� r� r� rc rb rd rk rj rm r� r: r: rY r; rO s � @ #! �4 �* �A �> , �8 �! # ) rO c @ � e Zd ZdZdd� Zdd� ZdS )rq z Host info. c C s( || _ || _|| _|| _|| _|| _d S r[ rp )r^ r� r} r� rn ro r9 r: r: r; r\ a s zOpenStack_2_Host.__init__c C � d� | j| j�S )Nz1<OpenStack_2_Host: id={}, hypervisor_hostname={}>)r� r� r} r� r: r: r; r i s �zOpenStack_2_Host.__repr__Nr� r: r: r: r; rq \ s rq c @ s@ e Zd ZdZdZdZdZdZdZdZ dZ d Z d d � Z d d � Z dS )ri z Lease info. r� rE r� rG r� �UPDATINGr� rH c C s. || _ || _|| _|| _|| _|| _|| _d S r[ rf )r^ r� r� rg rh r� re r� r: r: r; r\ ~ s zOpenStack_2_Lease.__init__c C r� )Nz.<OpenStack_2_Lease: id={}, name={}, status={}>)r� r� r� r� r� r: r: r; r � s �zOpenStack_2_Lease.__repr__N)r6 r7 r8 r� r� rE r� rG r� rt r� rH r\ r r: r: r: r; ri p s ri c @ �P e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dS )r) � Floating IP Pool info. c C r� r[ )r� rt )r^ r� rt r: r: r; r\ � r� z%OpenStack_1_1_FloatingIpPool.__init__c C r� )zu List floating IPs in the pool :rtype: ``list`` of :class:`OpenStack_1_1_FloatingIpAddress` r� r� r� r: r: r; �list_floating_ips� rG z.OpenStack_1_1_FloatingIpPool.list_floating_ipsc r� )Nr� c rN r: r� r| r� r: r; rf � rQ zAOpenStack_1_1_FloatingIpPool._to_floating_ips.<locals>.<listcomp>r: r� r: r� r; r� � r� z-OpenStack_1_1_FloatingIpPool._to_floating_ipsc C s" t |d |d | |d | jjd�S r� )r+ rt r� rv r: r: r; r� � s �z,OpenStack_1_1_FloatingIpPool._to_floating_ipc C r� )z� Get specified floating IP from the pool :param ip: floating IP to get :type ip: ``str`` :rtype: :class:`OpenStack_1_1_FloatingIpAddress` N)rw r� r� r: r: r; r_ � r� z,OpenStack_1_1_FloatingIpPool.get_floating_ipc C sH | j jddd| jid�}|jd }|d }|d }t||| d| j jd �S ) zn Create new floating IP in the pool :rtype: :class:`OpenStack_1_1_FloatingIpAddress` r� r� r� r� r� r� rZ Nr� )rt rl r� rm r+ r� )r^ r� ru r� r� r: r: r; r] � s �z/OpenStack_1_1_FloatingIpPool.create_floating_ipc C rO )�� Delete specified floating IP from the pool :param ip: floating IP to remove :type ip: :class:`OpenStack_1_1_FloatingIpAddress` :rtype: ``bool`` r� r� r� rQ r� r: r: r; �delete_floating_ip� r� z/OpenStack_1_1_FloatingIpPool.delete_floating_ipc C � d| j S )Nz'<OpenStack_1_1_FloatingIpPool: name=%s>r8 r� r: r: r; r � r� z%OpenStack_1_1_FloatingIpPool.__repr__N) r6 r7 r8 r� r\ rw r� r� r_ r] ry r r: r: r: r; r) � s r) c @ �* e Zd ZdZd dd�Zdd� Zdd� ZdS ) r+ z Floating IP info. Nc C s& t |�| _|| _|| _|| _|| _d S r[ )r r� r� r� r� r� )r^ r� r� r� r� r� r: r: r; r\ � s z(OpenStack_1_1_FloatingIpAddress.__init__c C s0 | j dur | j �| �S | jdur| j�| �S dS )zC Delete this floating IP :rtype: ``bool`` N)r� ry r� r� r� r: r: r; �delete� s �z&OpenStack_1_1_FloatingIpAddress.deletec C � d| j | j| j| jf S )NzH<OpenStack_1_1_FloatingIpAddress: id=%s, ip_addr=%s, pool=%s, driver=%s>�r� r� r� r� r� r: r: r; r � � �z(OpenStack_1_1_FloatingIpAddress.__repr__r� �r6 r7 r8 r� r\ r| r r: r: r: r; r+ � s r+ c @ s2 e Zd ZdZd dd�Zdd� Zdd� Zd d � ZdS ) r, z Floating IP info 2.0. Nc C s: t |�| _|| _|| _|| _|| _|r|| _d S i | _d S r[ )r r� r� r� r� r� r� )r^ r� r� r� r� r� r� r: r: r; r\ s z&OpenStack_2_FloatingIpAddress.__init__c C sT | j s'z | j�| jd �}W n ty d }Y nw |r't|j|j| jj�| _ | j S )NrX ) r� r� r r� r~ r* r� r� r� )r^ �netr: r: r; �get_pool s ��z&OpenStack_2_FloatingIpAddress.get_poolc C s� | j sXd| jvs | jd s8z | j�| jd �}W n ty# d }Y nw |r8|jd |jd |jd d�| jd< d| jv rX| jd rX| jd d }|rX|�d�rX| jd d | _ | j S )NrW r� r� r� r� )r� r� r� zcompute:)r� r� r� r r~ � startswith)r^ rV Z dev_ownerr: r: r; � get_node_id s" � �z)OpenStack_2_FloatingIpAddress.get_node_idc C r} )NzF<OpenStack_2_FloatingIpAddress: id=%s, ip_addr=%s, pool=%s, driver=%s>r~ r� r: r: r; r . r z&OpenStack_2_FloatingIpAddress.__repr__r� )r6 r7 r8 r� r\ r� r� r r: r: r: r; r, � s r, c @ ru )r* rv c C s || _ || _|| _d S r[ )r� r� rt )r^ r� r� rt r: r: r; r\ < s z#OpenStack_2_FloatingIpPool.__init__c r� )NrV c rN r: r� r| r� r: r; rf C rQ z?OpenStack_2_FloatingIpPool._to_floating_ips.<locals>.<listcomp>r: r� r: r� r; r� A r� z+OpenStack_2_FloatingIpPool._to_floating_ipsc C s@ i }|� d�|d< |� d�|d< t|d |d | d | jj|d�S )NrW r� r� rY rZ )rn r, rt r� r� r: r: r; r� E s �z*OpenStack_2_FloatingIpPool._to_floating_ipc C s d| j }| �| j�|�j�S )zs List floating IPs in the pool :rtype: ``list`` of :class:`OpenStack_2_FloatingIpAddress` �(/v2.0/floatingips?floating_network_id=%s�r� r� rt rl rm )r^ rr r: r: r; rw U s z,OpenStack_2_FloatingIpPool.list_floating_ipsc C s: d| j }|d| 7 }| �| j�|�j�}|r|d S dS )z� Get specified floating IP from the pool :param ip: floating IP to get :type ip: ``str`` :rtype: :class:`OpenStack_2_FloatingIpAddress` r� z&floating_ip_address=%sr Nr� )r^ rZ rr r� r: r: r; r_ ^ s z*OpenStack_2_FloatingIpPool.get_floating_ipc C sD | j jdddd| jiid�}|jd }t|d |d | d| j jd �S ) zl Create new floating IP in the pool :rtype: :class:`OpenStack_2_FloatingIpAddress` r[ r� r; rX r� r� rY Nr� )rt rl r� rm r, r� )r^ r� ru r: r: r; r] l s � �z-OpenStack_2_FloatingIpPool.create_floating_ipc C rO )rx r^ r� r� rQ r� r: r: r; ry � r� z-OpenStack_2_FloatingIpPool.delete_floating_ipc C rz )Nz%<OpenStack_2_FloatingIpPool: name=%s>r8 r� r: r: r; r � r� z#OpenStack_2_FloatingIpPool.__repr__N) r6 r7 r8 r� r\ r� r� rw r_ r] ry r r: r: r: r; r* 7 s r* c @ r� )r� z A Virtual SubNet. Nc C s0 t |�| _|| _|| _|| _|| _|pi | _d S r[ )r r� r� r� r r� r� )r^ r� r� r� r r� r� r: r: r; r\ � s zOpenStack_2_SubNet.__init__c C r� )Nz0<OpenStack_2_SubNet id="{}" name="{}" cidr="{}">r� r� r: r: r; r � r� zOpenStack_2_SubNet.__repr__r[ r� r: r: r: r; r� � s r� c @ r� )r z A Virtual Router. Nc C r� r[ )r r� r� r� r� r� )r^ r� r� r� r� r� r: r: r; r\ � r� zOpenStack_2_Router.__init__c C rs )Nz&<OpenStack_2_Router id="{}" name="{}">)r� r� r� r� r: r: r; r � r� zOpenStack_2_Router.__repr__r[ r� r: r: r: r; r � r� r c @ r{ ) r. ah Port Interface info. Similar in functionality to a floating IP (can be attached / detached from a compute instance) but implementation-wise a bit different. > A port is a connection point for attaching a single device, such as the > NIC of a server, to a network. The port also describes the associated > network configuration, such as the MAC and IP addresses to be used on > that port. https://docs.openstack.org/python-openstackclient/pike/cli/command-objects/port.html Also see: https://developer.openstack.org/api-ref/compute/#port-interfaces-servers-os-interface Nc C s4 t |�| _|| _|| _|| _|pi | _t�| � dS )a :param id: Port Interface ID. :type id: ``str`` :param state: State of the OpenStack_2_PortInterface. :type state: :class:`.OpenStack_2_PortInterfaceState` :param created: A datetime object that represents when the port interface was created :type created: ``datetime.datetime`` :param extra: Optional provided specific attributes associated with this image. :type extra: ``dict`` N)r r� r� r� r r� r r\ )r^ r� r� r� r r� r: r: r; r\ � s z"OpenStack_2_PortInterface.__init__c C s | j �| �S )zF Delete this Port Interface :rtype: ``bool`` )r� r� r� r: r: r; r| � s z OpenStack_2_PortInterface.deletec C s d| j | j| jjf S )Nz<<OpenStack_2_PortInterface: id=%s, state=%s, driver=%s ...>)r� r� r� r� r� r: r: r; r � s �z"OpenStack_2_PortInterface.__repr__r� r� r: r: r: r; r. � s r. c @ rr )�OpenStack_2_QuotaSetItemz� Qouta Set Item info. Each item has three attributes: in_use, limit and reserved. See: https://docs.openstack.org/api-ref/compute/?expanded=show-the-detail-of-quota-detail#show-a-quota c C s || _ || _|| _dS )a :param in_use: Number of currently used resources. :type in_use: ``int`` :param limit: Max number of available resources. :type limit: ``int`` :param reserved: Number of reserved resources. :type reserved: ``int`` N��in_use�limit�reserved)r^ r� r� r� r: r: r; r\ � s z!OpenStack_2_QuotaSetItem.__init__c C s d| j | j| jf S )Nz@<OpenStack_2_QuotaSetItem in_use="%s", limit="%s",reserved="%s">r� r� r: r: r; r � s �z!OpenStack_2_QuotaSetItem.__repr__Nr� r: r: r: r; r� � s r� c @ s< e Zd ZdZ d dd�Zdd� Zdd� ZdS ) r5 z� Quota Set info. To get the information about quotas and used resources. See: https://docs.openstack.org/api-ref/compute/?expanded=show-the-detail-of-quota-detail#show-a-quota Nc C s� t |�| _| �|�| _| �|�| _| �|�| _| �|�| _| �|�| _| �|�| _| �|�| _ | �| �| _ | �| �| _ | �| �| _ | �| �| _ | �| �| _| �|�| _| �|�| _| �|�| _|| _dS )a� :param id: Quota Set ID. :type id: ``str`` :param cores: Quota Set of cores. :type cores: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param instances: Quota Set of instances. :type instances: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param key_pairs: Quota Set of key pairs. :type key_pairs: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param metadata_items: Quota Set of metadata items. :type metadata_items: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param ram: Quota Set of RAM. :type ram: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param server_groups: Quota Set of server groups. :type server_groups: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param fixed_ips: Quota Set of fixed ips. (optional) :type fixed_ips: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param floating_ips: Quota Set of floating ips. (optional) :type floating_ips: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param networks: Quota Set of networks. (optional) :type networks: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param security_group_rules: Quota Set of security group rules. (optional) :type security_group_rules: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param security_groups: Quota Set of security groups. (optional) :type security_groups: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param injected_file_content_bytes: Quota Set of injected file content bytes. (optional) :type injected_file_content_bytes: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param injected_file_path_bytes: Quota Set of injected file path bytes. (optional) :type injected_file_path_bytes: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param injected_files: Quota Set of injected files. (optional) :type injected_files: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` N)r r� �_to_quota_set_itemr- r. r^ r/ r� r0 r1 r� r� r� rC r� r2 r3 r4 r� )r^ r� r- r. r^ r/ r� r0 r1 r� r� r� rC r� r2 r3 r4 r� r: r: r; r\ s" : z OpenStack_2_QuotaSet.__init__c C �< |r t |t�r |S t |t�rt|d |d |d �S d S d S )Nr� r� r� �r� r� r� rv r: r: r; r� \ � �z'OpenStack_2_QuotaSet._to_quota_set_itemc C r} )NzD<OpenStack_2_QuotaSet id="%s", cores="%s", ram="%s", instances="%s">)r� r- r� r. r� r: r: r; r e r z OpenStack_2_QuotaSet.__repr__) NNNNNNNNN�r6 r7 r8 r� r\ r� r r: r: r: r; r5 s �L r5 c @ �, e Zd ZdZ d dd�Zdd� Zdd� ZdS ) r> a Network Quota info. To get the information about quotas and used resources. See: https://docs.openstack.org/api-ref/network/v2/?expanded=show-quota-details-for-a-tenant-detail,list-quotas-for-a-project-detail#show-quota-details-for-a-tenant Nc C sv | � |�| _| � |�| _| � |�| _| � |�| _| � |�| _| � |�| _| � |�| _| � |�| _| � | �| _ | | _ dS )ap :param floatingip: Quota of floating ips. :type floatingip: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param network: Quota of networks. :type network: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param port: Quota of ports. :type port: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param rbac_policy: Quota of rbac policies. :type rbac_policy: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param router: Quota of routers. :type router: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param security_group: Quota of security groups. :type security_group: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param security_group_rule: Quota of security group rules. :type security_group_rule: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param subnet: Quota of subnets. :type subnet: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` :param subnetpool: Quota of subnet pools. :type subnetpool: :class:`.OpenStack_2_QuotaSetItem` or ``dict`` N) r� r; r@ rV r< r r� r> r� r= r� ) r^ r; r@ rV r< r r� r> r� r= r� r: r: r; r\ w s " z!OpenStack_2_NetworkQuota.__init__c C r� )N�usedr� r� r� rv r: r: r; r� � r� z+OpenStack_2_NetworkQuota._to_quota_set_itemc C r} )NzP<OpenStack_2_NetworkQuota Floating IPs="%s", networks="%s", SGs="%s", SGRs="%s">)r; r@ r� r> r� r: r: r; r � s ���z!OpenStack_2_NetworkQuota.__repr__r[ r� r: r: r: r; r> n s �- r> c @ r� ) rF a/ Volume Quota info. To get the information about quotas and used resources. See: https://docs.openstack.org/api-ref/block-storage/v2/index.html?expanded=show-quotas-detail https://docs.openstack.org/api-ref/block-storage/v3/index.html?expanded=show-quota-usage-for-a-project-detail Nc C sR | � |�| _| � |�| _| � |�| _| � |�| _| � |�| _| � |�| _|| _dS )a5 :param backup_gigabytes: Quota of backup size in gigabytes. :type backup_gigabytes: :class:`.OpenStack_2_QuotaSetItem` or ``int`` :param gigabytes: Quota of volume size in gigabytes. :type gigabytes: :class:`.OpenStack_2_QuotaSetItem` or ``int`` :param per_volume_gigabytes: Quota of per volume gigabytes. :type per_volume_gigabytes: :class:`.OpenStack_2_QuotaSetItem` or ``int`` :param backups: Quota of backups. :type backups: :class:`.OpenStack_2_QuotaSetItem` or ``int`` :param snapshots: Quota of snapshots. :type snapshots: :class:`.OpenStack_2_QuotaSetItem` or ``int`` :param volumes: Quota of security volumes. :type volumes: :class:`.OpenStack_2_QuotaSetItem` or ``int`` N)r� rB rC rD rE r� r� r� )r^ rB rC rD rE r� r� r� r: r: r; r\ � s z OpenStack_2_VolumeQuota.__init__c C sR |r't |t�r |S t |t�rt|d |d |d �S t |t�r%td|d�S d S d S )Nr� r� r� r )r� r� r� r� rv r: r: r; r� � s z*OpenStack_2_VolumeQuota._to_quota_set_itemc C r} )NzT<OpenStack_2_VolumeQuota Volumes="%s", gigabytes="%s", snapshots="%s", backups="%s">)r� rC r� rE r� r: r: r; r � s ��z OpenStack_2_VolumeQuota.__repr__r[ r� r: r: r: r; rF � s �! rF c @ s( e Zd ZdZ ddd�Zdd� ZdS )rP z� Server Group info. See: https://docs.openstack.org/api-ref/compute/?expanded=create-server-detail,list-server-groups-detail#server-groups-os-server-groups Nc C s0 || _ || _|| _|p g | _|pg | _|| _dS )ak :param id: Server Group ID. :type id: ``str`` :param name: Server Group Name. :type name: ``str`` :param policy: Server Group policy. :type policy: ``str`` :param members: Server Group members. :type members: ``list`` :param rules: Server Group rules. :type rules: ``list`` NrO )r^ r� r� rM r� r� r� r: r: r; r\ s z OpenStack_2_ServerGroup.__init__c C r� )NzS<OpenStack_2_ServerGroup id="%s", name="%s", policy="%s", members="%s", rules="%s">)r� r� rM r� r� r� r: r: r; r s ��z OpenStack_2_ServerGroup.__repr__r� r� r: r: r: r; rP � s � rP )\r� rf r- Zlibcloud.pricingr Zlibcloud.utils.py3r r r r r r Zlibcloud.utils.xmlr Zlibcloud.compute.baser r r r r r r r r r Zlibcloud.compute.typesr r r r r r Zlibcloud.utils.iso8601r Zlibcloud.common.openstackr r r r Zlibcloud.utils.networkingr Zlibcloud.common.exceptionsr Z simplejsonr� � ImportError�__all__ZATOM_NAMESPACEr� rq r2 r< r? rA rB rC r/ r� r! r" r# r$ r% r& r� r� r� r� r' r( r� r� r� r� r� r� r- rO rq ri r) r+ r, r* r� r r. r� r5 r> rF rP r: r: r: r; �<module> s� 0 � 5 G +_' ` P N <Y4 gL?
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings