File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/container/drivers/__pycache__/rancher.cpython-310.pyc
Back
o ;jM_ � @ s� d dl Z d dlmZmZmZ d dlmZmZ d dlm Z m Z m Z d dl m Z d dlmZ zd dlZW n ey? d dlZY nw ejejejejgZG dd� de�ZG d d � d e�ZG d d � d e�ZG d d� de �ZdS )� N)�b�httplib�urlparse)� JsonResponse�ConnectionUserAndKey)� Container�ContainerImage�ContainerDriver)�ContainerState)�Providerc s$ e Zd Z� fdd�Zdd� Z� ZS )�RancherResponsec sF t � �� }d|v rd�|d |d |d |d �S d�|d |d �S )NZ fieldNamezField {} is {}: {} - {}�code�messageZdetailz{} - {})�super� parse_error�format)�self�parsed�� __class__� �V/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/container/drivers/rancher.pyr ' s �zRancherResponse.parse_errorc C s | j tv S �N)�status�VALID_RESPONSE_CODES�r r r r �success3 s zRancherResponse.success)�__name__� __module__� __qualname__r r � __classcell__r r r r r & s r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�RancherExceptionc C s || _ || _||f| _d S r )r r �args)r r r r r r �__init__8 s zRancherException.__init__c C � d� | j| j�S )Nz{} {}�r r r r r r r �__str__= � zRancherException.__str__c C r$ )NzRancherException {} {}r% r r r r �__repr__@ r' zRancherException.__repr__N)r r r r# r& r( r r r r r! 7 s r! c @ s e Zd ZeZdZdd� ZdS )�RancherConnection� c C sL d|d< 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 zapplication/jsonz Content-TypeZAcceptz{}:{}zBasic %szutf-8Z Authorization)�keyZuser_id�base64� b64encoder r �decode)r �headersZuser_b64r r r �add_default_headersH s z%RancherConnection.add_default_headersN)r r r r Z responseCls�timeoutr0 r r r r r) D s r) c s& e Zd ZdZejZdZdZe Z dZ dZ d<� fd d � Z d d � Z d=dd�Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Z d>d d �Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Z d?d*d+�Z d,d-� Z d.d/� Z d0d1� Z d2d3� Z!d4d5� Z"d6d7� Z#d8d9� Z$d:d;� Z%� Z&S )@�RancherContainerDrivera& Driver for Rancher by Rancher Labs. This driver is capable of interacting with the Version 1 API of Rancher. It currently does NOT support the Version 2 API. Example: >>> from libcloud.container.providers import get_driver >>> from libcloud.container.types import Provider >>> driver = get_driver(Provider.RANCHER) >>> connection = driver(key="ACCESS_KEY_HERE", secret="SECRET_KEY_HERE", host="172.30.0.100", port=8080) >>> image = ContainerImage("hastebin", "hastebin", "rlister/hastebin", "latest", driver=None) >>> newcontainer = connection.deploy_container("myawesomepastebin", image, environment={"STORAGE_TYPE": "file"}) :ivar baseuri: The URL base path to the API. :type baseuri: ``str`` ZRancherzhttp://rancher.comF�1T� localhost� c sx d|vr |� d�s d| }t�|�}t� j|||jdkr dn||j|jr'|jn|d� |jr4|j| _ dS d| j | _ dS )a� Creates a new Rancher Container driver. :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. :type secure: ``bool`` :param host: Override hostname used for connections. This can also be a full URL string, including scheme, port, and base path. :type host: ``str`` :param port: Override port used for connections. :type port: ``int`` :return: A newly initialized driver instance. z://z//�httpF)r+ �secret�secure�host�portz/v%sN) � startswithr r r# �scheme�hostnamer: �path�version�baseuri)r r+ r7 r8 r9 r: r r r r r# y s �"z RancherContainerDriver.__init__c C � | j �d| j �j}|d S )z� List all Rancher Stacks http://docs.rancher.com/rancher/v1.2/en/api/api-resources/environment/ :rtype: ``list`` of ``dict`` �%s/environments�data�� connection�requestr@ �object�r �resultr r r �ex_list_stacks� � z%RancherContainerDriver.ex_list_stacksNc C sJ |||||||d�}t �dd� |�� D ��} | jjd| j | dd�j} | S )a� Deploy a new stack. http://docs.rancher.com/rancher/v1.2/en/api/api-resources/environment/#create :param name: The desired name of the stack. (required) :type name: ``str`` :param description: A desired description for the stack. :type description: ``str`` :param docker_compose: The Docker Compose configuration to use. :type docker_compose: ``str`` :param environment: Environment K/V specific to this stack. :type environment: ``dict`` :param external_id: The externalId of the stack. :type external_id: ``str`` :param rancher_compose: The Rancher Compose configuration for this env. :type rancher_compose: ``str`` :param start: Whether to start this stack on creation. :type start: ``bool`` :return: The newly created stack. :rtype: ``dict`` )� descriptionZ dockerCompose� environment� externalId�nameZrancherCompose� startOnCreatec S � i | ] \}}|d ur||�qS r r ��.0�k�vr r r � <dictcomp>� � z:RancherContainerDriver.ex_deploy_stack.<locals>.<dictcomp>rB �POST�rC �method)�json�dumps�itemsrE rF r@ rG ) r rO rL Zdocker_composerM � external_idZrancher_compose�start�payloadrC rI r r r �ex_deploy_stack� s )� ��z&RancherContainerDriver.ex_deploy_stackc C � | j �d�| j|��j}|S )z� Get a stack by ID :param env_id: The stack to be obtained. :type env_id: ``str`` :rtype: ``dict`` �{}/environments/{}�rE rF r r@ rG �r Zenv_idrI r r r � ex_get_stack� � z#RancherContainerDriver.ex_get_stackc C �R g }|� � D ] \}}|�|d | � qd�|�}| j�d�| j|��j}|d S )z� Search for stacks matching certain filters i.e. ``{ "name": "awesomestack"}`` :param search_params: A collection of search parameters to use. :type search_params: ``dict`` :rtype: ``list`` �=�&z{}/environments?{}rC �r] �append�joinrE rF r r@ rG �r Z search_paramsZ search_list�frU Z search_itemsrI r r r �ex_search_stacks� � ��z'RancherContainerDriver.ex_search_stacksc C �$ | j jd�| j|�dd�}|jtv S )a+ Destroy a stack by ID http://docs.rancher.com/rancher/v1.2/en/api/api-resources/environment/#delete :param env_id: The stack to be destroyed. :type env_id: ``str`` :return: True if destroy was successful, False otherwise. :rtype: ``bool`` rc �DELETE�rZ �rE rF r r@ r r re r r r �ex_destroy_stack � � z'RancherContainerDriver.ex_destroy_stackc C rr )aH Activate Services for a stack. http://docs.rancher.com/rancher/v1.2/en/api/api-resources/environment/#activateservices :param env_id: The stack to activate services for. :type env_id: ``str`` :return: True if activate was successful, False otherwise. :rtype: ``bool`` z*{}/environments/{}?action=activateservicesrX rt ru re r r r �ex_activate_stack � � z(RancherContainerDriver.ex_activate_stackc C rr )aP Deactivate Services for a stack. http://docs.rancher.com/rancher/v1.2/en/api/api-resources/environment/#deactivateservices :param env_id: The stack to deactivate services for. :type env_id: ``str`` :return: True if deactivate was successful, False otherwise. :rtype: ``bool`` z,{}/environments/{}?action=deactivateservicesrX rt ru re r r r �ex_deactivate_stack( s � z*RancherContainerDriver.ex_deactivate_stackc C rA )z� List all Rancher Services http://docs.rancher.com/rancher/v1.2/en/api/api-resources/service/ :rtype: ``list`` of ``dict`` � %s/servicesrC rD rH r r r �ex_list_services; rK z'RancherContainerDriver.ex_list_servicesc K sj | � |�f|d< |||||||| | | | | |||d�}t�dd� |�� D ��}| jjd| j |dd�j}|S )aY Deploy a Rancher Service under a stack. http://docs.rancher.com/rancher/v1.2/en/api/api-resources/service/#create *Any further configuration passed applies to the ``launchConfig``* :param name: The desired name of the service. (required) :type name: ``str`` :param image: The Image object to deploy. (required) :type image: :class:`libcloud.container.base.ContainerImage` :param environment_id: The stack ID this service is tied to. (required) :type environment_id: ``str`` :param start: Whether to start the service on creation. :type start: ``bool`` :param assign_service_ip_address: The IP address to assign the service. :type assign_service_ip_address: ``bool`` :param service_description: The service description. :type service_description: ``str`` :param external_id: The externalId for this service. :type external_id: ``str`` :param metadata: K/V Metadata for this service. :type metadata: ``dict`` :param retain_ip: Whether this service should retain its IP. :type retain_ip: ``bool`` :param scale: The scale of containers in this service. :type scale: ``int`` :param scale_policy: The scaling policy for this service. :type scale_policy: ``dict`` :param secondary_launch_configs: Secondary container launch configs. :type secondary_launch_configs: ``list`` :param selector_container: The selectorContainer for this service. :type selector_container: ``str`` :param selector_link: The selectorLink for this service. :type selector_link: ``type`` :param vip: The VIP to assign to this service. :type vip: ``str`` :return: The newly created service. :rtype: ``dict`` � imageUuid)ZassignServiceIpAddressrL Z environmentIdrN Z launchConfig�metadatarO ZretainIp�scaleZ scalePolicy�secondary_launch_configsZselectorContainerZ selectorLinkrP �vipc S rQ r r rR r r r rV � rW z<RancherContainerDriver.ex_deploy_service.<locals>.<dictcomp>r{ rX rY )� _degen_imager[ r\ r] rE rF r@ rG )r rO �imageZenvironment_idr_ Zassign_service_ip_addressZservice_descriptionr^ r~ Z retain_ipr Z scale_policyr� Zselector_containerZ selector_linkr� Z launch_confZservice_payloadrC rI r r r �ex_deploy_serviceG s0 K� ��z(RancherContainerDriver.ex_deploy_servicec C rb )z� Get a service by ID :param service_id: The service_id to be obtained. :type service_id: ``str`` :rtype: ``dict`` �{}/services/{}rd �r Z service_idrI r r r �ex_get_service� rg z%RancherContainerDriver.ex_get_servicec C rh )a Search for services matching certain filters i.e. ``{ "name": "awesomesause", "environmentId": "1e2"}`` :param search_params: A collection of search parameters to use. :type search_params: ``dict`` :rtype: ``list`` ri rj z{}/services?{}rC rk rn r r r �ex_search_services� s z)RancherContainerDriver.ex_search_servicesc C rr )a3 Destroy a service by ID http://docs.rancher.com/rancher/v1.2/en/api/api-resources/service/#delete :param service_id: The service to be destroyed. :type service_id: ``str`` :return: True if destroy was successful, False otherwise. :rtype: ``bool`` r� rs rt ru r� r r r �ex_destroy_service� rw z)RancherContainerDriver.ex_destroy_servicec C rr )a; Activate a service. http://docs.rancher.com/rancher/v1.2/en/api/api-resources/service/#activate :param service_id: The service to activate services for. :type service_id: ``str`` :return: True if activate was successful, False otherwise. :rtype: ``bool`` z {}/services/{}?action=activaterX rt ru r� r r r �ex_activate_service� rw z*RancherContainerDriver.ex_activate_servicec C rr )aC Deactivate a service. http://docs.rancher.com/rancher/v1.2/en/api/api-resources/service/#deactivate :param service_id: The service to deactivate services for. :type service_id: ``str`` :return: True if deactivate was successful, False otherwise. :rtype: ``bool`` z {}/services/{}?action=deactivaterX rt ru r� r r r �ex_deactivate_service� ry z,RancherContainerDriver.ex_deactivate_servicec s. � j �d� j �j}� fdd�|d D �}|S )z� List the deployed containers. http://docs.rancher.com/rancher/v1.2/en/api/api-resources/container/ :rtype: ``list`` of :class:`libcloud.container.base.Container` � %s/containersc s g | ]}� � |��qS r )� _to_container)rS �valuer r r � <listcomp> s z:RancherContainerDriver.list_containers.<locals>.<listcomp>rC rD )r rI Z containersr r r �list_containers s z&RancherContainerDriver.list_containersc K sJ || � |�|d�}|�|� t�|�}| jjd| j |dd�j}| �|�S )a) Deploy a new container. http://docs.rancher.com/rancher/v1.2/en/api/api-resources/container/#create **The following is the Image format used for ``ContainerImage``** *For a ``imageuuid``*: - ``docker:<hostname>:<port>/<namespace>/<imagename>:<version>`` *The following applies*: - ``id`` = ``<imagename>`` - ``name`` = ``<imagename>`` - ``path`` = ``<hostname>:<port>/<namespace>/<imagename>`` - ``version`` = ``<version>`` *Any extra configuration can also be passed i.e. "environment"* :param name: The desired name of the container. (required) :type name: ``str`` :param image: The Image object to deploy. (required) :type image: :class:`libcloud.container.base.ContainerImage` :param parameters: Container Image parameters (unused) :type parameters: ``str`` :param start: Whether to start the container on creation(startOnCreate) :type start: ``bool`` :rtype: :class:`Container` )rO r} rP r� rX rY ) r� �updater[ r\ rE rF r@ rG r� ) r rO r� � parametersr_ Zconfigr` rC rI r r r �deploy_container s %� �� z'RancherContainerDriver.deploy_containerc C s" | j �d�| j|��j}| �|�S )z� Get a container by ID :param con_id: The ID of the container to get :type con_id: ``str`` :rtype: :class:`libcloud.container.base.Container` �{}/containers/{})rE rF r r@ rG r� )r Zcon_idrI r r r � get_containerA s z$RancherContainerDriver.get_containerc C �( | j jd�| j|j�dd�j}| �|�S )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` z {}/containers/{}?action=startrX rt �rE rF r r@ �idrG r� �r � containerrI r r r �start_containerN s �� z&RancherContainerDriver.start_containerc C r� )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 {}/containers/{}?action=stoprX rt r� r� r r r �stop_container_ � �� z%RancherContainerDriver.stop_containerc C rh )a Search for containers matching certain filters i.e. ``{ "imageUuid": "docker:mysql", "state": "running"}`` :param search_params: A collection of search parameters to use. :type search_params: ``dict`` :rtype: ``list`` ri rj z{}/containers?{}rC rk rn r r r �ex_search_containerso rq z+RancherContainerDriver.ex_search_containersc C r� )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`` r� rs rt r� r� r r r �destroy_container� r� z(RancherContainerDriver.destroy_containerc C s� d|vr |� d�d }n|�d�d }d|v r(|� d�d }|� d�d }|}nd}|}|}|dkr?|� d�d �d�d }n|� d�d }t||||| jjd|id�S )a� This function converts a valid Rancher ``imageUuid`` string to a valid image object. Only supports docker based images hence `docker:` must prefix!! Please see the deploy_container() for details on the format. :param imageuuid: A valid Rancher image string i.e. ``docker:rlister/hastebin:8.0`` :type imageuuid: ``str`` :return: Converted ContainerImage object. :rtype: :class:`libcloud.container.base.ContainerImage` �/�:� r Zlatestr} )r� rO r> r? �driver�extra)� partition� rpartitionr rE r� )r Z imageuuidZimage_name_versionr? r� rO r> r r r � _gen_image� s* �z!RancherContainerDriver._gen_imagec C s4 d}|j dur|d |j d |j S |d |j S )zu Take in an image object to break down into an ``imageUuid`` :param image: :return: ZdockerNr� )r? r> )r r� Z image_typer r r r� � s z#RancherContainerDriver._degen_imagec s� |d � ddg}d� v rt j}n4d� v rt j}n,d� v r t j}n$d� v r(t j}n t� fdd �|D ��r7t j}n |d d krAt j}nt j}|}t |d |d | � |d �|d g|| j j |d�S )a$ Convert container in proper Container instance object ** Updating is NOT supported!! :param data: API data about container i.e. result.object :return: Proper Container object: see http://libcloud.readthedocs.io/en/latest/container/api.html �stateZremovedZpurgedZrunning�stoppedZ restarting�errorc 3 s � | ]}|� v V qd S r r )rS �x�Z rancher_stater r � <genexpr>� s � z7RancherContainerDriver._to_container.<locals>.<genexpr>Z transitioningZyesr� rO r} ZprimaryIpAddress)r� rO r� Z ip_addressesr� r� r� ) r ZRUNNINGZSTOPPEDZ REBOOTING�ERROR�anyZ TERMINATEDZPENDING�UNKNOWNr r� rE r� )r rC Zterminate_conditionr� r� r r� r r� � s2 �z$RancherContainerDriver._to_container)Tr4 r5 )NNNNNT) TNNNNNNNNNNN)NT)'r r r �__doc__r ZRANCHER�typerO Zwebsiter) Z connectionClsZsupports_clustersr? r# rJ ra rf rp rv rx rz r| r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r r2 V sf & �8 �f 3 .r2 ) r, Zlibcloud.utils.py3r r r Zlibcloud.common.baser r Zlibcloud.container.baser r r Zlibcloud.container.typesr Z libcloud.container.providersr Z simplejsonr[ � Exception�OK�ACCEPTED�CREATED� NO_CONTENTr r r! r) r2 r r r r �<module> s( ��
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings