File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/container/drivers/__pycache__/docker.cpython-310.pyc
Back
o ;j`e � @ s d dl Z d dlZd dlZd dlZd dlZd dlmZmZ d dlm Z m Z m Z d dl m Z d dlmZmZmZ d dlmZ d dlmZ zd dlZW n eyU d dlZY nw ejejejej gZ G dd � d e �Z G d d � d e�Z G d d � d e �Z G dd� de �Z!G dd� de�Z"dd� Z#dS )� N)�b�httplib)� JsonResponse�ConnectionUserAndKey�KeyCertificateConnection)�InvalidCredsError)� Container�ContainerImage�ContainerDriver)�ContainerState)�Providerc @ s8 e Zd ZejejejejgZdd� Z dd� Z dd� Z dS )�DockerResponsec 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 yj t �d | j�}|rf|�d �}t|��td��w )Nr z content-type�application/json� ztransfer-encoding�chunkedZ fromImagec S s g | ]}t �|��qS � )�json�loads)�.0�chunkr r �U/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/container/drivers/docker.py� <listcomp>@ s ��z-DockerResponse.parse_body.<locals>.<listcomp>� � z Error: (.+?)"� z.ConnectionError: Failed to parse JSON response)�len�bodyZparse_zero_length_body�headers�get�request�url�strip�replace�splitr r � ValueError�re�search�group� Exception)�self� content_typer �mZ error_msgr r r � parse_body3 s, �� � � �zDockerResponse.parse_bodyc C s | j dkr td��| jS )Ni� zInvalid credentials)�statusr r �r) r r r � parse_errorQ s zDockerResponse.parse_errorc C s | j | jv S �N)r- �valid_response_codesr. r r r �successV s zDockerResponse.successN) �__name__� __module__� __qualname__r �OK�ACCEPTED�CREATED� NO_CONTENTr1 r, r/ r2 r r r r r + s � r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�DockerExceptionc C s || _ || _||f| _d S r0 )�code�message�args)r) r; r< r r r �__init__[ s zDockerException.__init__c C � d� | j| j�S )Nz{} {}��formatr; r< r. r r r �__str__` � zDockerException.__str__c C r? )NzDockerException {} {}r@ r. r r r �__repr__c rC zDockerException.__repr__N)r3 r4 r5 r> rB rD r r r r r: Z s r: c @ s e Zd ZeZdZdd� ZdS )�DockerConnection�< 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 r � Content-Typez{}:{}zBasic %szutf-8Z Authorization)Zuser_id�key�base64� b64encoder rA �decode)r) r Zuser_b64r r r �add_default_headersk s z$DockerConnection.add_default_headersN)r3 r4 r5 r � responseCls�timeoutrL r r r r rE g s rE c s4 e Zd ZeZ d � fdd� Zdd� Z� ZS ) �DockertlsConnectionT� localhost� r c s� t � j|||||d d d d d d� |rJtj�|�} tj�| �o#tj�| �} | s*td��|| _tj�|�} tj�| �o>tj�| �} | sEtd��|| _ d S d S )N) �key_file� cert_file�secure�host�portr Z proxy_urlrN �backoffZ retry_delayzZYou need an key PEM file to authenticate with Docker tls. This can be found in the server.zbYou need an certificate PEM file to authenticate with Docker tls. This can be found in the server.) �superr> �os�path� expanduser�exists�isfiler rR rS ) r) rH �secretrT rU rV rR rS �kwargsZkeypathZ is_file_pathZcertpath�� __class__r r r> { s8 � � � �z DockertlsConnection.__init__c C s d|d< |S )Nr rG r )r) r r r r rL � s z'DockertlsConnection.add_default_headers)TrP rQ r r )r3 r4 r5 r rM r> rL � __classcell__r r r` r rO x s �*rO c s e Zd ZdZejZdZdZe Z dZ dZ d1� fd d � Z d d � Zdd� Zdd� Zd2dd�Z d3dd�Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd4d'd(�Zd)d*� Zd+d,� Z d-d.� Z d/d0� Z � Z S )5�DockerContainerDrivera] Docker container driver class. >>> from libcloud.container.providers import get_driver >>> driver = get_driver('docker') >>> conn = driver(host='198.61.239.128', port=4243) >>> conn.list_containers() or connecting to http basic auth protected https host: >>> conn = driver('user', 'pass', host='https://198.61.239.128', port=443) connect with tls authentication, by providing a hostname, port, a private key file (.pem) and certificate (.pem) file >>> conn = driver(host='https://198.61.239.128', >>> port=4243, key_file='key.pem', cert_file='cert.pem') ZDockerzhttp://docker.ioFz1.24r rP rQ Nc s� |r t | _|| _|| _d}|�d�rd}ddg}|D ] } |�| �r&|�| �}qt� j|||||||d� |s8|r@|r<|s@td��|| j _ || j _ || j _ | � � | _dS )a7 :param key: API key or username to used (required) :type key: ``str`` :param secret: Secret password to be used (required) :type secret: ``str`` :param secure: Whether to use HTTPS or HTTP. Note: Some providers only support HTTPS, and it is on by default. :type secure: ``bool`` :param host: Override hostname used for connections. :type host: ``str`` :param port: Override port used for connections. :type port: ``int`` :param key_file: Path to private key for TLS connection (optional) :type key_file: ``str`` :param cert_file: Path to public key for TLS connection (optional) :type cert_file: ``str`` :return: ``None`` Tzhttps://zhttp://)rH r^ rT rU rV rR rS zGNeeds both private key file and certificate file for tls authenticationN)rO � connectionClsrR rS � startswithr! rX r> r( � connectionrT rU rV �_get_api_version�version) r) rH r^ rT rU rV rR rS �prefixes�prefixr` r r r> � s< # �� �z DockerContainerDriver.__init__c C s0 i }t | d�r | j|d< t | d�r| j|d< |S )NrR rS )�hasattrrR rS )r) r_ r r r �_ex_connection_class_kwargs s z1DockerContainerDriver._ex_connection_class_kwargsc C s� i }t �|�}| jjd�| j|�|dd�}d|jv r td|j��d}t� d|j�s0t� d|j�r@t� d|j�r@t� d|j�d }|du rItdd ��t |||d| jj i d �}|S ) z� Install a container image from a remote path. :param path: Path to the container image :type path: ``str`` :rtype: :class:`libcloud.container.base.ContainerImage` z /v{}/images/create?fromImage={}�POST��data�methodZ errorDetailNzDownloaded newer imagez "Status: Image is up to datezsha256:(?P<id>[a-z0-9]{64})���zfailed to install image��id�namerZ rh �driver�extra) r �dumpsrf r rA rh r r: r% r& �findallr ru )r) rZ �payloadro �resultZimage_id�imager r r � install_image s4 � � �z#DockerContainerDriver.install_imagec C s� | j �d| j �j}g }|D ]9}z |�d�d }W n ty' |�d�}Y nw |�t|�d�||d| j j|�d�|�d�|�d�d �d �� q|S ) z� List the installed container images :rtype: ``list`` of :class:`libcloud.container.base.ContainerImage` z/v%s/images/jsonZRepoTagsr �IdN�CreatedZSizeZ VirtualSize)�created�sizeZ virtual_sizerr ) rf r rh �objectr r( �appendr ru )r) rz �imagesr{ rt r r r � list_imagesD s, ����z!DockerContainerDriver.list_imagesTc sz |rd}nd}z� j �d�� j|��j}W n ty1 } zt|dd�}|dkr,t|d��� d}~ww � fdd �|D �}|S ) aa List the deployed container images :param image: Filter to containers with a certain image :type image: :class:`libcloud.container.base.ContainerImage` :param all: Show all container (including stopped ones) :type all: ``bool`` :rtype: ``list`` of :class:`libcloud.container.base.Container` z?all=1r z/v{}/containers/json{}�errnoN�o z>Make sure docker host is accessibleand the API port is correctc s g | ]}� � |��qS r )� _to_container)r �valuer. r r r s z9DockerContainerDriver.list_containers.<locals>.<listcomp>)rf r rA rh r� r( �getattrr: )r) r{ �all�exrz �excr� Z containersr r. r �list_containersb s* �� ��� z%DockerContainerDriver.list_containersr �bridgec C s� t �t|��}|du r i }d|i}i d|�d|�d| �d|�d| �d|�d d �d | �d d �dd �dd �d| �d|�d| �d|j�d|�d|�|||||d |||d� �}t�|�}z| jjd| j ||dd�} W n% t y� } z| j put| �} | � d�r�t dd|j ��t d| ��d} ~ ww | j d } g d |d �}t�|�}|r�t| �� �d kr�| jjd �| j| �dd �} n| jjd �| j| �|dd!�} | �| �S )"a% Deploy an installed container image For details on the additional parameters see : http://bit.ly/1PjMVKV :param name: The name of the new container :type name: ``str`` :param image: The container image to deploy :type image: :class:`libcloud.container.base.ContainerImage` :param parameters: Container Image parameters :type parameters: ``str`` :param start: Start the container on deployment :type start: ``bool`` :rtype: :class:`Container` Nrt ZHostnameZ DomainnameZ ExposedPortsZUserZTtyZ OpenStdinZ StdinOnceFZMemoryZ AttachStdinTZ AttachStdoutZ AttachStderrZEnvZCmdZDns�ImageZVolumesZ VolumesFrom) ZNetworkDisabledZ EntrypointZ CpuSharesZ WorkingDirZ MemorySwap�PublishAllPorts� PortBindingsZ NetworkModeZLabelsz/v%s/containers/createrm )ro �paramsrp zNo such image:zNo such image: %sr} )�Bindsr� r� ��Q� ��?�/v{}/containers/{}/start�rp rn )�shlexr# �strrt r rw rf r rh r( r< re r: r� �floatrg rA � get_container) r) rt r{ � parameters�start�command�hostname�userZ stdin_openZttyZ mem_limit�portsZ environmentZdnsZvolumesZ volumes_fromZnetwork_disabledZ entrypointZ cpu_sharesZ working_dirZ domainnameZ memswap_limitZ port_bindingsZ network_mode�labelsr� ry ro rz �er< Zid_r r r �deploy_container� s� .�������� � � � � ������ � �� � � � z&DockerContainerDriver.deploy_containerc C s" | j �d�| j|��j}| �|�S )z� Get a container by ID :param id: The ID of the container to get :type id: ``str`` :rtype: :class:`libcloud.container.base.Container` z/v{}/containers/{}/json)rf r rA rh r� r� )r) rs rz r r r r� � s z#DockerContainerDriver.get_containerc C s� t | �� �dkr| jjd�| j|j�dd�}ng dd�}t�|�}| jjd�| j|j�d|d�}|j t v r;| � |j�S t |j d��) a Start a container :param container: The container to be started :type container: :class:`libcloud.container.base.Container` :return: The container refreshed with current data :rtype: :class:`libcloud.container.base.Container` r� r� rm r� T)r� r� �rp ro zfailed to start container) r� rg rf r rA rh rs r rw r- �VALID_RESPONSE_CODESr� r: )r) � containerrz ry ro r r r �start_container s �� � z%DockerContainerDriver.start_containerc C s> | j jd�| j|j�dd�}|jtv r| �|j�S t|jd��)a Stop a container :param container: The container to be stopped :type container: :class:`libcloud.container.base.Container` :return: The container refreshed with current data :rtype: :class:`libcloud.container.base.Container` z/v{}/containers/{}/stoprm r� zfailed to stop container) rf r rA rh rs r- r� r� r: �r) r� rz r r r �stop_container$ s � z$DockerContainerDriver.stop_containerc C sN t �ddi�}| jjd�| j|j�|dd�}|jtv r!| � |j�S t |jd��)a Restart a container :param container: The container to be stopped :type container: :class:`libcloud.container.base.Container` :return: The container refreshed with current data :rtype: :class:`libcloud.container.base.Container` �t� z/v{}/containers/{}/restartrm rn zfailed to restart container) r rw rf r rA rh rs r- r� r� r: )r) r� ro rz r r r �restart_container6 s � z'DockerContainerDriver.restart_containerc C �& | j jd�| j|j�dd�}|jtv S )a Remove a container :param container: The container to be destroyed :type container: :class:`libcloud.container.base.Container` :return: True if the destroy was successful, False otherwise. :rtype: ``bool`` z/v{}/containers/{}�DELETEr� )rf r rA rh rs r- r� r� r r r �destroy_containerL s � z'DockerContainerDriver.destroy_containerc C s | j �d�| j|j��j}|S )z� List processes running inside a container :param container: The container to list processes for. :type container: :class:`libcloud.container.base.Container` :rtype: ``str`` z/v{}/containers/{}/top)rf r rA rh rs r� r� r r r �ex_list_processes[ s ��z'DockerContainerDriver.ex_list_processesc C s8 | j jd�| j|j|�dd�}|jtv r| �|j�S dS )a Rename a container :param container: The container to be renamed :type container: :class:`libcloud.container.base.Container` :param name: The new name :type name: ``str`` :rtype: :class:`libcloud.container.base.Container` z!/v{}/containers/{}/rename?name={}rm r� N)rf r rA rh rs r- r� r� )r) r� rt rz r r r �ex_rename_containerj s � �z)DockerContainerDriver.ex_rename_containerc C st i }t �|�}t| �� �dkr#| j�d| j|jt|�f �j }|}|S | jjd| j|jt|�f d|d�}|j }|S )a� Get container logs If stream == True, logs will be yielded as a stream From Api Version 1.11 and above we need a GET request to get the logs Logs are in different format of those of Version 1.10 and below :param container: The container to list logs for :type container: :class:`libcloud.container.base.Container` :param stream: Stream the output :type stream: ``bool`` :rtype: ``bool`` g�������?z3/v%s/containers/%s/logs?follow=%s&stdout=1&stderr=1z</v%s/containers/%s/attach?logs=1&stream=%s&stdout=1&stderr=1rm r� ) r rw r� rg rf r rh rs r� r� r )r) r� �streamry ro rz �logsr r r � ex_get_logs} s* ��� ���z!DockerContainerDriver.ex_get_logsc C s� |� dd�}| j�d�| j|��j}g }|D ]'}|�d�}|�t||d|| jj |�d�|�d�|�d�|�d �d �d �� q|S ) a� Search for an image on Docker.io. Returns a list of ContainerImage objects >>> images = conn.ex_search_images(term='mistio') >>> images [<ContainerImage: id=rolikeusch/docker-mistio...>, <ContainerImage: id=mist/mistio, name=mist/mistio, driver=Docker ...>] :param term: The search term :type term: ``str`` :rtype: ``list`` of :class:`libcloud.container.base.ContainerImage` � �+z/v{}/images/search?term={}rt N� description� is_official� is_trusted� star_count)r� r� r� r� )rs rZ rh rt ru rv ) r" rf r rA rh r� r r� r ru )r) Ztermrz r� r{ rt r r r �ex_search_images� s0 �� ���z&DockerContainerDriver.ex_search_imagesc C r� )z� Remove image from the filesystem :param image: The image to remove :type image: :class:`libcloud.container.base.ContainerImage` :rtype: ``bool`` z/v{}/images/{}r� r� )rf r rA rh rt r- r� )r) r{ rz r r r �ex_delete_image� s � z%DockerContainerDriver.ex_delete_imagec C s� z |� d��d�}W n$ ty. z |� d�d �d�}W n ty+ |� d�}Y nw Y nw |� d�}t|t�rI|� d|durE|� d�nd�}n|� d�}d |v rVtj}n|�d �r_tj}n d |v rgtj}ntj}|� d �}|� d g �}|� d�}t|t �r�t |�}|� d�|� d�||||� d�|� d�|� d�d�}g } |dur�|D ]} | � d�dur�| � | � d�� q�t |d |t |� dd�||d| jjd�| || jj|d�S )z: Convert container in Container instances �Name�/ZNamesr r} �StateZStatusNZExitedzUp Zrunningr� ZPortsr~ ZCommandZSizeRwZ SizeRootFs)rs r- r r{ r� r� ZsizerwZ sizerootfsZIPZImageID)rs rZ rt rh ru )rs rt r{ Z ip_addresses�stateru rv )r r! r( � isinstance�dictr ZSTOPPEDre ZRUNNINGr� � ts_to_strr� r r rf ru ) r) ro rt r� r- r{ r� r rv �ipsrV r r r r� � sp ��� � � ��z#DockerContainerDriver._to_containerc C s$ | j �d�j}|p i }|�d�}|S )z8 Get the docker API version information z/versionZ ApiVersion)rf r r� r )r) rz � api_versionr r r rg s z&DockerContainerDriver._get_api_version)r r FrP rQ NN)NT)NTNNr TTr NNNNNFNNr Nr Nr� N)F) r3 r4 r5 �__doc__r ZDOCKER�typert ZwebsiterE rd Zsupports_clustersrh r> rl r| r� r� r� r� r� r� r� r� r� r� r� r� r� r� rg rb r r r` r rc � sn �M- $ �v $)<rc c C s t j �| �}|�d�}|S )zC Return a timestamp as a nicely formatted datetime string. z%d/%m/%Y %H:%M %Z)�datetime� fromtimestamp�strftime)� timestamp�dateZ date_stringr r r r� s r� )$rY r% r� rI r� Zlibcloud.utils.py3r r Zlibcloud.common.baser r r Zlibcloud.common.typesr Zlibcloud.container.baser r r Zlibcloud.container.typesr Z libcloud.container.providersr Z simplejsonr r( r6 r7 r8 r9 r� r r: rE rO rc r� r r r r �<module> s> ��/ 2 y
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings