File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/equinixmetal.cpython-310.pyc
Back
o ;joe � @ s� d Z zddlZW n ey dZY nw ddlZddlmZ ddlmZmZ ddl m Z m Z m Z m Z mZmZ ddlmZmZmZ dZdZd d � ZG d d � d e�ZG d d� de�ZG dd� de�ZG dd� d�ZdS )z Equinix Metal Driver � N)�httplib)� JsonResponse� ConnectionKey)�Node�KeyPair�NodeSize� NodeImage� NodeDriver� NodeLocation)�Provider� NodeState�InvalidCredsErrorzapi.equinix.comTc C s t d uotS �N)�asyncio�USE_ASYNC_IO_IF_AVAILABLE� r r �Y/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/equinixmetal.py� use_asyncio% � r c @ s0 e Zd ZejejejejgZdd� Z dd� Z dS )�EquinixMetalResponsec C st | j tjkr| �� }t|�d���| �� }d|v r'd�|�d�| j �}t|��d|v r4|�d�}t|��|}t|��)N�error�messagez {} (code: {})�errors)�statusr � UNAUTHORIZEDZ parse_bodyr �get�format� Exception)�self�bodyr r r r � parse_error1 s � �z EquinixMetalResponse.parse_errorc C s | j | jv S r )r �valid_response_codes�r r r r �success@ r z EquinixMetalResponse.successN) �__name__� __module__� __qualname__r �OK�ACCEPTED�CREATED� NO_CONTENTr! r r# r r r r r ) s � r c @ s e Zd ZdZeZeZdd� ZdS )�EquinixMetalConnectionz8 Connection class for the Equinix Metal driver. c C s d|d< | j |d< d|d< |S )zB Add headers that are necessary for every request zapplication/jsonz Content-Typez X-Auth-TokenZ@kcrhMn7hwG8Ceo2hAhGFa2qpxLBvVHxEjS9ue8iqmsNkeeB2iQgMq4dNc1893pYuzX-Consumer-Token��key)r �headersr r r �add_default_headersL s �z*EquinixMetalConnection.add_default_headersN) r$ r% r& �__doc__�EQUINIXMETAL_ENDPOINT�hostr Z responseClsr/ r r r r r+ D s r+ c s e Zd ZdZeZejZdZ dZ e j e j e j e j e j e j e je je je je jd� Zdl� fdd� Zedd � �Zd d � Zdld d �Zdd� Zdmdd�Zdd� Zdd� Zdldd�Z dndd �Z d d � Z d d � Z d!d"� Z d#d$� Z!d%d&� Z"d'd(� Z#d)d*� Z$d+d,� Z%d-d.� Z&d/d0� Z'dod2d3�Z(d4d5� Z)d6d7� Z*d8d9� Z+d:d;� Z,d<d=� Z-d>d?� Z.d@dA� Z/dBdC� Z0dDdE� Z1dFdG� Z2dldHdI�Z3dJdK� Z4dLdM� Z5dNdO� Z6dldPdQ�Z7dpdSdT�Z8dUdV� Z9dqdXdY�Z:dqdZd[�Z;drd]d^�Z< \drd_d`�Z=dldadb�Z> c 1 1dsddde�Z?dtdfdg�Z@dldhdi�ZAdjdk� ZB� ZCS )u�EquinixMetalNodeDriverz" Equinix Metal NodeDriver Z EquinixMetalzhttps://metal.equinix.com/) ZqueuedZ provisioningZ rebuildingZ powering_onZ powering_offZ rebootingZinactiveZdeletedZdeprovisioningZfailedZactiveNc s0 t � j|d� || _d| _|| _d| _d| _dS )a Initialize a NodeDriver for Equinix Metal using the API token and optionally the project (name or id). If project name is specified we validate it lazily and populate self.project_id during the first access of self.projects variable r, NF)�super�__init__� project_name� project_id�_project�_projects_populated� _projects)r r- �project�� __class__r r r5 q s z EquinixMetalNodeDriver.__init__c C sX | j s)| �� | _d| _ | jr)| jD ]}| j|j|jfv r"|j| _ nq| js)d| _| jS )z� Lazily retrieve projects and set self.project_id variable on initial access to self.projects variable. TN)r9 �ex_list_projectsr: r8 �name�idr7 r6 )r Z project_objr r r �projects� s �z EquinixMetalNodeDriver.projectsc C s2 g }| j �d�j}|�d�}|rdd� |D �}|S )Nz/metal/v1/projectsrA c S s g | ]}t |��qS r )�Project)�.0r; r r r � <listcomp>� s z;EquinixMetalNodeDriver.ex_list_projects.<locals>.<listcomp>�� connection�request�objectr )r rA �datar r r r> � s z'EquinixMetalNodeDriver.ex_list_projectsc C s\ |r| j |d�S | jr| j | jd�S t� s)g }| jD ] }|�| j |jd�� q|S | �d�S )N)� ex_project_id�nodes)�ex_list_nodes_for_projectr7 r rA �extendr@ �list_resources_async)r rJ rK r; r r r � list_nodes� s z!EquinixMetalNodeDriver.list_nodesc C st |dv sJ �t � }t� }td| ||� zt�� }W n ty. t�t�� � t�� }Y nw |�|d |d ��S )N)rK a� import asyncio @asyncio.coroutine def _list_async(driver): projects = [project.id for project in driver.projects] loop = asyncio.get_event_loop() futures = [ loop.run_in_executor(None, driver.ex_list_%s_for_project, p) for p in projects ] retval = [] for future in futures: result = yield from future retval.extend(result) return retvalZ _list_asyncr ) �globals�locals�execr Zget_event_loop� RuntimeErrorZset_event_loopZnew_event_loopZrun_until_complete)r Z resource_type�glob�locZloopr r r rN � s" �� �z+EquinixMetalNodeDriver.list_resources_async�plan� �� c C s6 |||d�}| j jd| |d�jd }tt| j|��S )N��include�page�per_page� /metal/v1/projects/%s/devices��params�devices)rF rG rH �list�map�_to_node)r rJ rZ r[ r\ r_ rI r r r rL � s ��z0EquinixMetalNodeDriver.ex_list_nodes_for_projectc C �" | j �d�jd }tt| j|��S )N�/metal/v1/locations/metros�metros)rF rG rH ra rb � _to_location�r rI r r r �list_locations� � z%EquinixMetalNodeDriver.list_locationsc C rd )Nz/metal/v1/operating-systemsZoperating_systems)rF rG rH ra rb � _to_imagerh r r r � list_images� rj z"EquinixMetalNodeDriver.list_imagesc s` |p� j pt� j�o� jd j}|r � j�d| �jd }n � j�d�jd }� fdd�|D �S )Nr z/metal/v1/projects/%s/plansZplansz/metal/v1/plansc s$ g | ]}|� d �dkr� �|��qS )�lineZ baremetal)r �_to_size)rC �sizer" r r rD s $ z5EquinixMetalNodeDriver.list_sizes.<locals>.<listcomp>)r7 �lenrA r@ rF rG rH )r rJ r7 rI r r" r � list_sizes� s ��z!EquinixMetalNodeDriver.list_sizesc K s� | j r| j }n|s td��|jd } | jstd��||j|j| ddd�} |r*|| d< | �|� |r5|| d< | jjd | t � | �d d �} | j � d d �} | dkrb| j � dd�} | j � d| �}td| ��| j | j d�}|S )zh Create a node. :return: The newly created node. :rtype: :class:`Node` z#ex_project_id needs to be specified�codezLFailed to create node: valid parameter metro [code] is required in the inputrV Zhourly)�hostnamerV �operating_system�metrorZ � billing_cycle� ip_addresses�userdatar] �POST)rI �methodr r' �ERRORr N� error_messagezFailed to create node: %s)rI )r7 r �extra�_valid_location� ValueErrorr@ �updaterF rG �json�dumpsrH r rc )r r? ro �image�locationrJ rw Z cloud_init�kwargsZ location_coder_ rI r r r| �noder r r � create_node sB �� � z"EquinixMetalNodeDriver.create_nodec C �, ddi}| j jd|j |dd�}|jtjkS )N�typeZreboot� /metal/v1/devices/%s/actionsry �r_ rz �rF rG r@ r r r' �r r� r_ �resr r r � reboot_nodeK � � z"EquinixMetalNodeDriver.reboot_nodec C r� )Nr� Zpower_onr� ry r� r� r� r r r � start_nodeS r� z!EquinixMetalNodeDriver.start_nodec C r� )Nr� Z power_offr� ry r� r� r� r r r � stop_node[ r� z EquinixMetalNodeDriver.stop_nodec C s" | j jd|j dd�}|jtjkS )N�/metal/v1/devices/%s�DELETE�rz r� )r r� r� r r r � destroy_nodec s z#EquinixMetalNodeDriver.destroy_nodec C � | j |d�S �N)r� )r� �r r� r r r � ex_start_nodeh � z$EquinixMetalNodeDriver.ex_start_nodec C r� r� )r� r� r r r � ex_stop_nodeo r� z#EquinixMetalNodeDriver.ex_stop_nodec C r� )Nr� Z reinstallr� ry r� r� r� r r r �ex_reinstall_nodev r� z(EquinixMetalNodeDriver.ex_reinstall_nodec C r� )Nr� Zrescuer� ry r� r� r� r r r �ex_rescue_node~ r� z%EquinixMetalNodeDriver.ex_rescue_nodec K s( d|j }| jj||dd�}|jtjkS )Nr� �PUTr� )r@ rF rG r r r' )r r� r� �pathr� r r r �ex_update_node� s z%EquinixMetalNodeDriver.ex_update_nodec C s& d|j }||d�}| jj||d�jS )Nz /metal/v1/devices/%s/bandwidth)�fromZuntilr^ �r@ rF rG rH )r r� Z from_timeZ until_timer� r_ r r r �ex_get_node_bandwidth� s z,EquinixMetalNodeDriver.ex_get_node_bandwidth� c C s$ d|j }d|i}| jj||d�jS )N�/metal/v1/devices/%s/ipsrZ r^ r� )r r� rZ r� r_ r r r � ex_list_ip_assignments_for_node� s z6EquinixMetalNodeDriver.ex_list_ip_assignments_for_nodec C rd )z� List all the available SSH keys. :return: Available SSH keys. :rtype: ``list`` of :class:`.KeyPair` objects �/metal/v1/ssh-keys�ssh_keys)rF rG rH ra rb � _to_key_pairsrh r r r �list_key_pairs� s z%EquinixMetalNodeDriver.list_key_pairsc C s( ||d�}| j jdd|d�j}| �|�S )z� Create a new SSH key. :param name: Key name (required) :type name: ``str`` :param public_key: Valid public key string (required) :type public_key: ``str`` )�labelr- r� ry )rz r_ )rF rG rH r� )r r? � public_keyr_ rI r r r �create_key_pair� s z&EquinixMetalNodeDriver.create_key_pairc C s& |j }| jjd| dd�}|jtjkS )z� Delete an existing SSH key. :param key: SSH key (required) :type key: :class:`KeyPair` z/metal/v1/ssh-keys/%sr� r� )r? rF rG r r r* )r r- Zkey_idr� r r r �delete_key_pair� s z&EquinixMetalNodeDriver.delete_key_pairc C sX i }g d�}d|v r| j �|d tj�}ntj}d|v r2|d d ur2| �|d �}|d }|d }ng }g }d|v rQ|d d urQ| �|d �}|d �d�|d< nd }d|v rn|d d urn| �|d �} |d �d �|d< nd } d |v rz|d |d < d |v r�|d d ur�|d |d < |D ] } | |v r�|| || < q�t|d |d |||| ||| d� } | S )N) � created_at� updated_atrx rv �lockedZiqnr� r; � description�staterw �public�privatert r? rV �slugZfacilityru r@ rs ) r@ r? r� � public_ips� private_ipsro r� r} �driver)�NODE_STATE_MAPr r �UNKNOWN� _parse_ipsrk rn r ) r rI r} Z extra_keysr� �ipsr� r� r� ro r- r� r r r rc � sN �� z EquinixMetalNodeDriver._to_nodec C s4 |d |d |� dg �d�}t|d |d || d�S )N�distro�versionZprovisionable_on)r� r� Zsupported_sizesr� r? )r@ r? r} r� )r r �r rI r} r r r rk � s �z EquinixMetalNodeDriver._to_imagec C s |}t |d |d d | |d�S )Nr@ r? )r@ r? Zcountryr� r} )r r� r r r rg s �z#EquinixMetalNodeDriver._to_locationc C sv z |d d d � d�}W n ty d }Y nw dd� |� dg �D �}|d |d ||d �}z+d }|d d d }d|v rGd}|�dd�}n d|v rSd}|�dd�}t|�| }W n tye d }Y nw d }|d � dd�r�d}|d d D ]$} | d �dd�} d| v r�t| d �dd��d } || d t| � 7 }qxd�|� d�|�} |d � d�} t|d | ||d| || d�S ) NZspecs�cpusr �countc S s g | ] }|� d ��dd��qS )�hrefre r� )r �replace)rC Zregionr r r rD s ��z3EquinixMetalNodeDriver._to_size.<locals>.<listcomp>Zavailable_in_metrosr� rm )r� rm r� �regionsrW Zmemory�totalZGBi r� ZTBi Zdrivesro rX z {} - {} RAMr? Zpricing�hourr� )r@ r? �ram�diskZ bandwidth�pricer} r� )r �KeyErrorr� �intr �floatr r ) r rI r� r� r} ZfactorZram_txtr� r� ZdisksZ disk_sizer? r� r r r rn s\ � �� ��z EquinixMetalNodeDriver._to_sizec C s8 |d |d |d d�}t |d |d |d d | |d�S ) Nr� r� r� )r� r� r� r@ � fingerprintr- )r? r� r� Z private_keyr� r} )r r� r r r r� B s ��z$EquinixMetalNodeDriver._to_key_pairsc C sb g }g }|D ]%}d|v r+|d d ur+d|v r$|d du r$|� |d � q|� |d � q||d�S )N�addressr� T)r� r� )�append)r rI r� r� r� r r r r� R s � z!EquinixMetalNodeDriver._parse_ipsc C � d| }| j �|�jS )Nz /metal/v1/projects/%s/bgp-config�rF rG rH �r rJ r� r r r � ex_get_bgp_config_for_project_ � z4EquinixMetalNodeDriver.ex_get_bgp_config_for_projectc C sV |r|g}n| j r| j g}ndd� | jD �}g }|D ]}| �|�}|r(|�|� q|S )Nc S � g | ]}|j �qS r �r@ �rC �pr r r rD j � z<EquinixMetalNodeDriver.ex_get_bgp_config.<locals>.<listcomp>)r7 rA r� r� )r rJ rA �retvalr� Zconfigr r r �ex_get_bgp_configd s �z(EquinixMetalNodeDriver.ex_get_bgp_configc C r� )N�/metal/v1/bgp/sessions/%sr� )r � session_uuidr� r r r �ex_get_bgp_sessionu r� z)EquinixMetalNodeDriver.ex_get_bgp_sessionc C s d|j }| j�|�jS )N�!/metal/v1/devices/%s/bgp/sessionsr� )r r� r� r r r � ex_list_bgp_sessions_for_nodez s z4EquinixMetalNodeDriver.ex_list_bgp_sessions_for_nodec C r� )Nz"/metal/v1/projects/%s/bgp/sessionsr� r� r r r � ex_list_bgp_sessions_for_project r� z7EquinixMetalNodeDriver.ex_list_bgp_sessions_for_projectc C sR |r|g}n| j r| j g}ndd� | jD �}g }|D ] }|�| �|�d � q|S )Nc S r� r r� r� r r r rD � r� z?EquinixMetalNodeDriver.ex_list_bgp_sessions.<locals>.<listcomp>Z bgp_sessions)r7 rA rM r� )r rJ rA r� r� r r r �ex_list_bgp_sessions� s z+EquinixMetalNodeDriver.ex_list_bgp_sessions�ipv4c C s* d|j }d|i}| jj||dd�}|jS )Nr� �address_familyry r� r� )r r� r� r� r_ r� r r r �ex_create_bgp_session� s z,EquinixMetalNodeDriver.ex_create_bgp_sessionc C s$ d| }| j j|dd�}|jtjkS )Nr� r� r� )rF rG r r r' )r r� r� r� r r r �ex_delete_bgp_session� s z,EquinixMetalNodeDriver.ex_delete_bgp_session� c C �( d|j }|||d�}| jj||d�jS )Nz/metal/v1/devices/%s/eventsrY r^ r� )r r� rZ r[ r\ r� r_ r r r �ex_list_events_for_node� � z.EquinixMetalNodeDriver.ex_list_events_for_nodec C r� )Nz /metal/v1/projects/%s/eventsrY r^ r� )r r; rZ r[ r\ r� r_ r r r �ex_list_events_for_project� r� z1EquinixMetalNodeDriver.ex_list_events_for_projectFc C sP |r|g}n| j r| j g}ndd� | jD �}g }|D ] }|�| �||�� q|S )Nc S r� r r� r� r r r rD � r� zDEquinixMetalNodeDriver.ex_describe_all_addresses.<locals>.<listcomp>)r7 rA rM �%ex_describe_all_addresses_for_project)r rJ �only_associatedrA r� r; r r r �ex_describe_all_addresses� s z0EquinixMetalNodeDriver.ex_describe_all_addressesc s@ d| }d|i}| j j||d�j}� fdd�|�dg �D �}|S )a� Returns all the reserved IP addresses for this project optionally, returns only addresses associated with nodes. :param only_associated: If true, return only the addresses that are associated with an instance. :type only_associated: ``bool`` :return: List of IP addresses. :rtype: ``list`` of :class:`dict` �/metal/v1/projects/%s/ipsrZ r^ c s( g | ]}� rt |�d g ��dkr|�qS )Z assignmentsr )rp r )rC �a�r� r r rD � s ��zPEquinixMetalNodeDriver.ex_describe_all_addresses_for_project.<locals>.<listcomp>rw rE )r rJ rZ r� r� r_ rw �resultr r� r r� � s � �z<EquinixMetalNodeDriver.ex_describe_all_addresses_for_projectc C s& d| }d|i}| j j||d�j}|S )N�/metal/v1/ips/%srZ r^ r� )r Z ex_address_idrZ r� r_ r� r r r �ex_describe_address� s �z*EquinixMetalNodeDriver.ex_describe_address� global_ipv4c C sN d| }||d�}|r||d< |r||d< |r||d< | j j||dd�j} | S )Nr� )r� �quantityru �comments� customdatary r� r� ) r rJ Z location_idr� r� r� r� r� r_ r� r r r � ex_request_address_reservation� s �z5EquinixMetalNodeDriver.ex_request_address_reservationc C s. d|j }|||d�}| jj||dd�j}|S )Nr� )r� � manageabler� ry r� r� )r r� r� r� r� r� r_ r� r r r � ex_associate_address_with_node� s �z5EquinixMetalNodeDriver.ex_associate_address_with_nodec C s0 d| }i }|r ||d< | j j||dd�j}|S )Nr� rZ r� r� r� )r Z address_uuidrZ r� r_ r� r r r �ex_disassociate_address s z.EquinixMetalNodeDriver.ex_disassociate_addressc C s: |sdS | j �d�jd }|D ] }|d |kr dS qdS )NFre rf rr Tr� )r Z metro_coderf ru r r r r~ s �z&EquinixMetalNodeDriver._valid_locationr )rV rW rX )NNN)r� )r� )NrW r� )NF)Nr� rW r� r� )Fr� )Dr$ r% r& r0 r+ Z connectionClsr Z EQUINIXMETALr� r? Zwebsiter ZPENDINGZ REBOOTINGZSTOPPEDZ TERMINATEDr{ ZRUNNINGr� r5 �propertyrA r> rO rN rL ri rl rq r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rc rk rg rn r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r~ � __classcell__r r r< r r3 Y s� � $ �@ ? 5 � � r3 c @ s e Zd Zdd� Zdd� ZdS )rB c C s� |� d�| _|� d�| _i | _|� d�| jd< |� d�| jd< |� d�| jd< |� d�| jd< |� d�| jd< |� d�| jd< |� d �| jd < |� d �| jd < |� d �| jd < |� d �| jd < d S ) Nr@ r? Z max_devicesZpayment_methodr� Z credit_amountr` Z invitationsZ membershipsr� �membersr� )r r@ r? r} )r r; r r r r5 s zProject.__init__c C s d| j | jf S )Nz<Project: id=%s, name=%s>)r@ r? r" r r r �__repr__) s zProject.__repr__N)r$ r% r& r5 r r r r r rB s rB )r0 r � ImportErrorr� Zlibcloud.utils.py3r Zlibcloud.common.baser r Zlibcloud.compute.baser r r r r r Zlibcloud.compute.typesr r r r1 r r r r+ r3 rB r r r r �<module> s. � E
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings