Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/openstack/cloud/__pycache__/_network.cpython-39.pyc
Ðазад
a t�hJ� � @ sj d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlm Z G dd� dej �Z dS ) � N)�exc)� _normalize)�_utils)� exceptions)�proxyc @ s� e Zd Zdd� Ze�� dd� �Zdd� Zd�dd �Zd�d d �Z d�d d �Z d�dd�Z d�dd�Z d�dd�Z d�dd�Zd�dd�Zdd� Zd�dd�Zd�d d �Zd�d d �Zd�d d!�Zd�d"d#�Zd�d$d%�Zd&d'� Zd�d(d)�Zd�d*d+�Zd,d-� Zd�d.d/�Zd0d1� Z d�d4d5�Z e� d6d7d8d9d:d;d<d=�d>d?� �Z d@dA� Z dBdC� Z!d�dDdE�Z"dFdG� Z#dHdI� Z$e� dJdKdLdMdNdOdPd6dQdRd7dSdTdU�dVdW� �Z%d�dXdY�Z&d�dZd[�Z'd�d\d]�Z(e� dJdKdLdMdNdOdPd6dQdRd7dSdTdU�d�d^d_��Z)d�d`da�Z*e� dbdKdcd6dQd7�ddde� �Z+d�dfdg�Z,d�dhdi�Z-d�djdk�Z.e� dbdKdcd6dQd7�d�dldm��Z/d�dndo�Z0d�dpdq�Z1e� d8dKdrdsd6dtdQd7�dudv� �Z2d�dwdx�Z3d�dydz�Z4d�d{d|�Z5e� d8dKdrdsd6dtdQd7�d�d}d~��Z6dd�� Z7e� d6dKd7d�dQ�d�d�� �Z8e� d6dKd7d�dQ�d�d�� �Z9d�d�� Z:d�d�d��Z;d�d�d��Z<d�d�� Z=e� d�d��d�d�� �Z>e� d�d�d��d�d�� �Z?d�d�� Z@d�d�d��ZA�d d�d��ZBd�d�� ZCd�d�� ZDe� d��d�d�� �ZEd�d�� ZF�dd�d��ZG�dd�d��ZHd�d�� ZIe� d��d�d�� �ZJe� d�d��d�d�� �ZKd�d�� ZL�dd�d��ZM�dd�d��ZN�dd�d��ZO�dd�d��ZP�dd�d��ZQd�d�� ZR�dd�d��ZSd�d�� ZT�d d�dÄZUe� d6d8d�d�d�d�d�d�d�d�d�d�d�d<d�dСd�d҄ �ZVe� d6d8d�d�d�d�d�d�d�d�d<d�dС d�dԄ �ZWd�dք ZX�d d�dZYd�dڄ ZZdS ( �NetworkCloudMixinc C s d | _ d| _t�� | _d S )Nr )�_ports� _ports_time� threading�Lock� _ports_lock��self� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/openstack/cloud/_network.py�__init__ s zNetworkCloudMixin.__init__c C sD t � }| j�d�}tj|dd�}| �d|�D ]}|�|d � q,|S )Nz/extensions.jsonz)Error fetching extension list for neutron�� error_message� extensions�alias)�set�network�getr �_json_response�_get_and_munchify�add)r r �resp�data� extensionr r r �_neutron_extensions" s �z%NetworkCloudMixin._neutron_extensionsc C s || � � v S )N�r )r Zextension_aliasr r r �_has_neutron_extension- s z(NetworkCloudMixin._has_neutron_extensionNc C s& | � t|t�r|nd�}t�|||�S )a� Search networks :param name_or_id: Name or ID of the desired network. :param filters: a dict containing additional filters to use. e.g. {'router:external': True} :returns: a list of ``munch.Munch`` containing the network description. :raises: ``OpenStackCloudException`` if something goes wrong during the OpenStack API call. N)� list_networks� isinstance�dictr � _filter_list)r � name_or_id�filters�networksr r r �search_networks0 s �z!NetworkCloudMixin.search_networksc C s& | � t|t�r|nd�}t�|||�S )a� Search routers :param name_or_id: Name or ID of the desired router. :param filters: a dict containing additional filters to use. e.g. {'admin_state_up': True} :returns: a list of ``munch.Munch`` containing the router description. :raises: ``OpenStackCloudException`` if something goes wrong during the OpenStack API call. N)� list_routersr# r$ r r% )r r& r' �routersr r r �search_routers@ s �z NetworkCloudMixin.search_routersc C s& | � t|t�r|nd�}t�|||�S )a� Search subnets :param name_or_id: Name or ID of the desired subnet. :param filters: a dict containing additional filters to use. e.g. {'enable_dhcp': True} :returns: a list of ``munch.Munch`` containing the subnet description. :raises: ``OpenStackCloudException`` if something goes wrong during the OpenStack API call. N)� list_subnetsr# r$ r r% )r r& r' �subnetsr r r �search_subnetsP s �z NetworkCloudMixin.search_subnetsc C s2 | j st|t�rd}n|}| �|�}t�|||�S )a� Search ports :param name_or_id: Name or ID of the desired port. :param filters: a dict containing additional filters to use. e.g. {'device_id': '2711c67a-b4a7-43dd-ace7-6187b791c3f0'} :returns: a list of ``munch.Munch`` containing the port description. :raises: ``OpenStackCloudException`` if something goes wrong during the OpenStack API call. N)� _PORT_AGEr# �str� list_portsr r% )r r& r' Zpushdown_filters�portsr r r � search_ports` s z NetworkCloudMixin.search_portsc C s2 | � d�sg S |si }| jjd|d�}| �d|�S )z�List all available networks. :param filters: (optional) dict of filter conditions to push down :returns: A list of ``munch.Munch`` containing network info. r �/networks.json��paramsr( �� has_servicer r r �r r' r r r r r" v s z NetworkCloudMixin.list_networksc C s@ | � d�sg S |si }| jjd|d�}tj|dd�}| �d|�S )z�List all available routers. :param filters: (optional) dict of filter conditions to push down :returns: A list of router ``munch.Munch``. r � /routers.jsonr6 zError fetching router listr r+ �r9 r r r r r �r r' r r r r r r* � s �z NetworkCloudMixin.list_routersc C s2 | � d�sg S |si }| jjd|d�}| �d|�S )z�List all available subnets. :param filters: (optional) dict of filter conditions to push down :returns: A list of subnet ``munch.Munch``. r � /subnets.jsonr6 r. r8 r: r r r r- � s z NetworkCloudMixin.list_subnetsc C s� |r| j dkr| �|�S t�� | j | j kr�| jdu }| j�|�r�z2|rR| jdush| �i �| _t�� | _W | j�� n | j�� 0 t� | jd|p�i �S )z�List all available ports. :param filters: (optional) dict of filter conditions to push down :returns: A list of port ``munch.Munch``. r N) r0 � _list_ports�timer r r �acquire�releaser r% )r r' Z first_runr r r r2 � s z NetworkCloudMixin.list_portsc C s8 | � d�sg S | jjd|d�}tj|dd�}| �d|�S )Nr � /ports.jsonr6 zError fetching port listr r3 r< r= r r r r? � s �z NetworkCloudMixin._list_portsc C s t �| d||�S )a� Get a QoS policy by name or ID. :param name_or_id: Name or ID of the policy. :param filters: A dictionary of meta data to use for further filtering. Elements of this dictionary may, themselves, be dictionaries. Example:: { 'last_name': 'Smith', 'other': { 'gender': 'Female' } } OR A string containing a jmespath expression for further filtering. Example:: "[?last_name==`Smith`] | [?other.gender]==`Female`]" :returns: A policy ``munch.Munch`` or None if no matching network is found. Z qos_policie�r Z _get_entity�r r& r' r r r �get_qos_policy� s �z NetworkCloudMixin.get_qos_policyc C s | � |�}t�|||�S )a� Search QoS policies :param name_or_id: Name or ID of the desired policy. :param filters: a dict containing additional filters to use. e.g. {'shared': True} :returns: a list of ``munch.Munch`` containing the network description. :raises: ``OpenStackCloudException`` if something goes wrong during the OpenStack API call. )�list_qos_policiesr r% )r r& r' �policiesr r r �search_qos_policies� s z%NetworkCloudMixin.search_qos_policiesc C sF | � d�st�d��|s i }| jjd|d�}tj|dd�}| �d|�S )z�List all available QoS rule types. :param filters: (optional) dict of filter conditions to push down :returns: A list of rule types ``munch.Munch``. �qos�.QoS extension is not available on target cloudz/qos/rule-types.jsonr6 z"Error fetching QoS rule types listr Z rule_types�r! r �"OpenStackCloudUnavailableExtensionr r r r r r= r r r �list_qos_rule_types� s ��z%NetworkCloudMixin.list_qos_rule_typesc C s^ | � d�st�d��| � d�s(t�d��| j�dj|d��}tj|dj|d�d�}| �d |�S ) z�Get a QoS rule type details by rule type name. :param string rule_type: Name of the QoS rule type. :returns: A rule type details ``munch.Munch`` or None if no matching rule type is found. rJ rK zqos-rule-type-detailsz@qos-rule-type-details extension is not available on target cloudz /qos/rule-types/{rule_type}.json)� rule_typez3Error fetching QoS details of {rule_type} rule typer rO ) r! r rM r r �formatr r r )r rO r' r r r r r �get_qos_rule_type_details s$ � � ���z+NetworkCloudMixin.get_qos_rule_type_detailsc C sF | � d�st�d��|s i }| jjd|d�}tj|dd�}| �d|�S )z�List all available QoS policies. :param filters: (optional) dict of filter conditions to push down :returns: A list of policies ``munch.Munch``. rJ rK �/qos/policies.jsonr6 z Error fetching QoS policies listr rH rL r= r r r rG + s ��z#NetworkCloudMixin.list_qos_policiesc C s t �| d||�S )a� Get a network by name or ID. :param name_or_id: Name or ID of the network. :param filters: A dictionary of meta data to use for further filtering. Elements of this dictionary may, themselves, be dictionaries. Example:: { 'last_name': 'Smith', 'other': { 'gender': 'Female' } } OR A string containing a jmespath expression for further filtering. Example:: "[?last_name==`Smith`] | [?other.gender]==`Female`]" :returns: A network ``munch.Munch`` or None if no matching network is found. r rD rE r r r � get_network> s z NetworkCloudMixin.get_networkc C s: | j �dj|d��}tj|dj|d�d�}| �d|�}|S )zq Get a network by ID :param id: ID of the network. :returns: A network ``munch.Munch``. z/networks/{id}��idz"Error getting network with ID {id}r r �r r rP r r r )r rU r r r r r r �get_network_by_idW s � z#NetworkCloudMixin.get_network_by_idc C s t �| d||�S )a� Get a router by name or ID. :param name_or_id: Name or ID of the router. :param filters: A dictionary of meta data to use for further filtering. Elements of this dictionary may, themselves, be dictionaries. Example:: { 'last_name': 'Smith', 'other': { 'gender': 'Female' } } OR A string containing a jmespath expression for further filtering. Example:: "[?last_name==`Smith`] | [?other.gender]==`Female`]" :returns: A router ``munch.Munch`` or None if no matching router is found. �routerrD rE r r r � get_routerf s z NetworkCloudMixin.get_routerc C s t �| d||�S )a Get a subnet by name or ID. :param name_or_id: Name or ID of the subnet. :param filters: A dictionary of meta data to use for further filtering. Elements of this dictionary may, themselves, be dictionaries. Example:: { 'last_name': 'Smith', 'other': { 'gender': 'Female' } } :returns: A subnet ``munch.Munch`` or None if no matching subnet is found. �subnetrD rE r r r � get_subnet s z NetworkCloudMixin.get_subnetc C s: | j �dj|d��}tj|dj|d�d�}| �d|�}|S )zn Get a subnet by ID :param id: ID of the subnet. :returns: A subnet ``munch.Munch``. z /subnets/{id}rT z!Error getting subnet with ID {id}r rZ rV )r rU r r rZ r r r �get_subnet_by_id� s � z"NetworkCloudMixin.get_subnet_by_idc C s t �| d||�S )a� Get a port by name or ID. :param name_or_id: Name or ID of the port. :param filters: A dictionary of meta data to use for further filtering. Elements of this dictionary may, themselves, be dictionaries. Example:: { 'last_name': 'Smith', 'other': { 'gender': 'Female' } } OR A string containing a jmespath expression for further filtering. Example:: "[?last_name==`Smith`] | [?other.gender]==`Female`]" :returns: A port ``munch.Munch`` or None if no matching port is found. �portrD rE r r r �get_port� s zNetworkCloudMixin.get_portc C s: | j �dj|d��}tj|dj|d�d�}| �d|�}|S )zh Get a port by ID :param id: ID of the port. :returns: A port ``munch.Munch``. z /ports/{id}rT z Error getting port with ID {id}r r] rV )r rU r r r] r r r �get_port_by_id� s � z NetworkCloudMixin.get_port_by_idFTc C s4 ||d�} |r|| d< |dur&|| d< |dur^t |t�sBt�d��| �d�sVt�d��|| d< |r�t |t�svt�d ��d D ] } | |v rzd | } || | | < qz|r�d | d < |dur�t |t�s�t�d��|| d< | r�t | t�s�t�d��| dks�t�d��| | d< | �r | | d< | j j dd| id�}| � � | � d|�S )a; Create a network. :param string name: Name of the network being created. :param bool shared: Set the network as shared. :param bool admin_state_up: Set the network administrative state to up. :param bool external: Whether this network is externally accessible. :param dict provider: A dict of network provider options. Example:: { 'network_type': 'vlan', 'segmentation_id': 'vlan1' } :param string project_id: Specify the project ID this network will be created on (admin-only). :param types.ListType availability_zone_hints: A list of availability zone hints. :param bool port_security_enabled: Enable / Disable port security :param int mtu_size: maximum transmission unit value to address fragmentation. Minimum value is 68 for IPv4, and 1280 for IPv6. :param string dns_domain: Specify the DNS domain associated with this network. :returns: The network object. :raises: OpenStackCloudException on operation error. )�name�admin_state_up�sharedN� tenant_id�2Parameter 'availability_zone_hints' must be a listZnetwork_availability_zonezDnetwork_availability_zone extension is not available on target cloud�availability_zone_hints�#Parameter 'provider' must be a dict�Zphysical_networkZ network_typeZsegmentation_id� provider:T�router:external�0Parameter 'port_security_enabled' must be a bool�port_security_enabled�(Parameter 'mtu_size' must be an integer.�D �-Parameter 'mtu_size' must be greater than 67.�mtu� dns_domainr5 r ��json) r# �listr �OpenStackCloudExceptionr! rM r$ �bool�intr �post�_reset_network_cachesr )r r` rb ra �external�provider� project_idre rk �mtu_sizerp r �attr�argr r r r �create_network� sb � � � � � ��z NetworkCloudMixin.create_networkr` rb ra ry rz r| rk rp c K s. d|v rVt |d t�s t�d��i }|d D ] }|dv r,|d | |d| < q,||d< d|v rl|�d�|d< d|v r�t |d t�s�t�d��d |v r�t |d t�s�t�d ��|d d k r�t�d ��|�d �|d < | �|�}|s�t�d| ��tj | j j dj |j d�d|id�d� |�d�}| �� | �d|�S )a� Update a network. :param string name_or_id: Name or ID of the network being updated. :param string name: New name of the network. :param bool shared: Set the network as shared. :param bool admin_state_up: Set the network administrative state to up. :param bool external: Whether this network is externally accessible. :param dict provider: A dict of network provider options. Example:: { 'network_type': 'vlan', 'segmentation_id': 'vlan1' } :param int mtu_size: New maximum transmission unit value to address fragmentation. Minimum value is 68 for IPv4, and 1280 for IPv6. :param bool port_security_enabled: Enable or disable port security. :param string dns_domain: Specify the DNS domain associated with this network. :returns: The updated network object. :raises: OpenStackCloudException on operation error. rz rf rg rh ry ri rk rj r| rl rm rn ro �Network %s not found.z/networks/{net_id}.json)Znet_idr rq zError updating network {0}r )r# r$ r rt �popru rv rS r r r �putrP rU rx r )r r& �kwargsrz �keyr r r r r �update_network$ sP � �� � � ��z NetworkCloudMixin.update_networkc C sJ | � |�}|s | j�d|� dS t�| j�dj|d d��� | �� dS )z�Delete a network. :param name_or_id: Name or ID of the network being deleted. :returns: True if delete succeeded, False otherwise. :raises: OpenStackCloudException on operation error. z!Network %s not found for deletingFz/networks/{network_id}.jsonrU )� network_idT) rS �log�debugr �raise_from_responser �deleterP rx )r r& r r r r �delete_networkf s �z NetworkCloudMixin.delete_networkc K sL | � |�}|st�d��tj| jjdj|jd�d|id�d�|j�d� dS ) a Set a network quota in a project :param name_or_id: project name or id :param kwargs: key/value pairs of quota name and quota value :raises: OpenStackCloudException if the resource to set the quota does not exist. �project does not exist�/quotas/{project_id}.json�r{ �quotarq z-Error setting Neutron's quota for project {0}r N) � get_projectr rt r r� r r� rP rU )r r& r� �projr r r �set_network_quotas| s ���z$NetworkCloudMixin.set_network_quotasc C sd | � |�}|st�d��dj|jd�}|r2|d }|d }tj| j�|�d�|j�d�}| � d|�S ) aK Get network quotas for a project :param name_or_id: project name or id :param details: if set to True it will return details about usage of quotas by given project :raises: OpenStackCloudException if it's not a valid project :returns: Munch object with the quotas r� z/quotas/{project_id}r� z/detailsz.jsonz.Error fetching Neutron's quota for project {0}r r� ) r� r rt rP rU r r r r r )r r& �detailsr� �urlr r r r �get_network_quotas� s ��z$NetworkCloudMixin.get_network_quotasc C s | � � S )zbGet Cloud provided network extensions :returns: set of Neutron extension aliases r r r r r �get_network_extensions� s z(NetworkCloudMixin.get_network_extensionsc C sD | � |�}|st�d��tj| j�dj|jd��d�|j�d� dS )z� Delete network quotas for a project :param name_or_id: project name or id :raises: OpenStackCloudException if it's not a valid project or the network client call failed :returns: dict with the quotas r� r� r� z.Error deleting Neutron's quota for project {0}r N) r� r rt r r� r r� rP rU )r r& r� r r r �delete_network_quotas� s ���z'NetworkCloudMixin.delete_network_quotas�action� descriptionZ destination_firewall_group_idZdestination_ip_addressZdestination_port�enabled� ip_versionr{ �protocolZsource_firewall_group_idZsource_ip_addressZ source_portc K s | j jf i |��S )aZ Creates firewall rule. :param action: Action performed on traffic. Valid values: allow, deny Defaults to deny. :param description: Human-readable description. :param destination_firewall_group_id: ID of destination firewall group. :param destination_ip_address: IPv4-, IPv6 address or CIDR. :param destination_port: Port or port range (e.g. 80:90) :param bool enabled: Status of firewall rule. You can disable rules without disassociating them from firewall policies. Defaults to True. :param int ip_version: IP Version. Valid values: 4, 6 Defaults to 4. :param name: Human-readable name. :param project_id: Project id. :param protocol: IP protocol. Valid values: icmp, tcp, udp, null :param bool shared: Visibility to other projects. Defaults to False. :param source_firewall_group_id: ID of source firewall group. :param source_ip_address: IPv4-, IPv6 address or CIDR. :param source_port: Port or port range (e.g. 80:90) :raises: BadRequestException if parameters are malformed :return: created firewall rule :rtype: FirewallRule )r �create_firewall_rule�r r� r r r r� � s #z&NetworkCloudMixin.create_firewall_rulec C s^ |si }z,| j j|fddi|��}| j j|dd� W n$ tjyX | j�d|� Y dS 0 dS )an Deletes firewall rule. Prints debug message in case to-be-deleted resource was not found. :param name_or_id: firewall rule name or id :param dict filters: optional filters :raises: DuplicateResource on multiple matches :return: True if resource is successfully deleted, False otherwise. :rtype: bool �ignore_missingF�r� z'Firewall rule %s not found for deletingT)r �find_firewall_rule�delete_firewall_ruler �ResourceNotFoundr� r� )r r& r' � firewall_ruler r r r� � s& ���� �z&NetworkCloudMixin.delete_firewall_rulec C s |si }| j j|fi |��S )a# Retrieves a single firewall rule. :param name_or_id: firewall rule name or id :param dict filters: optional filters :raises: DuplicateResource on multiple matches :return: firewall rule dict or None if not found :rtype: FirewallRule )r r� rE r r r �get_firewall_rule� s z#NetworkCloudMixin.get_firewall_rulec C s |si }t | jjf i |���S )z� Lists firewall rules. :param dict filters: optional filters :return: list of firewall rules :rtype: list[FirewallRule] )rs r �firewall_rules�r r' r r r �list_firewall_rules s z%NetworkCloudMixin.list_firewall_rulesc K s4 |si }| j j|fddi|��}| j j|fi |��S )a� Updates firewall rule. :param name_or_id: firewall rule name or id :param dict filters: optional filters :param kwargs: firewall rule update parameters. See create_firewall_rule docstring for valid parameters. :raises: BadRequestException if parameters are malformed :raises: NotFoundException if resource is not found :return: updated firewall rule :rtype: FirewallRule r� F)r r� �update_firewall_rule)r r& r' r� r� r r r r� s ���z&NetworkCloudMixin.update_firewall_rulec C s< |si }g }|D ]&}|� | jj|fddi|��d � q|S )a� Takes a list of firewall rule name or ids, looks them up and returns a list of firewall rule ids. Used by `create_firewall_policy` and `update_firewall_policy`. :param list[str] name_or_id_list: firewall rule name or id list :param dict filters: optional filters :raises: DuplicateResource on multiple matches :raises: NotFoundException if resource is not found :return: list of firewall rule ids :rtype: list[str] r� FrU )�appendr r� )r �name_or_id_listr' �ids_listr& r r r �_get_firewall_rule_ids1 s ����z(NetworkCloudMixin._get_firewall_rule_idsZauditedr� c K s, d|v r| � |d �|d< | jjf i |��S )aO Create firewall policy. :param bool audited: Status of audition of firewall policy. Set to False each time the firewall policy or the associated firewall rules are changed. Has to be explicitly set to True. :param description: Human-readable description. :param list[str] firewall_rules: List of associated firewall rules. :param name: Human-readable name. :param project_id: Project id. :param bool shared: Visibility to other projects. Defaults to False. :raises: BadRequestException if parameters are malformed :raises: ResourceNotFound if a resource from firewall_list not found :return: created firewall policy :rtype: FirewallPolicy r� )r� r �create_firewall_policyr� r r r r� G s �z(NetworkCloudMixin.create_firewall_policyc C s^ |si }z,| j j|fddi|��}| j j|dd� W n$ tjyX | j�d|� Y dS 0 dS )ar Deletes firewall policy. Prints debug message in case to-be-deleted resource was not found. :param name_or_id: firewall policy name or id :param dict filters: optional filters :raises: DuplicateResource on multiple matches :return: True if resource is successfully deleted, False otherwise. :rtype: bool r� Fr� z)Firewall policy %s not found for deletingT)r �find_firewall_policy�delete_firewall_policyr r� r� r� )r r& r' �firewall_policyr r r r� b s& ���� �z(NetworkCloudMixin.delete_firewall_policyc C s |si }| j j|fi |��S )a& Retrieves a single firewall policy. :param name_or_id: firewall policy name or id :param dict filters: optional filters :raises: DuplicateResource on multiple matches :return: firewall policy or None if not found :rtype: FirewallPolicy �r r� rE r r r �get_firewall_policyz s z%NetworkCloudMixin.get_firewall_policyc C s |si }t | jjf i |���S )z� Lists firewall policies. :param dict filters: optional filters :return: list of firewall policies :rtype: list[FirewallPolicy] )rs r Zfirewall_policiesr� r r r �list_firewall_policies� s z(NetworkCloudMixin.list_firewall_policiesc K sN |si }| j j|fddi|��}d|v r:| �|d �|d< | j j|fi |��S )a Updates firewall policy. :param name_or_id: firewall policy name or id :param dict filters: optional filters :param kwargs: firewall policy update parameters See create_firewall_policy docstring for valid parameters. :raises: BadRequestException if parameters are malformed :raises: DuplicateResource on multiple matches :raises: ResourceNotFound if resource is not found :return: updated firewall policy :rtype: FirewallPolicy r� Fr� )r r� r� �update_firewall_policy)r r& r' r� r� r r r r� � s ����z(NetworkCloudMixin.update_firewall_policyc C s� |si }| j j|fddi|��}| j j|dd�}|d |d v rT| j�d||� |S i }|durx| j j|dd�d |d< |dur�| j j|dd�d |d < | j j|d |d fi |��S ) a� Adds firewall rule to the firewall_rules list of a firewall policy. Short-circuits and returns the firewall policy early if the firewall rule id is already present in the firewall_rules list. This method doesn't do re-ordering. If you want to move a firewall rule or down the list, you have to remove and re-add it. :param name_or_id: firewall policy name or id :param rule_name_or_id: firewall rule name or id :param insert_after: rule name or id that should precede added rule :param insert_before: rule name or id that should succeed added rule :param dict filters: optional filters :raises: DuplicateResource on multiple matches :raises: ResourceNotFound if firewall policy or any of the firewall rules (inserted, after, before) is not found. :return: updated firewall policy :rtype: FirewallPolicy r� Fr� rU r� z;Firewall rule %s already associated with firewall policy %sN� insert_after� insert_before)r r� r� r� r� �insert_rule_into_policy) r r& �rule_name_or_idr� r� r' r� r� Z pos_paramsr r r r� � sH ��������� ��z)NetworkCloudMixin.insert_rule_into_policyc C s| |si }| j j|fddi|��}| j �|�}|sB| j�d|� |S |d |d vrf| j�d||� |S | j �|d |d �S )a3 Remove firewall rule from firewall policy's firewall_rules list. Short-circuits and returns firewall policy early if firewall rule is already absent from the firewall_rules list. :param name_or_id: firewall policy name or id :param rule_name_or_id: firewall rule name or id :param dict filters: optional filters :raises: DuplicateResource on multiple matches :raises: ResourceNotFound if firewall policy is not found :return: updated firewall policy :rtype: FirewallPolicy r� Fz'Firewall rule %s not found for removingrU r� z7Firewall rule %s not associated with firewall policy %s)r r� r� r� r� �remove_rule_from_policy)r r& r� r' r� r� r r r r� � s0 ��� �� �z)NetworkCloudMixin.remove_rule_from_policy�egress_firewall_policy�ingress_firewall_policyr3 c K s6 | � |� d|v r$| �|d �|d< | jjf i |��S )a� Creates firewall group. The keys egress_firewall_policy and ingress_firewall_policy are looked up and mapped as egress_firewall_policy_id and ingress_firewall_policy_id respectively. Port name or ids list is transformed to port ids list before the POST request. :param bool admin_state_up: State of firewall group. Will block all traffic if set to False. Defaults to True. :param description: Human-readable description. :param egress_firewall_policy: Name or id of egress firewall policy. :param ingress_firewall_policy: Name or id of ingress firewall policy. :param name: Human-readable name. :param list[str] ports: List of associated ports (name or id) :param project_id: Project id. :param shared: Visibility to other projects. Defaults to False. :raises: BadRequestException if parameters are malformed :raises: DuplicateResource on multiple matches :raises: ResourceNotFound if (ingress-, egress-) firewall policy or a port is not found. :return: created firewall group :rtype: FirewallGroup r3 )�*_lookup_ingress_egress_firewall_policy_ids� _get_port_idsr �create_firewall_groupr� r r r r� s z'NetworkCloudMixin.create_firewall_groupc C s^ |si }z,| j j|fddi|��}| j j|dd� W n$ tjyX | j�d|� Y dS 0 dS )ap Deletes firewall group. Prints debug message in case to-be-deleted resource was not found. :param name_or_id: firewall group name or id :param dict filters: optional filters :raises: DuplicateResource on multiple matches :return: True if resource is successfully deleted, False otherwise. :rtype: bool r� Fr� z(Firewall group %s not found for deletingT)r �find_firewall_group�delete_firewall_groupr r� r� r� )r r& r' �firewall_groupr r r r� ) s& ���� �z'NetworkCloudMixin.delete_firewall_groupc C s |si }| j j|fi |��S )a Retrieves firewall group. :param name_or_id: firewall group name or id :param dict filters: optional filters :raises: DuplicateResource on multiple matches :return: firewall group or None if not found :rtype: FirewallGroup )r r� rE r r r �get_firewall_groupA s z$NetworkCloudMixin.get_firewall_groupc C s |si }t | jjf i |���S )z� Lists firewall groups. :param dict filters: optional filters :return: list of firewall groups :rtype: list[FirewallGroup] )rs r Zfirewall_groupsr� r r r �list_firewall_groupsO s z&NetworkCloudMixin.list_firewall_groupsc K sX |si }| j j|fddi|��}| �|� d|v rD| �|d �|d< | j j|fi |��S )aL Updates firewall group. To unset egress- or ingress firewall policy, set egress_firewall_policy or ingress_firewall_policy to None. You can also set egress_firewall_policy_id and ingress_firewall_policy_id directly, which will skip the policy lookups. :param name_or_id: firewall group name or id :param dict filters: optional filters :param kwargs: firewall group update parameters See create_firewall_group docstring for valid parameters. :raises: BadRequestException if parameters are malformed :raises: DuplicateResource on multiple matches :raises: ResourceNotFound if firewall group, a firewall policy (egress, ingress) or port is not found :return: updated firewall group :rtype: FirewallGroup r� Fr3 )r r� r� r� �update_firewall_group)r r& r' r� r� r r r r� [ s ��� z'NetworkCloudMixin.update_firewall_groupc C sT dD ]J}||vrq|| du r$d}n| j j|| dd�d }|||d < ||= qdS )a� Transforms firewall_group dict IN-PLACE. Takes the value of the keys egress_firewall_policy and ingress_firewall_policy, looks up the policy ids and maps them to egress_firewall_policy_id and ingress_firewall_policy_id. Old keys which were used for the lookup are deleted. :param dict firewall_group: firewall group dict :raises: DuplicateResource on multiple matches :raises: ResourceNotFound if a firewall policy is not found )r� r� NFr� rU Z_idr� )r r� r� �valr r r r� { s �� z<NetworkCloudMixin._lookup_ingress_egress_firewall_policy_ids�defaultc K sh | � d�st�d��|�dd�}|durH| � d�r<||d< n | j�d� | jjdd |id �}| �d |�S ) a Create a QoS policy. :param string name: Name of the QoS policy being created. :param string description: Description of created QoS policy. :param bool shared: Set the QoS policy as shared. :param bool default: Set the QoS policy as default for project. :param string project_id: Specify the project ID this QoS policy will be created on (admin-only). :returns: The QoS policy object. :raises: OpenStackCloudException on operation error. rJ rK r� N� qos-default� is_default�8'qos-default' extension is not available on target cloudrR �policyrq ) r! r rM r� r� r� r rw r )r r� r� r r r r �create_qos_policy� s � z#NetworkCloudMixin.create_qos_policyc K s� | � d�st�d��|�dd�}|durH| � d�r<||d< n | j�d� |s\| j�d� dS | �|�}|sxt�d | ��| jj d j |d d �d |id�}| � d |�S )aL Update an existing QoS policy. :param string name_or_id: Name or ID of the QoS policy to update. :param string policy_name: The new name of the QoS policy. :param string description: The new description of the QoS policy. :param bool shared: If True, the QoS policy will be set as shared. :param bool default: If True, the QoS policy will be set as default for project. :returns: The updated QoS policy object. :raises: OpenStackCloudException on operation error. rJ rK r� Nr� r� r� z No QoS policy data to updatezQoS policy %s not found.� /qos/policies/{policy_id}.jsonrU �� policy_idr� rq ) r! r rM r� r� r� rF rt r r� rP r )r r& r� r� Z curr_policyr r r r �update_qos_policy� s0 � ���z#NetworkCloudMixin.update_qos_policyc C sV | � d�st�d��| �|�}|s4| j�d|� dS t�| j� dj |d d��� dS ) z�Delete a QoS policy. :param name_or_id: Name or ID of the policy being deleted. :returns: True if delete succeeded, False otherwise. :raises: OpenStackCloudException on operation error. rJ rK z$QoS policy %s not found for deletingFr� rU r� T) r! r rM rF r� r� r r� r r� rP )r r& r� r r r �delete_qos_policy� s � �z#NetworkCloudMixin.delete_qos_policyc C s | � ||�}t�|||�S )a& Search QoS bandwidth limit rules :param string policy_name_or_id: Name or ID of the QoS policy to which rules should be associated. :param string rule_id: ID of searched rule. :param filters: a dict containing additional filters to use. e.g. {'max_kbps': 1000} :returns: a list of ``munch.Munch`` containing the bandwidth limit rule descriptions. :raises: ``OpenStackCloudException`` if something goes wrong during the OpenStack API call. )� list_qos_bandwidth_limit_rulesr r% �r �policy_name_or_id�rule_idr' �rulesr r r � search_qos_bandwidth_limit_rules� s z2NetworkCloudMixin.search_qos_bandwidth_limit_rulesc C s~ | � d�st�d��| �|�}|s4t�dj|d���|s<i }| jjdj|d d�|d�}tj |d j|d d �d �}| � d |�S ) a� List all available QoS bandwidth limit rules. :param string policy_name_or_id: Name or ID of the QoS policy from from rules should be listed. :param filters: (optional) dict of filter conditions to push down :returns: A list of ``munch.Munch`` containing rule info. :raises: ``OpenStackCloudResourceNotFound`` if QoS policy will not be found. rJ rK �"QoS policy {name_or_id} not Found.�r& z4/qos/policies/{policy_id}/bandwidth_limit_rules.jsonrU r� r6 z6Error fetching QoS bandwidth limit rules from {policy}�r� r Zbandwidth_limit_rules� r! r rM rF � OpenStackCloudResourceNotFoundrP r r r r r �r r� r' r� r r r r r r� s4 � ������z0NetworkCloudMixin.list_qos_bandwidth_limit_rulesc C sv | � d�st�d��| �|�}|s4t�dj|d���| j�dj|d |d��}tj |dj||d d �d �}| � d |�S ) aB Get a QoS bandwidth limit rule by name or ID. :param string policy_name_or_id: Name or ID of the QoS policy to which rule should be associated. :param rule_id: ID of the rule. :returns: A bandwidth limit rule ``munch.Munch`` or None if no matching rule is found. rJ rK r� r� �>/qos/policies/{policy_id}/bandwidth_limit_rules/{rule_id}.jsonrU �r� r� z?Error fetching QoS bandwidth limit rule {rule_id} from {policy}�r� r� r �bandwidth_limit_ruler� �r r� r� r� r r r r r � get_qos_bandwidth_limit_rule* s0 � ������z.NetworkCloudMixin.get_qos_bandwidth_limit_ruleZmax_burst_kbps� directionc K s� | � d�st�d��| �|�}|s4t�dj|d���|�d�durb| � d�sb|�d� | j� d� ||d < | j j d j|d d �d |id�}| � d |�S )a+ Create a QoS bandwidth limit rule. :param string policy_name_or_id: Name or ID of the QoS policy to which rule should be associated. :param int max_kbps: Maximum bandwidth limit value (in kilobits per second). :param int max_burst_kbps: Maximum burst value (in kilobits). :param string direction: Ingress or egress. The direction in which the traffic will be limited. :returns: The QoS bandwidth limit rule. :raises: OpenStackCloudException on operation error. rJ rK r� r� r� N�qos-bw-limit-direction�C'qos-bw-limit-direction' extension is not available on target cloud�max_kbpsz//qos/policies/{policy_id}/bandwidth_limit_rulesrU r� r� rq ) r! r rM rF r� rP r r� r� r� r rw r )r r� r� r� r� r r r r � create_qos_bandwidth_limit_ruleI s2 � �� ���z1NetworkCloudMixin.create_qos_bandwidth_limit_ruler� c K s� | � d�st�d��| �|�}|s4t�dj|d���|�d�durb| � d�sb|�d� | j� d� |sv| j� d � dS | � ||�}|s�t� d j||d d ���| j j d j|d |d�d|id�}| �d|�S )aa Update a QoS bandwidth limit rule. :param string policy_name_or_id: Name or ID of the QoS policy to which rule is associated. :param string rule_id: ID of rule to update. :param int max_kbps: Maximum bandwidth limit value (in kilobits per second). :param int max_burst_kbps: Maximum burst value (in kilobits). :param string direction: Ingress or egress. The direction in which the traffic will be limited. :returns: The updated QoS bandwidth limit rule. :raises: OpenStackCloudException on operation error. rJ rK r� r� r� Nr� r� z*No QoS bandwidth limit rule data to updatezBQoS bandwidth_limit_rule {rule_id} not found in policy {policy_id}rU �r� r� r� r� r� rq )r! r rM rF r� rP r r� r� r� r� rt r r� r �r r� r� r� r� Z curr_ruler r r r � update_qos_bandwidth_limit_ruleq sJ � �� � �����z1NetworkCloudMixin.update_qos_bandwidth_limit_rulec C s� | � d�st�d��| �|�}|s4t�dj|d���z$t�| j� dj|d |d��� W n0 tj y� | j � dj||d d �� Y d S 0 d S ) a Delete a QoS bandwidth limit rule. :param string policy_name_or_id: Name or ID of the QoS policy to which rule is associated. :param string rule_id: ID of rule to update. :raises: OpenStackCloudException on operation error. rJ rK r� r� z8/qos/policies/{policy}/bandwidth_limit_rules/{rule}.jsonrU �r� �rulezMQoS bandwidth limit rule {rule_id} not found in policy {policy_id}. Ignoring.r� FT� r! r rM rF r� rP r r� r r� ZOpenStackCloudURINotFoundr� r� �r r� r� r� r r r � delete_qos_bandwidth_limit_rule� s4 � �� �� ��z1NetworkCloudMixin.delete_qos_bandwidth_limit_rulec C s | � ||�}t�|||�S )a Search QoS DSCP marking rules :param string policy_name_or_id: Name or ID of the QoS policy to which rules should be associated. :param string rule_id: ID of searched rule. :param filters: a dict containing additional filters to use. e.g. {'dscp_mark': 32} :returns: a list of ``munch.Munch`` containing the dscp marking rule descriptions. :raises: ``OpenStackCloudException`` if something goes wrong during the OpenStack API call. )�list_qos_dscp_marking_rulesr r% r� r r r � search_qos_dscp_marking_rules� s z/NetworkCloudMixin.search_qos_dscp_marking_rulesc C s~ | � d�st�d��| �|�}|s4t�dj|d���|s<i }| jjdj|d d�|d�}tj |d j|d d �d �}| � d |�S ) a� List all available QoS DSCP marking rules. :param string policy_name_or_id: Name or ID of the QoS policy from from rules should be listed. :param filters: (optional) dict of filter conditions to push down :returns: A list of ``munch.Munch`` containing rule info. :raises: ``OpenStackCloudResourceNotFound`` if QoS policy will not be found. rJ rK r� r� z1/qos/policies/{policy_id}/dscp_marking_rules.jsonrU r� r6 z3Error fetching QoS DSCP marking rules from {policy}r� r Zdscp_marking_rulesr� r� r r r r� � s4 � ������z-NetworkCloudMixin.list_qos_dscp_marking_rulesc C sv | � d�st�d��| �|�}|s4t�dj|d���| j�dj|d |d��}tj |dj||d d �d �}| � d |�S ) a? Get a QoS DSCP marking rule by name or ID. :param string policy_name_or_id: Name or ID of the QoS policy to which rule should be associated. :param rule_id: ID of the rule. :returns: A bandwidth limit rule ``munch.Munch`` or None if no matching rule is found. rJ rK r� r� �;/qos/policies/{policy_id}/dscp_marking_rules/{rule_id}.jsonrU r� z<Error fetching QoS DSCP marking rule {rule_id} from {policy}r� r �dscp_marking_ruler� r� r r r �get_qos_dscp_marking_rule� s0 � ������z+NetworkCloudMixin.get_qos_dscp_marking_rulec C sh | � d�st�d��| �|�}|s4t�dj|d���d|i}| jjdj|d d�d |id �}| �d |�S ) a8 Create a QoS DSCP marking rule. :param string policy_name_or_id: Name or ID of the QoS policy to which rule should be associated. :param int dscp_mark: DSCP mark value :returns: The QoS DSCP marking rule. :raises: OpenStackCloudException on operation error. rJ rK r� r� � dscp_markz,/qos/policies/{policy_id}/dscp_marking_rulesrU r� r� rq � r! r rM rF r� rP r rw r )r r� r� r� �bodyr r r r � create_qos_dscp_marking_rule s( � �����z.NetworkCloudMixin.create_qos_dscp_marking_ruler� c K s� | � d�st�d��| �|�}|s4t�dj|d���|sH| j�d� dS | �||�}|spt� dj||d d ���| j j d j|d |d �d |id �}| � d |�S )aq Update a QoS DSCP marking rule. :param string policy_name_or_id: Name or ID of the QoS policy to which rule is associated. :param string rule_id: ID of rule to update. :param int dscp_mark: DSCP mark value :returns: The updated QoS bandwidth limit rule. :raises: OpenStackCloudException on operation error. rJ rK r� r� z'No QoS DSCP marking rule data to updateNz?QoS dscp_marking_rule {rule_id} not found in policy {policy_id}rU r� r� r� r� rq ) r! r rM rF r� rP r� r� r� rt r r� r r� r r r � update_qos_dscp_marking_rule7 s> � �� �����z.NetworkCloudMixin.update_qos_dscp_marking_rulec C s� | � d�st�d��| �|�}|s4t�dj|d���z$t�| j� dj|d |d��� W n0 tj y� | j � dj||d d �� Y d S 0 d S ) a Delete a QoS DSCP marking rule. :param string policy_name_or_id: Name or ID of the QoS policy to which rule is associated. :param string rule_id: ID of rule to update. :raises: OpenStackCloudException on operation error. rJ rK r� r� z5/qos/policies/{policy}/dscp_marking_rules/{rule}.jsonrU r� zJQoS DSCP marking rule {rule_id} not found in policy {policy_id}. Ignoring.r� FTr� r� r r r � delete_qos_dscp_marking_rule` s4 � �� �� ��z.NetworkCloudMixin.delete_qos_dscp_marking_rulec C s | � ||�}t�|||�S )a( Search QoS minimum bandwidth rules :param string policy_name_or_id: Name or ID of the QoS policy to which rules should be associated. :param string rule_id: ID of searched rule. :param filters: a dict containing additional filters to use. e.g. {'min_kbps': 1000} :returns: a list of ``munch.Munch`` containing the bandwidth limit rule descriptions. :raises: ``OpenStackCloudException`` if something goes wrong during the OpenStack API call. )� list_qos_minimum_bandwidth_rulesr r% r� r r r �"search_qos_minimum_bandwidth_rules� s �z4NetworkCloudMixin.search_qos_minimum_bandwidth_rulesc C s~ | � d�st�d��| �|�}|s4t�dj|d���|s<i }| jjdj|d d�|d�}tj |d j|d d �d �}| � d |�S ) a� List all available QoS minimum bandwidth rules. :param string policy_name_or_id: Name or ID of the QoS policy from from rules should be listed. :param filters: (optional) dict of filter conditions to push down :returns: A list of ``munch.Munch`` containing rule info. :raises: ``OpenStackCloudResourceNotFound`` if QoS policy will not be found. rJ rK r� r� z6/qos/policies/{policy_id}/minimum_bandwidth_rules.jsonrU r� r6 z8Error fetching QoS minimum bandwidth rules from {policy}r� r Zminimum_bandwidth_rulesr� r� r r r r� � s4 � ������z2NetworkCloudMixin.list_qos_minimum_bandwidth_rulesc C sv | � d�st�d��| �|�}|s4t�dj|d���| j�dj|d |d��}tj |dj||d d �d �}| � d |�S ) aD Get a QoS minimum bandwidth rule by name or ID. :param string policy_name_or_id: Name or ID of the QoS policy to which rule should be associated. :param rule_id: ID of the rule. :returns: A bandwidth limit rule ``munch.Munch`` or None if no matching rule is found. rJ rK r� r� �@/qos/policies/{policy_id}/minimum_bandwidth_rules/{rule_id}.jsonrU r� zAError fetching QoS minimum_bandwidth rule {rule_id} from {policy}r� r �minimum_bandwidth_ruler� r� r r r � get_qos_minimum_bandwidth_rule� s0 � ������z0NetworkCloudMixin.get_qos_minimum_bandwidth_rulec K sh | � d�st�d��| �|�}|s4t�dj|d���||d< | jjdj|d d�d |id �}| �d |�S ) a� Create a QoS minimum bandwidth limit rule. :param string policy_name_or_id: Name or ID of the QoS policy to which rule should be associated. :param int min_kbps: Minimum bandwidth value (in kilobits per second). :param string direction: Ingress or egress. The direction in which the traffic will be available. :returns: The QoS minimum bandwidth rule. :raises: OpenStackCloudException on operation error. rJ rK r� r� �min_kbpsz1/qos/policies/{policy_id}/minimum_bandwidth_rulesrU r� r� rq r� )r r� r r� r� r r r r �!create_qos_minimum_bandwidth_rule� s& � ����z3NetworkCloudMixin.create_qos_minimum_bandwidth_ruler c K s� | � d�st�d��| �|�}|s4t�dj|d���|sH| j�d� dS | �||�}|spt� dj||d d ���| j j d j|d |d �d |id �}| � d |�S )a Update a QoS minimum bandwidth rule. :param string policy_name_or_id: Name or ID of the QoS policy to which rule is associated. :param string rule_id: ID of rule to update. :param int min_kbps: Minimum bandwidth value (in kilobits per second). :param string direction: Ingress or egress. The direction in which the traffic will be available. :returns: The updated QoS minimum bandwidth rule. :raises: OpenStackCloudException on operation error. rJ rK r� r� z,No QoS minimum bandwidth rule data to updateNzDQoS minimum_bandwidth_rule {rule_id} not found in policy {policy_id}rU r� r� r� r� rq ) r! r rM rF r� rP r� r� r rt r r� r r� r r r �!update_qos_minimum_bandwidth_rule� s> � �� �����z3NetworkCloudMixin.update_qos_minimum_bandwidth_rulec C s� | � d�st�d��| �|�}|s4t�dj|d���z$t�| j� dj|d |d��� W n0 tj y� | j � dj||d d �� Y d S 0 d S ) a Delete a QoS minimum bandwidth rule. :param string policy_name_or_id: Name or ID of the QoS policy to which rule is associated. :param string rule_id: ID of rule to delete. :raises: OpenStackCloudException on operation error. rJ rK r� r� z:/qos/policies/{policy}/minimum_bandwidth_rules/{rule}.jsonrU r� zOQoS minimum bandwidth rule {rule_id} not found in policy {policy_id}. Ignoring.r� FTr� r� r r r �!delete_qos_minimum_bandwidth_rule! s4 � �� �� ��z3NetworkCloudMixin.delete_qos_minimum_bandwidth_rulec C sL i }|r||d< |r ||d< t j| jjdj|d d�|d�d�|d �d�S ) a� Attach a subnet to an internal router interface. Either a subnet ID or port ID must be specified for the internal interface. Supplying both will result in an error. :param dict router: The dict object of the router being changed :param string subnet_id: The ID of the subnet to use for the interface :param string port_id: The ID of the port to use for the interface :returns: A ``munch.Munch`` with the router ID (ID), subnet ID (subnet_id), port ID (port_id) and tenant ID (tenant_id). :raises: OpenStackCloudException on operation error. � subnet_id�port_idz./routers/{router_id}/add_router_interface.jsonrU �Z router_idrq z'Error attaching interface to router {0}r )r r r r� rP �r rX r r Z json_bodyr r r �add_router_interfaceA s ����z&NetworkCloudMixin.add_router_interfacec C s\ i }|r||d< |r ||d< |s(t d��tj| jjdj|d d�|d�d�|d �d � d S ) a� Detach a subnet from an internal router interface. At least one of subnet_id or port_id must be supplied. If you specify both subnet and port ID, the subnet ID must correspond to the subnet ID of the first IP address on the port specified by the port ID. Otherwise an error occurs. :param dict router: The dict object of the router being changed :param string subnet_id: The ID of the subnet to use for the interface :param string port_id: The ID of the port to use for the interface :returns: None on success :raises: OpenStackCloudException on operation error. r r z6At least one of subnet_id or port_id must be supplied.z1/routers/{router_id}/remove_router_interface.jsonrU r rq z)Error detaching interface from router {0}r N)� ValueErrorr r� r r� rP r r r r �remove_router_interface_ s( �����z)NetworkCloudMixin.remove_router_interfacec C s� | j |d dd�d�| j |d dd�d� | j |d dd�d� }| j |d dd�d�}|| }|r||dkrp|S |d kr||S |S ) aM List all interfaces for a router. :param dict router: A router dict object. :param string interface_type: One of None, "internal", or "external". Controls whether all, internal interfaces or external interfaces are returned. :returns: A list of port ``munch.Munch`` objects. rU znetwork:router_interface)� device_id� device_owner)r' z$network:router_interface_distributedz&network:ha_router_replicated_interfaceznetwork:router_gatewayZinternalry )r4 )r rX Zinterface_typeZrouter_interfacesZrouter_gatewaysr3 r r r �list_router_interfaces� s2 ����� � z(NetworkCloudMixin.list_router_interfacesc C s� d|i}|dur||d< |r$||d< | � |||�} | r>| |d< |durvt|t�sZt�d��| �d�snt�d��||d < tj| j j d d |id �d � |�d�} | � d | �S )az Create a logical router. :param string name: The router name. :param bool admin_state_up: The administrative state of the router. :param string ext_gateway_net_id: Network ID for the external gateway. :param bool enable_snat: Enable Source NAT (SNAT) attribute. :param ext_fixed_ips: List of dictionaries of desired IP and/or subnet on the external network. Example:: [ { "subnet_id": "8ca37218-28ff-41cb-9b10-039601ea7e6b", "ip_address": "192.168.10.2" } ] :param string project_id: Project ID for the router. :param types.ListType availability_zone_hints: A list of availability zone hints. :returns: The router object. :raises: OpenStackCloudException on operation error. ra Nrc r` �external_gateway_inford Zrouter_availability_zonezCrouter_availability_zone extension is not available on target cloudre r; rX rq zError creating router {0}r ) � _build_external_gateway_infor# rs r rt r! rM r r r rw rP r ) r r` ra �ext_gateway_net_id� enable_snat� ext_fixed_ipsr{ re rX � ext_gw_infor r r r � create_router� s4 �� � ��z NetworkCloudMixin.create_routerc C s� i }|r||d< |dur ||d< | � |||�} | r:| |d< |durb| �d�rV||d< n | j�d� |sv| j�d� dS | �|�} | s�t�d | ��| jj d j | d d �d |id�} t j | d� |�d�} | � d | �S )a� Update an existing logical router. :param string name_or_id: The name or UUID of the router to update. :param string name: The new router name. :param bool admin_state_up: The administrative state of the router. :param string ext_gateway_net_id: The network ID for the external gateway. :param bool enable_snat: Enable Source NAT (SNAT) attribute. :param ext_fixed_ips: List of dictionaries of desired IP and/or subnet on the external network. Example:: [ { "subnet_id": "8ca37218-28ff-41cb-9b10-039601ea7e6b", "ip_address": "192.168.10.2" } ] :param list routes: A list of dictionaries with destination and nexthop parameters. To clear all routes pass an empty list ([]). Example:: [ { "destination": "179.24.1.0/24", "nexthop": "172.24.3.99" } ] :returns: The router object. :raises: OpenStackCloudException on operation error. r` Nra r Z extraroute�routesz7extra routes extension is not available on target cloudzNo router data to updatezRouter %s not found.�/routers/{router_id}.jsonrU r rX rq zError updating router {0}r )r r! r� �warningr� rY r rt r r� rP r r r ) r r& r` ra r r r r rX r Z curr_routerr r r r r � update_router� sB $� � ���z NetworkCloudMixin.update_routerc C sL | � |�}|s | j�d|� dS t�| jjdj|d d�d�|�d�� dS ) a� Delete a logical router. If a name, instead of a unique UUID, is supplied, it is possible that we could find more than one matching router since names are not required to be unique. An error will be raised in this case. :param name_or_id: Name or ID of the router being deleted. :returns: True if delete succeeded, False otherwise. :raises: OpenStackCloudException on operation error. z Router %s not found for deletingFr rU r zError deleting router {0}r T)rY r� r� r r� r r� rP )r r& rX r r r � delete_router s �z NetworkCloudMixin.delete_router� c K sx |durd|i}nd}| � ||�}|s4t�d| ��| rF|rFt�d��|sX|sXt�d��|rj|rjt�d��t|t�r�z t|�}W n ty� t�d��Y n0 t|d ||d �fi |��}|r�||d < |r�||d < |r�||d< |r�||d < |r�||d < | �rd|d < | �r| |d< | �r | |d< | �r.| |d< | �r<| |d< |�rJ||d< |�rXd|d< | jj dd|id�}| � d|�S )a� Create a subnet on a specified network. :param string network_name_or_id: The unique name or ID of the attached network. If a non-unique name is supplied, an exception is raised. :param string cidr: The CIDR. :param int ip_version: The IP version, which is 4 or 6. :param bool enable_dhcp: Set to ``True`` if DHCP is enabled and ``False`` if disabled. Default is ``False``. :param string subnet_name: The name of the subnet. :param string tenant_id: The ID of the tenant who owns the network. Only administrative users can specify a tenant ID other than their own. :param allocation_pools: A list of dictionaries of the start and end addresses for the allocation pools. For example:: [ { "start": "192.168.199.2", "end": "192.168.199.254" } ] :param string gateway_ip: The gateway IP address. When you specify both allocation_pools and gateway_ip, you must ensure that the gateway IP does not overlap with the specified allocation pools. :param bool disable_gateway_ip: Set to ``True`` if gateway IP address is disabled and ``False`` if enabled. It is not allowed with gateway_ip. Default is ``False``. :param dns_nameservers: A list of DNS name servers for the subnet. For example:: [ "8.8.8.7", "8.8.8.8" ] :param host_routes: A list of host route dictionaries for the subnet. For example:: [ { "destination": "0.0.0.0/0", "nexthop": "123.456.78.9" }, { "destination": "192.168.0.0/24", "nexthop": "192.168.0.1" } ] :param string ipv6_ra_mode: IPv6 Router Advertisement mode. Valid values are: 'dhcpv6-stateful', 'dhcpv6-stateless', or 'slaac'. :param string ipv6_address_mode: IPv6 address mode. Valid values are: 'dhcpv6-stateful', 'dhcpv6-stateless', or 'slaac'. :param string prefixlen: The prefix length to use for subnet allocation from a subnet pool. :param bool use_default_subnetpool: Use the default subnetpool for ``ip_version`` to obtain a CIDR. It is required to pass ``None`` to the ``cidr`` argument when enabling this option. :param kwargs: Key value pairs to be passed to the Neutron API. :returns: The new subnet object. :raises: OpenStackCloudException on operation error. Nrc r� �9arg:disable_gateway_ip is not allowed with arg:gateway_ipz2arg:cidr is required when a subnetpool is not usedz@arg:cidr must be set to None when use_default_subnetpool == Truez ip_version must be an integerrU )r� r� � enable_dhcp�cidrr` �allocation_pools� gateway_ip�dns_nameservers� host_routes� ipv6_ra_mode�ipv6_address_mode� prefixlenT�use_default_subnetpoolr> rZ rq ) rS r rt r# r1 rv r r$ r rw r )r Znetwork_name_or_idr r� r � subnet_namerc r r �disable_gateway_ipr! r" r# r$ r% r& r� r' r rZ �responser r r � create_subnet7 sx P ���� � ��z NetworkCloudMixin.create_subnetc C sB | � |�}|s | j�d|� dS t�| j�dj|d d��� dS )a� Delete a subnet. If a name, instead of a unique UUID, is supplied, it is possible that we could find more than one matching subnet since names are not required to be unique. An error will be raised in this case. :param name_or_id: Name or ID of the subnet being deleted. :returns: True if delete succeeded, False otherwise. :raises: OpenStackCloudException on operation error. z Subnet %s not found for deletingF�/subnets/{subnet_id}.jsonrU �r T)r[ r� r� r r� r r� rP )r r& rZ r r r � delete_subnet� s �z NetworkCloudMixin.delete_subnetc C s� i } |r|| d< |dur || d< |r,|| d< |r8d| d< |rD|| d< |rP|| d< |r\|| d< | sp| j �d� dS |r�|r�t�d ��| �|�} | s�t�d | ��| jjd j| d d �d| id�} | �d| �S )a� Update an existing subnet. :param string name_or_id: Name or ID of the subnet to update. :param string subnet_name: The new name of the subnet. :param bool enable_dhcp: Set to ``True`` if DHCP is enabled and ``False`` if disabled. :param string gateway_ip: The gateway IP address. When you specify both allocation_pools and gateway_ip, you must ensure that the gateway IP does not overlap with the specified allocation pools. :param bool disable_gateway_ip: Set to ``True`` if gateway IP address is disabled and ``False`` if enabled. It is not allowed with gateway_ip. Default is ``False``. :param allocation_pools: A list of dictionaries of the start and end addresses for the allocation pools. For example:: [ { "start": "192.168.199.2", "end": "192.168.199.254" } ] :param dns_nameservers: A list of DNS name servers for the subnet. For example:: [ "8.8.8.7", "8.8.8.8" ] :param host_routes: A list of host route dictionaries for the subnet. For example:: [ { "destination": "0.0.0.0/0", "nexthop": "123.456.78.9" }, { "destination": "192.168.0.0/24", "nexthop": "192.168.0.1" } ] :returns: The updated subnet object. :raises: OpenStackCloudException on operation error. r` Nr r r r! r" zNo subnet data to updater zSubnet %s not found.r+ rU r, rZ rq ) r� r� r rt r[ r r� rP r ) r r& r' r r r( r r! r" rZ Z curr_subnetr) r r r � update_subnet� s@ 5 � ��z NetworkCloudMixin.update_subnetZ mac_addressZ fixed_ipsr � ip_addressZsecurity_groupsZallowed_address_pairsZextra_dhcp_optsr r zbinding:vnic_typezbinding:profileZ qos_policy_idzbinding:host_idc K s8 ||d< t j| jjdd|id�d�|�d�}| �d|�S )aR Create a port :param network_id: The ID of the network. (Required) :param name: A symbolic name for the port. (Optional) :param admin_state_up: The administrative status of the port, which is up (true, default) or down (false). (Optional) :param mac_address: The MAC address. (Optional) :param fixed_ips: List of ip_addresses and subnet_ids. See subnet_id and ip_address. (Optional) For example:: [ { "ip_address": "10.29.29.13", "subnet_id": "a78484c4-c380-4b47-85aa-21c51a2d8cbd" }, ... ] :param subnet_id: If you specify only a subnet ID, OpenStack Networking allocates an available IP from that subnet to the port. (Optional) If you specify both a subnet ID and an IP address, OpenStack Networking tries to allocate the specified address to the port. :param ip_address: If you specify both a subnet ID and an IP address, OpenStack Networking tries to allocate the specified address to the port. :param security_groups: List of security group UUIDs. (Optional) :param allowed_address_pairs: Allowed address pairs list (Optional) For example:: [ { "ip_address": "23.23.23.1", "mac_address": "fa:16:3e:c4:cd:3f" }, ... ] :param extra_dhcp_opts: Extra DHCP options. (Optional). For example:: [ { "opt_name": "opt name1", "opt_value": "value1" }, ... ] :param device_owner: The ID of the entity that uses this port. For example, a DHCP agent. (Optional) :param device_id: The ID of the device that uses this port. For example, a virtual server. (Optional) :param binding vnic_type: The type of the created port. (Optional) :param port_security_enabled: The security port state created on the network. (Optional) :param qos_policy_id: The ID of the QoS policy to apply for port. :returns: a ``munch.Munch`` describing the created port. :raises: ``OpenStackCloudException`` on operation error. r� rC r] rq z#Error creating port for network {0}r )r r r rw rP r )r r� r� r r r r � create_port9 s ?��z NetworkCloudMixin.create_portc K sb | j |d�}|du r&t�dj|d���tj| jjdj|d d�d|id �d �|�d �}| �d|�S ) aa Update a port Note: to unset an attribute use None value. To leave an attribute untouched just omit it. :param name_or_id: name or ID of the port to update. (Required) :param name: A symbolic name for the port. (Optional) :param admin_state_up: The administrative status of the port, which is up (true) or down (false). (Optional) :param fixed_ips: List of ip_addresses and subnet_ids. (Optional) If you specify only a subnet ID, OpenStack Networking allocates an available IP from that subnet to the port. If you specify both a subnet ID and an IP address, OpenStack Networking tries to allocate the specified address to the port. For example:: [ { "ip_address": "10.29.29.13", "subnet_id": "a78484c4-c380-4b47-85aa-21c51a2d8cbd" }, ... ] :param security_groups: List of security group UUIDs. (Optional) :param allowed_address_pairs: Allowed address pairs list (Optional) For example:: [ { "ip_address": "23.23.23.1", "mac_address": "fa:16:3e:c4:cd:3f" }, ... ] :param extra_dhcp_opts: Extra DHCP options. (Optional). For example:: [ { "opt_name": "opt name1", "opt_value": "value1" }, ... ] :param device_owner: The ID of the entity that uses this port. For example, a DHCP agent. (Optional) :param device_id: The ID of the resource this port is attached to. :param binding vnic_type: The type of the created port. (Optional) :param port_security_enabled: The security port state created on the network. (Optional) :param qos_policy_id: The ID of the QoS policy to apply for port. :returns: a ``munch.Munch`` describing the updated port. :raises: OpenStackCloudException on operation error. r� Nz failed to find port '{port}')r] �/ports/{port_id}.jsonrU �r r] rq zError updating port {0}r ) r^ r rt rP r r r r� r )r r& r� r] r r r r � update_port� s < ���z NetworkCloudMixin.update_portc C sR | j |d�}|du r&| j�d|� dS tj| j�dj|d d��d�|�d � d S ) z�Delete a port :param name_or_id: ID or name of the port to delete. :returns: True if delete succeeded, False otherwise. :raises: OpenStackCloudException on operation error. r� Nz Port %s not found for deletingFr1 rU r2 zError deleting port {0}r T)r^ r� r� r r� r r� rP )r r& r] r r r � delete_port� s ��z NetworkCloudMixin.delete_portc C sB g }|D ]4}| � ||�}|s.t�dj|d���|�|d � q|S )a� Takes a list of port names or ids, retrieves ports and returns a list with port ids only. :param list[str] name_or_id_list: list of port names or ids :param dict filters: optional filters :raises: SDKException on multiple matches :raises: ResourceNotFound if a port is not found :return: list of port ids :rtype: list[str] zPort {id} not foundrT rU )r^ r r� rP r� )r r� r' r� r& r] r r r r� � s �z NetworkCloudMixin._get_port_idsc C s8 i }|r||d< |d ur ||d< |r,||d< |r4|S d S )Nr� r Zexternal_fixed_ipsr )r r r r �infor r r r � s z.NetworkCloudMixin._build_external_gateway_info)NN)NN)NN)NN)N)N)N)N)N)NN)N)N)N)N)N)N)N) FTFNNNNNN)F)N)N)N)N)N)N)N)N)N)NNN)N)N)N)N)N)NN)N)NN)N)NN)N)NN)NN)N)NTNNNNN)NNNNNN)Nr FNNNNFNNNNNF)NNNNNNN)N)[�__name__� __module__� __qualname__r r Zcache_on_argumentsr r! r) r, r/ r4 r" r* r- r2 r? rF rI rN rQ rG rS rW rY r[ r\ r^ r_ r Z valid_kwargsr� 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� r� r� r� r� r r r r r r r r r r r* r- r. r0 r3 r4 r� r r r r r r s\ ! � Z � ? � � � � � 2 � ' � � � � , � # ' 3 � # (!� � $ * # � 6 � G � � W � A � B r ) r@ r �typesZopenstack.cloudr r r Z openstackr r Z Normalizerr r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка