File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/kubernetesmod.cpython-310.pyc
Back
o ;j� � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl Z ddlZ ddlZ ddlZ ddlmZmZ z8ddlZddlZddlmZ ddlmZ zddlmZ ddlm Z W n e yt dd lmZm Z Y nw d Z W n e y� d Z Y nw e� e!�Z"d Z#d d� Z$e j%j&�'� s�e dd� �Z(dZ)dd� Z*dd� Z+dd� Z,dd� Z-dd� Z.d d � Z/d d � Z0d d!� Z1d"d#� Z2d$d%� Z3d&d'� Z4dnd)d*�Z5dnd+d,�Z6dnd-d.�Z7dnd/d0�Z8dnd1d2�Z9dnd3d4�Z:dnd5d6�Z;dnd7d8�Z<d9d:� Z=dod;d<�Z>dnd=d>�Z?dnd?d@�Z@dndAdB�ZAdndCdD�ZBdEdF� ZCdndGdH�ZDdndIdJ�ZEdKdL� ZFdMdN� ZGdOdP� ZH ( QdpdRdS�ZI QdqdTdU�ZJdVdW� ZK (dndXdY�ZL (dndZd[�ZM Q (drd\d]�ZN Q (drd^d_�ZOd`da� ZPdbdc� ZQddde� ZRdfdg� ZSdhdi� ZTdjdk� ZUdldm� ZVdS )sai Module for handling kubernetes calls. :optdepends: - kubernetes Python client < 4.0 - PyYAML < 6.0 :configuration: The k8s API settings are provided either in a pillar, in the minion's config file, or in master's config file:: kubernetes.kubeconfig: '/path/to/kubeconfig' kubernetes.kubeconfig-data: '<base64 encoded kubeconfig content' kubernetes.context: 'context' These settings can be overridden by adding `context and `kubeconfig` or `kubeconfig_data` parameters when calling a function. The data format for `kubernetes.kubeconfig-data` value is the content of `kubeconfig` base64 encoded in one line. Only `kubeconfig` or `kubeconfig-data` should be provided. In case both are provided `kubeconfig` entry is preferred. CLI Example: .. code-block:: bash salt '*' kubernetes.nodes kubeconfig=/etc/salt/k8s/kubeconfig context=minikube .. versionadded:: 2017.7.0 .. versionchanged:: 2019.2.0 .. warning:: Configuration options changed in 2019.2.0. The following configuration options have been removed: - kubernetes.user - kubernetes.password - kubernetes.api_url - kubernetes.certificate-authority-data/file - kubernetes.client-certificate-data/file - kubernetes.client-key-data/file Please use now: - kubernetes.kubeconfig or kubernetes.kubeconfig-data - kubernetes.context � N)�contextmanager)�CommandExecutionError� TimeoutError)� ApiException)� HTTPError)�V1beta1Deployment)�V1beta1DeploymentSpec)�AppsV1beta1Deployment�AppsV1beta1DeploymentSpecTF� kubernetesc C s t rtS dS )z Check dependencies )Fz#python kubernetes library not found)�HAS_LIBS�__virtualname__� r r �N/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/kubernetesmod.py� __virtual__[ s r c c sF � dd� }t � t j|� t �| � z d V W t �d� d S t �d� w )Nc S s t �)N)r )�signum�framer r r �signal_handleri s z#_time_limit.<locals>.signal_handlerr )�signal�SIGALRM�alarm)�secondsr r r r � _time_limitg s � r � c K s| t d dd�}t d d�}t d d�}t d d�}t d d�}t d d�}t d d �}t d d �}t d d �} d | v r@| �d �}d | v rI| �d �}d| v rR| �d�}d| v r[| �d�}d| v rd| �d�}d| v rm| �d�} tjjj|ks�tjjj|ks�tjjj|kr�tjj�� |tjj_|tjj_|tjj_ |r�|tjj_ n-|r�t j ddd��} | � t�|�� | jtjj_ W d � n1 s�w Y ndtjj_ |r�|tjj_n-|r�t j ddd��} | � t�|�� | jtjj_W d � n1 s�w Y ndtjj_| �r | tjj_i S |�r7t j ddd��} | � t�|�� | jtjj_W d � i S 1 �s0w Y i S dtjj_i S )z? Setup kubernetes API connection singleton the old way � config.option�kubernetes.api_urlzhttp://localhost:8080zkubernetes.userzkubernetes.passwordz%kubernetes.certificate-authority-dataz"kubernetes.client-certificate-datazkubernetes.client-key-dataz%kubernetes.certificate-authority-filez"kubernetes.client-certificate-filezkubernetes.client-key-file�api_urlZapi_userZ api_passwordZ api_certificate_authority_fileZapi_client_certificate_fileZapi_client_key_file� salt-kube-F��prefix�deleteN)�__salt__�getr �client� configuration�host�user�password�__init__�passwd� ssl_ca_cert�tempfile�NamedTemporaryFile�write�base64� b64decode�name� cert_file�key_file) �kwargsr% �usernamer' Zca_certZ client_certZ client_keyZ ca_cert_fileZclient_cert_fileZclient_key_file�ca�c�kr r r �_setup_conn_oldv sv �� �� � �� �r8 c K s | � d�p td d�}| � d�ptd d�}| � d�p td d�}|r%|r,|rN| � d�rNtjdd d ��}|�t�|�� |j}W d � n1 sIw Y |rR|su| � d �s]td d �rqztdi | ��W S t yp t d��w t d��t j j ||d� ||d�S )z3 Setup kubernetes API connection singleton � kubeconfigr zkubernetes.kubeconfig�kubeconfig_datazkubernetes.kubeconfig-data�contextzkubernetes.context�salt-kubeconfig-Fr Nr r zROld style kubernetes configuration is only supported up to python-kubernetes 2.0.0zTInvalid kubernetes configuration. Parameter 'kubeconfig' and 'context' are required.)Z config_filer; )r9 r; r )r" r! r+ r, r- r. r/ r0 r8 � Exceptionr r ZconfigZload_kube_config)r3 r9 r: r; Zkcfgr r r � _setup_conn� sB ����� � ��� r> c K s� zct jjj}t jjj}t jjj}|r(tj�|�r(tj� |�� d�r(t j j �|� |r@tj�|�r@tj� |�� d�r@t j j �|� |r[tj�|�r^tj� |�� d�rat j j �|� W d S W d S W d S W d S tym Y d S w )Nr )r r# r$ r* r1 r2 �os�path�exists�basename� startswith�salt�utils�filesZsafe_rmr= )r3 r5 �cert�keyr r r � _cleanup_old� s0 � ��� ��"� �rI c K s� | s t di | ��S d| v rK| �d�}|rMtj�|��d�rOzt�|� W d S tyJ } z|jtj kr?t � |� W Y d }~d S W Y d }~d S d }~ww d S d S d S )Nr9 r< r ) rI r" r? r@ rB rC �unlink�OSError�errno�ENOENT�log� exception)r3 r9 �errr r r �_cleanup s ����rQ c K s2 d}z t di | �� W |S ty d}Y |S w )z� Checks connections with the kubernetes API server. Returns True if the connection can be established, False otherwise. CLI Example: .. code-block:: bash salt '*' kubernetes.ping TFNr )�nodesr )r3 �statusr r r �ping s ��rT c K � t di | ��}zOz tj�� }|�� }dd� |�� �d�D �W W tdi |�� S tt fyV } z"t |t�rI|j dkrIW Y d}~W tdi |�� dS t � d� t|��d}~ww tdi |�� w )z� Return the names of the nodes composing the kubernetes cluster CLI Example: .. code-block:: bash salt '*' kubernetes.nodes salt '*' kubernetes.nodes kubeconfig=/etc/salt/k8s/kubeconfig context=minikube c S � g | ]}|d d �qS ��metadatar0 r )�.0�k8s_noder r r � <listcomp>3 s ��znodes.<locals>.<listcomp>�items� N�+Exception when calling CoreV1Api->list_noder )r> r r# � CoreV1Api� list_node�to_dictr" rQ r r � isinstancerS rN rO r �r3 �cfg� api_instance� api_response�excr r r rR # s" � � ���rR c K s� t di |��}zEz tj�� }|�� }W n0 ttfyC } z"t|t�r6|jdkr6W Y d}~W t di |�� dS t � d� t |��d}~ww W t di |�� nt di |�� w |j D ]}|jj| krf|�� S qXdS )z� Return the details of the node identified by the specified name CLI Example: .. code-block:: bash salt '*' kubernetes.node name='minikube' r] Nr^ r )r> r r# r_ r` r r rb rS rQ rN rO r r\ rX r0 ra )r0 r3 rd re rf rg rZ r r r �nodeA s& ���� �rh c K s( t | fi |��}|dur|d d S i S )z� Return the labels of the node identified by the specified name CLI Example: .. code-block:: bash salt '*' kubernetes.node_labels name="minikube" NrX �labels)rh )r0 r3 �matchr r r � node_labels_ s rk c K s� t di |��}zOz tj�� }dd||iii}|�| |�}|W W tdi |�� S ttfyV } z"t|t�rI|j dkrIW Y d}~W tdi |�� dS t � d� t |��d}~ww tdi |�� w )aF Set the value of the label identified by `label_name` to `label_value` on the node identified by the name `node_name`. Creates the label if not present. CLI Example: .. code-block:: bash salt '*' kubernetes.node_add_label node_name="minikube" label_name="foo" label_value="bar" rX ri r] N�,Exception when calling CoreV1Api->patch_noder � r> r r# r_ Z patch_noderQ r r rb rS rN rO r ) � node_name� label_nameZ label_valuer3 rd re �bodyrf rg r r r �node_add_labelq s � ���rq c K s� t di |��}zOz tj�� }dd|diii}|�| |�}|W W tdi |�� S ttfyV } z"t|t�rI|j dkrIW Y d}~W tdi |�� dS t � d� t |��d}~ww tdi |�� w )z� Removes the label identified by `label_name` from the node identified by the name `node_name`. CLI Example: .. code-block:: bash salt '*' kubernetes.node_remove_label node_name="minikube" label_name="foo" rX ri Nr] rl r rm )rn ro r3 rd re rp rf rg r r r �node_remove_label� s � ���rr c K rU )z� Return the names of the available namespaces CLI Example: .. code-block:: bash salt '*' kubernetes.namespaces salt '*' kubernetes.namespaces kubeconfig=/etc/salt/k8s/kubeconfig context=minikube c S rV rW r )rY Znmsr r r r[ � � z namespaces.<locals>.<listcomp>r\ r] Nz0Exception when calling CoreV1Api->list_namespacer )r> r r# r_ Zlist_namespacera r" rQ r r rb rS rN rO r rc r r r � namespaces� s � ���rt �defaultc K � t di |��}zPz tj�� }|�| �}dd� |�� �d�D �W W tdi |�� S tt fyW } z"t |t�rJ|j dkrJW Y d}~W tdi |�� dS t � d� t|��d}~ww tdi |�� w )z� Return a list of kubernetes deployments defined in the namespace CLI Example: .. code-block:: bash salt '*' kubernetes.deployments salt '*' kubernetes.deployments namespace=default c S rV rW r )rY Zdepr r r r[ � rs z deployments.<locals>.<listcomp>r\ r] NzGException when calling ExtensionsV1beta1Api->list_namespaced_deploymentr )r> r r# �ExtensionsV1beta1ApiZlist_namespaced_deploymentra r" rQ r r rb rS rN rO r �� namespacer3 rd re rf rg r r r � deployments� s" � ���� rz c K rv )z� Return a list of kubernetes services defined in the namespace CLI Example: .. code-block:: bash salt '*' kubernetes.services salt '*' kubernetes.services namespace=default c S rV rW r )rY Zsrvr r r r[ � rs z services.<locals>.<listcomp>r\ r] Nz9Exception when calling CoreV1Api->list_namespaced_servicer )r> r r# r_ Zlist_namespaced_servicera r" rQ r r rb rS rN rO r rx r r r �services� � � ���r{ c K rv )z� Return a list of kubernetes pods defined in the namespace CLI Example: .. code-block:: bash salt '*' kubernetes.pods salt '*' kubernetes.pods namespace=default c S rV rW r )rY Zpodr r r r[ rs zpods.<locals>.<listcomp>r\ r] Nz5Exception when calling CoreV1Api->list_namespaced_podr )r> r r# r_ Zlist_namespaced_podra r" rQ r r rb rS rN rO r rx r r r �pods r| r} c K rv )z� Return a list of kubernetes secrets defined in the namespace CLI Example: .. code-block:: bash salt '*' kubernetes.secrets salt '*' kubernetes.secrets namespace=default c S rV rW r �rY Zsecretr r r r[ - � �zsecrets.<locals>.<listcomp>r\ r] Nz8Exception when calling CoreV1Api->list_namespaced_secretr )r> r r# r_ Zlist_namespaced_secretra r" rQ r r rb rS rN rO r rx r r r �secrets s" � � ���r� c K rv )z� Return a list of kubernetes configmaps defined in the namespace CLI Example: .. code-block:: bash salt '*' kubernetes.configmaps salt '*' kubernetes.configmaps namespace=default c S rV rW r r~ r r r r[ J r z configmaps.<locals>.<listcomp>r\ r] Nz<Exception when calling CoreV1Api->list_namespaced_config_mapr )r> r r# r_ Zlist_namespaced_config_mapra r" rQ r r rb rS rN rO r rx r r r � configmaps: s& � � ���� r� c K � t di |��}zIztj�� }|�| |�}|�� W W tdi |�� S ttfyP } z"t |t�rC|j dkrCW Y d}~W tdi |�� dS t � d� t |��d}~ww tdi |�� w )z� Return the kubernetes deployment defined by name and namespace CLI Example: .. code-block:: bash salt '*' kubernetes.show_deployment my-nginx default salt '*' kubernetes.show_deployment name=my-nginx namespace=default r] NzGException when calling ExtensionsV1beta1Api->read_namespaced_deploymentr )r> r r# rw Zread_namespaced_deploymentra rQ r r rb rS rN rO r �r0 ry r3 rd re rf rg r r r �show_deploymentY s" � ���� r� c K r� )z� Return the kubernetes service defined by name and namespace CLI Example: .. code-block:: bash salt '*' kubernetes.show_service my-nginx default salt '*' kubernetes.show_service name=my-nginx namespace=default r] Nz9Exception when calling CoreV1Api->read_namespaced_servicer )r> r r# r_ Zread_namespaced_servicera rQ r r rb rS rN rO r r� r r r � show_servicew � � ���r� c K r� )a Return POD information for a given pod name defined in the namespace CLI Example: .. code-block:: bash salt '*' kubernetes.show_pod guestbook-708336848-fqr2x salt '*' kubernetes.show_pod guestbook-708336848-fqr2x namespace=default r] Nz5Exception when calling CoreV1Api->read_namespaced_podr )r> r r# r_ Zread_namespaced_podra rQ r r rb rS rN rO r r� r r r �show_pod� r� r� c K s� t di |��}zHztj�� }|�| �}|�� W W tdi |�� S ttfyO } z"t |t�rB|j dkrBW Y d}~W tdi |�� dS t � d� t |��d}~ww tdi |�� w )z� Return information for a given namespace defined by the specified name CLI Example: .. code-block:: bash salt '*' kubernetes.show_namespace kube-system r] Nz0Exception when calling CoreV1Api->read_namespacer )r> r r# r_ Zread_namespacera rQ r r rb rS rN rO r )r0 r3 rd re rf rg r r r �show_namespace� s � ���r� c K s� t di |��}zez4tj�� }|�| |�}|jr0|s |dkr0|jD ]}|j| }t�|�|j|< q |�� W W t di |�� S t t fyl } z"t | t �r_| j dkr_W Y d} ~ W t di |�� dS t�d� t| ��d} ~ ww t di |�� w )a� Return the kubernetes secret defined by name and namespace. The secrets can be decoded if specified by the user. Warning: this has security implications. CLI Example: .. code-block:: bash salt '*' kubernetes.show_secret confidential default salt '*' kubernetes.show_secret name=confidential namespace=default salt '*' kubernetes.show_secret name=confidential decode=True �Truer] Nz8Exception when calling CoreV1Api->read_namespaced_secretr )r> r r# r_ Zread_namespaced_secret�datar. r/ ra rQ r r rb rS rN rO r ) r0 ry �decoder3 rd re rf rH �valuerg r r r � show_secret� s& � ���r� c K r� )a Return the kubernetes configmap defined by name and namespace. CLI Example: .. code-block:: bash salt '*' kubernetes.show_configmap game-config default salt '*' kubernetes.show_configmap name=game-config namespace=default r] Nz<Exception when calling CoreV1Api->read_namespaced_config_mapr )r> r r# r_ Zread_namespaced_config_mapra rQ r r rb rS rN rO r r� r r r �show_configmap� s" � ���� r� c K s� t d i |��}tjjdd�}z�z}tj�� }|j| ||d�}|�� }tjj � � s^z-t t �� t | |�dur@t�d� t | |�dus4d|d< W d � n1 sNw Y W n" ty] Y nw td�D ]}t | |�du rqd|d< nt�d� qb|d dkr�t�d � |W W td i |�� S ttfy� } z"t| t�r�| jd kr�W Y d} ~ W td i |�� dS t�d � t| ��d} ~ ww td i |�� w ) z� Deletes the kubernetes deployment defined by name and namespace CLI Example: .. code-block:: bash salt '*' kubernetes.delete_deployment my-nginx salt '*' kubernetes.delete_deployment name=my-nginx namespace=default T�Zorphan_dependents�r0 ry rp N� �� �code�< z|Reached polling time limit. Deployment is not yet deleted, but we are backing off. Sorry, but you'll have to check manually.r] zIException when calling ExtensionsV1beta1Api->delete_namespaced_deploymentr )r> r r# �V1DeleteOptionsrw Z delete_namespaced_deploymentra rD rE �platform� is_windowsr �POLLING_TIME_LIMITr� �time�sleepr �rangerN �warningrQ r r rb rS rO r ) r0 ry r3 rd rp re rf Zmutable_api_response�irg r r r �delete_deployment sT � � �� � � � ���� r� c K s� t di |��}zJztj�� }|j| |d�}|�� W W tdi |�� S ttfyQ } z"t |t�rD|j dkrDW Y d}~W tdi |�� dS t � d� t |��d}~ww tdi |�� w )z� Deletes the kubernetes service defined by name and namespace CLI Example: .. code-block:: bash salt '*' kubernetes.delete_service my-nginx default salt '*' kubernetes.delete_service name=my-nginx namespace=default )r0 ry r] Nz;Exception when calling CoreV1Api->delete_namespaced_servicer )r> r r# r_ Zdelete_namespaced_servicera rQ r r rb rS rN rO r r� r r r �delete_serviceA s" � � ���r� c K �� t di |��}tjjdd�}zKztj�� }|j| ||d�}|�� W W tdi |�� S tt fyY } z"t |t�rL|j dkrLW Y d}~W tdi |�� dS t � d� t|��d}~ww tdi |�� w )a Deletes the kubernetes pod defined by name and namespace CLI Example: .. code-block:: bash salt '*' kubernetes.delete_pod guestbook-708336848-5nl8c default salt '*' kubernetes.delete_pod name=guestbook-708336848-5nl8c namespace=default Tr� r� r] Nz7Exception when calling CoreV1Api->delete_namespaced_podr )r> r r# r� r_ Zdelete_namespaced_podra rQ r r rb rS rN rO r �r0 ry r3 rd rp re rf rg r r r � delete_pod_ �$ � � ���r� c K s� t di |��}tjjdd�}zJztj�� }|j| |d�}|�� W W tdi |�� S tt fyX } z"t |t�rK|j dkrKW Y d}~W tdi |�� dS t � d� t|��d}~ww tdi |�� w )z� Deletes the kubernetes namespace defined by name CLI Example: .. code-block:: bash salt '*' kubernetes.delete_namespace salt salt '*' kubernetes.delete_namespace name=salt Tr� )r0 rp r] Nz2Exception when calling CoreV1Api->delete_namespacer )r> r r# r� r_ �delete_namespacera rQ r r rb rS rN rO r )r0 r3 rd rp re rf rg r r r r� ~ s � ���r� c K r� )z� Deletes the kubernetes secret defined by name and namespace CLI Example: .. code-block:: bash salt '*' kubernetes.delete_secret confidential default salt '*' kubernetes.delete_secret name=confidential namespace=default Tr� r� r] Nz:Exception when calling CoreV1Api->delete_namespaced_secretr )r> r r# r� r_ Zdelete_namespaced_secretra rQ r r rb rS rN rO r r� r r r � delete_secret� r� r� c K r� )a Deletes the kubernetes configmap defined by name and namespace CLI Example: .. code-block:: bash salt '*' kubernetes.delete_configmap settings default salt '*' kubernetes.delete_configmap name=settings namespace=default Tr� r� r] Nz>Exception when calling CoreV1Api->delete_namespaced_config_mapr )r> r r# r� r_ Z delete_namespaced_config_mapra rQ r r rb rS rN rO r r� r r r �delete_configmap� s( � � ���� r� c K s� t dtt| ||||||d� }tdi |��} zIztj�� } | �||�} | �� W W t di | �� S t t fy^ } z"t | t �rQ| j dkrQW Y d} ~ W t di | �� dS t�d� t| ��d} ~ ww t di | �� w )�C Creates the kubernetes deployment as defined by the user. � Deployment� �kind� obj_class� spec_creatorr0 ry rX �spec�source�template�saltenvr] NzIException when calling ExtensionsV1beta1Api->create_namespaced_deploymentr )�__create_object_bodyr �__dict_to_deployment_specr> r r# rw Z create_namespaced_deploymentra rQ r r rb rS rN rO r � r0 ry rX r� r� r� r� r3 rp rd re rf rg r r r �create_deployment� s: � � ���� r� c K �� t dtjjt| ||||||d� }tdi |��} zIztj�� } | �||�} | �� W W t di | �� S t t fy` } z"t | t �rS| j dkrSW Y d} ~ W t di | �� dS t�d� t| ��d} ~ ww t di | �� w )r� ZPodr� r] Nz7Exception when calling CoreV1Api->create_namespaced_podr )r� r r# ZV1Pod�__dict_to_pod_specr> r_ Zcreate_namespaced_podra rQ r r rb rS rN rO r r� r r r � create_pod s6 � � ���r� c K r� )z@ Creates the kubernetes service as defined by the user. �Servicer� r] Nz;Exception when calling CoreV1Api->create_namespaced_servicer )r� r r# � V1Service�__dict_to_service_specr> r_ Zcreate_namespaced_servicera rQ r r rb rS rN rO r r� r r r �create_service# s6 � � ���r� �basec K s |r t |||�}n|du ri }t|�}|D ] }t�|| �||< qtjjt| |i �|d�}tdi |��} zIztj� � } | � ||�} | � � W W t di | �� S t tfy} } z"t| t �rp| jdkrpW Y d} ~ W t di | �� dS t�d� t| ��d} ~ ww t di | �� w )aE Creates the kubernetes secret as defined by the user. CLI Example: .. code-block:: bash salt 'minion1' kubernetes.create_secret passwords default '{"db": "letmein"}' salt 'minion2' kubernetes.create_secret name=passwords namespace=default data='{"db": "letmein"}' N�rX r� r] z:Exception when calling CoreV1Api->create_namespaced_secretr )�__read_and_render_yaml_file�__enforce_only_strings_dictr. � b64encoder r# �V1Secret�__dict_to_object_metar> r_ Zcreate_namespaced_secretra rQ r r rb rS rN rO r ) r0 ry r� r� r� r� r3 rH rp rd re rf rg r r r � create_secretG s2 � � ���r� c K s� |r t |||�}n|du ri }t|�}tjjt| |i �|d�}tdi |��}zIztj�� } | �||�} | � � W W t di |�� S t t fyo } z"t | t �rb| jdkrbW Y d} ~ W t di |�� dS t�d� t| ��d} ~ ww t di |�� w )an Creates the kubernetes configmap as defined by the user. CLI Example: .. code-block:: bash salt 'minion1' kubernetes.create_configmap settings default '{"example.conf": "# example file"}' salt 'minion2' kubernetes.create_configmap name=settings namespace=default data='{"example.conf": "# example file"}' Nr� r] z>Exception when calling CoreV1Api->create_namespaced_config_mapr )r� r� r r# � V1ConfigMapr� r> r_ Z create_namespaced_config_mapra rQ r r rb rS rN rO r ) r0 ry r� r� r� r� r3 rp rd re rf rg r r r �create_configmap} s2 � � ���� r� c K s� t jj| d�}t jj|d�}| |j_tdi |��}zHzt j�� }|�|�}|� � W W t di |�� S t t fya } z"t |t �rT|jdkrTW Y d}~W t di |�� dS t�d� t|��d}~ww t di |�� w )z� Creates a namespace with the specified name. CLI Example: .. code-block:: bash salt '*' kubernetes.create_namespace salt salt '*' kubernetes.create_namespace name=salt )r0 )rX r] Nz2Exception when calling CoreV1Api->create_namespacer )r r# � V1ObjectMetaZ V1NamespacerX r0 r> r_ �create_namespacera rQ r r rb rS rN rO r )r0 r3 �meta_objrp rd re rf rg r r r r� � s$ � ���r� c K s� t dtt| ||||||d� }tdi |��} zJztj�� } | �| ||�} | �� W W t di | �� S t t fy_ } z"t | t �rR| j dkrRW Y d} ~ W t di | �� dS t�d� t| ��d} ~ ww t di | �� w )z� Replaces an existing deployment with a new one defined by name and namespace, having the specificed metadata and spec. r� r� r] NzJException when calling ExtensionsV1beta1Api->replace_namespaced_deploymentr )r� r r� r> r r# rw Z replace_namespaced_deploymentra rQ r r rb rS rN rO r ) r0 rX r� r� r� r� ry r3 rp rd re rf rg r r r �replace_deployment� s: � � ���� r� c K s� t dtjjt| ||||||d� } |d d | j_|d d | j_t d i |��} zJztj� � } | � | || �} | � � W W t d i | �� S ttfyq } z"t| t�rd| jdkrdW Y d} ~ W t d i | �� dS t�d � t| ��d} ~ ww t d i | �� w ) z� Replaces an existing service with a new one defined by name and namespace, having the specificed metadata and spec. r� r� r� � cluster_iprX �resource_versionr] Nz<Exception when calling CoreV1Api->replace_namespaced_servicer )r� r r# r� r� r� r� rX r� r> r_ Zreplace_namespaced_servicera rQ r r rb rS rN rO r )r0 rX r� r� r� Z old_servicer� ry r3 rp rd re rf rg r r r �replace_service� s> � � ���� r� c K s |r t |||�}n|du ri }t|�}|D ] }t�|| �||< qtjjt| |i �|d�}tdi |��} zJztj� � } | � | ||�} | � � W W t di | �� S t tfy~ } z"t| t �rq| jdkrqW Y d} ~ W t di | �� dS t�d� t| ��d} ~ ww t di | �� w )a� Replaces an existing secret with a new one defined by name and namespace, having the specificed data. CLI Example: .. code-block:: bash salt 'minion1' kubernetes.replace_secret name=passwords data='{"db": "letmein"}' salt 'minion2' kubernetes.replace_secret name=passwords namespace=saltstack data='{"db": "passw0rd"}' Nr� r] z;Exception when calling CoreV1Api->replace_namespaced_secretr )r� r� r. r� r r# r� r� r> r_ Zreplace_namespaced_secretra rQ r r rb rS rN rO r ) r0 r� r� r� r� ry r3 rH rp rd re rf rg r r r �replace_secret( s2 � � ���r� c K s� |rt |||�}t|�}tjjt| |i �|d�}tdi |��}zJztj�� } | �| ||�} | � � W W t di |�� S t t fyi } z"t | t �r\| jdkr\W Y d} ~ W t di |�� dS t�d� t| ��d} ~ ww t di |�� w )a� Replaces an existing configmap with a new one defined by name and namespace with the specified data. CLI Example: .. code-block:: bash salt 'minion1' kubernetes.replace_configmap settings default '{"example.conf": "# example file"}' salt 'minion2' kubernetes.replace_configmap name=settings namespace=default data='{"example.conf": "# example file"}' r� r] Nz>Exception when calling CoreV1Api->replace_namespaced_configmapr )r� r� r r# r� r� r> r_ Z replace_namespaced_config_mapra rQ r r rb rS rN rO r ) r0 r� r� r� r� ry r3 rp rd re rf rg r r r �replace_configmap_ s. � � ���� r� c C sv |r/t ||| �} t| t�rd| vs| d | kr td| � d���d| v r'| d }d| v r/| d }|t|||�||�d�S )z3 Create a Kubernetes Object body instance. r� z%The source file should define only a z objectrX r� )rX r� )r� rb �dictr r� ) r� r� r� r0 ry rX r� r� r� r� Zsrc_objr r r r� � s" � � �r� c C s� t d | |�}|std| � d���tjj�|d��I}|�� }|rT|tjjjv rMtjjj| |dd|t t t t d�}|d sEtd� |d ���|d � d �}ntd |� ���tjj�|�W d � S 1 sew Y d S ) z� Read a yaml file and, if needed, renders that using the specifieds templating. Returns the python objects defined inside of the file. z cp.cache_filez Source file 'z ' not found�rT)Zfrom_strZto_strr� ZgrainsZpillarrD �opts�resultz)Failed to render file path with error: {}r� zutf-8z Unknown template specified: N)r! r rD rE rF Zfopen�readZ templatesZTEMPLATE_REGISTRYZ __grains__Z __pillar__Z__opts__�format�encodeZyamlZ safe_load)r� r� r� Zsfn�src�contentsr� r r r r� � s2 � � $�r� c C s� t j�� }||_d|vri |d< d|d vr d�tj�|d d< |�� D ]\}}t||�r3t |||� q$|j | krAt � d� | |_ |S )zF Converts a dictionary into kubernetes ObjectMetaV1 instance. � annotationszkubernetes.io/change-cause� z[The object already has a name attribute, overwriting it with the one defined inside of salt) r r# r� ry �join�sys�argvr\ �hasattr�setattrr0 rN r� )r0 ry rX r� rH r� r r r r� � s � �r� c C s> t | �dd�d�}| �� D ]\}}t||�r t|||� q |S )zS Converts a dictionary into kubernetes AppsV1beta1DeploymentSpec instance. r� � )r� )r r" r\ r� r� �r� �spec_objrH r� r r r r� � s �r� c C s6 t j�� }| �� D ]\}}t||�rt|||� q |S )zC Converts a dictionary into kubernetes V1PodSpec instance. )r r# Z V1PodSpecr\ r� r� r� r r r r� s �r� c C s� t j�� }| �� D ]D\}}|dkrBg |_|D ]*}t j�� }t|t�r7|�� D ]\}}t||�r5t |||� q&n||_ |j� |� qq t||�rMt |||� q |S )zG Converts a dictionary into kubernetes V1ServiceSpec instance. �ports) r r# Z V1ServiceSpecr\ r� Z V1ServicePortrb r� r� r� �port�append)r� r� rH r� r� Z kube_portZport_keyZ port_valuer r r r� s& ��� �r� c C s* i }| � � D ] \}}t|�|t|�< q|S )z? Returns a dictionary that has string keys and values. )r\ �str)Z dictionary�retrH r� r r r r� * s r� )ru )ru F)ru NNNr� )NNr� )NNr� ru )W�__doc__r. rL �loggingZos.pathr? r r� r+ r� � contextlibr Zsalt.utils.filesrD Zsalt.utils.platformZsalt.utils.templatesZsalt.utils.yamlZsalt.exceptionsr r r Zkubernetes.clientZkubernetes.client.restr Zurllib3.exceptionsr r r r r � ImportErrorr � getLogger�__name__rN r r rE r� r� r r� r8 r> rI rQ rT rR rh rk rq rr rt rz 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 r r �<module> s� 0 � � K) # : !'"& �7 �." �0 �7 �: �3%)
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings