File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/container/drivers/__pycache__/kubernetes.cpython-310.pyc
Back
o ;jzT � @ s� d dl Z d dlZd dlZd dlmZmZmZmZmZ d dl m Z d dl m Z m Z mZ d dlmZ d dlmZmZmZmZ d dlmZ d dlmZ d d lmZm Z m Z d d l m Z g d �Z d Z!e d dddddd��Z"de#de$fdd�Z%d.de$dee# de#fdd�Z&d ee$e'f de#fd d �Z(d e#dee$e'f fd d!�Z)d"d#� Z*G d$d%� d%�Z+G d&d'� d'�Z,G d(d)� d)e�Z-G d*d+� d+e e�Z.d,d-� Z/dS )/� N)�Any�Dict�List�Union�Optional)� OrderedDict)�Node�NodeSize� NodeImage)� NodeState)� Container�ContainerImage�ContainerDriver�ContainerCluster)�ContainerState)� BaseHTTPError)�KubernetesException�KubernetesDriverMixin� KubernetesBasicAuthConnection)�Provider)�KubernetesContainerDriver� to_n_bytes� to_memory_str� to_cpu_str� to_n_cpusz/api/�� i �@B i � ʚ;i @)�KZKi�MZMi�GZGi� memory_str�returnc C sT | � d�rdS | �� rt| �S t�� D ]\}}| �|�r't| �|��| S qdS )zNConvert memory string to number of bytes (e.g. '1234Mi'-> 1293942784) �0r N)� startswith� isnumeric�int� K8S_UNIT_MAP�items�endswith�strip)r! �unit� multiplier� r- �Y/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/container/drivers/kubernetes.pyr : s ��r �n_bytesr+ c C s� | dkrdS t | �} d}|du r4tt�� �D ]\}}| | }| | }|� |� �}|d dkr1 |S q|S t�|�rC| t| � |� �}|S )zSConvert number of bytes to k8s memory string (e.g. 1293942784 -> '1234Mi') r �0KN� )r& �reversedr' r( �get)r/ r+ r! r, Zconverted_n_bytes_floatZconverted_n_bytesr- r- r. r J s" � �r �n_cpusc C sf | dkrdS | d }|d dkrt |�� d�S | d }|d dkr(t |�� d�S | d }t |�� d �S ) zBConvert number of cpus to cpu string (e.g. 0.5 -> '500m') r r# r r1 �mr �ur �n)r& )r4 Z millicoresZ microcoresZ nanocoresr- r- r. r b s r �cpu_strc C sh | � d�rt| �d��d S | � d�r t| �d��d S | � d�r*t| �d��d S | �� r2t| �S dS )zVConvert cpu string to number of cpus (e.g. '500m' -> 0.5, '2000000000n' -> 2) r7 r r6 r r5 r r )r) r& r* r% )r8 r- r- r. r v s r c G sL d}d}| D ]}|t |�dd��7 }|t|�dd��7 }qt|�t|�d�S )Nr �cpuZ0m�memoryr0 )r9 r: )r r3 r r r )Zresource_dictsZ total_cpuZ total_memoryZrdr- r- r. � sum_resources� s r; c @ sR e Zd Z d dedededededeeef deeeef fd d �Zd d � Z dS )�KubernetesDeploymentN�id�name� namespace� created_at�replicas�selector�extrac C s2 || _ || _|| _|| _|| _|| _|pi | _d S �N�r= r> r? r@ rA rB rC )�selfr= r> r? r@ rA rB rC r- r- r. �__init__� s z KubernetesDeployment.__init__c C � d� | j| j| j�S )Nz7<KubernetesDeployment name={} namespace={} replicas={}>)�formatr> r? rA �rF r- r- r. �__repr__� � �z KubernetesDeployment.__repr__rD ) �__name__� __module__� __qualname__�strr& r r r rG rK r- r- r- r. r< � s$ ������ � � r< c @ sT e Zd Zdededee dededee dejded eeef fd d �Z d d � Z dS )� KubernetesPodr= r> � containersr? �state� ip_addressesr@ � node_namerC c C s: || _ || _|| _|| _|| _|| _|| _|| _| | _dS )z" A Kubernetes pod N) r= r> rR r? rS rT r@ rU rC ) rF r= r> rR r? rS rT r@ rU rC r- r- r. rG � s zKubernetesPod.__init__c C rH )Nz-<KubernetesPod name={} namespace={} state={}>)rI r> r? rS rJ r- r- r. rK � rL zKubernetesPod.__repr__N) rM rN rO rP r r �datetimer r rG rK r- r- r- r. rQ � s* ������� � � rQ c @ s e Zd ZdZdd� ZdS )�KubernetesNamespacez A Kubernetes namespace c C s d� | j�S )Nz <KubernetesNamespace name={}>)rI r> rJ r- r- r. rK � s z KubernetesNamespace.__repr__N)rM rN rO �__doc__rK r- r- r- r. rW � s rW c @ s� e Zd ZejZdZdZeZ dZ d=de e fdd�Z dede fd d �Zde e fd d �Zdedefd d�Zdedefdd�Zdedefdd�Z d>dedededee dee f dd�Zde defdd �Zd?d ede e fd d �Zded!edefd"d#�Z de e fd$d%�Z d&edefd'd(�Z defd)d*�Z de e!ee"f fd+d,�Z#de e!ee"f fd-d.�Z$de e!ee"f fd/d0�Z%de e& fd1d2�Z'd3d4� Z(d5d6� Z)d@d7d8�Z*d9d:� Z+d;d<� Z,dS )Ar Z Kuberneteszhttp://kubernetes.ioTNr" c s� z � j �td �j}W n ty' } zt|dd�}|dkr"t|d��� d}~ww � fdd�|d D �}g }|D ]}|�|j� q7|S ) aY List the deployed container images :param image: Filter to containers with a certain image(unused) :type image: :class:`libcloud.container.base.ContainerImage` :param all: Show all container (unused) :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 � g | ]}� � |��qS r- ��_to_pod��.0�valuerJ r- r. � <listcomp>� � z=KubernetesContainerDriver.list_containers.<locals>.<listcomp>r( ) � connection�request�ROOT_URL�object� Exception�getattrr �extendrR ) rF �image�all�result�excrZ ZpodsrR �podr- rJ r. �list_containers� s" ��� z)KubernetesContainerDriver.list_containersr= c 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- �r= )ra � containerrr r- r. rc � z;KubernetesContainerDriver.get_container.<locals>.<listcomp>r )rq )rF r= rR �matchr- rr r. � get_container� s z'KubernetesContainerDriver.get_containerc sj z � j �td �j}W n ty' } zt|dd�}|dkr"t|d��� d}~ww � fdd�|d D �}|S ) z� Get a list of namespaces that pods can be deployed into :rtype: ``list`` of :class:`.KubernetesNamespace` zv1/namespaces/rZ Nr[ r\ c r] r- )� _to_namespacer` rJ r- r. rc rd z=KubernetesContainerDriver.list_namespaces.<locals>.<listcomp>r( )re rf rg rh ri rj r )rF rn ro rZ Z namespacesr- rJ r. �list_namespaces s ��� z)KubernetesContainerDriver.list_namespacesc C s | j �td| �j}| �|�S )z� Get a namespace by ID :param id: The ID of the namespace to get :type id: ``str`` :rtype: :class:`.KubernetesNamespace` �v1/namespaces/%s)re rf rg rh rw )rF r= rn r- r- r. � get_namespace# s z'KubernetesContainerDriver.get_namespacer? c C s | j jtd|j dd�j dS )z� Delete a namespace :return: ``True`` if the destroy was successful, otherwise ``False``. :rtype: ``bool`` ry �DELETE��methodT)re rf rg r= rh )rF r? r- r- r. �delete_namespace0 s �z*KubernetesContainerDriver.delete_namespacer> c C s4 dd|ii}| j jtd dt�|�d�j}| �|�S )z� Create a namespace :param name: The name of the namespace :type name: ``str`` :rtype: :class:`.KubernetesNamespace` �metadatar> z v1/namespaces�POST�r} �data)re rf rg �json�dumpsrh rw )rF r> rf rn r- r- r. �create_namespace= s �� z*KubernetesContainerDriver.create_namespacerl � parameters�startc 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 namespace: The namespace to deploy to, None is default :type namespace: :class:`.KubernetesNamespace` :param parameters: Container Image parameters(unused) :type parameters: ``str`` :param start: Start the container on deployment(unused) :type start: ``bool`` :rtype: :class:`.Container` N�defaultr> rR )r> rl )r �speczv1/namespaces/%s/podsr� r� ) r= r> re rf rg r� r� rh rw )rF r> rl r? r� r� rf rn r- r- r. �deploy_containerM s � �� z*KubernetesContainerDriver.deploy_containerrs c 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? rp )�ex_destroy_podrC )rF rs r- r- r. �destroy_container| s z+KubernetesContainerDriver.destroy_containerF� fetch_metricsc s\ �j �td �j}d� |r"z dd� ��� D �� W n ty! Y nw � �fdd�|d D �S )z� List available Pods :param fetch_metrics: Fetch metrics for pods :type fetch_metrics: ``bool`` :rtype: ``list`` of :class:`.KubernetesPod` rY Nc S s* i | ]}|d d |d d f|d �qS )r r> r? rR r- )ra Zmetricr- r- r. � <dictcomp>� s � ��z:KubernetesContainerDriver.ex_list_pods.<locals>.<dictcomp>c s g | ] }�j |� d ��qS ))�metricsr^ r` �r� rF r- r. rc � rt z:KubernetesContainerDriver.ex_list_pods.<locals>.<listcomp>r( )re rf rg rh �ex_list_pods_metricsr )rF r� rn r- r� r. � ex_list_pods� s � �z&KubernetesContainerDriver.ex_list_pods�pod_namec C s" | j jtd�||� dd�j dS )z� Delete a pod and the containers within it. :param namespace: The pod's namespace :type namespace: ``str`` :param pod_name: Name of the pod to destroy :type pod_name: ``str`` :rtype: ``bool`` zv1/namespaces/{}/pods/{}r{ r| T)re rf rg rI rh )rF r? r� r- r- r. r� � s �z(KubernetesContainerDriver.ex_destroy_podc s( � j �td �j}� fdd�|d D �S )zR List available Nodes :rtype: ``list`` of :class:`.Node` zv1/nodesc r] r- )�_to_node)ra �noderJ r- r. rc � rd z;KubernetesContainerDriver.ex_list_nodes.<locals>.<listcomp>r( �re rf rg rh )rF rn r- rJ r. � ex_list_nodes� s z'KubernetesContainerDriver.ex_list_nodesrU c C s | j jtd|� � dd�j dS )z� Destroy a node. :param node_name: Name of the node to destroy :type node_name: ``str`` :rtype: ``bool`` z v1/nodes/r{ r| Tr� )rF rU r- r- r. �ex_destroy_node� s z)KubernetesContainerDriver.ex_destroy_nodec C � | j �d�jd S )z8Get Kubernetes version :rtype: ``str`` z/versionZ gitVersion�re rf rh rJ r- r- r. �ex_get_version� � z(KubernetesContainerDriver.ex_get_versionc C r� )z_Get nodes metrics from Kubernetes Metrics Server :rtype: ``list`` of ``dict`` z"/apis/metrics.k8s.io/v1beta1/nodesr( r� rJ r- r- r. �ex_list_nodes_metrics� r� z/KubernetesContainerDriver.ex_list_nodes_metricsc C r� )z^Get pods metrics from Kubernetes Metrics Server :rtype: ``list`` of ``dict`` z!/apis/metrics.k8s.io/v1beta1/podsr( r� rJ r- r- r. r� � r� z.KubernetesContainerDriver.ex_list_pods_metricsc C s | j �td �jd S )zCGet cluster services :rtype: ``list`` of ``dict`` z v1/servicesr( r� rJ r- r- r. �ex_list_services� s z*KubernetesContainerDriver.ex_list_servicesc s$ � j �d�jd }� fdd�|D �S )z\Get cluster deployments :rtype: ``list`` of :class:`.KubernetesDeployment` z/apis/apps/v1/deploymentsr( c r] r- )�_to_deployment)ra �itemrJ r- r. rc � rd zAKubernetesContainerDriver.ex_list_deployments.<locals>.<listcomp>r� )rF r( r- rJ r. �ex_list_deployments� s z-KubernetesContainerDriver.ex_list_deploymentsc C s� |d d }|d d }|d d }|d d }|d d }|d d }|d d |d d d |d d |d d |d d |d d |d d d�}t |||||||d�S )Nr �uidr> r? �creationTimestampr� rA rB �labels�strategy�type�statusZupdatedReplicasZ readyReplicasZavailableReplicas� conditions)r� r� Ztotal_replicasZupdated_replicasZready_replicasZavailable_replicasr� rE )r< ) rF r� �id_r> r? r@ rA rB rC r- r- r. r� � s. � �z(KubernetesContainerDriver._to_deploymentc C s� |d d }|d d }| j j}|d �di ��dd�}|d �di ��dd �}t|t�r5|�� s5t|�}|d d �d �}t|||�}|� d |� d �} t� | � d��� � } d|i} t | | |ddd|| d�} ||d�} |d d �d�| d< |d d d | d< |�di ��d�| d< |d d D ]}|d dkr�|d d kr�t j} nq�t j}g g }}|d d D ] }|d d kr�|�|d � q�|d d kr�|�|d � q�tj�|d d! d"�}t|||||||| | |d#� S )$zD Convert an API node data object to a `Node` object r r� r> r� Zcapacityr: r0 r9 �1ZnodeInfoZosImagez vCPUs, z Ramzutf-8Zcpusr )r= r> ZramZdiskZ bandwidthZprice�driverrC )r: r9 ZoperatingSystem�osZkubeletVersionr� Z providerIDZ provider_idr� r� ZReady�True� addressesZ InternalIP�addressZ ExternalIPr� �%Y-%m-%dT%H:%M:%SZ) r= r> rS � public_ips� private_ipsr� rl �sizerC r@ )re r� r3 � isinstancerP r% r r �hashlib�md5�encode� hexdigestr r �RUNNING�UNKNOWN�appendrV �strptimer )rF r� �IDr> r� r: r9 Z image_namerl Z size_nameZsize_id� extra_sizer� rC Z conditionrS r� r� r� r@ r- r- r. r� sl � � � ��z"KubernetesContainerDriver._to_nodec sx |d d }|d d }|d d }|d d � � }|d �d�}|d �d i �}g } d i i} |rEz |||f | d < W n tyD Y nw |d d D ]K� |r]tt� fd d�|��d } n|} | �� | |�} | d } | j�d i �}t| �di �|�di ��| d< t| �di �|�di ��| d d< | �| � qKdd� |d �dg �D �}t j � |d d d�}t |||||| ||| d� S )z9 Convert an API response to a Pod object r r� r> r? r� �phaser� ZnodeNameZcontainerStatuses� resourcesr� rR c s | d � d kS )Nr> r- )�i�rs r- r. �<lambda>i s z3KubernetesContainerDriver._to_pod.<locals>.<lambda>r ZlimitsZrequestsc S s g | ]}|d �qS )�ipr- )ra Zip_dictr- r- r. rc w s z5KubernetesContainerDriver._to_pod.<locals>.<listcomp>ZpodIPsr� r� ) r= r> r? rS rT rR r@ rU rC ) �lowerr3 �KeyError�list�filter� _to_containerrC r; r� rV r� rQ )rF r� r� r� r> r? rS rU Zcontainer_statusesrR rC r� Z container_objr� Zcontainer_resourcesrT r@ r- r� r. r_ R sV � � � ��z!KubernetesContainerDriver._to_podc C s� |� d�}d}|r t|�� �d � d�}|r tj�|d�}|d d |d d d �}|� d �}|r5||d < t|� d �p>|d |d t|� d �pJ|d |d dd| jjd�d|rZt j nt j | jj||d�S )z: Convert container in Container instances rS Nr Z startedAtr� r r> r? )rp r? r� Z containerIDZimageIDrl )r= r> �path�versionr� )r= r> rl rT rS r� r@ rC ) r3 r� �valuesrV r� r r re r� r r� r� ) rF r� Zcontainer_statusZpod_datarS r@ Z started_atrC r� r- r- r. r� � s8 � ��z'KubernetesContainerDriver._to_containerc C s0 t |d d |d d | jjd|d d id�S )zS Convert an API node data object to a `KubernetesNamespace` object r r> r� r� )r= r> r� rC )rW re r� )rF r� r- r- r. rw � s �z'KubernetesContainerDriver._to_namespace)NT)NNT)FrD )-rM rN rO r Z KUBERNETESr� r> Zwebsiter Z connectionClsZsupports_clustersr r rq rP rv rW rx rz �boolr~ r� r r r� r� rQ r� r� r r� r� r� r r r� r� r� r< r� r� r� r_ r� rw r- r- r- r. r � sR ����� �/ ?6 &r c C s t j �| �}|�d�}|S )zC Return a timestamp as a nicely formatted datetime string. z%d/%m/%Y %H:%M %Z)rV � fromtimestamp�strftime)� timestamp�dateZ date_stringr- r- r. � ts_to_str� s r� rD )0r� r� rV �typingr r r r r � collectionsr Zlibcloud.compute.baser r r Zlibcloud.compute.typesr Zlibcloud.container.baser r r r Zlibcloud.container.typesr Zlibcloud.common.exceptionsr Zlibcloud.common.kubernetesr r r Z libcloud.container.providersr �__all__rg r' rP r& r r �floatr r r; r< rQ rW r r� r- r- r- r. �<module> sH �� " f
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings