File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/backup/drivers/__pycache__/gce.cpython-310.pyc
Back
o ;j:? � @ s� d gZ ddlmZmZmZmZ ddlmZmZ ddl m Z m Z ddl m Z dZdZG dd � d e �ZG d d � d e �ZG d d � d e�Zd S )�GCEBackupDriver� )� BackupDriver� BackupTarget�BackupTargetJob�BackupTargetRecoveryPoint)�BackupTargetType�BackupTargetJobStatusType)�GoogleResponse�GoogleBaseConnection)� parse_dateZv1� c @ s e Zd ZdS )� GCEResponseN)�__name__� __module__� __qualname__� r r �O/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/backup/drivers/gce.pyr s r c sH e Zd ZdZdZeZ d � fdd� Z� fdd�Z� fdd �Z � Z S ) � GCEConnectiona{ Connection class for the GCE driver. GCEConnection extends :class:`google.GoogleBaseConnection` for 2 reasons: 1. modify request_path for GCE URI. 2. Implement gce_params functionality described below. If the parameter gce_params is set to a dict prior to calling request(), the URL parameters will be updated to include those key/values FOR A SINGLE REQUEST. If the response contains a nextPageToken, gce_params['pageToken'] will be set to its value. This can be used to implement paging in list: >>> params, more_results = {'maxResults': 2}, True >>> while more_results: ... driver.connection.gce_params=params ... driver.ex_list_urlmaps() ... more_results = 'pageToken' in params ... [<GCEUrlMap id="..." name="cli-map">, <GCEUrlMap id="..." name="lc-map">] [<GCEUrlMap id="..." name="web-map">] zwww.googleapis.comNc s6 t � j||f|||d�|�� d�t|�| _i | _d S )N)�secure� auth_type�credential_file�/compute/{}/projects/{})�super�__init__�format� API_VERSIONZ request_path� gce_params)�self�user_id�keyr r r �project�kwargs�� __class__r r r ? s ��� zGCEConnection.__init__c s, t � �||�\}}| jr|�| j� ||fS )z� Update URL parameters with values from self.gce_params. @inherits: :class:`GoogleBaseConnection.pre_connect_hook` )r �pre_connect_hookr �update)r �params�headersr" r r r$ T s z GCEConnection.pre_connect_hookc sP t � j|i |��}| jr&d|jv r|jd | jd< n d| jv r#| jd= d| _|S )z� Perform request then do GCE-specific processing of URL params. @inherits: :class:`GoogleBaseConnection.request` Z nextPageTokenZ pageTokenN)r �requestr �object)r �argsr! �responser" r r r( _ s zGCEConnection.request)NNN) r r r �__doc__�hostr Z responseClsr r$ r( � __classcell__r r r" r r $ s � r c s e Zd ZdZdZeZ d2� fdd� Zdd� Zdd � Z e j dfd d �Z e j dfd d �Ze jdfdd�Zdd� Zdd� Zd3dd�Zd4dd�Zd4dd�Zdd� Zd d � Zd4d d �Zd d!� Zd"d#� Zd$d%� Zd&d'� Z d(d)� Z d*d+� Z d,d-� Z d.d/� Z d0d1� Z!� Z"S )5r z#Google Compute Engine Backup Driverzhttp://cloud.google.com/Nc sX |st d��|| _|| _|| _|pd| j | _t� j||fi |�� d�t| j�| _ dS )a� :param user_id: The email address (for service accounts) or Client ID (for installed apps) to be used for authentication. :type user_id: ``str`` :param key: The RSA Key (for service accounts) or file path containing key or Client Secret (for installed apps) to be used for authentication. :type key: ``str`` :keyword project: Your GCE project name. (required) :type project: ``str`` :keyword auth_type: Accepted values are "SA" or "IA" or "GCE" ("Service Account" or "Installed Application" or "GCE" if libcloud is being used on a GCE instance with service account enabled). If not supplied, auth_type will be guessed based on value of user_id or if the code is being executed in a GCE instance. :type auth_type: ``str`` :keyword scopes: List of authorization URLs. Default is empty and grants read/write to Compute, Storage, DNS. :type scopes: ``list`` :keyword credential_file: Path to file for caching authentication information used by GCEConnection. :type credential_file: ``str`` z7Project name must be specified using "project" keyword.z~/.gce_libcloud_auth.r N) � ValueErrorr r �scopesr r r r r � base_path)r r r r r r0 r r! r" r r r x s (zGCEBackupDriver.__init__c C s t jgS )z� Get a list of backup target types this driver supports :return: ``list`` of :class:``BackupTargetType`` )r �VOLUME�r r r r �get_supported_target_types� � z*GCEBackupDriver.get_supported_target_typesc C � t d��)z[ List all backuptargets :rtype: ``list`` of :class:`BackupTarget` z,list_targets not implemented for this driver��NotImplementedErrorr3 r r r � list_targets� r5 z GCEBackupDriver.list_targetsc C s | � |�S )a� Creates a new backup target :param name: Name of the target :type name: ``str`` :param address: The volume ID. :type address: ``str`` :param type: Backup target type (Physical, Virtual, ...). :type type: :class:`BackupTargetType` :param extra: (optional) Extra attributes (driver specific). :type extra: ``dict`` :rtype: Instance of :class:`BackupTarget` ��ex_get_target_by_source)r �name�address�type�extrar r r � create_target� � z GCEBackupDriver.create_targetc C s8 |j d }|dur| j|j|d d tjdd�S td��)a� Creates a new backup target from an existing node :param node: The Node to backup :type node: ``Node`` :param type: Backup target type (Physical, Virtual, ...). :type type: :class:`BackupTargetType` :param extra: (optional) Extra attributes (driver specific). :type extra: ``dict`` :rtype: Instance of :class:`BackupTarget` �disksNr �source)r< r= r> r? z$Node does not have any block devices)r? r@ r< r r2 � RuntimeError)r �noder> r? rB r r r �create_target_from_node� s �z'GCEBackupDriver.create_target_from_nodec C r6 )a� Creates a new backup target from an existing storage container :param node: The Container to backup :type node: ``Container`` :param type: Backup target type (Physical, Virtual, ...). :type type: :class:`BackupTargetType` :param extra: (optional) Extra attributes (driver specific). :type extra: ``dict`` :rtype: Instance of :class:`BackupTarget` z<create_target_from_container not implemented for this driverr7 )r � containerr> r? r r r � create_target_from_container� � z,GCEBackupDriver.create_target_from_containerc C s | � |�S )a� Update the properties of a backup target :param target: Backup target to update :type target: Instance of :class:`BackupTarget` :param name: Name of the target :type name: ``str`` :param address: Hostname, FQDN, IP, file path etc. :type address: ``str`` :param extra: (optional) Extra attributes (driver specific). :type extra: ``dict`` :rtype: Instance of :class:`BackupTarget` r: )r �targetr< r= r? r r r � update_target� rA z GCEBackupDriver.update_targetc C r6 )z� Delete a backup target :param target: Backup target to delete :type target: Instance of :class:`BackupTarget` z-delete_target not implemented for this driverr7 �r rJ r r r � delete_target s z GCEBackupDriver.delete_targetc C s" d}| j j|dd�j}| �||�S )a� List the recovery points available for a target :param target: Backup target to delete :type target: Instance of :class:`BackupTarget` :param start_date: The start date to show jobs between (optional) :type start_date: :class:`datetime.datetime` :param end_date: The end date to show jobs between (optional) :type end_date: :class:`datetime.datetime`` :rtype: ``list`` of :class:`BackupTargetRecoveryPoint` z/global/snapshots�GET��method)� connectionr( r) �_to_recovery_points)r rJ Z start_dateZend_dater( r+ r r r �list_recovery_points s z$GCEBackupDriver.list_recovery_pointsc C r6 )a� Recover a backup target to a recovery point :param target: Backup target to delete :type target: Instance of :class:`BackupTarget` :param recovery_point: Backup target with the backup data :type recovery_point: Instance of :class:`BackupTarget` :param path: The part of the recovery point to recover (optional) :type path: ``str`` :rtype: Instance of :class:`BackupTargetJob` z.recover_target not implemented for this driverr7 )r rJ �recovery_point�pathr r r �recover_target0 rI z GCEBackupDriver.recover_targetc C r6 )am Recover a backup target to a recovery point out-of-place :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :param recovery_point: Backup target with the backup data :type recovery_point: Instance of :class:`BackupTarget` :param recovery_target: Backup target with to recover the data to :type recovery_target: Instance of :class:`BackupTarget` :param path: The part of the recovery point to recover (optional) :type path: ``str`` :rtype: Instance of :class:`BackupTargetJob` z;recover_target_out_of_place not implemented for this driverr7 )r rJ rT Zrecovery_targetrU r r r �recover_target_out_of_placeA s z+GCEBackupDriver.recover_target_out_of_placec s$ | � |�}tt� fdd�|��d S )a; Get a specific backup job by ID :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :param id: Backup target with the backup data :type id: Instance of :class:`BackupTarget` :rtype: :class:`BackupTargetJob` c s | j � kS �N��id)�xrY r r �<lambda>b s z0GCEBackupDriver.get_target_job.<locals>.<lambda>r )�list_target_jobs�list�filter)r rJ rZ Zjobsr rY r �get_target_jobU s z GCEBackupDriver.get_target_jobc C s g S )z� List the backup jobs on a target :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :rtype: ``list`` of :class:`BackupTargetJob` r rL r r r r] d s z GCEBackupDriver.list_target_jobsc C sN |j }d�|jd j |j �}d|jd i}| jj|d|d� | �| �|�|�S )aC Create a new backup job on a target :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :param extra: (optional) Extra attributes (driver specific). :type extra: ``dict`` :rtype: Instance of :class:`BackupTargetJob` z!/zones/{}/disks/{}/createSnapshot�zonerC �POST)rP �data)r< r r? rQ Z async_request�_to_job�ex_get_snapshot)r rJ r? r< r( Z snapshot_datar r r �create_target_jobo s �z!GCEBackupDriver.create_target_jobc C r6 )a3 Resume a suspended backup job on a target :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :param job: Backup target job to resume :type job: Instance of :class:`BackupTargetJob` :rtype: ``bool`` z/resume_target_job not supported for this driverr7 �r rJ �jobr r r �resume_target_job� � z!GCEBackupDriver.resume_target_jobc C r6 )a3 Suspend a running backup job on a target :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :param job: Backup target job to suspend :type job: Instance of :class:`BackupTargetJob` :rtype: ``bool`` z0suspend_target_job not supported for this driverr7 rg r r r �suspend_target_job� rj z"GCEBackupDriver.suspend_target_jobc C r6 )a) Cancel a backup job on a target :param target: Backup target with the backup data :type target: Instance of :class:`BackupTarget` :param job: Backup target job to cancel :type job: Instance of :class:`BackupTargetJob` :rtype: ``bool`` z/cancel_target_job not supported for this driverr7 rg r r r �cancel_target_job� rj z!GCEBackupDriver.cancel_target_jobc � � �fdd�|j D �S )Nc � g | ]}� � |���qS r )�_to_recovery_point��.0�itemrL r r � <listcomp>� � z7GCEBackupDriver._to_recovery_points.<locals>.<listcomp>��items�r rc rJ r rL r rR � � z#GCEBackupDriver._to_recovery_pointsc C s. |j }t|j�}t|||| jjd|id�}|S )Nz snapshot-id)rZ �daterJ �driverr? )rZ r ZcreationTimestampr rQ rz )r rr rJ rZ ry Zpointr r r ro � s �z"GCEBackupDriver._to_recovery_pointc rm )Nc rn r )rd rp rL r r rs � rt z,GCEBackupDriver._to_jobs.<locals>.<listcomp>ru rw r rL r �_to_jobs� rx zGCEBackupDriver._to_jobsc C s$ |j }t|tjd|| jji d�}|S )Nr )rZ �statusZprogressrJ rz r? )rZ r r ZPENDINGrQ rz )r rr rJ rZ rh r r r rd � s �zGCEBackupDriver._to_jobc C s d| }| j j|dd�j}|S )Nz/global/snapshots/%srN rO )rQ r( r) )r r< r( r+ r r r re � s z GCEBackupDriver.ex_get_snapshotc C s t |||tj| jjd|id�S )NrC )rZ r< r= r> rz r? )r r r2 rQ rz )r rC r r r r; � s �z'GCEBackupDriver.ex_get_target_by_source)NNNNN)NNrX )#r r r r< Zwebsiter Z connectionClsr r4 r9 r r2 r@ ZVIRTUALrF ZOBJECTrH rK rM rS rV rW r` r] rf ri rk rl rR ro r{ rd re r; r. r r r" r r s s@ �6 N)�__all__Zlibcloud.backup.baser r r r Zlibcloud.backup.typesr r Zlibcloud.common.googler r Zlibcloud.utils.iso8601r r Z DEFAULT_TASK_COMPLETION_TIMEOUTr r r r r r r �<module> s O
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings