Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/oneandone.cpython-39.pyc
Ðазад
a q�h�� � @ s� d Z ddlZddlmZ ddlmZmZ ddlmZm Z m Z m Z m Z m Z ddlmZ ddlmZ ddlmZ dd lmZ dd lmZ d Zd Zg d �ZG dd� de�ZG dd� de�ZG dd� de�Z dS )z! 1&1 Cloud Server Compute driver � N)�Provider)� JsonResponse� ConnectionKey)�NodeSize� NodeImage� NodeLocation�Node�NodeAuthPassword�NodeAuthSSHKey)�InvalidCredsError)� NodeState)�httplib)� NodeDriver)�sleepzcloudpanel-api.1and1.comz/v1/)�API_HOST� API_VERSION�OneAndOneResponse�OneAndOneConnection�OneAndOneNodeDriverc @ s0 e Zd ZdZejejejgZdd� Z dd� Z dS )r z% OneAndOne response parsing. c C sR | j tjkr"| �� }t|d ��n,| �� }d|v rFd|d | j f }n|}|S d S )N�messagez %s (code: %s))�statusr � UNAUTHORIZEDZ parse_bodyr )�self�body�error� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/oneandone.py� parse_error1 s z OneAndOneResponse.parse_errorc C s | j | jv S �N)r �valid_response_codes�r r r r �success> s zOneAndOneResponse.successN) �__name__� __module__� __qualname__�__doc__r �OK�CREATED�ACCEPTEDr r r! r r r r r + s r c s> e Zd ZdZeZeZeZ dd� Z dd� Z d � fd d � Z � Z S ) r z- Connection class for the 1&1 driver c C s t �|�S r )�json�dumps�r �datar r r � encode_dataK s z OneAndOneConnection.encode_datac C s | j |d< d|d< |S )z� Add headers that are necessary for every request This method adds ``token`` and ``Content-Type`` to the request. zX-Tokenzapplication/jsonz Content-Type)�key)r �headersr r r �add_default_headersN s z'OneAndOneConnection.add_default_headersN�GETFc s, | j |�d� }tt| �j||||||d�S )a Some requests will use the href attribute directly. If this is not the case, then we should formulate the url based on the action specified. If we are using a full url, we need to remove the host and protocol components. �/)�action�paramsr, r/ �method�raw)� api_prefix�lstrip�superr �request)r r3 r4 r, r/ r5 r6 �� __class__r r r: X s �zOneAndOneConnection.request)NNNr1 F)r" r# r$ r% r �hostr r7 r Z responseClsr- r0 r: � __classcell__r r r; r r B s �r c @ s e Zd ZdZeZdZdZej Z e j e j e je je je je je j d�Zdd� Zdd� Zd�d d �Zd d � Zd�dd�Zdd� Zd�dd�Zdd� Zd�dd�Z dd� Z d�dd �Z d�d d �Z d d � Z d!d"� Z!d#d$� Z"d%d&� Z#d�d(d)�Z$d*d+� Z%d�d,d-�Z&d.d/� Z'd0d1� Z(d2d3� Z)d�d4d5�Z*d6d7� Z+d8d9� Z,d�d:d;�Z-d<d=� Z.d>d?� Z/d@dA� Z0dBdC� Z1dDdE� Z2d�dFdG�Z3dHdI� Z4dJdK� Z5dLdM� Z6dNdO� Z7d�dPdQ�Z8d�dRdS�Z9g fdTdU�Z:dVdW� Z;d�dXdY�Z<dZd[� Z=d\d]� Z>d^d_� Z?d`da� Z@dbdc� ZAddde� ZBdfdg� ZCdhdi� ZDdjdk� ZEd�dldm�ZFdndo� ZGdpdq� ZHdrds� ZIdtdu� ZJd�dvdw�ZKdxdy� ZLd�dzd{�ZMd|d}� ZNd~d� ZOd�d�� ZPd�d�� ZQd�d�d��ZRd�d�� ZSd�d�d��ZTd�d�� ZUd�d�� ZVd�d�� ZWd�d�� ZXd�d�� ZYd�d�� ZZd�d�� Z[d�d�� Z\d�d�� Z]d�d�� Z^d�d�� Z_d�d�� Z`d�d�d��Zad�d�� Zbd�d�� Zcd�d�� Zdd�d�� Zed�d�� Zfd�d�d��Zgd�d�� Zhd S )�r z' Base OneAndOne node driver. Z1and1zhttp://www.1and1.com)Z POWERING_ONZ POWERING_OFF� POWERED_OFFZ POWERED_ON� REBOOTINGZ CONFIGURINGZREMOVINGZ DEPLOYINGc C s. g }| � � }|D ]}| �|�}|�|� q|S )z� Lists all sizes :return: A list of all configurable node sizes. :rtype: ``list`` of :class:`NodeSize` )�_list_fixed_instances� _to_node_size�append)r �sizesZfixed_instances�value� node_sizer r r � list_sizes� s z OneAndOneNodeDriver.list_sizesc C s. | � � }g }|D ]}| �|�}|�|� q|S )zr Lists all locations :return: ``list`` of :class:`NodeLocation` :rtype: ``list`` )�ex_list_datacenters� _to_locationrC )r � datacenters� locations�valuesrF r r r �list_locations� s z"OneAndOneNodeDriver.list_locationsNc C s | j jddd�}| �|j|�S )zS :return: ``list`` of :class: `NodeImage` :rtype: ``list`` Zserver_appliancesr1 �r3 r5 )� connectionr: � _to_images�object)r � image_type�responser r r � list_images� s �z OneAndOneNodeDriver.list_imagesc C s | j jd| dd�}| �|j�S )Nzserver_appliances/%sr1 rN )rO r: � _to_imagerQ )r �image_idrS r r r � get_image� s �z OneAndOneNodeDriver.get_imagec C s� ||j d|id�} |dur$|j | d< | dur4| | d< | durD| | d< |durT|| d< |durd|| d< | durt| | d < |dur�t|t�r�|j| d < nt|t�r�|j| d < |dur�|| d < | jjd | dd�} | �| j �S )a� Creates a node. :param name: The name of the new node :type name: `str` :param ex_fixed_instance_size_id: Fixed instance size ID from list_sizes :type ex_fixed_instance_size_id: ``str`` :param location: 1&1 Data center Location :type location: `NodeLocation` :param ex_ip: IP address :type ex_ip: `str` :param ex_ssh_key: SSH Key :type ex_ssh_key: `str` :param password: Password :type password: `str` :param ex_monitoring_policy_id: :type ex_firewall_policy_id: `str` :param ex_firewall_policy_id: :type ex_firewall_policy_id: `str` :param ex_loadbalancer_id: :type ex_loadbalancer_id: `str` :param ex_description: :type ex_description: `str` :param ex_power_on: :type ex_power_on: `bool` :return: Instance of class ``Node`` :rtype: :class:`Node` �fixed_instance_size_id)�nameZ appliance_id�hardwareN� datacenter_idZpower_on� descriptionZfirewall_policy_idZmonitoring_policy_idZloadbalancer_id�passwordZrsa_key�ip_id�servers�POST�r3 r, r5 ) �id� isinstancer r] r ZpubkeyrO r: �_to_noderQ )r rY �imageZex_fixed_instance_size_id�location�authZex_ipZex_monitoring_policy_idZex_firewall_policy_idZex_loadbalancer_idZex_descriptionZ ex_power_onr rS r r r � create_node� s< 6�� �z OneAndOneNodeDriver.create_nodec C s | j jddd�}| �|j�S )zf List all nodes. :return: ``list`` of :class:`Node` :rtype: ``list`` r_ r1 rN )rO r: � _to_nodesrQ �r rS r r r � list_nodes s �z OneAndOneNodeDriver.list_nodesFc C sB | � |j� | �|jd� | jjd|j d|idd�}| �|j�S )aC Destroys a node. :param node: The node you wish to destroy. :type volume: :class:`Node` :param ex_keep_ips: True to keep all IP addresses assigned to the node :type ex_keep_ips: : ``bool`` :return: Instance of class ``Node`` :rtype: :class: `Node` r? � servers/%sZkeep_ips�DELETE)r3 r4 r5 )�ex_shutdown_serverrb �_wait_for_staterO r: rd rQ )r �nodeZ ex_keep_ipsrS r r r � destroy_node& s �z OneAndOneNodeDriver.destroy_nodec C s. ddd�}| j jd|j |dd�}| �|j�S )z� Reboots the node. :param node: The node you wish to destroy. :type volume: :class:`Node` :return: Instance of class ``Node`` :rtype: :class: `Node` ZREBOOTZHARDWARErN �servers/%s/status/action�PUTra )rO r: rb rd rQ )r rp � shutdown_bodyrS r r r � reboot_node? s ��z OneAndOneNodeDriver.reboot_nodec C sF i }|dur||d< |dur$||d< | j jd| |dd�}| �|j�S )aM Renames the server :param server_id: ID of the server you want to rename :param name: New name of the server :type: ``str`` :param description: New description of the server :type: ``str`` :return: Instance of class ``Node`` :rtype: :class: `Node` NrY r\ rl rs ra �rO r: rd rQ )r � server_idrY r\ r rS r r r �ex_rename_serverX s �z$OneAndOneNodeDriver.ex_rename_serverc C s | j jd| dd�}|jS )z� Gets all server hardware :param server_id: Id of the server :type: ``str`` :return: Server's hardware :rtype: ``dict`` �servers/%s/hardwarer1 rN �rO r: rQ �r rw rS r r r �ex_get_server_hardwareu s �z*OneAndOneNodeDriver.ex_get_server_hardwarec C sf i }|dur||d< |dur$||d< |dur4||d< |durD||d< | j jd| |dd�}| �|j�S ) a� Modifies server's hardware :param server_id: :type: ``str`` :param fixed_instance_size_id: Id of the fixed instance size :type: ``str`` :param vcore: Virtual cores count :type: ``int`` :param cores_per_processor: Count of cores per procesor :type: ``int`` :param ram: Amount of ram for the server :type: ``int`` :return: Instance of class ``Node`` :type: :class: `Node` NrX �vcore�cores_per_processor�ramry rs ra rv )r rw rX r} r~ r r rS r r r �ex_modify_server_hardware� s �z-OneAndOneNodeDriver.ex_modify_server_hardwarec C s> i }|dur:||d< | j jd||f |dd�}| �|j�S dS )aN Modifies server hard disk drives :param server_id: Id of the server :type: ``str`` :param hdd_id: Id of the hard disk :type: ``str`` :param size: Size of the hard disk :type: ``str`` :return: Instance of class ``Node`` :rtype: :class: `Node` N�size�servers/%s/hardware/hdds/%srs ra rv )r rw �hdd_idr� r rS r r r �ex_modify_server_hdd� s �z(OneAndOneNodeDriver.ex_modify_server_hddc C s, ||d�}| j jd| |dd�}| �|j�S )am Add a hard disk to the server :param server_id: Id of the server :type: ``str`` :param size: Size of the new disk :type: ``str`` :param is_main: Indicates if the disk is going to be the boot disk :type: ``boolean`` :return: Instance of class ``Node`` :type: :class: `Node` )r� �is_mainzservers/%s/hardware/hddsr` ra rv )r rw r� r� r rS r r r � ex_add_hdd� s ��z OneAndOneNodeDriver.ex_add_hddc C s$ | j jd||f dd�}| �|j�S )a Removes existing hard disk :param server_id: Id of the server :type: ``str`` :param hdd_id: Id of the hard disk :type: ``str`` :return: Instance of class ``Node`` :rtype: :class: `Node` r� rm rN rv )r rw r� rS r r r � ex_remove_hdd� s �z!OneAndOneNodeDriver.ex_remove_hddc C s | j jddd�}|jS )zh Lists all data centers :return: List of data centers :rtype: ``dict`` rJ r1 rN rz rj r r r rH s �z'OneAndOneNodeDriver.ex_list_datacentersc C s | j jd| dd�}| �|j�S )z� Gets a server :param server_id: Id of the server to be retrieved :type: ``str`` :return: Instance of class ``Node`` :rtype: :class: `Node` rl r1 rN rv r{ r r r � ex_get_server s �z!OneAndOneNodeDriver.ex_get_server�SOFTWAREc C s, d|d�}| j jd| |dd�}| �|j�S )a Shuts down the server :param server_id: Id of the server to be shut down :type: ``str`` :param method: Method of shutting down "SOFTWARE" or "HARDWARE" :return: Instance of class ``Node`` :rtype: :class: `Node` Z POWER_OFFrN rr rs ra rv )r rw r5 rt rS r r r rn - s ��z&OneAndOneNodeDriver.ex_shutdown_serverc C s | j jd| dd�}|jS )z� Gets server image :param server_id: Id of the server :type: ``str`` :return: Server image :rtype: ``dict`` �servers/%s/imager1 rN rz r{ r r r �ex_get_server_imageI s �z'OneAndOneNodeDriver.ex_get_server_imagec C s: d|i}|dur||d< | j jd| |dd�}| �|j�S )aT Installs a new image on the server :param server_id: Id of the server :type: ``str`` :param image_id: Id of the image (Server Appliance) :type: ``str`` :param password: New password for the server :return: Instance of class ``Node`` :rtype: :class: `Node` rb Nr] r� rs ra rv )r rw rV r] r rS r r r �ex_reinstall_server_imageZ s ��z-OneAndOneNodeDriver.ex_reinstall_server_imagec C s | j jd| dd�}|jS )z� Gets all server IP objects :param server_id: Id of the server :type: ``str`` :return: List of server IP objects :rtype: ``list`` of ``dict`` �servers/%s/ipsr1 rN rz r{ r r r �ex_list_server_ips| s �z&OneAndOneNodeDriver.ex_list_server_ipsc C s | j jd||f dd�}|jS )z� Get a single server IP object :param server_id: Id of the server :type: ``str`` :param ip_id: ID of the IP address :type: ``str`` :return: IP address object :rtype: ``dict`` �servers/%s/ips/%sr1 rN rz �r rw r^ rS r r r �ex_get_server_ip� s �z$OneAndOneNodeDriver.ex_get_server_ipc C s* d|i}| j jd| |dd�}| �|j�S )a Assigns a new IP address to the server :param server_id: Id of the server :type: ``str`` :param ip_type: Type of the IP address [IPV4,IPV6] :type: ``str`` :return: ``Node`` instance :rtype: ``Node`` �typer� r` ra rv )r rw Zip_typer rS r r r �ex_assign_server_ip� s ��z'OneAndOneNodeDriver.ex_assign_server_ipc C s: i }|dur||d< | j jd||f |dd�}| �|j�S )a� Removes an IP address from the server :param server_id: Id of the server :type: ``str`` :param ip_id: ID of the IP address :type: ``str`` :param keep_ip: Indicates whether IP address will be removed from the Cloud Panel :type: ``boolean`` :return: ``Node`` instance :rtype: ``Node`` N�keep_ipr� rm ra rv )r rw r^ r� r rS r r r �ex_remove_server_ip� s �z'OneAndOneNodeDriver.ex_remove_server_ipc C s | j jd||f dd�}|jS )a Gets a firewall policy of attached to the server's IP :param server_id: Id of the server :type: ``str`` :param ip_id: ID of the IP address :type: ``str`` :return: IP address object :rtype: ``dict`` �"/servers/%s/ips/%s/firewall_policyr1 rN rz r� r r r � ex_get_server_firewall_policies� s �z3OneAndOneNodeDriver.ex_get_server_firewall_policiesc C s. d|i}| j jd||f |dd�}| �|j�S )aT Adds a firewall policy to the server's IP address :param server_id: Id of the server :type: ``str`` :param ip_id: ID of the IP address :type: ``str`` :param firewall_id: ID of the firewall policy :type: ``str`` :return: ``Node`` instance :rtype: ``Node`` rb r� r` ra rv )r rw r^ Z firewall_idr rS r r r � ex_add_server_firewall_policy� s � �z1OneAndOneNodeDriver.ex_add_server_firewall_policyc C sN d|i}|dur||d< t |�dkr.td��n||d< | jjd|dd �}|jS ) z� Creates a firewall Policy. :param name: :param description: :param rules: :rtype: `dict` :return: `dict` firewall policy rY Nr\ r z'At least one firewall rule is required.�rules�firewall_policiesr` ra )�len� ValueErrorrO r: rQ )r rY r� r\ r rS r r r �ex_create_firewall_policy s � ��z-OneAndOneNodeDriver.ex_create_firewall_policyc C s | j jddd�}|jS )zB" List firewall policies :return: 'dict' r� r1 rN rz rj r r r �ex_list_firewall_policies/ s �z-OneAndOneNodeDriver.ex_list_firewall_policiesc C s | j jd| dd�}|jS )zo Gets firewall policy :param fw_id: ID of the firewall policy :return: 'dict' �firewall_policy/%sr1 rN rz �r Zfw_idrS r r r �ex_get_firewall_policy= s �z*OneAndOneNodeDriver.ex_get_firewall_policyc C s | j jd| dd�}|jS )zk Deletes firewall policy :param fw_id: ID of the Firewall :return: 'dict' r� rm rN rz r� r r r �ex_delete_firewall_policyL s �z-OneAndOneNodeDriver.ex_delete_firewall_policyc C s | j jddd�}|jS )zA List of shared storages :return: 'dict' �shared_storagesr1 rN rz rj r r r �ex_list_shared_storages^ s �z+OneAndOneNodeDriver.ex_list_shared_storagesc C s | j jd| dd�}|jS )z? Gets a shared storage :return: 'dict' �shared_storages/%sr1 rN rz �r � storage_idrS r r r �ex_get_shared_storagej s �z)OneAndOneNodeDriver.ex_get_shared_storagec C s4 |||d�}|dur ||d< | j jd|dd�}|jS )a Creates a shared storage :param name: Name of the storage :param size: Size of the storage :param datacenter_id: datacenter where storage should be created :param description: description ot the storage :return: 'dict' )rY r� r[ Nr\ r� r` ra rz )r rY r� r[ r\ r rS r r r �ex_create_shared_storagev s ��z,OneAndOneNodeDriver.ex_create_shared_storagec C s | j jd| dd�}|jS )z� Removes a shared storage :param storage_id: Id of the shared storage :type: ``str`` :return: Instnace of shared storage :rtype: ``list`` of ``dict`` r� rm rN rz r� r r r �ex_delete_shared_storage� s �z,OneAndOneNodeDriver.ex_delete_shared_storagec C s, d||d�gi}| j jd| |dd�}|jS )a Attaches a single server to a shared storage :param storage_id: Id of the shared storage :param server_id: Id of the server to be attached to the shared storage :param rights: :return: :rtype: 'dict' Zsevers)rb �rightszshared_storages/%s/serversr` ra rz )r r� rw r� r rS r r r �"ex_attach_server_to_shared_storage� s ��� �z6OneAndOneNodeDriver.ex_attach_server_to_shared_storagec C s | j jd||f d�}|jS )zv Gets a shared storage's server :param storage_id: :param server_id: :return: � shared_storages/%s/servers/%s)r3 rz �r r� rw rS r r r � ex_get_shared_storage_server� s �z0OneAndOneNodeDriver.ex_get_shared_storage_serverc C s | j jd||f dd�}|jS )a Detaches a server from shared storage :param storage_id: Id of the shared storage :type: ``str`` :param server_id: Id of the server :type: ``str`` :return: Instance of shared storage :rtype: ``dict`` r� rm rN rz r� r r r �$ex_detach_server_from_shared_storage� s �z8OneAndOneNodeDriver.ex_detach_server_from_shared_storagec C s� ||d�} g | d< || d< |dur*|| d< |dur:|| d< |durJ|| d< |durZ|| d< |durj|| d< | durz| | d < | dur�| | d < | dur�| | d < | j jd | d d�} | jS )a~ :param name: Name of the load balancer :param method: Load balancer method :param rules: Load balancer rules :type rules: ``list`` of ``dict`` :param persistence: Indictes if persistance is set :type persistence: ``boolean`` :param persistence_time: Persistance time :type persistence_time: ``int`` :param health_check_test: Type of test :type health_check_test:``str`` :param health_check_interval: Interval of the check :param health_check_path: Path :type health_check_path: ``str`` :param health_check_parser: Parser :type health_check_parser:``str`` :param datacenter_id: Data center id :type datacenter_id:``str`` :param description: Description of load balancer :type description:``str`` :return: ``dict`` )rY r5 r� N� persistence�persistence_time�health_check_test�health_check_interval�health_check_path�health_check_parserr[ r\ �load_balancersr` ra rz )r rY r5 r� r� r� r� r� r� r� r[ r\ r rS r r r �ex_create_load_balancer� s6 -��z+OneAndOneNodeDriver.ex_create_load_balancerc C s� i } |d ur|| d< |d ur$|| d< |d ur4|| d< |d urD|| d< |d urT|| d< |d urd|| d< |d urt|| d< | j jd| | d d �} | jS ) NrY r\ r� r� r� r� r5 �load_balancers/%srs ra rz ) r �lb_idrY r\ r� r� r� r� r5 r rS r r r �ex_update_load_balancer2 s* �z+OneAndOneNodeDriver.ex_update_load_balancerc C s$ d|i}| j jd| |dd�}|jS )a Adds server's IP address to load balancer :param lb_id: Load balancer ID :type: ``str`` :param server_ips: Array of server IP IDs :type: ``list`` of ``str`` :return: Instance of load balancer :rtype: ``dict`` � server_ips� load_balancers/%s/server_ipsr` ra rz )r r� r� r rS r r r � ex_add_servers_to_load_balancerQ s ��z3OneAndOneNodeDriver.ex_add_servers_to_load_balancerc C s | j jd||f dd�}|jS )a Removes server's IP from load balancer :param lb_id: Load balancer ID :type: ``str`` :param server_ip: ID of the server IP :type: ``str`` :return: Instance of load balancer :rtype: ``dict`` z /load_balancers/%s/server_ips/%srm rN rz �r r� Z server_iprS r r r �#ex_remove_server_from_load_balancerj s �z7OneAndOneNodeDriver.ex_remove_server_from_load_balancerc C sF d|||d�gi}|dur*||d d d< | j jd| |dd�}|jS ) a� Adds a rule to load balancer :param lb_id: Load balancer ID :rtype: ``str`` :param protocol: Load balancer protocol :rtype: ``str`` :param port_balancer: Port to be balananced :rtype: ``int`` :param port_server: Server port :rtype: ``int`` :param source: Source IP address :rtype: ``str`` :return: Instance of load balancer :rtype: ``dict`` r� )�protocol� port_balancer� port_serverNr �sourcez/load_balancers/%s/rulesr` ra rz )r r� r� r� r� r� r rS r r r �ex_add_load_balancer_rule s ��� �z-OneAndOneNodeDriver.ex_add_load_balancer_rulec C s | j jd||f dd�}|jS )z� Removes load balancer rule :param lb_id: Load balancer ID :rtype: ``str`` :param rule_id: Rule ID :rtype: ``str`` :return: Instance of load balancer :rtype: ``dict`` z/load_balancers/%s/rules/%srm rN rz �r r� Zrule_idrS r r r � ex_remove_load_balancer_rule� s �z0OneAndOneNodeDriver.ex_remove_load_balancer_rulec C s | j jddd�}|jS )zx Lists all load balancers :return: List of load balancers :rtype: ``list`` of ``dict`` r� r1 rN rz rj r r r �ex_list_load_balancers� s �z*OneAndOneNodeDriver.ex_list_load_balancersc C s | j jd| dd�}|jS )z� Gets a single load balancer :param lb_id: ID of the load balancer :type lb_id: ``str`` :return: Instance of load balancer :rtype: ``dict`` r� r1 rN rz �r r� rS r r r �ex_get_load_balancer� s �z(OneAndOneNodeDriver.ex_get_load_balancerc C s | j jd| dd�}|jS )z� List balanced server IP addresses :param lb_id: ID of the load balancer :type lb_id: ``str`` :return: Array of IP address IDs :rtype: ``dict`` r� r1 rN rz r� r r r � ex_list_load_balancer_server_ips� s �z4OneAndOneNodeDriver.ex_list_load_balancer_server_ipsc C s | j jd||f dd�}|jS )z� Gets load balanced server id :param lb_id: ID of the load balancer :type lb_id: ``str`` :param server_ip: ID of the server IP :type server_ip: ``str`` :return: Server IP :rtype: ``dict`` z load_balancers/%s/server_ips/%sr1 rN rz r� r r r � ex_get_load_balancer_server_ip� s �z2OneAndOneNodeDriver.ex_get_load_balancer_server_ipc C s | j jd| dd�}|jS )z� Lists loadbalancer rules :param lb_id: ID of the load balancer :type lb_id: ``str`` :return: Lists of rules :rtype: ``list`` of ``dict`` zload_balancers/%s/rulesr1 rN rz r� r r r �ex_list_load_balancer_rules s �z/OneAndOneNodeDriver.ex_list_load_balancer_rulesc C s | j jd||f dd�}|jS )z� Get a load balancer rule :param lb_id: ID of the load balancer :type lb_id: ``str`` :param rule_id: Rule ID :type rule_id: ``str`` :return: A load balancer rule :rtype: ``dict`` zload_balancers/%s/rules/%sr1 rN rz r� r r r �ex_get_load_balancer_rule s �z-OneAndOneNodeDriver.ex_get_load_balancer_rulec C s | j jd| dd�}|jS )z� Deletes a load balancer rule :param lb_id: ID of the load balancer :type lb_id: ``str`` :param rule_id: Rule ID :type rule_id: ``str`` :return: Instance of load balancer :rtype: ``dict`` r� rm rN rz r� r r r �ex_delete_load_balancer( s �z+OneAndOneNodeDriver.ex_delete_load_balancerc C s | j jddd�}|jS )z� Lists all public IP addresses :return: Array of public addresses :rtype: ``list`` of ``dict`` � public_ipsr1 rN rz rj r r r �ex_list_public_ips@ s �z&OneAndOneNodeDriver.ex_list_public_ipsc C s@ d|i}|dur||d< |dur(||d< | j jd|dd�}|jS )ap Creates a public IP :param type: Type of IP (IPV4 or IPV6) :type type: ``str`` :param reverse_dns: Reverse DNS :type reverse_dns: ``str`` :param datacenter_id: Datacenter ID where IP address will be crated :type datacenter_id: ``str`` :return: Instance of Public IP :rtype: ``dict`` r� N� reverse_dnsr[ r� r` ra rz )r r� r� r[ r rS r r r �ex_create_public_ipN s ��z'OneAndOneNodeDriver.ex_create_public_ipc C s | j jd| dd�}|jS )z� Gets a Public IP :param ip_id: ID of the IP :type ip_id: ``str`` :return: Instance of Public IP :rtype: ``dict`` � public_ips/%sr1 rN rz �r r^ rS r r r �ex_get_public_ipo s �z$OneAndOneNodeDriver.ex_get_public_ipc C s | j jd| dd�}|S )z� Deletes a public IP :param ip_id: ID of public IP :type ip_id: ``str`` :return: Instance of IP Address :rtype: ``dict`` r� rm rN )rO r: r� r r r �ex_delete_public_ip� s �z'OneAndOneNodeDriver.ex_delete_public_ipc C s$ d|i}| j jd| |dd�}|jS )z� Updates a Public IP :param ip_id: ID of public IP :type ip_id: ``str`` :param reverse_dns: Reverse DNS :type reverse_dns: ``str`` :return: Instance of Public IP :rtype: ``dict`` r� r� rm ra rz )r r^ r� r rS r r r �ex_update_public_ip� s ��z'OneAndOneNodeDriver.ex_update_public_ipc C s | j jddd�}|jS )zp Lists all private networks :return: List of private networks :rtype: ``dict`` �private_networksr1 rN rz rj r r r �ex_list_private_networks� s �z,OneAndOneNodeDriver.ex_list_private_networksc C s` d|i}|dur||d< |dur(||d< |dur8||d< |durH||d< | j jd|dd �}|jS ) ai Creates a private network :param name: Name of the private network :type name: ``str`` :param description: Description of the private network :type description: ``str`` :param datacenter_id: ID of the data center for the private network :type datacenter_id: ``str`` :param network_address: Network address of the private network :type network_address: ``str`` :param subnet_mask: Subnet mask of the private network :type subnet_mask: ``str`` :return: Newly created private network :rtype: ``dict`` rY Nr\ r[ �network_address� subnet_maksr� r` ra rz )r rY r\ r[ r� � subnet_maskr rS r r r �ex_create_private_network� s ��z-OneAndOneNodeDriver.ex_create_private_networkc C s | j jd| dd�}|jS )z� Deletes a private network :param network_id: Id of the private network :type network_id: ``str`` :return: Instance of the private network being deleted :rtype: ``dict`` r� rm rN rz �r � network_idrS r r r �ex_delete_private_network� s �z-OneAndOneNodeDriver.ex_delete_private_networkc C sl i }|dur||d< |dur$||d< |dur4||d< |durD||d< |durT||d< | j jd|dd �}|jS ) aY Updates a private network :param name: Name of the private network :type name: ``str`` :param description: Description of the private network :type description: ``str`` :param datacenter_id: ID of the data center for the private network :type datacenter_id: ``str`` :param network_address: Network address of the private network :type network_address: ``str`` :param subnet_mask: Subnet mask of the private network :type subnet_mask: ``str`` :return: Instance of private network :rtype: ``dict`` NrY r\ r[ r� r� zprivate_networks/%srs ra rz ) r r� rY r\ r[ r� r� r rS r r r �ex_update_private_network� s" �z-OneAndOneNodeDriver.ex_update_private_networkc C s | j jd| dd�}|jS )z� Lists all private network servers :param network_id: Private network ID :type network_id: ``str`` :return: List of private network servers :rtype: ``dict`` � /private_networks/%s/serversr1 rN rz r� r r r � ex_list_private_network_servers* s �z3OneAndOneNodeDriver.ex_list_private_network_serversc C s$ d|i}| j jd| |dd�}|jS )a# Add servers to private network :param network_id: Private Network ID :type network_id: ``str`` :param server_ids: List of server IDs :type server_ids: ``list`` of ``str`` :return: List of attached servers :rtype: ``dict`` r_ r� r` ra rz )r r� Z server_idsr rS r r r � ex_add_private_network_server: s ��z1OneAndOneNodeDriver.ex_add_private_network_serverc C s | j jd||f dd�}|jS )a$ Removes a server from the private network :param network_id: Private Network ID :type network_id: ``str`` :param server_id: Id of the server :type server_id: ``str`` :return: Instance of the private network :rtype: ``dict`` z /private_networks/%s/servers/%sr` rN rz )r r� rw rS r r r �%ex_remove_server_from_private_networkU s �z9OneAndOneNodeDriver.ex_remove_server_from_private_networkc C s | j jddd�}|jS )zv Lists all monitoring policies :return: List of monitoring policies :rtype: ``dict`` �monitoring_policiesr1 rN rz rj r r r �ex_list_monitoring_policiesm s �z/OneAndOneNodeDriver.ex_list_monitoring_policiesc C sV ||||d�}|dur ||d< |dur.||d< |dur>||d< | j jd|dd�} | jS ) a Creates a monitoring policy :param name: Name for the monitoring policy :type name: ``str`` :param thresholds: Thresholds for the monitoring policy :type thresholds: ``dict`` :param ports: Monitoring policies for ports :type ports: ``list`` of ``dict`` :param processes: Processes to be monitored :type processes: ``list`` of ``dict`` :param description: Description for the monitoring policy :type description: ``str`` :param email: Email for notifications :type email: ``str`` :param agent: Indicates if agent application will be installed :type agent: ``boolean`` :return: Newly created instance of monitofing policy :rtype: ``dict`` )rY � thresholds�ports� processesNr\ �email�agentr� r` ra rz ) r rY r� r� r� r\ r� r� r rS r r r �ex_create_monitoring_policy{ s" #��z/OneAndOneNodeDriver.ex_create_monitoring_policyc C s | j jd| dd�}|jS )z� Deletes a monitoring policy :param policy_id: Id of the monitoring policy :type policy_id: ``str`` :return: Instance of the monitoring policy being deleted :rtype: ``dict`` r� rm rN rz �r � policy_idrS r r r �ex_delete_monitoring_policy� s �z/OneAndOneNodeDriver.ex_delete_monitoring_policyc C s` i }|dur||d< |dur$||d< |dur4||d< |durD||d< | j jd| |dd�}|jS ) aJ Updates monitoring policy :param policy_id: Id of the monitoring policy :type policy_id: ``str`` :param email: Email to send notifications to :type email: ``str`` :param thresholds: Thresholds for the monitoring policy :type thresholds: ``dict`` :param name: Name of the monitoring policy :type name: ``str`` :param description: Description of the monitoring policy :type description: ``str`` :return: Instance of the monitoring policy being deleted :rtype: ``dict`` NrY r\ r� r� �monitoring_policies/%srs ra rz )r r� r� r� rY r\ r rS r r r �ex_update_monitoring_policy� s �z/OneAndOneNodeDriver.ex_update_monitoring_policyc C s | j jd| dd�}|jS )z� Fetches a monitoring policy :param policy_id: Id of the monitoring policy :type policy_id: ``str`` :return: Instance of a monitoring policy :rtype: ``dict`` r� r1 rN rz r� r r r �ex_get_monitoring_policy� s �z,OneAndOneNodeDriver.ex_get_monitoring_policyc C s | j jd| dd�}|jS )z� Fetches monitoring policy ports :param policy_id: Id of the monitoring policy :type policy_id: :return: Instance of a monitoring policy :rtype: ``dict`` � monitoring_policies/%s/portsr1 rN rz r� r r r � ex_get_monitoring_policy_ports s �z2OneAndOneNodeDriver.ex_get_monitoring_policy_portsc C s | j jd||f dd�}|jS )a Fetches monitoring policy port :param policy_id: Id of the monitoring policy :type policy_id: ``str`` :param port_id: Id of the port :type port_id: ``str`` :return: Instance of a monitoring policy :rtype: ``dict`` � monitoring_policies/%s/ports/%sr1 rN rz �r r� Zport_idrS r r r � ex_get_monitoring_policy_port s �z1OneAndOneNodeDriver.ex_get_monitoring_policy_portc C s | j jd||f dd�}|jS )a Removes monitoring policy port :param policy_id: Id of the monitoring policy :type policy_id: ``str`` :param port_id: Id of the port :type port_id: ``str`` :return: Instance of a monitoring policy :rtype: ``dict`` r� rm rN rz r� r r r � ex_remove_monitoring_policy_port( s �z4OneAndOneNodeDriver.ex_remove_monitoring_policy_portc C s$ d|i}| j jd| |dd�}|jS )a� Add monitoring policy ports :param policy_id: Id of the monitoring policy :type policy_id: ``str`` :param ports: List of ports :type ports: ``dict`` [ { 'protocol':'TCP', 'port':'80', 'alert_if':'RESPONDING', 'email_notification':true } ] :return: Instance of a monitoring policy :rtype: ``dict`` r� r� r` ra rz )r r� r� r rS r r r � ex_add_monitoring_policy_ports= s �z2OneAndOneNodeDriver.ex_add_monitoring_policy_portsc C s | j jd| dd�}|jS )z� Fetches monitoring policy processes :param policy_id: Id of the monitoring policy :type policy_id: ``str`` :return: Instance of a monitoring policy :rtype: ``dict`` � monitoring_policies/%s/processesr1 rN rz r� r r r �"ex_get_monitoring_policy_processes] s �z6OneAndOneNodeDriver.ex_get_monitoring_policy_processesc C s | j jd||f dd�}|jS )a& Fetches monitoring policy process :param policy_id: Id of the monitoring policy :type policy_id: ``str`` :param process_id: Id of the process :type process_id: ``str`` :return: Instance of a monitoring policy :rtype: ``dict`` �#monitoring_policies/%s/processes/%sr1 rN rz �r r� Z process_idrS r r r � ex_get_monitoring_policy_processo s ��z4OneAndOneNodeDriver.ex_get_monitoring_policy_processc C s | j jd||f dd�}|jS )a& Removes monitoring policy process :param policy_id: Id of the monitoring policy :type policy_id: ``str`` :param process_id: Id of the process :type process_id: ``str`` :return: Instance of a monitoring policy :rtype: ``dict`` r� rm rN rz r� r r r �#ex_remove_monitoring_policy_process� s ��z7OneAndOneNodeDriver.ex_remove_monitoring_policy_processc C s$ d|i}| j jd| |dd�}|jS )a� Add monitoring policy processes :param policy_id: Id of the monitoring policy :type policy_id: ``str`` :param processes: List of processes :type processes: ``list`` of ``dict`` [ { 'process': 'taskmmgr', 'alert_if': 'RUNNING', 'email_notification': true } ] :return: Instance of a monitoring policy :rtype: ``dict`` r� r� r` ra rz )r r� r� r rS r r r �"ex_add_monitoring_policy_processes� s �z6OneAndOneNodeDriver.ex_add_monitoring_policy_processesc C s | j jd| dd�}|jS )z� List all servers that are being monitoried by the policy :param policy_id: Id of the monitoring policy :type policy_id: ``str`` :return: List of servers being monitored :rtype: ``list`` of ``dict`` � monitoring_policies/%s/serversr1 rN rz r� r r r �!ex_list_monitoring_policy_servers� s �z5OneAndOneNodeDriver.ex_list_monitoring_policy_serversc C s$ d|i}| j jd| |dd�}|jS )a, Adds servers to monitoring policy :param policy_id: Id of the monitoring policy :type policy_id: ``str`` :param servers: List of server ID :type servers: ``list`` of ``str`` :return: Instance of a monitoring policy :rtype: ``dict`` r_ r r` ra rz )r r� r_ r rS r r r �#ex_add_servers_to_monitoring_policy� s ��z7OneAndOneNodeDriver.ex_add_servers_to_monitoring_policyc C s | j jd||f dd�}|jS )a) Removes a server from monitoring policy :param policy_id: Id of the monitoring policy :type policy_id: ``str`` :param server_id: Id of the server :type server_id: ``str`` :return: Instance of a monitoring policy :rtype: ``dict`` z!monitoring_policies/%s/servers/%srm rN rz )r r� rw rS r r r �'ex_remove_server_from_monitoring_policy� s ��z;OneAndOneNodeDriver.ex_remove_server_from_monitoring_policyc s< � d ur � fdd�|D �}ndd� |D �}�fdd�|D �S )Nc s g | ]}|d � kr|�qS )r� r ��.0re )rR r r � <listcomp>� � z2OneAndOneNodeDriver._to_images.<locals>.<listcomp>c S s g | ]}|�qS r r r r r r r r c s g | ]}� � |��qS r )rU r r r r r r r )r rQ rR Zimagesr )rR r r rP � s z OneAndOneNodeDriver._to_imagesc C sZ |d |d |d |d |d |d |d |d |d |d d � }t |d |d | |d�S )N� os_family�os� os_version�os_architecture� os_image_type� min_hdd_size�available_datacenters�licenses�version� categories) r r r r r r r r r r rb rY )rb rY �driver�extra)r )r r, r r r r rU s � �z OneAndOneNodeDriver._to_imagec C sR t |d |d |d d |d d d d d d | jj|d d |d d d �d �S ) Nrb rY rZ r Zhddsr r� r} r~ )Zvcoresr~ )rb rY r Zdisk� bandwidthZpricer r )r rO r r+ r r r rB s ��z!OneAndOneNodeDriver._to_node_sizec C s t |d |d |d | jjd�S )Nrb Z country_coderf )rb rY Zcountryr )r rO r )r rf r r r rI $ s �z OneAndOneNodeDriver._to_locationc s � fdd�|D �S )Nc s g | ]}� � |��qS r )rd )r �serverr r r r - s ��z1OneAndOneNodeDriver._to_nodes.<locals>.<listcomp>r )r r_ r r r ri , s �z OneAndOneNodeDriver._to_nodesc C s< i }|d |d< d|v r$|d |d< d|v r8|d |d< d|v rL|d |d< d|v r`|d |d< d|v rt|d |d< d|v r�|d |d< d|v r�|d |d< d |v r�|d |d < d |v r�|d |d < d |v r�|d |d < g }|d d u�r|d D ]}|� |d � q�| j�|d d �}t|d ||d | jj|d |d�S )NZ datacenterr\ r re rZ �dvdZsnapshot�ipsZalertsZmonitoring_policyr� �ip�staterb rY )rb r rY r r� Z private_ipsr )rC �NODE_STATE_MAP�getr rO r )r r r r r r r r r rd 0 sL ��z OneAndOneNodeDriver._to_node�2 c C sL d|fD ]>}| � |�}|jd d |kr. d S td� ||krtd��qd S )Nr r r � zRetries count reached)r� r r � Exception)r rw r �retries�ir r r r ro [ s z#OneAndOneNodeDriver._wait_for_statec C s | j jddd�}|jS )Nz /servers/fixed_instance_sizesr1 rN rz rj r r r rA f s �z)OneAndOneNodeDriver._list_fixed_instances)N)NNNNNNNN)F)NN)NNNN)NN)r� )N)N)N)NN)NNNNNNNN)NNNNNNN)N)NN)NNNN)NNNNN)NNN)NN)N)r )ir" r# r$ r% r Z connectionClsrY Zwebsiter Z ONEANDONEr� r ZSTARTINGZPENDINGZSTOPPINGZRUNNINGr@ Z RECONFIGURING�UNKNOWNr rG rM rT rW rh rk rq ru rx r| r� r� r� r� rH r� rn 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� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r r rP rU rB rI ri rd ro rA r r r r r l s � � ^ � 0 " " � � M � � - ! � . � / � 7 � - + r ) r% r) Zlibcloud.compute.providersr Zlibcloud.common.baser r Zlibcloud.compute.baser r r r r r Zlibcloud.common.typesr Zlibcloud.compute.typesr Zlibcloud.utils.py3r r �timer r r �__all__r r r r r r r �<module> s *
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка