File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/kamatera.cpython-310.pyc
Back
o ;j�[ � @ s� d Z ddlZddlZddlZddlmZ ddlmZmZ ddl m Z m Z m Z m Z mZmZ ddlmZ G dd� de�ZG d d � d e�ZG d d � d e�ZdS ) z Kamatera node driver � N)� basestring)� JsonResponse�ConnectionUserAndKey)�Node�NodeSize� NodeImage� NodeState� NodeDriver� NodeLocation)�Providerc @ s e Zd ZdZdd� ZdS )�KamateraResponsez+ Response class for KamateraDriver c C s" | � � }d|v r |d S t�|�S )N�message)Z parse_body�json�dumps)�self�data� r �U/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/kamatera.py� parse_error" s z KamateraResponse.parse_errorN)�__name__� __module__� __qualname__�__doc__r r r r r r s r c @ s e Zd ZdZdZeZdd� ZdS )�KamateraConnectionz- Connection class for KamateraDriver zcloudcli.cloudwm.comc C s( | j |d< | j|d< d|d< d|d< |S )z-Adds headers that are needed for all requestsZ AuthClientIdZ AuthSecretzapplication/jsonZAcceptz Content-Type)Zuser_id�key)r �headersr r r �add_default_headers2 s z&KamateraConnection.add_default_headersN)r r r r �hostr Z responseClsr r r r r r * s r c @ s e Zd ZdZejZdZdZe Z dg d�iZ dZ dZ dd � Zd d � Zd d � Zdddde ddfdd�Zd3dd�Zd4dd�Zd4dd�Zd4dd�Zd4dd �Zd4d d �Zd5d d �Z d6d!d"�Zd7d#d$�Zd%d&� Zd8d)d*�Z d+d,� Z dde j ddddddddddddfd-d.�Z d/d0� Z!d1d2� Z"dS )9�KamateraNodeDriverz� Kamatera node driver :keyword key: API Client ID, required for authentication :type key: ``str`` :keyword secret: API Secret, required for authentcaiont :type secret: ``str`` ZKamaterazhttps://www.kamatera.com/� create_node)�passwordZgenerates_passwordZssh_keyZhourlyZmonthlyc s � j �d�}� fdd�|jD �S )zl List available locations for deployment :rtype: ``list`` of :class:`NodeLocation` zservice/server?datacenter=1c s& g | ]}� � |d |d |d ��qS )�idZ subCategory�name)�ex_get_location)�.0� datacenter�r r r � <listcomp>V s ��z5KamateraNodeDriver.list_locations.<locals>.<listcomp>)� connection�request�object)r �responser r& r �list_locationsO s �z!KamateraNodeDriver.list_locationsc s& � j �d|j �}� fdd�|jD �S )z� List predefined sizes for the given location. :param location: Location of the deployment. :type location: :class:`.NodeLocation` @inherits: :class:`NodeDriver.list_sizes` z$service/server?sizes=1&datacenter=%sc s< g | ]}� j |d |d |d |d g |d |d d��qS )�ramMB� diskSizeGB�cpuType�cpuCores�monthlyTrafficPackager! )�extraDiskSizesGBr1 r! )� ex_get_size)r$ �sizer& r r r' e s ���z1KamateraNodeDriver.list_sizes.<locals>.<listcomp>�r( r) r! r* )r �locationr+ r r& r � list_sizes[ s �z KamateraNodeDriver.list_sizesc C sN | j �d|j �}g }|jD ]}| �d|�}|�| �|d |d |�� q|S )a List available disk images. :param location: Location of the deployment. Available disk images depend on location. :type location: :class:`.NodeLocation` :rtype: ``list`` of :class:`NodeImage` z%service/server?images=1&datacenter=%s)r% �os�codeZ osDiskSizeGBZramMBMinr" r! )r( r) r! r* � _copy_dict�append� ex_get_image)r r6 r+ Zimages�image�extrar r r � list_imagesr s z KamateraNodeDriver.list_imagesNFTc C s� d} d} d}t |t�r|} n#| �|�}t|dd�r d} d}nt|d�r)|j} d}nt|d�r1|j} |s9dd d �g}i d |�d| pAd �d | pFd �d| pKd �d|j�d|j�dd�|j d |j d ��d|j �dd� dd� |j g|j d D ���d|r|d nd �d |r�d nd �d d� d d� |D ���d!d"�d#| �d$|j d% p�d �d&| r�d nd �}| j jd'd(t�|�d)�}|r�|jd* }|jd }n|j}d}t|�d"kr�td+��| j||||||| ||d, | d-� }| �rZd.|j vs�|jtjkr�td/��| �|j d. �}|�d0�|j d1< |j �d&��r tj|_ntj |_|�d2��r!t j � |d2 d3�|_ d4d� |j d1 � d5�D �}t|�d"k�r9td6��|d, �!d7d �|_"| j jd8d(t�d |j"i�d)�}| �#||jd, � |S )9a� Creates a Kamatera node. If auth is not given then password will be generated. :param name: String with a name for this new node (required) :type name: ``str`` :param size: The size of resources allocated to this node (required) :type size: :class:`.NodeSize` :param image: OS Image to boot on node. (required) :type image: :class:`.NodeImage` :param location: Which data center to create a node in. (required) :type location: :class:`.NodeLocation` :param auth: Authentication information for the node (optional) :type auth: :class:`.NodeAuthSSHKey` or :class:`.NodeAuthPassword` :param ex_networks: Network configurations (optional) :type ex_networks: ``list`` of ``dict`` :param ex_dailybackup: Whether to create daily backups (optional) :type ex_dailybackup: ``bool`` :param ex_managed: Whether to provide managed support (optional) :type ex_managed: ``bool`` :param ex_billingcycle: billing cycle (hourly / monthly) (optional) :type ex_billingcycle: ``str`` :param ex_poweronaftercreate: power on after creation (optional) :type ex_poweronaftercreate: ``bool`` :param ex_wait: wait for server to be running (optional) :type ex_wait: ``bool`` :return: The newly created node. :rtype: :class:`.Node` NFZ generatedZ __generate__Tr �pubkeyZwan�auto)r" �ipr" � ZpasswordValidatezssh-keyr% r= Zcpuz{}{}r0 r/ �ram�disk� c S s g | ]}d | �qS )zsize=%dr )r$ Zdisksizer r r r' � s z2KamateraNodeDriver.create_node.<locals>.<listcomp>r2 � dailybackupZyes�no�managed�networkc S s$ g | ]}d � dd� |�� D ���qS )�,c S s g | ] \}}d � ||��qS )z{}={})�format)r$ �k�vr r r r' � s z=KamateraNodeDriver.create_node.<locals>.<listcomp>.<listcomp>)�join�items)r$ rJ r r r r' � s ��Zquantity� � billingcycleZmonthlypackager1 �poweronaftercreatezservice/server�POST��methodr Z commandIds�invalid responser ) r" r4 r= r6 rG rI rR �generated_password�create_command_idrS rY z'invalid node for updating create status�logZ create_logZ completedz%Y-%m-%d %H:%M:%Sc S s g | ] }|� d �r|�qS )�Name: )� startswith)r$ �liner r r r' s ��� z Invalid node create log responser[ �/service/server/info)$� isinstancer Z_get_and_check_auth�getattr�hasattrr r@ r! rL r> rD rO rE r( r) r r r* �len� RuntimeError� ex_get_node�stater �UNKNOWN� ValueError�ex_wait_command�get�RUNNING�STOPPED�datetime�strptime� created_at�split�replacer" � _update_node_from_server_info)r r" r4 r= r6 ZauthZ ex_networksZex_dailybackupZ ex_managedZex_billingcycleZex_poweronaftercreate�ex_waitr r@ Zgenerate_passwordZauth_obj� request_datar+ Z command_idsrX �node�commandZ name_linesr r r r � s� 7 �������� �� � ������� � � � ���z KamateraNodeDriver.create_nodec sz |s|s|r-i }|r||d< n|sd}||d< � j jddt�|�d�}� fdd�|jD �S � j �d �}� fd d�|jD �S ) a� List nodes :param ex_name_regex: Regular expression to match node names if set returns full node details (optional) :type ex_name_regex: ``str`` :param ex_full_details: Whether to return full node details takes longer to complete (optional) :type ex_full_details: ``bool`` :return: List of node objects :rtype: ``list`` of :class:`Node` r! z.*r" r_ rT rU c s g | ] }� � � �� |��qS r )rr re �r$ �serverr& r r r' 0 s ��z1KamateraNodeDriver.list_nodes.<locals>.<listcomp>z/service/serversc sD g | ] }� j |d |d |d dkrtjntj� �|d �d��qS )r! r" �power�onr% )r! r" rf r6 )re r rk rl r# rw r& r r r' 6 s � ��)r( r) r r r* )r Z ex_name_regexZex_full_detailsZex_idrt r+ r r& r � list_nodes s" � � �z KamateraNodeDriver.list_nodesc C � | � |d|�S )z� Reboot the given node :param node: the node to reboot :type node: :class:`Node` :param ex_wait: wait for reboot to complete (optional) :type ex_wait: ``bool`` :rtype: ``bool`` Zreboot��ex_node_operation�r ru rs r r r � reboot_node@ � z KamateraNodeDriver.reboot_nodec C r| )z� Destroy the given node :param node: the node to destroy :type node: :class:`Node` :param ex_wait: wait for destroy to complete (optional) :type ex_wait: ``bool`` :rtype: ``bool`` � terminater} r r r r � destroy_nodeN r� z KamateraNodeDriver.destroy_nodec C r| )z� Stop the given node :param node: the node to stop :type node: :class:`Node` :param ex_wait: wait for stop to complete (optional) :type ex_wait: ``bool`` :rtype: ``bool`` Zpoweroffr} r r r r � stop_node\ r� z KamateraNodeDriver.stop_nodec C r| )z� Start the given node :param node: the node to start :type node: :class:`Node` :param ex_wait: wait for start to complete (optional) :type ex_wait: ``bool`` :rtype: ``bool`` Zpoweronr} r r r r � start_nodej r� z KamateraNodeDriver.start_nodec C s� |j r d|j i}n|jrd|ji}ntd| ��|dkr d|d< | jjd| dt�|�d �jd }|r:| �|� dS ||j d | < dS ) ae Run custom operations on the node :param node: the node to run operation on :type node: :class:`Node` :param operation: the operation to run :type operation: ``str`` :param ex_wait: wait for destroy to complete (optional) :type ex_wait: ``bool`` :rtype: ``bool`` r! r" z5Invalid node for %s node operation: missing id / namer� T�forcez/service/server/%srT rU r z %s_command_id) r! r" rh r( r) r r r* ri r> )r ru Z operation�waitrt � command_idr r r r~ x s& �� �z$KamateraNodeDriver.ex_node_operationc C s t |||| d�S )a~ Get a NodeLocation object to use for other methods :param id: Location ID - uppercase letters code (required) :type id: ``str`` :param name: Location Name (optional) :type name: ``str`` :param name: Location country (optional) :type name: ``str`` :rtype: :class:`.NodeLocation` )r! r" �country�driver)r )r r! r" r� r r r r# � s z"KamateraNodeDriver.ex_get_locationc C sr |s t |�| }|dt |� d t |� d 7 }|r |d| 7 }|s$|}t||||dd| jj||||p4g d�d�S )aB Get a NodeSize object to use for other methods :param ramMB: Amount of RAM to allocate in MB (required) :type ramMB: ``int`` :param diskSizeGB: disk size GB for primary hard disk (required) :type diskSizeGB: ``int`` :param cpuType: CPU type ID (single uppercase letter), see ex_list_capabilities (required) :type cpuType: ``str`` :param cpuCores: Number of CPU cores to allocate (required) :type cpuCores: ``int`` :param extraDiskSizesGB: additional disk sizes in GB (optional) :type extraDiskSizesGB: ``list`` of :int: :param monthlyTrafficPackage: ID of monthly traffic package see ex_list_capabilities (optional) :type monthlyTrafficPackage: ``str`` :param id: Size ID (optional) :type id: ``str`` :param name: Size Name (optional) :type name: ``str`` :rtype: :class:`.NodeLocation` �-zMB-ZGBr )r/ r0 r1 r2 )r! r" rD rE Z bandwidthZpricer� r> )�strr r( r� ) r r- r. r/ r0 r2 r1 r! r" r r r r3 � s* * ��z KamateraNodeDriver.ex_get_sizec C s, |s|st d��t|p ||pd| |pi d�S )Nz,either id or name are required for NodeImagerC )r! r" r� r> )rh r )r r" r! r> r r r r< � s z KamateraNodeDriver.ex_get_imagec C s | j �d|j �jS )z� List capabilities for given location. :param location: Location of the deployment. :type location: :class:`.NodeLocation` :return: ``dict`` z+service/server?capabilities=1&datacenter=%sr5 )r r6 r r r �ex_list_capabilities� s ��z'KamateraNodeDriver.ex_list_capabilities�X � c C s� t j �� }t�|� |t j|d� }|t j �� k r&tdt|�t|�f ��t�|� | �|�}|�d�}|dkr;|S |dkrHt d|�d� ��q ) a� Wait for command to complete and return the command status details :param command_id: Command ID to wait for. (required) :type command_id: ``int`` :param timeout_seconds: Max seconds to wait for command. (optional) :type timeout_seconds: ``int`` :param poll_interval_seconds: Poll interval in seconds (optional) :type poll_interval_seconds: ``int`` :return: ``dict`` T)�secondsz?Timeout waiting for command (timeout_seconds=%s, command_id=%s)�statusZcomplete�errorzCommand failed: rZ ) rm �now�time�sleep� timedelta� TimeoutErrorr� �ex_get_command_statusrj rd )r r� Ztimeout_secondsZpoll_interval_secondsZ start_timeZmax_timerv r� r r r ri � s$ �� �z"KamateraNodeDriver.ex_wait_commandc C s4 | j �dt|� �}t|j�dkrtd��|jd S )z� Get Kamatera command status details :param command_id: Command ID to get details for. (required) :type command_id: ``int`` :return: ``dict`` z/service/queue?id=rQ rW r )r( r) r� rc r* rd )r r� r+ r r r r� s z(KamateraNodeDriver.ex_get_command_statusc C s� i }| r| |d< | dur| |d< | dur| |d< | dur | |d< | dur(| |d< |dur0||d< |dur8||d< t |||||| ||||d � S ) a} Get a Kamatera node object. :param id: Node ID (optional) :type id: ``str`` :param name: Node name (optional) :type name: ``str`` :param state: Node state (optional) :type state: :class:`libcloud.compute.types.NodeState` :param public_ips: Node public IPS. (optional) :type public_ips: ``list`` of :str: :param private_ips: Node private IPS. (optional) :type private_ips: ``list`` of :str: :param size: node size. (optional) :type size: :class:`.NodeSize` :param image: Node OS Image. (optional) :type image: :class:`.NodeImage` :param created_at: Node creation time. (optional) :type created_at: ``datetime.datetime`` :param location: Node datacenter. (optional) :type location: :class:`.NodeLocation` :param dailybackup: create daily backups for the node (optional) :type dailybackup: ``bool`` :param managed: provide managed support for the node (optional) :type managed: ``bool`` :param billingcycle: billing cycle (hourly / monthly) (optional) :type billingcycle: ``str`` :param generated_password: server generated password (optional) :type generated_password: ``str`` :param create_command_id: creation task command ID (optional) :type create_command_id: ``int`` :param poweronaftercreate: power on the node after create (optional) :type poweronaftercreate: ``bool`` :return: The node. :rtype: :class:`.Node` r6 NrG rI rR rX rY rS ) r! r" rf � public_ips� private_ipsr� r4 r= ro r> )r )r r! r" rf r� r� r4 r= ro r6 rG rI rR rX rY rS r> r r r re , s6 E�z KamateraNodeDriver.ex_get_nodec C s i }|D ]}|| ||< q|S )Nr )r �keys�dr> r r r r r: � s z KamateraNodeDriver._copy_dictc C s> |d |_ |d |_|d dkrtj|_ntj|_|�dg �D ]!}|�d��d�r5| j|�dg �7 _q | j |�dg �7 _ q |�d |j �d ��� � }|| j kri| j |j d < |�d �|j d < |�d �|j d< n| j |j d < |�d�|j d < |�d�|j d< | �|d �|j d< |�d�dk|j d< |�d�dk|j d< |S )Nr! r" ry rz ZnetworksrJ zwan-�ips�billingrR Z priceHourlyOnZpriceOnZpriceHourlyOffZpriceOffZpriceMonthlyOnr% r6 Zbackup�1rG rI )r! r" r rk rf rl rj r\ r� r� r> �lower�EX_BILLINGCYCLE_HOURLY�EX_BILLINGCYCLE_MONTHLYr# )r ru rx rJ r� r r r rr � s* z0KamateraNodeDriver._update_node_from_server_info)NFN)T)NN)NNNN)NNN)r� r� )#r r r r r ZKAMATERA�typer" Zwebsiter Z connectionClsZfeaturesr� r� r, r7 r? r r{ r� r� r� r� r~ r# r3 r< r� ri r� r rg re r: rr r r r r r ; sn � * " � A �a r )r r r� rm Zlibcloud.utils.py3r Zlibcloud.common.baser r Zlibcloud.compute.baser r r r r r Zlibcloud.compute.typesr r r r r r r r �<module> s
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings