golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/openstack/__pycache__
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.cpython-310.pyc
207 B
Del
OK
neutron.cpython-310.pyc
25.58 KB
Del
OK
nova.cpython-310.pyc
28.33 KB
Del
OK
swift.cpython-310.pyc
6.61 KB
Del
OK
Edit: neutron.cpython-310.pyc
o �xe�� � @ s� d Z ddlZddlZddlmZ dZzddlmZ ddlm Z dZW n e y+ Y nw dZ z ddl Z ddlZ dZ W n e yC Y nw e�e�Zdd � Zd d � Zd d � ZG dd� de�ZdS )z Neutron class � N)� exceptionsF)� NeutronShell)�clientTc C � t S �N)� HAS_NEUTRON� r r �P/opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/openstack/neutron.py� check_neutron$ � r c C r r )�HAS_KEYSTONEAUTHr r r r �check_keystone( r r c C s. d}i }| � � D ] }||v r| | ||< q|S )N)�usernameZuser_id�password�token� tenant_name� tenant_id�auth_url� service_typeZ endpoint_type� region_name�verifyZ endpoint_url�timeoutZinsecureZca_certZretriesZ raise_error�session�auth)�keys)�kwargsZ variables�ret�varr r r �sanitize_neutronclient, s �r c @ s� e Zd ZdZ d�dd�Z d�dd �Z d�d d �Zed d � �Zdd� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Zd2d3� Zd4d5� Z d6d7� Z d8d9� Z d:d;� Z d<d=� Z d�d>d?�Z!d@dA� Z"dBdC� Z#dDdE� Z$dFdG� Z%d�dHdI�Z&d�dJdK�Z'dLdM� Z(dNdO� Z)dPdQ� Z* d�dRdS�Z+dTdU� Z,dVdW� Z-dXdY� Z.dZd[� Z/d�d]d^�Z0d�d_d`�Z1dadb� Z2dcdd� Z3dedf� Z4d�dgdh�Z5d�didj�Z6dkdl� Z7dmdn� Z8dodp� Z9dqdr� Z:dsdt� Z;dudv� Z<dwdx� Z=d�dydz�Z>d�d{d|�Z?d}d~� Z@dd�� ZAd�d�� ZBd�d�d��ZCd�d�d��ZDd�d�� ZEd�d�� ZFd�d�� ZG � d�d�d��ZHd�d�� ZId�d�d��ZJd�d�� ZKd�d�d��ZLd�d�� ZMd�d�� ZNd�d�� ZOd�d�� ZP d�d�d��ZQd�d�� ZRd�d�� ZSd�d�� ZTd�d�� ZUd�d�� ZVd�d�� ZWd�d�� ZXd�d�� ZYd�d�� ZZd�d�� Z[d�d�� Z\d�d�� Z]d�d�� Z^ d�d�d��Z_d�d�� Z`d�d�� Zad�dÄ Zbd�dń ZcdS )�� SaltNeutronz/ Class for all neutronclient functions N�networkFc K sl t jj�dd� ts dS t|tg�r$| jd|||||||d�| �� dS | jd|||||||d�| �� dS )z, Set up neutron credentials ZArgonaG The neutron module has been deprecated and will be removed in {version}. This includes * salt.utils.openstack.neutron * salt.modules.neutron * salt.pillar.neutron Please migrate to neutronng. salt.modules.neutron -> salt.modules.neutronng salt.pillar.neutron -> salt.pillar.neutronng Please update to using the neutronng moduleN)r � project_namer r r �os_auth_pluginr )r r r r r r" r r ) �salt�utilsZversionsZ warn_untilr �allr � _new_init� _old_init) �selfr r r r r r r" Zuse_keystoneauthr r r r �__init__P s: � � � � �zSaltNeutron.__init__Tc K s� |d u ri }t j�|p d�} | �� | _|�� | _|| jd< || jd< || jd< || jd< |�d�rC| �dd�| jd< | �dd�| jd< || jd < || jd < t| j�| _| j d i | j��} t j j | | d �| _ t j d d | j i| j��| _d S )Nr r r! r �3Zuser_domain_name�defaultZproject_domain_namer r )r r r r )� keystoneauth1�loadingZget_plugin_loader�copyZ client_kwargsr �endswith�getr Zload_from_optionsr ZSessionr �Client� network_conn) r( r r! r r r r r" r r r �loader�optionsr r r r& � s( � zSaltNeutron._new_initc K st | � � | _|| jd< || jd< || jd< || jd< || jd< || jd< | | jd< t| j�| _tjdi | j��| _d S ) Nr r r r r r r r )r. r r r r1 r2 ) r( r r r r r r r" r r r r r r r' � s zSaltNeutron._old_initc C sf g }| D ]}|d |kr| S |� d�|kr |�|� q|s$t�d��t|�dkr/t�d��|d S )N�id�namezResource not found.� z Multiple resource matches found.r )r0 �appendr Z MinionError�len)� resources� name_or_idr �resourcer r r �_fetch� s � zSaltNeutron._fetchc C � | � |�}|d S �Nr5 �� _fetch_port�r( r< r r r � _find_port_id� � zSaltNeutron._find_port_idc C r> r? ��_fetch_networkrB r r r �_find_network_id� rD z SaltNeutron._find_network_idc C r> r? �� _fetch_subnetrB r r r �_find_subnet_id� rD zSaltNeutron._find_subnet_idc C r> r? �� _fetch_routerrB r r r �_find_router_id� rD zSaltNeutron._find_router_idc C r> r? ��_fetch_security_grouprB r r r �_find_security_group_id� rD z#SaltNeutron._find_security_group_idc C r> r? )�_fetch_vpnservicerB r r r �_find_vpnservice_id� rD z SaltNeutron._find_vpnservice_idc C r> r? �� _fetch_ipsec_site_connectionrB r r r � _find_ipsec_site_connection_id� rD z*SaltNeutron._find_ipsec_site_connection_idc C r> r? ��_fetch_ikepolicyrB r r r �_find_ikepolicy_id� rD z SaltNeutron._find_ikepolicy_idc C r> r? ��_fetch_ipsecpolicyrB r r r �_find_ipsecpolicy_id� rD z SaltNeutron._find_ipsecpolicy_idc C r> r? ��_fetch_firewall_rulerB r r r �_find_firewall_rule_id� rD z"SaltNeutron._find_firewall_rule_idc C � | � � d }| �||�S )NZports)� list_portsr= �r( r; r: r r r rA � � zSaltNeutron._fetch_portc C r_ )NZnetworks)� list_networksr= ra r r r rF rb zSaltNeutron._fetch_networkc C r_ )NZsubnets)� list_subnetsr= ra r r r rI rb zSaltNeutron._fetch_subnetc C r_ )NZrouters)� list_routersr= ra r r r rL rb zSaltNeutron._fetch_routerc C r_ )NZsecurity_groups)�list_security_groupsr= ra r r r rO rb z!SaltNeutron._fetch_security_groupc C r_ )NZ vpnservices)�list_vpnservicesr= ra r r r rQ rb z SaltNeutron._fetch_vpnservicec C r_ )NZipsec_site_connections)�list_ipsec_site_connectionsr= ra r r r rT rb z(SaltNeutron._fetch_ipsec_site_connectionc C r_ )NZ ikepolicies)�list_ikepoliciesr= ra r r r rW rb z SaltNeutron._fetch_ikepolicyc C r_ )NZ ipsecpolicies)�list_ipsecpoliciesr= ra r r r rZ rb z SaltNeutron._fetch_ipsecpolicyc C r_ )NZfirewall_rules)�list_firewall_rulesr= ra r r r r] # rb z SaltNeutron._fetch_firewall_rulec C r_ )NZ firewalls)�list_firewallsr= ra r r r �_fetch_firewall' rb zSaltNeutron._fetch_firewallc C s | � � S )z_ Fetches tenant info in server's context for following quota operation )�get_quotas_tenant�r( r r r rn + s z SaltNeutron.get_quotas_tenantc C � | j �� S )z, Fetches all tenants quotas )r2 � list_quotasro r r r rq 2 � zSaltNeutron.list_quotasc C s | j j|d�S )zB Fetches information of a certain tenant's quotas �r )r2 � show_quota)r( r r r r rt 8 s zSaltNeutron.show_quotac C sl i } |r|| d< |r|| d< |r|| d< |r|| d< |r || d< |r&|| d< |r,|| d< | j j|d| id �S ) z) Update a tenant's quota �subnet�routerr � floatingip�port�security_group�security_group_ruleZquota)r �body)r2 � update_quota) r( r ru rv r rw rx �sec_grpZ sec_grp_ruler{ r r r r| > s zSaltNeutron.update_quotac C � | j j|d�}|r |S dS )z; Delete the specified tenant's quota value rs T)r2 � delete_quota)r( r r r r r r ] s zSaltNeutron.delete_quotac C rp )zA Fetches a list of all extensions on server side )r2 �list_extensionsro r r r r� d rr zSaltNeutron.list_extensionsc C rp )z: Fetches a list of all ports for a tenant )r2 r` ro r r r r` j rr zSaltNeutron.list_portsc C � | � |�S )z7 Fetches information of a certain port r@ )r( rx r r r � show_portp rr zSaltNeutron.show_portc C s4 | � |�}|||d�}|r||d< | jjd|id�S )z$ Creates a new port )�admin_state_upr6 � network_id� device_idrx �r{ )rG r2 � create_port)r( r6 r r� r� �net_idr{ r r r r� v s zSaltNeutron.create_portc C s( | � |�}||d�}| jj|d|id�S )z Updates a port �r6 r� rx )rx r{ )rC r2 � update_port)r( rx r6 r� �port_idr{ r r r r� � s zSaltNeutron.update_portc C �$ | � |�}| jj|d�}|r|S dS )z, Deletes the specified port )rx T)rC r2 � delete_port)r( rx r� r r r r r� � � zSaltNeutron.delete_portc C rp �z= Fetches a list of all networks for a tenant )r2 rc ro r r r rc � rr zSaltNeutron.list_networksc C r� )z: Fetches information of a certain network rE )r( r r r r � show_network� rr zSaltNeutron.show_networkc C sd ||d�} |r || d< |r|| d< |r|| d< |r || d< |r#|| d< |r)|| d< | j jd| id �S ) z' Creates a new network r� zrouter:externalzprovider:network_typezprovider:physical_networkzprovider:segmentation_id�shared�vlan_transparentr r� )r2 �create_network) r( r6 r� Z router_extZ network_typeZphysical_networkZsegmentation_idr� r� r{ r r r r� � s zSaltNeutron.create_networkc C �" | � |�}| jj|dd|iid�S )z# Updates a network r r6 )r r{ )rG r2 �update_network)r( r r6 r� r r r r� � � �zSaltNeutron.update_networkc C r� )z/ Deletes the specified network )r T)rG r2 �delete_network)r( r r� r r r r r� � r� zSaltNeutron.delete_networkc C rp r� )r2 rd ro r r r rd � rr zSaltNeutron.list_subnetsc C r� )z9 Fetches information of a certain subnet rH )r( ru r r r � show_subnet� rr zSaltNeutron.show_subnet� c C s* | � |�}||||d�}| jjd|id�S )z& Creates a new subnet )�cidr� ip_versionr� r6 ru r� )rG r2 � create_subnet)r( r r� r6 r� r� r{ r r r r� � s �zSaltNeutron.create_subnetc C r� )z" Updates a subnet ru r6 )ru r{ )rJ r2 � update_subnet)r( ru r6 � subnet_idr r r r� � r� zSaltNeutron.update_subnetc C r� )z. Deletes the specified subnet )ru T)rJ r2 � delete_subnet)r( ru r� r r r r r� � r� zSaltNeutron.delete_subnetc C rp )z< Fetches a list of all routers for a tenant )r2 re ro r r r re � rr zSaltNeutron.list_routersc C r� )z9 Fetches information of a certain router rK �r( rv r r r � show_router� rr zSaltNeutron.show_routerc C s6 ||d�}|r| � |�}d|i|d< | jjd|id�S )z& Creates a new router r� r� �external_gateway_inforv r� )rG r2 � create_router)r( r6 � ext_networkr� r{ r� r r r r� s zSaltNeutron.create_routerc K s~ | � |�}i }d|v r%|�d�du rd|d< n| �|�d��}d|i|d< |dur-||d< |dur5||d< | jj|d|id�S ) z" Updates a router r� Nr� r� r6 r� rv �rv r{ )rM r0 rG r2 � update_router)r( rv r6 r� r � router_idr{ r� r r r r� s zSaltNeutron.update_routerc C r� )z- Delete the specified router �rv T)rM r2 � delete_router)r( rv r� r r r r r� r� zSaltNeutron.delete_routerc C �( | � |�}| �|�}| jj|d|id�S )zL Adds an internal network interface to the specified router r� r� )rM rJ r2 �add_interface_router�r( rv ru r� r� r r r r� % � �z SaltNeutron.add_interface_routerc C r� )zQ Removes an internal network interface from the specified router r� r� )rM rJ r2 �remove_interface_routerr� r r r r� / r� z#SaltNeutron.remove_interface_routerc C r� )zJ Adds an external network gateway to the specified router r� r� )rM rG r2 �add_gateway_router)r( rv r r� r� r r r r� 9 r� z SaltNeutron.add_gateway_routerc C s | � |�}| jj|d�S )zO Removes an external network gateway from the specified router r� )rM r2 �remove_gateway_router)r( rv r� r r r r� C s z!SaltNeutron.remove_gateway_routerc C rp )z> Fetch a list of all floatingips for a tenant )r2 �list_floatingipsro r r r r� J rr z SaltNeutron.list_floatingipsc C � | j �|�S )z= Fetches information of a certain floatingip )r2 �show_floatingip)r( � floatingip_idr r r r� P � zSaltNeutron.show_floatingipc C s: | � |�}d|i}|r| �|�}||d< | jjd|id�S )z* Creates a new floatingip Zfloating_network_idr� rw r� )rG rC r2 �create_floatingip)r( Zfloating_networkrx r� r{ r� r r r r� V s z SaltNeutron.create_floatingipc C s8 |du r di i}n | � |�}dd|ii}| jj||d�S )zf Updates a floatingip, disassociates the floating ip if port is set to `None` Nrw r� )rw r{ )rC r2 �update_floatingip)r( r� rx r{ r� r r r r� b s z SaltNeutron.update_floatingipc C s | j �|�}|r |S dS )z2 Deletes the specified floatingip T)r2 �delete_floatingip)r( r� r r r r r� n s z SaltNeutron.delete_floatingipc C rp )zD Fetches a list of all security groups for a tenant )r2 rf ro r r r rf u rr z SaltNeutron.list_security_groupsc C r� )zA Fetches information of a certain security group rN )r( r} r r r �show_security_group{ rr z SaltNeutron.show_security_groupc C s d||d�i}| j j|d�S )z. Creates a new security group ry )r6 � descriptionr� )r2 �create_security_group)r( r6 �descr{ r r r r� � s z!SaltNeutron.create_security_groupc C sB | � |�}di i}|r||d d< |r||d d< | jj||d�S )z* Updates a security group ry r6 r� r� )rP r2 �update_security_group)r( r} r6 r� � sec_grp_idr{ r r r r� � s z!SaltNeutron.update_security_groupc C �" | � |�}| j�|�}|r|S dS )z6 Deletes the specified security group T)rP r2 �delete_security_group)r( r} r� r r r r r� � � z!SaltNeutron.delete_security_groupc C rp )zI Fetches a list of all security group rules for a tenant )r2 �list_security_group_rulesro r r r r� � rr z%SaltNeutron.list_security_group_rulesc C s | j �|�d S )zF Fetches information of a certain security group rule rz )r2 �show_security_group_rule)r( �sec_grp_rule_idr r r r� � s �z$SaltNeutron.show_security_group_rule�ingressc C s0 | � |�}|||||||d�} | jjd| id�S )z3 Creates a new security group rule )Zsecurity_group_idZremote_group_id� direction�protocol�port_range_min�port_range_maxZ ethertyperz r� )rP r2 �create_security_group_rule) r( r} Z remote_grp_idr� r� r� r� Zetherr� r{ r r r r� � s � �z&SaltNeutron.create_security_group_rulec C r~ )z; Deletes the specified security group rule )rz T)r2 �delete_security_group_rule)r( r� r r r r r� � s � z&SaltNeutron.delete_security_group_rulec K s | j j|fi |��S )zL Fetches a list of all configured VPN services for a tenant )r2 rg )r( Z retrieve_allr r r r rg � s z SaltNeutron.list_vpnservicesc K s | � |�}| jj|fi |��S )z? Fetches information of a specific VPN service )rR r2 �show_vpnservice)r( � vpnservicer � vpnservice_idr r r r� � s zSaltNeutron.show_vpnservicec C s4 | � |�}| �|�}||||d�}| jjd|id�S )z+ Creates a new VPN service )r� r� r6 r� r� r� )rJ rM r2 �create_vpnservice)r( ru rv r6 r� r� r� r{ r r r r� � s �z SaltNeutron.create_vpnservicec C s& | � |�}d|i}| jj|d|id�S )z' Updates a VPN service r� r� r� )rR r2 �update_vpnservice)r( r� r� r� r{ r r r r� � s �z SaltNeutron.update_vpnservicec C r� )z3 Deletes the specified VPN service T)rR r2 �delete_vpnservice)r( r� r� r r r r r� � r� z SaltNeutron.delete_vpnservicec C rp )zL Fetches all configured IPsec Site Connections for a tenant )r2 rh ro r r r rh � rr z'SaltNeutron.list_ipsec_site_connectionsc C r� )zG Fetches information of a specific IPsecSiteConnection rS )r( �ipsec_site_connectionr r r �show_ipsec_site_connection rr z&SaltNeutron.show_ipsec_site_connectionc K s� | � |�} | �|�} | �|�} || | |g| | |||d� }d| v r&| d |d< d| v r0| d |d< d| v r<d| d i|d< d| v rPd|vrHi |d< | d |d d< d | v rdd|vr\i |d< | d |d d < | jjd |id �S ) z3 Creates a new IPsecSiteConnection ) �psk�ipsecpolicy_idr� � peer_cidrs� ikepolicy_idr� � peer_address�peer_idr6 Z initiatorZmtuZ dpd_action�actionZdpdZ dpd_interval�intervalZ dpd_timeoutr r� r� )r[ rX rR r2 � create_ipsec_site_connection)r( r6 � ipsecpolicy� ikepolicyr� r� r� r� r� r� r r� r� r� r{ r r r r� s< � �z(SaltNeutron.create_ipsec_site_connectionc C r� )z; Deletes the specified IPsecSiteConnection T)rU r2 � delete_ipsec_site_connection)r( r� Zipsec_site_connection_idr r r r r� 7 s � z(SaltNeutron.delete_ipsec_site_connectionc C rp )zK Fetches a list of all configured IKEPolicies for a tenant )r2 ri ro r r r ri A rr z SaltNeutron.list_ikepoliciesc C r� )z= Fetches information of a specific IKEPolicy rV )r( r� r r r �show_ikepolicyG rr zSaltNeutron.show_ikepolicyc K � d|i}d|v r|d |d< d|v r|d |d< d|v r"|d |d< d|v r,|d |d< d|v r6|d |d< d|v rBd|d i|d< d |v rVd|vrNi |d< |d |d d < | j jd |id �S ) z) Creates a new IKEPolicy r6 Zphase1_negotiation_mode�auth_algorithm�encryption_algorithm�pfsZ ike_version�units�lifetime�valuer� r� )r2 �create_ikepolicy�r( r6 r r{ r r r r� M �$ z SaltNeutron.create_ikepolicyc C r� )z1 Deletes the specified IKEPolicy T)rX r2 �delete_ikepolicy)r( r� r� r r r r r� d r� z SaltNeutron.delete_ikepolicyc C rp )zM Fetches a list of all configured IPsecPolicies for a tenant )r2 rj ro r r r rj l rr z SaltNeutron.list_ipsecpoliciesc C r� )z? Fetches information of a specific IPsecPolicy rY )r( r� r r r �show_ipsecpolicyr rr z SaltNeutron.show_ipsecpolicyc K r� ) z+ Creates a new IPsecPolicy r6 Ztransform_protocolr� Zencapsulation_moder� r� r� r� r� r� r� )r2 �create_ipsecpolicyr� r r r r� x r� z SaltNeutron.create_ipsecpolicyc C r� )z3 Deletes the specified IPsecPolicy T)r[ r2 �delete_ipsecpolicy)r( Z ipseecpolicyZipseecpolicy_idr r r r r� � r� z SaltNeutron.delete_ipsecpolicyc C rp )zN Fetches a list of all configured firewall rules for a tenant )r2 rk ro r r r rk � rr z SaltNeutron.list_firewall_rulesc C r� )zA Fetches information of a specific firewall rule r\ )r( � firewall_ruler r r �show_firewall_rule� rr z SaltNeutron.show_firewall_rulec K s� ||d�}d|v r|d |d< d|v r|d |d< d|v r#|d |d< d|v r-|d |d< d|v r7|d |d< d|v rA|d |d< d|v rK|d |d< d |v rU|d |d < | j jd |id �S ) z, Create a new firlwall rule )r� r� r r6 r� r� �source_ip_address�destination_portr� �enabledr� r� )r2 �create_firewall_rule)r( r� r� r r{ r r r r� � s$ z SaltNeutron.create_firewall_rulec C r� )z5 Deletes the specified firewall rule T)r^ r2 �delete_firewall_rule)r( r� Zfirewall_rule_idr r r r r� � r� z SaltNeutron.delete_firewall_rulec C s� i } |r|| d< |r|| d< |r|| d< |r|| d< |r || d< |r&|| d< |r,|| d< | r2| | d< | r8| | d < | r>| | d < | rD| | d < | j j|d | id �S )z( Update a firewall rule r� r� r6 r� r� r� �destination_ip_address� source_portr� r� r� r� r� )r2 �update_firewall_rule)r( r� r� r� r6 r� r� r� r� r� r� r� r� r{ r r r r� � s4 �z SaltNeutron.update_firewall_rulec C rp )z> Fetches a list of all firewalls for a tenant )r2 rl ro r r r rl � rr zSaltNeutron.list_firewallsc C r� )z< Fetches information of a specific firewall )rm )r( Zfirewallr r r � show_firewall� rr zSaltNeutron.show_firewallc C r� )z! List L3 agents. )r2 � list_l3_agent_hosting_routersr� r r r r� � r� z)SaltNeutron.list_l3_agent_hosting_routersc C rp )z List agents. )r2 � list_agentsro r r r r� rr zSaltNeutron.list_agents)NNr NF)NT)NNNNNNN)T)TNNNNNN)Nr� r )NN)Nr� NNNN) NNNNNNNNNNN)d�__name__� __module__� __qualname__�__doc__r) r& r' � staticmethodr= rC rG rJ rM rP rR rU rX r[ r^ rA rF rI rL rO rQ rT rW rZ r] rm rn rq rt r| r r� r` r� r� r� r� rc r� r� r� r� rd r� r� r� r� re r� r� r� r� r� r� r� r� r� r� r� r� r� rf r� r� r� r� r� r� r� r� rg r� r� r� r� rh r� r� r� ri r� r� r� rj r� r� r� rk r� r� r� r� rl r� r� r� r r r r r K s �? �0 � � � � �0 �- r )r� ZloggingZsalt.utils.versionsr# r r Zneutronclient.shellr Zneutronclient.v2_0r � ImportErrorr Zkeystoneauth1.loadingr, Zkeystoneauth1.sessionZ getLoggerr� �logr r r r r r r r �<module> s2 � �
Save