Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/container/drivers/__pycache__/lxd.cpython-39.pyc
Ðазад
a q�h\� � @ s� d dl Z d dlZd dlZd dlZz d dlZW n eyF d dlZY n0 d dlmZ d dlm Z d dl m Z m Z d dl m Z d dlmZ d dlmZmZmZ d dlmZ d d lmZ d d lmZ d d lmZ d gZ g d �Z g d�Z dZ dd� Z dd� Z!dd� Z"G dd� de�Z#G dd� de$�Z%G dd� de$�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)�httplib)�b)� JsonResponse�ConnectionUserAndKey)�KeyCertificateConnection)�InvalidCredsError)� Container�ContainerDriver�ContainerImage)� BaseHTTPError)� StorageVolume)�Provider)�ContainerStateZSuccess)�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 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/container/drivers/lxd.py�strip_http_prefix6 s r c K s$ | du s|du rt d��| dks(|dkr0t d��d|�� v rv| �d�}|d |d vrvt dt|d � d |d ��d |�� v r�|�d�}|d |d vr�t d t|d � d |d ��tj�| �}tj�|�o�tj�|�}|s�t d ��tj�|�}tj�|��otj�|�}|�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_certificates? s@ ��� ��� r/ c C sD | d t krtd| 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 {0} but is {1}N)�LXD_ERROR_STATUS_RESP�LXDAPIException�format)r2 r3 �msgr r r �assert_responsep 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 OccurredNc s || _ || _tt| ��|� d S �N)r1 r2 �superr5 �__init__)�selfr1 r2 �� __class__r r r< � s zLXDAPIException.__init__c C s | j S r: �r1 �r= r r r �__str__� s zLXDAPIException.__str__)r9 N)�__name__� __module__� __qualname__�__doc__r< rB � __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= rJ rK rL rM rN r r r r< � s zLXDStoragePool.__init__N)rC rD rE rF r< r r r r rH � s rH 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�authrM � environment�public) rO �getrP rQ rR rS rM rT rU )�cls�metadataZ server_infor r r �build_from_response� s z!LXDServerInfo.build_from_responsec C s. d | _ d | _d | _d | _d | _d | _d | _d S r: )rP rQ rR rS rM rT rU rA 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& rP rQ rR rS rM rT rU rA r r r rB � s �����zLXDServerInfo.__str__N)rC rD rE rF � classmethodrY r< rB r r r r rO � s rO �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 zv| j�dd�}|dks:|dkr�| j�d�dkrzd| jjv rzdd � | j�� �d d�� d �D �}q�t � | j�}n| j}W nJ t y� t �d | j�}|r�|�d �}t|��nd| j }t|��Y n0 |S )Nr z content-type�application/jsonr! ztransfer-encoding�chunkedZ fromImagec S s g | ]}t �|��qS r )�json�loads)�.0�chunkr r r � <listcomp>� � z*LXDResponse.parse_body.<locals>.<listcomp>� � z Error: (.+?)"� z8ConnectionError: Failed to parse JSON response (body=%s))�len�bodyZparse_zero_length_body�headersrV �request�urlr �replacer% rd re � ValueError�re�search�group� Exception)r= � content_typern �m� error_msgr7 r r r � parse_body� s. �� �zLXDResponse.parse_bodyc C s | j dkrtd��| jS )Ni� zInvalid credentials)�statusr rn rA r r r � parse_error s zLXDResponse.parse_errorc C s | j | jv S r: )r| �valid_response_codesrA r r r �success s zLXDResponse.successN) rC rD rE r �OK�ACCEPTED�CREATED� NO_CONTENTr~ r{ r} r r r r r ra � s �ra c @ s e Zd ZeZdZdd� ZdS )� LXDConnection�< c C sD d|d< | j r@| jr@t�td| j | jf ��}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 rb � Content-Typez%s:%szBasic %szutf-8� Authorization)Zuser_id�key�base64� b64encoder �decode)r= ro Zuser_b64r r r �add_default_headers s z!LXDConnection.add_default_headersN)rC rD rE ra � responseCls�timeoutr� r r r r r� s r� c s* e Zd ZeZd � fdd� Zdd � Z� ZS ) �LXDtlsConnectionT� localhost� r! Nc s^ | d ur| ||d� nt f ||d�| �� tt| �j|||||d d d d d d� || _|| _d S )N)r, r- ) r, r- �securer �portrq � proxy_urlr� �backoffZ retry_delay)r/ r; r� r< r, r- ) r= r� �secretr� r r� �ca_certr, r- �certificate_validatorr. r> r r r< & s" �� �zLXDtlsConnection.__init__c C s d|d< |S )Nrb r� r )r= ro r r r r� < s z$LXDtlsConnection.add_default_headers)Tr� r� r! NNN)rC rD rE ra r� r< r� rG r r r> r r� " s �r� c s� e Zd ZdZejZdZdZe Z dZ dZ dZ dZdZdZdddd d d d d ef � fd d � Zdd� Zdd� Zd d ded ed d d f dd�ZdUdd�Ze ddfdd�Ze ddfdd�Ze ddfdd �Ze fd d �Ze fd d �Ze fd!d"�Z d#d$� Z dVd%d&�Z d'd(� Z e fd)d*�Z d+d,� Z!dWd-d.�Z"d/d0� Z#d1d2� Z$d3d4� Z%dXd5d6�Z&d7d8� Z'd9d:� Z(d;d<� Z)d=d>� Z*d?d@� Z+dAdB� Z,dCdD� Z-dEdF� Z.e fdGdH�Z/dIdJ� Z0dKdL� Z1� fdMdN�Z2e3dOdP� �Z4e3dQdR� �Z5e3dSdT� �Z6� Z7S )Y�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.|st dd��t| _|| _|| _| | _d}|�d�r<d}t|d�}tt | �j |||||||d� |rt|| j j _ n d| j j _ || j _ || j _|| j _| �� | _d S )NzBNeed both private key and certificate files for tls authenticationr@ Tr )r )r� r� r� r r� r, r- F)r5 r� � connectionClsr, r- 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< ^ s0 � zLXDContainerDriver.__init__c 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 rX )r� rp 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� rX �rX )r� rp r� r{ r8 rO rY )r= r� r2 �metar r r �ex_get_server_configuration� s z.LXDContainerDriver.ex_get_server_configurationTc C sF t j|||| | | d�} |r$t�|�}| j|||| d�} |rB| �� | S )aj 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`` dictioanry 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`` :rtype: :class:`libcloud.container.base.Container` )� architecture�profiles� ephemeralrM �devices� instance_type)rJ r � parameters� cont_params)r� �_fix_cont_paramsrd re � _deploy_container_from_imager )r= rJ r �clusterr� r Zex_architectureZ ex_profilesZ ex_ephemeralZ ex_configZ ex_devicesZex_instance_typer� � containerr r r �deploy_container� s" 7�� �z#LXDContainerDriver.deploy_containerc C s� d| j |f }| j�|�}|�� }t|dd� |d }g }|r�d| j |f }| j�|�}|�� } t| dd� | d d dur�| d d d } | d } | D ]} |�| d � q�|�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` �/%s/containers/%sr� r� rX �/%s/containers/%s/state�networkNZeth0� addresses�address�ipsr� )r� r� rp r{ r8 �append�update� _to_container) r= �idZex_get_ip_addr�reqr� Z result_dictrX r� Z ip_responseZip_result_dictZnetworksr� �itemr r r � get_container� s$ z LXDContainerDriver.get_containerc C s | 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� � ex_timeoutZex_forceZ ex_statefulr r r �start_container s �z"LXDContainerDriver.start_containerc C s | j |d|||d�S )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_container5 s �z!LXDContainerDriver.stop_containerc C s | j |d|||d�S )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_containerL s �z$LXDContainerDriver.restart_containerc C s | 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_containerc s �z&LXDContainerDriver.ex_freeze_containerc C s | j |d|ddd�S )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_containerv s �z(LXDContainerDriver.ex_unfreeze_containerc C s� d| j |jf }| jj|dd�}|�� }t|dd� z,|d d }d| j ||f }| j�|�}W nV ty� } z>|j�d �}|d �d �d } | d kr�t |jd��W Y d}~n d}~0 0 |�� }t|dd� t | |j|jt j dg dd�}|S )am Destroy a deployed container. Raises and exception if he 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� rX r� �!/%s/operations/%s/wait?timeout=%s�,r �:r# � "not found"r@ Nr� �rK rJ r� �stater � ip_addresses�extra) r� rJ r� rp r{ r8 r r1 r% r5 r r � TERMINATED) r= r� r� r� r� r2 r� �e� message_listr1 r r r �destroy_container� s2 � " �z$LXDContainerDriver.destroy_containerc K sd d|i}t j|fi |��}t�|�}d| j|f }| jj|d|d�}|�� }t|dd� |d d d } |d d } |d d u r�|d d u r�t | | d | d | d | d i dd�S |d d u r�|d d u r�t | | 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 dS )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/%s/containers/%s/exec�POST�r� �datar� r� rX �fdsr� �wait-for-websocketT� interactiveF�0�1�2r^ Nr\ � record-outputr_ r` ) r� �_create_exec_configurationrd �dumpsr� r� rp r{ r8 r[ ) r= Zcont_idr� rM �inputr� r� r� r2 r� r] r_ r` r r r �ex_execute_cmd_on_container� sb N �� �� �� �z.LXDContainerDriver.ex_execute_cmd_on_containerc C s� | j �d| j �}|�� }t|dd� |d }g }|D ]F}|�d�d }|sft| |tj||g i d�} n | j |d�} |� | � q6|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� rX r� r# )rK rJ r� r� r r� r� �r� ) r� rp r� r{ r8 r% r r �UNKNOWNr� r� ) r= r r� Z ex_detailedr` r� � containersr� Z container_idr� r r r �list_containersB s" � z"LXDContainerDriver.list_containersc C s> d| j |f }| 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 /%s/images/%sr� r� rX r� )r� r� rp r{ r8 � _to_image)r= � fingerprintr� r� r2 r r r � ex_get_imagel s z LXDContainerDriver.ex_get_imagec K s� |sd}t |d��|d }| jjd| j d|d�}|�� }t|dd� z,|d d }d | j||f } | j�| �}W nV ty� } z>| j�d �} | d �d�d } | dkr�t | jd��W Y d} ~ n d} ~ 0 0 |�� }t|dd� | j |d d�S )aI Install a container image from a remote path. Not that the path currently is not used. Image data should be provided int the ex_img_data under the key 'image_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_datar@ Z image_data� /%s/imagesr� )r� rd r� r� rX r� r� r� r r� r# r� Nr� r� ) r5 r� rp r� r{ r8 r r1 r% r� ) r= r( r� Z ex_img_datar7 r� r� r2 r� r� r� r� r1 r r r � install_image~ s0 � � " z LXDContainerDriver.install_imagec C s` | j �d| j �}|�� }t|dd� |d }g }|D ]$}|�d�d }|�| j|d�� q6|S )zx List of URLs for images the server is publishing :rtype: ``list`` of :class:`.ContainerImage` r� r� r� rX r� r# )r� )r� rp r� r{ r8 r% r� r� )r= r� r2 rX Zimagesr r� r r r � list_images� s z LXDContainerDriver.list_imagesc C s~ | j �d| j �}|�� }t|dd� g }|d D ]F}|�d�d }|sf|�| �|ddddd��� q2|�| j|d �� q2|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� rX r� r# NrI r� ) r� rp 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 |f }| j�|�}|�� }t|dd� |d sJd�|�}t|d��| j|d d�S )z� Returns information about a storage pool :param id: the name of the storage pool :rtype: :class: StoragePool �/%s/storage-pools/%sr� r� rX z&Storage pool with name {0} has no datar@ )r� )r� r� rp r{ r8 r6 r5 r� )r= r� r� r� r2 r7 r r r r� � s z&LXDContainerDriver.ex_get_storage_poolc C sR |s t 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 64M 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� rJ r� ) r5 rd r� r� rp r� r{ r8 r� )r= � definitionr� r� r2 r r r �ex_create_storage_pool s ) � z)LXDContainerDriver.ex_create_storage_poolc C s6 d| j |f }| 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)r� r� rp r{ r8 )r= r� r� r� r2 r r r �ex_delete_storage_pool; s z)LXDContainerDriver.ex_delete_storage_poolc C s� d| j |f }| j�|�}|�� }t|dd� g }|d D ]b}|�d�}|d }|d } |s�dd 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 � /%s/storage-pools/%s/volumesr� r� rX r� r# ����sizeN)rM rJ r0 rL r� ��pool_idr0 rJ ) r� r� rp r{ r8 r% r� �_to_storage_volume�ex_get_storage_pool_volume) r= r r� r� r� r2 Zvolumes�volumerJ r0 rX r r r � ex_list_storage_pool_volumesM s& �� z/LXDContainerDriver.ex_list_storage_pool_volumesc C s@ d| j |||f }| j�|�}|�� }t|dd� | �|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 �"/%s/storage-pools/%s/volumes/%s/%sr� r� rX )r� r� rp r{ r8 r )r= r r0 rJ r� r� r2 r r r r v s � z-LXDContainerDriver.ex_get_storage_pool_volumec C sb |s t d��t�|�}d| j|f }| jj|d|d�}|�� }t|dd� | 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 definitionr r� r� r� r� r0 rJ r ) r5 rd r� r� r� rp r{ r8 r )r= r r r� r� r� r2 r r r � ex_create_storage_pool_volume� s �z0LXDContainerDriver.ex_create_storage_pool_volumec C sZ |s t d��t�|�}| jjd| j|||f d|d�}|�� }t|dd� | j|||d�S )z� Replace the storage volume information :param pool_id: :param type: :param name: :param definition :return: r r �PUTr� r� r� r ) r5 rd r� r� rp r� r{ r8 r )r= r r0 rJ r r� r� r2 r r r � ex_replace_storage_volume_config� s ��� �z3LXDContainerDriver.ex_replace_storage_volume_configc C s6 | j jd| j|||f dd�}|�� }t|dd� dS )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� T)r� rp r� r{ r8 )r= r r0 rJ r� r2 r r r � ex_delete_storage_pool_volume� s ��� z0LXDContainerDriver.ex_delete_storage_pool_volumec C s� |d }|d }|dkr t j}n|dkr0t 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 rJ r| ZRunningZFrozenrM zvolatile.base_imageNz image.versionr� �r� rJ r( r� rK r� r� )r �RUNNINGZPAUSEDZSTOPPEDrV r r ) r= rX rJ r� r� Zimg_idZ img_versionr� r r� r r r r� � s& ��z LXDContainerDriver._to_containerc C s> |t vrtd��|j}||d�}t�|�}d| j|jf }| jj|d|d�} | � � } t | dd� |sjt j }z,| d d } d | j| |f }| j�|�} W nV t y� } z>| j�d �} | d �d �d }|dkr�t| jd��W Y d} ~ n d} ~ 0 0 |tjk�r0|jd �r0|dk�r0t| |j|jtjdg dd�}|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� rX r� r� r� r r� r# r� r@ Nr� r r� r� )�LXD_API_STATE_ACTIONSrs r� rd r� r� rJ r� rp r{ r8 r� �default_time_outr r1 r% r5 r r r� r r� r� )r= r� r� r� r� r� r� r� r� r� r2 r� r� r� r1 r r r r� � sH � � " ���z'LXDContainerDriver._do_container_actionc C sX |� dg �}|r&|� d�d � d�}n |� d�}|� d�� d�}|}t||d|| |d�S ) z� Returns a container image from the given metadata :param metadata: :type metadata: ``dict`` :rtype: :class:`.ContainerImage` �aliasesr rJ r� Z update_source�aliasNr )rV r )r= rX r rJ r� r� r r r r� 5 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 rJ rK rL rM FrI )rH )r= r� r r r r� K s �z#LXDContainerDriver._to_storage_poolc C s: |du rt dd��|ddid�}|r6|d �|d � |d d tvr\dtt� }t |d��|�|� t�|�}| jjd | j d |d �}|� � } t | d d � |s�t j }z,| d d } d| j| |f } | j�| �}W nZ t �y, } z@| j�d�} | d �d�d }|dk�rt | jd��W Y d} ~ n d} ~ 0 0 | j|d�S )a� Deploy a new container from the given image :param name: the name of the container :param image: .ContainerImage :param parameters: string describing the source attribute :type parameters ``str`` :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 dictr@ r0 r )rJ �sourcer zsource type must in r� r� r� r� r� rX r� r� r� r r� r# r� r� )r5 r� �LXD_API_IMAGE_SOURCE_TYPEr& rd r� r� rp r� r{ r8 r� r r r1 r% r� )r= rJ r r� r� r� r� r7 r� r2 r� �req_strr� r� r1 r r r r� W s< � � "z/LXDContainerDriver._deploy_container_from_imagec C sZ d}d|d � � v r(t�|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 rM r0 rL )r0 rL rM rJ )r� rJ rK r r� )r$ r� �_to_gb�popr )r= rX r r� r r r r � s ��z%LXDContainerDriver._to_storage_volumec C s t jS )z) Get the LXD API version )r� r� rA r r r r� � s z#LXDContainerDriver._get_api_versionc s4 t | d�r&t | d�r&| j| j| jd�S tt| ��� S )zy Return extra connection keyword arguments which are passed to the Connection class constructor. r, r- )r, r- r� )�hasattrr, r- r� r; r� �_ex_connection_class_kwargsrA r> r r r � s �z.LXDContainerDriver._ex_connection_class_kwargsc K s d|� � v r|d | d< d|� � v r2|d | d< nd| d< d|� � v rT|d | d< nd| d< d|� � v rt|d | d< d|� � v r�|d | d< d|� � v r�|d | d< d |� � v r�|d | d < nd | d < d |� � v r�|d | d < nd | d < d |� � v �r|d | d < nd | d < | S )zG Prepares the input parameters for executyion API call rT �width�P �height� �userrv �cwdr� Fr� r� T)r$ )r� rM r r r r� � s0 z-LXDContainerDriver._create_exec_configurationc C s� i }| dur| |d< |dur&||d< n t jg|d< |durD||d< n t j|d< |dur^||d< |durn||d< |dur~||d< |S )z> Returns a dict with the container parameters Nr� r� r� rM r� r� )r� �default_profiles�default_ephemeral)r� r� r� rM r� r� r� r r r r� � s z#LXDContainerDriver._fix_cont_paramsc C s t | �} | d S )z� Convert the given size in bytes to gigabyte :param size: in bytes :return: int representing the gigabytes i ʚ;)�int)r r r r r s zLXDContainerDriver._to_gb)T)NNT)T)T)8rC rD rE rF r r� r0 rJ Zwebsiter� r� Zsupports_clustersr� r Zdefault_architecturer& 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 � staticmethodr� r� r rG r r r> r r� A s� �- � J )� � � 3 * ; !8 )"?� J , "r� )-r� rt r' � collectionsZ simplejsonrd rw Zlibcloud.utils.py3r r Zlibcloud.common.baser r r Zlibcloud.common.typesr Zlibcloud.container.baser r r Zlibcloud.common.exceptionsr Zlibcloud.compute.baser Z libcloud.container.providersr Zlibcloud.container.typesr ZLXD_API_SUCCESS_STATUSr r r4 r r/ r8 r5 �objectrH rO � namedtupler[ ra r� r� r� r r r r �<module> sD 11� (
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка