Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/container/drivers/__pycache__/kubernetes.cpython-39.pyc
Ðазад
a q�h[' � @ s� d dl Z d dlZd dlmZmZmZmZ d dlmZ d dlm Z d dlm Z d dl m Z d dl mZ dgZd ZG d d � d e�ZG d d� de e�Zd d� ZdS )� N)� Container�ContainerDriver�ContainerImage�ContainerCluster)�KubernetesException)� KubernetesBasicAuthConnection)�KubernetesDriverMixin)�Provider)�ContainerState�KubernetesContainerDriverz/api/c @ s e Zd Zdd� ZdS )� KubernetesPodc C s || _ || _|| _dS )z" A Kubernetes pod N)�name� containers� namespace)�selfr r r � 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/kubernetes.py�__init__& s zKubernetesPod.__init__N)�__name__� __module__� __qualname__r r r r r r % s r c @ s� e Zd ZejZdZdZeZ dZ d dd�Z dd� Z d d � Z d d � Zd d� Zd dd�Zd!dd�Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � ZdS )"r Z Kuberneteszhttp://kubernetes.ioTNc s� z� j �td �j}W nD tyZ } z,t|dd�}|dkrDt|d��� W Y d}~n d}~0 0 � fdd�|d D �}g }|D ]}|�|j� qz|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` �v1/pods�errnoN�o �<Make sure kube host is accessibleand the API port is correctc s g | ]}� � |��qS r ��_to_pod��.0�value�r r r � <listcomp>N � z=KubernetesContainerDriver.list_containers.<locals>.<listcomp>�items) � connection�request�ROOT_URL�object� Exception�getattrr �extendr ) r �image�all�result�excr Zpodsr �podr r r �list_containers6 s" � �z)KubernetesContainerDriver.list_containersc s" | � � }� fdd�|D �}|d 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` c s g | ]}|j � kr|�qS r ��id)r � containerr1 r r r! ^ r" z;KubernetesContainerDriver.get_container.<locals>.<listcomp>r )r0 )r r2 r �matchr r1 r � get_containerT s z'KubernetesContainerDriver.get_containerc sv z� j �td �j}W nD tyZ } z,t|dd�}|dkrDt|d��� W Y d}~n d}~0 0 � fdd�|d D �}|S ) a Get a list of namespaces that pods can be deployed into :param location: The location to search in :type location: :class:`libcloud.container.base.ClusterLocation` :rtype: ``list`` of :class:`libcloud.container.base.ContainerCluster` zv1/namespaces/r Nr r c s g | ]}� � |��qS r )� _to_clusterr r r r r! v r" z;KubernetesContainerDriver.list_clusters.<locals>.<listcomp>r# )r$ r% r& r' r( r) r )r r- r. r Zclustersr r r � list_clustersa s � �z'KubernetesContainerDriver.list_clustersc C s | j �td| �j}| �|�S )z� Get a cluster by ID :param id: The ID of the cluster to get :type id: ``str`` :rtype: :class:`libcloud.container.base.ContainerCluster` �v1/namespaces/%s)r$ r% r& r' r6 )r r2 r- r r r � get_clustery s � z%KubernetesContainerDriver.get_clusterc C s | j jtd|j dd�j dS )z� Delete a cluster (namespace) :return: ``True`` if the destroy was successful, otherwise ``False``. :rtype: ``bool`` r8 �DELETE��methodT)r$ r% r& r2 r' )r �clusterr r r �destroy_cluster� s ��z)KubernetesContainerDriver.destroy_clusterc C s4 dd|ii}| j jtd dt�|�d�j}| �|�S )a( Create a container cluster (a namespace) :param name: The name of the cluster :type name: ``str`` :param location: The location to create the cluster in :type location: :class:`.ClusterLocation` :rtype: :class:`.ContainerCluster` �metadatar z v1/namespaces�POST�r< �data)r$ r% r& �json�dumpsr' r6 )r r �locationr% r- r r r �create_cluster� s �� �z(KubernetesContainerDriver.create_clusterc C s\ |du rd}n|j }d|id||jd�gid�}| jjtd| dt�|�d �j}| �|�S ) a� Deploy an installed container image. In kubernetes this deploys a single container Pod. https://cloud.google.com/container-engine/docs/pods/single-container :param name: The name of the new container :type name: ``str`` :param image: The container image to deploy :type image: :class:`.ContainerImage` :param cluster: The cluster to deploy to, None is default :type cluster: :class:`.ContainerCluster` :param parameters: Container Image parameters :type parameters: ``str`` :param start: Start the container on deployment :type start: ``bool`` :rtype: :class:`.Container` N�defaultr r )r r+ )r? �speczv1/namespaces/%s/podsr@ rA ) r2 r r$ r% r& rC rD r' r6 ) r r r+ r= � parameters�startr r% r- r r r �deploy_container� s& ����� ��z*KubernetesContainerDriver.deploy_containerc C s | � |jd |jd �S )z� Destroy a deployed container. Because the containers are single container pods, this will delete the pod. :param container: The container to destroy :type container: :class:`.Container` :rtype: ``bool`` r r/ )�ex_destroy_pod�extra)r r3 r r r �destroy_container� s �z+KubernetesContainerDriver.destroy_containerc s( � j �td �j}� fdd�|d D �S )zZ List available Pods :rtype: ``list`` of :class:`.KubernetesPod` r c s g | ]}� � |��qS r r r r r r r! � r" z:KubernetesContainerDriver.ex_list_pods.<locals>.<listcomp>r# �r$ r% r& r' )r r- r r r � ex_list_pods� s z&KubernetesContainerDriver.ex_list_podsc C s" | j jtd||f dd�j dS )z< Delete a pod and the containers within it. zv1/namespaces/%s/pods/%sr: r; TrO )r r Zpod_namer r r rL � s ��z(KubernetesContainerDriver.ex_destroy_podc sn |d d }g }|d d D ]2� t t� fdd�|��d }|�| �� ||�� q t|d d |d d |d �S ) z9 Convert an API response to a Pod object �statusZcontainerStatusesrH r c s | d � d kS )Nr r )�i�r3 r r �<lambda>� r" z3KubernetesContainerDriver._to_pod.<locals>.<lambda>r r? r r )r r r )�list�filter�append� _to_containerr )r rB Zcontainer_statusesr rH r rS r r � s �� � �z!KubernetesContainerDriver._to_podc C sT t |d |d t|d |d dd| jjd�dtj| jj|d d |d d d �d �S ) z: Convert container in Container instances Z containerIDr ZimageIDr+ N)r2 r �path�version�driverr? r )r/ r )r2 r r+ Z ip_addresses�stater[ rM )r r r$ r[ r ZRUNNING)r rB Zcontainer_statusZpod_datar r r rX s" � ��z'KubernetesContainerDriver._to_containerc C s4 |d }|d }t |d |d | jjd|d id�S )z0 Convert namespace to a cluster r? rQ r Zphase)r2 r r[ rM )r r$ r[ )r rB r? rQ r r r r6 s �z%KubernetesContainerDriver._to_cluster)NT)N)NNT)r r r r Z KUBERNETES�typer Zwebsiter Z connectionClsZsupports_clustersr0 r5 r7 r9 r> rF rK rN rP rL r rX r6 r r r r r / s( � / c C s t j �| �}|�d�}|S )zB Return a timestamp as a nicely formated datetime string. z%d/%m/%Y %H:%M %Z)�datetime� fromtimestamp�strftime)� timestamp�dateZ date_stringr r r � ts_to_str+ s rc )r^ rC Zlibcloud.container.baser r r r Zlibcloud.common.kubernetesr r r Z libcloud.container.providersr Zlibcloud.container.typesr �__all__r& r' r r rc r r r r �<module> s � }
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка