Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/container/drivers/__pycache__/rancher.cpython-39.pyc
Ðазад
a q�hKb � @ s� d dl Z z d dlZW n ey. d dlZY n0 d dlmZmZ d dlmZ d dlm Z m Z d dl m Z m Z mZ d dlmZ d dlmZ ejejejejgZG dd � d e �ZG d d � d e�ZG d d � d e �ZG dd� de �ZdS )� N)�httplib�urlparse)�b)� JsonResponse�ConnectionUserAndKey)� Container�ContainerDriver�ContainerImage)�Provider)�ContainerStatec s$ e Zd Z� fdd�Zdd� Z� ZS )�RancherResponsec sN t t| ��� }d|v r6d|d |d |d |d f S d|d |d f S d S )NZ fieldNamezField %s is %s: %s - %s�code�message�detailz%s - %s)�superr � parse_error)�self�parsed�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/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 �success2 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 s d| j | jf S )Nz%s %s�r r r r r r �__str__= s zRancherException.__str__c C s d| j | jf S )NzRancherException %s %sr$ r r r r �__repr__@ s zRancherException.__repr__N)r r r r# r% r& r r r r r! 6 s r! c @ s e Zd ZeZdZdd� ZdS )�RancherConnection� c C sL d|d< d|d< | j rH| jrHt�td| j| j f ��}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-Type�Acceptz%s:%szBasic %szutf-8� Authorization)�keyZuser_id�base64� b64encoder �decode)r �headersZuser_b64r r r �add_default_headersI 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 � Zd=dd�Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd>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 sv d|vr|� d�sd| }t�|�}tt| �j|||jdkr@dn||j|jrR|jn|d� |jrf|jnd| 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 r2 r# �scheme�hostnamer: �path�version�baseuri)r r+ r7 r8 r9 r: r r r r r# z s �z RancherContainerDriver.__init__c C s | 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� s �z%RancherContainerDriver.ex_list_stacksNc C sN |||||||d�}t �tdd� |�� 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 s" | ]\}}|d ur||fV qd S r r ��.0�k�vr r r � <genexpr>� s �z9RancherContainerDriver.ex_deploy_stack.<locals>.<genexpr>rA �POST�rB �method)�json�dumps�dict�itemsrD rE r@ rF ) r rM rJ Zdocker_composerK � external_idZrancher_compose�start�payloadrB rH r r r �ex_deploy_stack� s "� ��z&RancherContainerDriver.ex_deploy_stackc C s | j �d| j|f �j}|S )z� Get a stack by ID :param env_id: The stack to be obtained. :type env_id: ``str`` :rtype: ``dict`` �%s/environments/%srC �r Zenv_idrH r r r � ex_get_stack� s �z#RancherContainerDriver.ex_get_stackc C sR g }|� � D ]\}}|�|d | � q d�|�}| j�d| j|f �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%s/environments?%srB �rZ �append�joinrD rE r@ rF �r Z search_paramsZ search_list�frR Z search_itemsrH r r r �ex_search_stacks� s � z'RancherContainerDriver.ex_search_stacksc C s$ | j jd| j|f 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`` r_ �DELETE�rV �rD rE r@ r r r` r r r �ex_destroy_stack s ��z'RancherContainerDriver.ex_destroy_stackc C s$ | j jd| j|f dd�}|jtv S )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*%s/environments/%s?action=activateservicesrT rk rl r` r r r �ex_activate_stack s ��z(RancherContainerDriver.ex_activate_stackc C s$ | j jd| j|f dd�}|jtv S )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,%s/environments/%s?action=deactivateservicesrT rk rl r` r r r �ex_deactivate_stack$ s ��z*RancherContainerDriver.ex_deactivate_stackc C s | j �d| j �j}|d S )z� List all Rancher Services http://docs.rancher.com/rancher/v1.2/en/api/api-resources/service/ :rtype: ``list`` of ``dict`` � %s/servicesrB rC rG r r r �ex_list_services7 s z'RancherContainerDriver.ex_list_servicesc K sn | � |�f|d< |||||||| | | | | |||d�}t�tdd� |�� 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)ZassignServiceIpAddressrJ Z environmentIdrL Z launchConfig�metadatarM ZretainIp�scaleZ scalePolicy�secondary_launch_configsZselectorContainerZ selectorLinkrN �vipc s s" | ]\}}|d ur||fV qd S r r rO r r r rS � s �z;RancherContainerDriver.ex_deploy_service.<locals>.<genexpr>rp rT rU ) � _degen_imagerW rX rY rZ rD rE r@ rF )r rM �imageZenvironment_idr\ Zassign_service_ip_addressZservice_descriptionr[ rs Z retain_iprt Z scale_policyru Zselector_containerZ selector_linkrv Z launch_confZservice_payloadrB rH r r r �ex_deploy_serviceC s, ?� �z(RancherContainerDriver.ex_deploy_servicec C s | j �d| j|f �j}|S )z� Get a service by ID :param service_id: The service_id to be obtained. :type service_id: ``str`` :rtype: ``dict`` �%s/services/%srC �r Z service_idrH r r r �ex_get_service� s �z%RancherContainerDriver.ex_get_servicec C sR g }|� � D ]\}}|�|d | � q d�|�}| j�d| j|f �j}|d S )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`` rb rc z%s/services?%srB rd rg r r r �ex_search_services� s � z)RancherContainerDriver.ex_search_servicesc C s$ | j jd| j|f dd�}|jtv S )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`` rz rj rk rl r{ r r r �ex_destroy_service� s ��z)RancherContainerDriver.ex_destroy_servicec C s$ | j jd| j|f dd�}|jtv S )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 %s/services/%s?action=activaterT rk rl r{ r r r �ex_activate_service� s ��z*RancherContainerDriver.ex_activate_servicec C s$ | j jd| j|f dd�}|jtv S )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 %s/services/%s?action=deactivaterT rk rl r{ r r r �ex_deactivate_service� s ��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)rP �valuer r r � <listcomp>� � z:RancherContainerDriver.list_containers.<locals>.<listcomp>rB rC )r rH � 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` )rM rr rN r� rT rU ) rw �updaterW rX rD rE r@ rF r� ) r rM rx � parametersr\ �configr] rB rH r r r �deploy_container� s &� �z'RancherContainerDriver.deploy_containerc C s" | j �d| j|f �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` �%s/containers/%s)rD rE r@ rF r� )r Zcon_idrH r r r � get_container1 s �z$RancherContainerDriver.get_containerc C s( | j jd| j|jf 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 %s/containers/%s?action=startrT rk �rD rE r@ �idrF r� �r � containerrH r r r �start_container? s ��z&RancherContainerDriver.start_containerc C s( | j jd| j|jf dd�j}| �|�S )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 %s/containers/%s?action=stoprT rk r� r� r r r �stop_containerO s ��z%RancherContainerDriver.stop_containerc C sR g }|� � D ]\}}|�|d | � q d�|�}| j�d| j|f �j}|d S )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`` rb rc z%s/containers?%srB rd rg r r r �ex_search_containers_ s � z+RancherContainerDriver.ex_search_containersc C s( | j jd| j|jf dd�j}| �|�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`` r� rj rk r� r� r r r �destroy_containers s ��z(RancherContainerDriver.destroy_containerc C s� d|vr|� d�d }n|�d�d }d|v rP|� d�d }|� d�d }|}n d}|}|}|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 Zlatestrr )r� rM r> r? �driver�extra)� partition� rpartitionr rD r� )r Z imageuuidZimage_name_versionr? r� rM r> r r r � _gen_image� s, ��z!RancherContainerDriver._gen_imagec C s8 d}|j dur&|d |j d |j S |d |j S dS )zu Take in an image object to break down into an ``imageUuid`` :param image: :return: �dockerNr� )r? r> )r rx Z image_typer r r rw � s z#RancherContainerDriver._degen_imagec s� |d � ddg}d� v r t j}nhd� v r0t j}nXd� v r@t j}nHd� v rPt j}n8t� fdd �|D ��rnt j}n|d d kr�t 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 �stateZremovedZpurged�running�stoppedZ restarting�errorc 3 s | ]}|� v V qd S r r )rP �x�Z rancher_stater r rS � r� z7RancherContainerDriver._to_container.<locals>.<genexpr>Z transitioning�yesr� rM rr ZprimaryIpAddress)r� rM rx Z ip_addressesr� r� r� ) r ZRUNNINGZSTOPPEDZ REBOOTING�ERROR�anyZ TERMINATEDZPENDING�UNKNOWNr r� rD r� )r rB Zterminate_conditionr� r� r r� r r� � s2 �z$RancherContainerDriver._to_container)Tr4 r5 )NNNNNT) TNNNNNNNNNNN)NT)'r r r �__doc__r ZRANCHER�typerM Zwebsiter' Z connectionClsZsupports_clustersr? r# rI r^ ra ri rm rn ro rq ry r| r} r~ r r� r� r� r� r� r� r� r� r� rw r� r r r r r r2 W sR & � 2 � Z 30r2 ) r, Z simplejsonrW � ExceptionZlibcloud.utils.py3r r r Zlibcloud.common.baser r Zlibcloud.container.baser r r Z libcloud.container.providersr Zlibcloud.container.typesr �OK�ACCEPTED�CREATED� NO_CONTENTr r r! r' r2 r r r r �<module> s" �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка