File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/container/drivers/__pycache__/lxd.cpython-310.pyc
Back
o ;j[� � @ s| d dl Z d dlZd dlZd dlZd dlmZmZ d dlmZm Z m Z d dl m Z d dl mZ d dlmZmZmZ d dlmZ d dlmZ d d lmZ zd dlZW n ey] d dlZY nw d gZ g d �Z g d �Z d Z dd� Z dd� Z!dd� Z"G dd� de�Z#G dd� d�Z$G dd� d�Z%G dd� d�Z&e�'d g d ��Z(G d d � d e�Z)G d d!� d!e �Z*G d"d#� d#e �Z+G d$d%� d%e�Z,dS )&� N)�b�httplib)� JsonResponse�ConnectionUserAndKey�KeyCertificateConnection)�InvalidCredsError)� StorageVolume)� Container�ContainerImage�ContainerDriver)�ContainerState)� BaseHTTPError)�ProviderZSuccess)�stop�start�restart�freeze�unfreeze)�imageZ migration�copy�none�errorc C s* ddg}|D ] }| � |�r| �|�} q| S )Nzhttp://�https://)� startswith�strip)�host�prefixes�prefix� r �R/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/container/drivers/lxd.py�strip_http_prefix/ s �r c K s | du s|du r t d��| dks|dkrt d��d|�� v r;| �d�}|d |d vr;t dt|d � d |d ��d |�� v r^|�d�}|d |d vr^t d t|d � d |d ��tj�| �}tj�|�ootj�|�}|svt d ��tj�|�}tj�|�o�tj�|�}|s�t d ��dS ) zH Basic checks for the provided certificates in LXDtlsConnection NzJTLS Connection requires specification of a key file and a certificate file� Zkey_files_allowed�.���zValid key files are: zyou provided: Zcert_files_allowedz Valid certification files are: zRYou need a key file to authenticate with LXD tls. This can be found in the server.zZYou need a certificate file to authenticate with LXD tls. This can be found in the server.) r �keys�split�str�os�path� expanduser�exists�isfile)�key_file� cert_file�kwargsZkey_file_suffixZcert_file_suffixZkeypathZ is_file_pathZcertpathr r r �check_certificates8 sZ �� ���� ���� � ��r/ c C sD | d t kr td| d��| d |kr d�|| d �}t|| d��dS )zS Basic checks that the response is of the type the client is expecting �typezresponse type is error)�message� response_dict� status_codez*Status code should be {} but is {}N)�LXD_ERROR_STATUS_RESP�LXDAPIException�format)r2 r3 �msgr r r �assert_responset s � �r8 c s* e Zd ZdZd � fdd� Zdd� Z� ZS ) r5 zW Basic exception to be thrown when LXD API returns with some kind of error �Unknown Error OccurredNr! c s" || _ || _|| _t� �|� d S �N)r1 r2 r0 �super�__init__)�selfr1 r2 � error_type�� __class__r r r< � s zLXDAPIException.__init__c C s | j S r: �r1 �r= r r r �__str__� s zLXDAPIException.__str__)r9 Nr! )�__name__� __module__� __qualname__�__doc__r< rC � __classcell__r r r? r r5 � s r5 c @ s e Zd ZdZdd� ZdS )�LXDStoragePoolzj Utility class representing an LXD storage pool https://lxd.readthedocs.io/en/latest/storage/ c C s" || _ || _|| _|| _|| _d S r: ��name�driver�used_by�config�managed)r= rK rL rM rN rO r r r r< � s zLXDStoragePool.__init__N)rD rE rF rG r< r r r r rI � s rI c @ s$ e Zd ZdZedd� �Zdd� ZdS )� LXDNetworkz3 Utility class representing an LXD network c C s� t � }|�dd �|_|�dd �|_|�dd �|_|�dd �|_|�dd �|_|�dd �|_|�dd �|_|�dd �|_ |�dd �|_ |S ) NrK � descriptionr0 rN �status� locationsrO rM ) rP �getrK �idrQ r0 rN rR rS rO rM )�cls�metadataZ lxd_networkr r r �build_from_response� s z LXDNetwork.build_from_responsec C s@ d | _ d | _d | _d | _d | _d | _d | _d | _d | _i | _ d S r: ) rK rU rQ r0 rN rR rS rO rM �extrarB r r r r< � s zLXDNetwork.__init__N)rD rE rF rG � classmethodrX r< r r r r rP � s rP c @ s, e Zd ZdZedd� �Zdd� Zdd� ZdS ) � LXDServerInfoz& Wraps the response form /1.0 c C sl t � }|�dd �|_|�dd �|_|�dd �|_|�dd �|_|�dd �|_|�dd �|_|�dd �|_|S )N�api_extensions� api_status� api_version�authrN � environment�public) r[ rT r\ r] r^ r_ rN r` ra )rV rW Z server_infor r r rX � s z!LXDServerInfo.build_from_responsec C s. d | _ d | _d | _d | _d | _d | _d | _d S r: )r\ r] r^ r_ rN r` ra rB r r r r< � s zLXDServerInfo.__init__c C sF t | j�t | j� t | j� t | j� t | j� t | j� t | j� S r: )r& r\ r] r^ r_ rN r` ra rB r r r rC � s �������zLXDServerInfo.__str__N)rD rE rF rG rZ rX r< rC r r r r r[ � s r[ �LXDContainerExecuteResult��uuidZsecret_0Zsecret_1Zsecret_2�control�output�resultc @ s8 e Zd ZejejejejgZdd� Z dd� Z dd� Z dS )� LXDResponsec C s� t | j�dkr | js | jS z@| j�dd�}|dks |dkrH| j�d�dkr?d| jjv r?dd � | j�� �d d�� d �D �}W |S t � | j�}W |S | j}W |S t yo t �d | j�}|rf|�d �}t|��d| j }t|��w )Nr z content-type�application/jsonr! ztransfer-encoding�chunkedZ fromImagec S s g | ]}t �|��qS r )�json�loads)�.0�chunkr r r � <listcomp> s ��z*LXDResponse.parse_body.<locals>.<listcomp>� � z Error: (.+?)"� z8ConnectionError: Failed to parse JSON response (body=%s))�len�bodyZparse_zero_length_body�headersrT �request�urlr �replacer% rk rl � ValueError�re�search�group� Exception)r= � content_typert �mZ error_msgr7 r r r � parse_body s. �� � � �zLXDResponse.parse_bodyc C s | j dkr td��| jS )Ni� zInvalid credentials)rR r rt rB r r r � parse_error0 s zLXDResponse.parse_errorc C s | j | jv S r: )rR �valid_response_codesrB r r r �success5 s zLXDResponse.successN) rD rE rF r �OK�ACCEPTED�CREATED� NO_CONTENTr� r� r� r� r r r r rh s � rh c @ s e Zd ZeZdZdd� ZdS )� LXDConnection�< c C sD d|d< | j r | jr t�td�| j | j���}d|�d� |d< |S )z� Add parameters that are necessary for every request If user and password are specified, include a base http auth header ri � Content-Typez{}:{}zBasic %szutf-8Z Authorization)Zuser_id�key�base64� b64encoder r6 �decode)r= ru Zuser_b64r r r �add_default_headers= s z!LXDConnection.add_default_headersN)rD rE rF rh � responseCls�timeoutr� r r r r r� 9 s r� c s8 e Zd ZeZ d � fdd� Zdd � Z� ZS ) �LXDtlsConnectionT� localhost� r! Nc sZ | d ur | ||d� n t d||d�| �� t� j|||||d d d d d d� || _|| _d S )N)r, r- ) r, r- �securer �portrw Z proxy_urlr� �backoffZ retry_delayr )r/ r; r< r, r- ) r= r� �secretr� r r� �ca_certr, r- �certificate_validatorr. r? r r r< M s" � zLXDtlsConnection.__init__c C s d|d< |S )Nri r� r )r= ru r r r r� o s z$LXDtlsConnection.add_default_headers)Tr� r� r! NNN)rD rE rF rh r� r< r� rH r r r? r r� J s �"r� c s, e Zd ZdZejZdZdZe Z dZ dZ dZ dZdZdZdddd d d d d ef � fd d � Zdd� Zdd� Zdd� Zd d ded ed d d e f dd�Zdkdd�Ze ddfdd�Ze ddfdd �Ze ddfd d �Ze fd d �Ze fd!d"�Z e fd#d$�Z d%d&� Z dld'd(�Z d)d*� Z e fd+d,�Z!d-d.� Z"d/d0� Z#dkd1d2�Z$d3d4� Z%d5d6� Z&d7d8� Z'dkd9d:�Z(d;d<� Z)dmd>d?�Z*d@dA� Z+e fdBdC�Z,dDdE� Z-dFdG� Z.dHdI� Z/dJdK� Z0dLdM� Z1dNdO� Z2dPdQ� Z3dRdS� Z4dTdU� Z5dVdW� Z6e fdXdY�Z7dZd[� Z8d\d]� Z9� fd^d_�Z:e;d`da� �Z<e;dbdc� �Z=ddde� Z>e;dfdg� �Z?e;dndidj��Z@� ZAS )o�LXDContainerDriverz� Driver for LXD REST API of LXC containers https://lxd.readthedocs.io/en/stable-2.0/rest-api/ https://github.com/lxc/lxd/blob/master/doc/rest-api.md �LXDz https://linuxcontainers.org/Fz1.0� r! �defaultr� r� Nc s� |r|s t dd��t| _|| _|| _| | _d}|�d�r d}t|d�}t� j |||||||d� |r8|| j j _ nd| j j _ || j _ || j _ || j _| �� | _d S )NzBNeed both private key and certificate files for tls authenticationrA Tr )r )r� r� r� r r� r, r- F)r5 r� � connectionClsr, r- r� r r r; r< � connectionr� r� r r� �_get_api_version�version) r= r� r� r� r r� r, r- r� r� r? r r r< � s: � � zLXDContainerDriver.__init__c C s d| j j| j j| j||f }|S )Nz0wss://%s:%s/%s/operations/%s/websocket?secret=%s)r� r r� r� )r= rd Zw_secretZurir r r � build_operation_websocket_url� s �z0LXDContainerDriver.build_operation_websocket_urlc C s( | j �d�}|�� }t|dd� |d S )z� Description: List of supported APIs Authentication: guest Operation: sync Return: list of supported API endpoint URLs �/�� �r2 r3 rW )r� rv r� r8 )r= �responser2 r r r �ex_get_api_endpoints� s z'LXDContainerDriver.ex_get_api_endpointsc C s: | j �d| j �}|�� }t|dd� |d }tj|d�S )aS Description: Server configuration and environment information Authentication: guest, untrusted or trusted Operation: sync Return: Dict representing server state The returned configuration depends on whether the connection is trusted or not :rtype: :class: .LXDServerInfo z/%sr� r� rW �rW )r� rv r� r� r8 r[ rX )r= r� r2 �metar r r �ex_get_server_configuration� s z.LXDContainerDriver.ex_get_server_configurationTc C s� |r<t �|�}|d �dd�dkr<z | jd d| d�|��}W n ty1 } ztd| d��d} ~ ww dd|jd d �i}tj|||| | | d �}| j ||||| d �}|rW|� � |S )a� Create a new container Authentication: trusted Operation: async :param name: The name of the new container. 64 chars max, ASCII, no slash, no colon and no comma :type name: ``str`` :param image: The container image to deploy. Currently not used :type image: :class:`.ContainerImage` :param cluster: The cluster to deploy to, None is default :type cluster: :class:`.ContainerCluster` :param parameters: Container Image parameters. This parameter should represent the the ``source`` dictionary expected by the LXD API call. For more information how this parameter should be structured see https://github.com/lxc/lxd/blob/master/doc/rest-api.md :type parameters: ``str`` :param start: Start the container on deployment. True is the default :type start: ``bool`` :param ex_architecture: string e.g. x86_64 :type ex_architecture: ``str`` :param ex_profiles: List of profiles :type ex_profiles: ``list`` :param ex_ephemeral: Whether to destroy the container on shutdown :type ex_ephemeral: ``bool`` :param ex_config: Config override e.g. {"limits.cpu": "2"} :type ex_config: ``dict`` :param ex_devices: optional list of devices the container should have :type ex_devices: ``dict`` :param ex_instance_type: An optional instance type to use as basis for limits e.g. "c2.micro" :type ex_instance_type: ``str`` :param ex_timeout: Timeout :type ex_timeout: ``int`` :rtype: :class:`libcloud.container.base.Container` �source�modeN�pull)r( � ex_timeoutz=Deploying container failed: Image could not be installed. %rrA r � fingerprint)r0 r� )� architecture�profiles� ephemeralrN �devices� instance_type)rK r � parameters� cont_paramsr� r ) rk rl rT � install_imager} r5 rY r� �_fix_cont_params� _deploy_container_from_imager )r= rK r �clusterr� r Zex_architectureZ ex_profilesZ ex_ephemeralZ ex_configZ ex_devicesZex_instance_typer� �er� � containerr r r �deploy_container� sH A ���� ��� �z#LXDContainerDriver.deploy_containerc C s� d� | j|�}| j�|�}|�� }t|dd� |d }g }|rVd� | j|�}| j�|�}|�� } t| dd� | d d durV| d d d } | d } | D ] } |�| d � qL|�d |i� | j|d �S ) a` Get a container by ID :param id: The ID of the container to get :type id: ``str`` :param ex_get_ip_addr: Indicates whether ip addresses should also be included. This requires an extra GET request :type ex_get_ip_addr: ``boolean``` :rtype: :class:`libcloud.container.base.Container` �/{}/containers/{}r� r� rW �/{}/containers/{}/state�networkNZeth0� addresses�address�ipsr� ) r6 r� r� rv r� r8 �append�update� _to_container) r= rU �ex_get_ip_addr�reqr� Z result_dictrW r� Z ip_responseZip_result_dict�networksr� �itemr r r � get_containerd s$ z LXDContainerDriver.get_containerc C � | j |d|||d�S )a� Start a container :param container: The container to start :type container: :class:`libcloud.container.base.Container` :param ex_timeout: Time to wait for the operation to complete :type ex_timeout: ``int`` :param ex_force: :type ex_force: ``boolean`` :param ex_stateful: :type ex_stateful: ``boolean`` :rtype: :class:`libcloud.container.base.Container` r �r� �actionr� �force�stateful��_do_container_action�r= r� r� Zex_forceZ ex_statefulr r r �start_container� � �z"LXDContainerDriver.start_containerc C r� )a� Stop the given container :param container: The container to be stopped :type container: :class:`libcloud.container.base.Container` :param ex_timeout: Time to wait for the operation to complete :type ex_timeout: ``int`` :param ex_force: :type ex_force: ``boolean`` :param ex_stateful: :type ex_stateful: ``boolean`` :rtype: :class:`libcloud.container.base.Container r r� r� r� r r r �stop_container� r� z!LXDContainerDriver.stop_containerc C r� )a� Restart a deployed container :param container: The container to restart :type container: :class:`.Container` :param ex_timeout: Time to wait for the operation to complete :type ex_timeout: ``int`` :param ex_force: :type ex_force: ``boolean`` :param ex_stateful: :type ex_stateful: ``boolean`` :rtype: :class:`libcloud.container.base.Container r r� r� r� r r r �restart_container� r� z$LXDContainerDriver.restart_containerc C � | j |d|ddd�S )aD Set the given container into a freeze state :param container: The container to restart :type container: :class:`.Container` :param ex_timeout: Time to wait for the operation to complete :type ex_timeout: ``int`` :rtype :class: `libcloud.container.base.Container r Tr� r� �r= r� r� r r r �ex_freeze_container� � �z&LXDContainerDriver.ex_freeze_containerc C r� )aE Set the given container into unfreeze state :param container: The container to restart :type container: :class:`.Container` :param ex_timeout: Time to wait for the operation to complete :type ex_timeout: ``int`` :rtype :class: `libcloud.container.base.Container r Tr� r� r� r r r �ex_unfreeze_container� r� z(LXDContainerDriver.ex_unfreeze_containerc C s� d� | j|j�}z| jj|dd�}|�� }t|dd� W n ty- } z| �|��d}~ww z|d d }d � | j||�}| j�|�}W n tyb } z| �|�}|j d krX|�W Y d}~nd}~ww |�� }t|d d� t | |j|jt j dg dd �}|S ) ao Destroy a deployed container. Raises and exception if the container is running :param container: The container to destroy :type container: :class:`.Container` :param ex_timeout: Time to wait for the operation to complete :type ex_timeout ``int`` :rtype: :class:`libcloud.container.base.Container r� �DELETE��method�d r� NrW rU �!/{}/operations/{}/wait?timeout={}� not foundr� �rL rK rU �stater � ip_addressesrY ) r6 r� rK r� rv r� r8 r � _get_lxd_api_exception_for_errorr1 r r � TERMINATED) r= r� r� r� r� r2 �errrU � lxd_exceptionr r r �destroy_container s@ �� ��� � z$LXDContainerDriver.destroy_containerc K s\ d|i}t j|fi |��}t�|�}d�| j|�}| jj|d|d�}|�� }t |dd� |d d d } |d d } |d d u rY|d d u rYt | | d | d | d | d i dd�S |d d u rt|d d u rtt | | d dd| d i dd�S |d d u r�|d d u r�|d d d } |d d d } t | dddd| | d�S |d d d } t | ddddi | d�S )a� Description: run a remote command Operation: async Return: Depends on the the configuration if wait-for-websocket=true and interactive=false returns a LXDContainerExecuteResult with: uuid=uuid, secret_0=fds["0"], secret_1=fds["1"], secret_2=fds["2"], control=fds["control"], output={}, result=None if wait-for-websocket=true and interactive=true returns a LXDContainerExecuteResult with: uuid=uuid, secret_0=fds["0"], secret_1=None, secret_2=None, control=fds["control"], output={}, result=None if interactive=false and record-output=true returns a LXDContainerExecuteResult with: uuid=uuid, secret_0=None, secret_1=None, secret_2=None, control=None, output=output, result=result if none of the above it assumes that the command has been executed and returns LXDContainerExecuteResult with: uuid=uuid, secret_0=None, secret_1=None, secret_2=None, control=None, output=None, result=result in all the above uuid is the operation id :param cont_id: The container name to run the commands ":type cont_id: ``str`` :param command: a list of strings indicating the commands and their arguments e.g: ["/bin/bash ls -l"] :type command ``list`` :param config: Dict with extra arguments. For example: width: Initial width of the terminal default 80 height: Initial height of the terminal default 25 user: User to run the command as default 1000 group: Group to run the command as default 1000 cwd: Current working directory default /tmp wait-for-websocket: Whether to wait for a connection before starting the process. Default False record-output: Whether to store stdout and stderr (only valid with wait-for-websocket=false) (requires API extension container_exec_recording). Default False interactive: Whether to allocate a pts device instead of PIPEs. Default true :type config ``dict`` :rtype LXDContainerExecuteResult �commandz/{}/containers/{}/exec�POST�r� �datar� r� rW �fdsrU �wait-for-websocketT� interactiveF�0�1�2re Nrc � record-outputrf rg ) r� �_create_exec_configurationrk �dumpsr6 r� r� rv r� r8 rb ) r= Zcont_idr� rN �inputr� r� r� r2 r� rd rf rg r r r �ex_execute_cmd_on_container@ sf N � � � �z.LXDContainerDriver.ex_execute_cmd_on_containerc C s� | j �d| j �}|�� }t|dd� |d }g }|D ]#}|�d�d }|s3t| |tj||g i d�} n| j |d�} |� | � q|S ) aL List the deployed container images :param image: Filter to containers with a certain image :type image: :class:`.ContainerImage` :param cluster: Filter to containers in a cluster :type cluster: :class:`.ContainerCluster` :param ex_detailed: Flag indicating whether detail info of the containers is required. This will cause a GET request for every container present in the host. Default is True :type ex_detailed: ``bool`` :rtype: ``list`` of :class:`libcloud.container.base.Container �/%s/containersr� r� rW r� r# )rL rK r� rU r r� rY �rU ) r� rv r� r� r8 r% r r �UNKNOWNr� r� ) r= r r� Z ex_detailedrg r� Z containersr� � container_idr� r r r �list_containers� s( � z"LXDContainerDriver.list_containersc C s> d� | j|�}| j�|�}|�� }t|dd� | j|d d�S )z� Returns a container image from the given image fingerprint :param fingerprint: image fingerprint :type fingerprint: ``str`` :rtype: :class:`.ContainerImage` z /{}/images/{}r� r� rW r� )r6 r� r� rv r� r8 � _to_image)r= r� r� r� r2 r r r � ex_get_image� s z LXDContainerDriver.ex_get_imagec K sn |s d}t |d��|d }|�dd�|�dd�|�di �gd d |d d �d �}t�|�}| jjd | j d|d�}|�� }t|dd� z|d d } d� | j| |�} | j�| �}W n t yv } z| � | �} | j dkrl| �W Y d} ~ nd} ~ ww t� |�}t|d �dkr�d|d d v r�|d d d } n |d d �d�d } | j| d�\}}|s�t d | d��| j|d �S ) a6 Install a container image from a remote path. Not that the path currently is not used. Image data should be provided under the key 'ex_img_data'. Creating an image in LXD is an asynchronous operation :param path: Path to the container image :type path: ``str`` :param ex_timeout: Time to wait before signaling timeout :type ex_timeout: ``int`` :param ex_img_data: Dictionary describing the image data :type ex_img_data: ``dict`` :rtype: :class:`.ContainerImage` z=Install an image for LXD requires specification of image_datarA r� ra T� auto_updateF�aliasesrw r� )r0 r� rw )ra r r r� � /%s/imagesr� r� r� r� rW rU r� r� Nr rK r� r# )�aliaszImage %s was not installed �r� )r5 rT rk r� r� rv r� r� r8 r6 r r� r1 rl rs r% � ex_has_imager )r= r( r� Z ex_img_datar7 r� rN r� r2 rU r� r� r� Z image_aliasZhasr� r r r r� sD � � ��� z LXDContainerDriver.install_imagec C s` | j �d| j �}|�� }t|dd� |d }g }|D ]}|�d�d }|�| j|d�� q|S )zx List of URLs for images the server is publishing :rtype: ``list`` of :class:`.ContainerImage` r r� r� rW r� r# r )r� rv r� r� r8 r% r� r )r= r� r2 rW Zimagesr r� r r r � list_imagesS s z LXDContainerDriver.list_imagesc C s� z| j �d�| j|��}|jd }d|�d�fW S ty7 } z| �|�}|jdkr1W Y d}~dS |�d}~w t yG } z| �|��d}~ww )a Helper function. Returns true and the image fingerprint if the image with the given alias exists on the host. :param alias: the image alias :type alias: ``str`` :rtype: ``tuple`` :: (``boolean``, ``str``) z/{}/images/aliases/{}rW T�targetr� N)Fr# ) r� rv r6 r� �objectrT r r� r1 r} )r= r r� rW r� r� r r r r h s � ��z LXDContainerDriver.ex_has_imagec C s~ | j �d| j �}|�� }t|dd� g }|d D ]#}|�d�d }|s3|�| �|ddddd��� q|�| j|d �� q|S ) z� Returns a list of storage pools defined currently defined on the host Description: list of storage pools Authentication: trusted Operation: sync ":rtype: list of StoragePool items �/%s/storage-poolsr� r� rW r� r# NrJ r� ) r� rv r� r� r8 r% r� �_to_storage_pool�ex_get_storage_pool)r= �detailedr� r2 �poolsZ pool_itemZ pool_namer r r �ex_list_storage_pools� s& ��� z(LXDContainerDriver.ex_list_storage_poolsc C sZ d� | j|�}| j�|�}|�� }t|dd� |d s%d� |�}t|d��| j|d d�S )z� Returns information about a storage pool :param id: the name of the storage pool :rtype: :class: StoragePool �/{}/storage-pools/{}r� r� rW z%Storage pool with name {} has no datarA )r� )r6 r� r� rv r� r8 r5 r )r= rU r� r� r2 r7 r r r r � s z&LXDContainerDriver.ex_get_storage_poolc C sR |st d��t�|�}| jjd| j d|d�}|�� }t|dd� | j|d d�S ) a Create a storage_pool from definition. Implements POST /1.0/storage-pools The `definition` parameter defines what the storage pool will be. An example config for the zfs driver is: { "config": { "size": "10GB" }, "driver": "zfs", "name": "pool1" } Note that **all** fields in the `definition` parameter are strings. Note that size has to be at least 64MB in order to create the pool For further details on the storage pool types see: https://lxd.readthedocs.io/en/latest/storage/ The function returns the a `StoragePool` instance, if it is successfully created, otherwise an LXDAPIException is raised. :param definition: the fields to pass to the LXD API endpoint :type definition: dict :returns: a storage pool if successful, raises NotFound if not found :rtype: :class:`StoragePool` :raises: :class:`LXDAPIExtensionNotAvailable` if the 'storage' api extension is missing. :raises: :class:`LXDAPIException` if the storage pool couldn't be created. z2Cannot create a storage pool without a definitionr r� r� r� r� rK r� ) r5 rk r� r� rv r� r� r8 r )r= � definitionr� r� r2 r r r �ex_create_storage_pool� s ( � z)LXDContainerDriver.ex_create_storage_poolc C �6 d� | j|�}| jj|dd�}|�� }t|dd� dS )a# Delete the storage pool. Implements DELETE /1.0/storage-pools/<self.name> Deleting a storage pool may fail if it is being used. See the LXD documentation for further details. :raises: :class:`LXDAPIException` if the storage pool can't be deleted. r r� r� r� r� N�r6 r� r� rv r� r8 )r= rU r� r� r2 r r r �ex_delete_storage_pool� s z)LXDContainerDriver.ex_delete_storage_poolc C s� d� | j|�}| j�|�}|�� }t|dd� g }|d D ]2}|�d�}|d }|d } |sBdd i|| d d �} |�| j|| d �� q | j || |d �}|�|� q |S ) a Description: list of storage volumes associated with the given storage pool :param pool_id: the id of the storage pool to query :param detailed: boolean flag. If True extra API calls are made to fill in the missing details of the storage volumes Authentication: trusted Operation: sync Return: list of storage volumes that currently exist on a given storage pool :rtype: A list of :class: StorageVolume � /{}/storage-pools/{}/volumesr� r� rW r� r# ����sizeN)rN rK r0 rM ��pool_idrW �r r0 rK ) r6 r� r� rv r� r8 r% r� �_to_storage_volume�ex_get_storage_pool_volume) r= r r r� r� r2 �volumesZvolumerK r0 rW r r r � ex_list_storage_pool_volumes s& � z/LXDContainerDriver.ex_list_storage_pool_volumesc C sD d� | j|||�}| j�|�}|�� }t|dd� | j||d d�S )a Description: information about a storage volume of a given type on a storage pool Introduced: with API extension storage Authentication: trusted Operation: sync Return: A StorageVolume representing a storage volume �"/{}/storage-pools/{}/volumes/{}/{}r� r� rW r )r6 r� r� rv r� r8 r )r= r r0 rK r� r� r2 r r r r 1 s z-LXDContainerDriver.ex_get_storage_pool_volume�customc C sz d| j }| j�|�}|�� }t|dd� |d }|D ] }|�d�d }| j|d�} | D ] } | j|kr9| S q,qdS ) a Returns a storage volume that has the given name. The function will loop over all storage-polls available and will pick the first volume from the first storage poll that matches the given name. Thus this function can be quite expensive :param name: The name of the volume to look for :type name: str :param vol_type: The type of the volume default is custom :type vol_type: str :return: A StorageVolume representing a storage volume r r� r� rW r� r# )r N)r� r� rv r� r8 r% r rK ) r= rK Zvol_typer� r� r2 r �poolr r Zvolr r r �ex_get_volume_by_nameA s ��z(LXDContainerDriver.ex_get_volume_by_namec K s� |st d��|�d�}ttj|d d |d��|d d< t�|�}d�| j|�}| j j |d|d�}|� � }t |d d � | j ||d |d d �S )z� Create a new storage volume on a given storage pool Operation: sync or async (when copying an existing volume) :return: A StorageVolume representing a storage volume �3Cannot create a storage volume without a definition� size_typerN r )r& r r� r� r� r� r0 rK r )r5 �popr& r� � _to_bytesrk r� r6 r� r� rv r� r8 r ) r= r r r. r& r� r� r� r2 r r r � create_volumed s � �z LXDContainerDriver.create_volumec C s� | j |d�}|j}||d||d�i|d< t�|�} d�| j|�} | jj| d| d�} | �� } t | dd � z| d d } d �| j| |�} | j�| �} W n t yg } z| � |�}|j d kr]|�W Y d}~nd}~ww | �� } t | dd � | j |dd�S )zc Attach the volume with id volume_id to the container with id container_id r� Zdisk)r( r0 r� r# r� r� �PUTr� r� r� rW rU r� r� Nr� T)rU r� ) r� rY rk r� r6 r� r� rv r� r8 r r� r1 )r= r� Z volume_idr rK r( r� r� rN r� r� r� r2 �oidr� r� r r r � attach_volume� s. � ��� z LXDContainerDriver.attach_volumec C sZ |st d��t�|�}| jjd�| j|||�d|d�}|�� }t|dd� | j |||d�S )z� Replace the storage volume information :param pool_id: :param type: :param name: :param definition r% r! r* r� r� r� r ) r5 rk r� r� rv r6 r� r� r8 r )r= r r0 rK r r� r� r2 r r r � ex_replace_storage_volume_config� s � z3LXDContainerDriver.ex_replace_storage_volume_configc C s` z d� | j|||�}| jj|dd�}|�� }t|dd� W dS ty/ } z| �|��d}~ww )z� Delete a storage volume of a given type on a given storage pool :param pool_id: :type ``str`` :param type: :type ``str`` :param name: :type ``str`` :return: r! r� r� r� r� NT)r6 r� r� rv r� r8 r r� )r= r r0 rK r� r� r2 r� r r r � ex_delete_storage_pool_volume� s �� ��z0LXDContainerDriver.ex_delete_storage_pool_volumec C sd d| j }| j�|�}|�� }t|dd� |d }g }|D ]}|�d�d }|�| j|d�� q |S )z� Returns a list of networks. Implements GET /1.0/networks Authentication: trusted Operation: sync :rtype: list of LXDNetwork objects � /%s/networksr� r� rW r� r# �rK )r� r� rv r� r8 r% r� �ex_get_network)r= r� r� r2 �netsr� �netrK r r r �ex_list_networks� s z#LXDContainerDriver.ex_list_networksc C s< d� | j|�}| j�|�}|�� }t|dd� t�|d �S )a Returns the LXD network with the given name. Implements GET /1.0/networks/<name> Authentication: trusted Operation: sync :param name: The name of the network to return :type name: str :rtype: LXDNetwork �/{}/networks/{}r� r� rW )r6 r� r� rv r� r8 rP rX �r= rK r� r� r2 r r r r1 � s z!LXDContainerDriver.ex_get_networkc K sN ||d< t �|�}d| j }| jj|d|d�}|�� }t|dd� | j|d�S )z� Create a new network with the given name and and the specified configuration Authentication: trusted Operation: sync :param name: The name of the new network :type name: str rK r/ r� r� r� r� r0 )rk r� r� r� rv r� r8 r1 )r= rK r. r� r� r� r2 r r r �ex_create_network s z$LXDContainerDriver.ex_create_networkc C r )z� Delete the network with the given name Authentication: trusted Operation: sync :param name: The network name to delete :type name: str :return: True is successfully deleted the network r5 r� r� r� r� Tr r6 r r r �ex_delete_network! s z$LXDContainerDriver.ex_delete_networkc C s� |d }|d }|dkrt j}n |dkrt j}nt j}|}|d �dd�}|d �dd�}|d }t||d|| dd �}t| ||||||d �} | S ) z� Returns Container instance built from the given metadata :param metadata: dictionary with the container metadata :type metadata: ``dict`` :rtype :class:`libcloud.container.base.Container rK rR ZRunningZFrozenrN zvolatile.base_imageNz image.versionr� �rU rK r( r� rL rY r� )r �RUNNINGZPAUSEDZSTOPPEDrT r r ) r= rW rK r� rY Zimg_idZ img_versionr� r r� r r r r� 4 s: � � z LXDContainerDriver._to_containerc C s |t vrtd��|j}||d�}t�|�}d�| j|j�}| jj |d|d�} | � � } t | dd� |s5t j }z| d d } d �| j| |�}| j� |�} W n tyi } z| �| �} | jd kr_| �W Y d } ~ nd } ~ ww |tjkr�|jd r�|dkr�t| |j|jtjd g d d�}|S | j|jd�S )z� change the container state by performing the given action action may be either stop, start, restart, freeze or unfreeze zInvalid action specified)r� r� r� r* r� r� r� rW rU r� r� Nr� r r� r� )�LXD_API_STATE_ACTIONSry r� rk r� r6 r� rK r� rv r� r8 r� �default_time_outr r� r1 r r: rY r r� r� )r= r� r� r� r� r� r� r� r� r� r2 rU r� r� r r r r� b sD ��� � z'LXDContainerDriver._do_container_actionc C sp |� d�}|� dg �}|r|� d�d � d�}n |� di �� d�p"|}|� di �� d�}|}t||d || |d �S ) z� Returns a container image from the given metadata :param metadata: :type metadata: ``dict`` :rtype: :class:`.ContainerImage` r� r r rK Z propertiesrQ Z update_sourcer Nr9 )rT r )r= rW r� r rK r� rY r r r r � s �z LXDContainerDriver._to_imagec C s t |d |d |d dgdd�S )z� Given a dictionary with the storage pool configuration it returns a StoragePool object :param data: the storage pool configuration :return: :class: .StoragePool rK rL rM rN FrJ )rI )r= r� r r r r � s �z#LXDContainerDriver._to_storage_poolc C s |du r t dd��|ddid�}|r|d �|d � |d d tvr.dtt� }t |d��|�|� t�|�}| jjd | j d |d �}|� � } t | d d � |sSt j }z| d d } d� | j| |�} | j�| �}W n ty� } z| �| �} | jdkr}| �W Y d} ~ nd} ~ ww | j|d�S )a� Deploy a new container from the given image :param name: the name of the container :param image: .ContainerImage :param parameters: dictionary describing the source attribute :type parameters ``dict`` :param cont_params: dictionary describing the container configuration :type cont_params: dict :param timeout: Time to wait for the operation before timeout :type timeout: int :rtype: :class: .Container Nz cont_params must be a valid dictrA r0 r )rK r� r� zsource type must in r� r� r� r� r� rW rU r� r� r� )r5 r� �LXD_API_IMAGE_SOURCE_TYPEr& rk r� r� rv r� r� r8 r� r< r6 r r� r1 r� )r= rK r r� r� r� r� r7 r� r2 rU Zreq_strr� r� r r r r� � s: � ��� z/LXDContainerDriver._deploy_container_from_imagec C s\ d}d|d � � v rt�|d �d��}||d |d |d d�}t|d |d | ||d�S ) z� Returns StorageVolume object from metadata :param metadata: dict representing the volume :rtype: StorageVolume r r rN r0 rM )r r0 rM rN rK )rU rK rL r rY )r$ r� �_to_gbr' r )r= r rW r rY r r r r s ��z%LXDContainerDriver._to_storage_volumec C s t jS )z) Get the LXD API version )r� r� rB r r r r� * s z#LXDContainerDriver._get_api_versionc s0 t | d�rt | d�r| j| j| jd�S t� �� S )zy Return extra connection keyword arguments which are passed to the Connection class constructor. r, r- )r, r- r� )�hasattrr, r- r� r; �_ex_connection_class_kwargsrB r? r r r@ 0 s � z.LXDContainerDriver._ex_connection_class_kwargsc K s d|� � v r |d | d< d|� � v rt|d �| d< nd| d< d|� � v r.t|d �| d< nd| d< d|� � v r>|d | d< d|� � v rJ|d | d< d|� � v rV|d | d< d |� � v rc|d | d < nd | d < d |� � v rs|d | d < d |� � v r|d | d < | S ) zG Prepares the input parameters for executyion API call r` �width�P �height� �userr| �cwdr� Fr� r� )r$ �int)r� rN r r r r� > s, z-LXDContainerDriver._create_exec_configurationc C s� i }| dur | |d< |dur||d< nt jg|d< |dur"||d< nt j|d< |dur/||d< |dur7||d< |dur?||d< |S )z> Returns a dict with the container parameters Nr� r� r� rN r� r� )r� �default_profiles�default_ephemeral)r� r� r� rN r� r� r� r r r r� f s z#LXDContainerDriver._fix_cont_paramsc C s* t �|j�}|�d�}t||�dd�d�S )Nr r0 r! )r1 r> )rk rl r1 rT r5 )r= r Z error_dictr1 r r r r� � s z3LXDContainerDriver._get_lxd_api_exception_for_errorc C s t | �} | d S )z� Convert the given size in bytes to gigabyte :param size: in bytes :return: int representing the gigabytes � ʚ;�rG )r r r r r> � s zLXDContainerDriver._to_gb�GBc C s, t | �} |dkr | d S |dkr| d S dS )z{ convert the given size in GB to bytes :param size: in GBs :return: int representing bytes rL rJ ZMBi@B NrK )r r& r r r r( � s �z LXDContainerDriver._to_bytes)T)NNT)r" )rL )BrD rE rF rG r r� r0 rK Zwebsiter� r� Zsupports_clustersr� r< Zdefault_architecturerH 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. r4 r1 r7 r8 r� r� r r r� r r� r@ � staticmethodr� r� r� r> r( rH r r r? r r� t s� �9 � o) � � � 6 - H '7 , # �* .< �E ' r� )-r' rz r� � collectionsZlibcloud.utils.py3r r Zlibcloud.common.baser r r Zlibcloud.common.typesr Zlibcloud.compute.baser Zlibcloud.container.baser r r Zlibcloud.container.typesr Zlibcloud.common.exceptionsr Z libcloud.container.providersr Z simplejsonrk r} ZLXD_API_SUCCESS_STATUSr; r= r4 r r/ r8 r5 rI rP r[ � namedtuplerb rh r� r� r� r r r r �<module> sH � < 4�.*
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings