🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 06:04:02 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
influxdb_client
/
service
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/influxdb_client/service/__pycache__
🔄 Refresh
✏️
Editing: replications_service.cpython-38.pyc
Read Only
U w�i.� � @ s8 d Z ddlmZ ddlZddlmZ G dd� de�ZdS )a InfluxDB OSS API Service. The InfluxDB v2 API provides a programmatic interface for all interactions with InfluxDB. Access the InfluxDB API using the `/api/v2/` endpoint. # noqa: E501 OpenAPI spec version: 2.0.0 Generated by: https://openapi-generator.tech � )�absolute_importN)� _BaseServicec s� e Zd ZdZd5� fdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Z � Z S )6�ReplicationsServicez�NOTE: This class is auto generated by OpenAPI Generator. Ref: https://openapi-generator.tech Do not edit the class manually. Nc s t � �|� dS )z5ReplicationsService - a operation defined in OpenAPI.N)�super�__init__)�self� api_client�� __class__� �]/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/service/replications_service.pyr s z ReplicationsService.__init__c K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a" Delete a replication. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_replication_by_id(replication_id, async_req=True) >>> result = thread.get() :param async_req bool :param str replication_id: (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. T�_return_http_data_only� async_reqN)�get�'delete_replication_by_id_with_http_info�r �replication_id�kwargs�datar r r �delete_replication_by_id s z,ReplicationsService.delete_replication_by_idc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �S ) a1 Delete a replication. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_replication_by_id_with_http_info(replication_id, async_req=True) >>> result = thread.get() :param async_req bool :param str replication_id: (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. �$/api/v2/replications/{replicationID}�DELETENr r �_preload_contentT�_request_timeout� urlopen_kw� �bodyZ post_params�filesZ response_typeZ auth_settingsr r r r Zcollection_formatsr ��!_delete_replication_by_id_preparer �call_apir �r r r �local_var_params� path_params� query_params� header_params� body_paramsr r r r 6 s( � �z;ReplicationsService.delete_replication_by_id_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �I dH S ) a\ Delete a replication. This method makes an asynchronous HTTP request. :param async_req bool :param str replication_id: (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. r r Nr r r Tr r r r r! r r r � delete_replication_by_id_asyncY s( � �z2ReplicationsService.delete_replication_by_id_asyncc K s� t � }ddg}| �d||� d|ks0|d d kr8td��i }d|krP|d |d< g }i }d|krl|d |d< d }| j�dg�|d< |||||fS ) Nr �zap_trace_spanr zWMissing the required parameter `replication_id` when calling `delete_replication_by_id`� replicationID�Zap-Trace-Span�application/json�Accept��locals�_check_operation_params� ValueErrorr �select_header_accept� r r r r" � all_paramsr# r$ r% r& r r r r y s& � �z5ReplicationsService._delete_replication_by_id_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a( Retrieve a replication. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_replication_by_id(replication_id, async_req=True) >>> result = thread.get() :param async_req bool :param str replication_id: (required) :param str zap_trace_span: OpenTracing span context :return: Replication If the method is called asynchronously, returns the request thread. Tr r N)r �$get_replication_by_id_with_http_infor r r r �get_replication_by_id� s z)ReplicationsService.get_replication_by_idc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a7 Retrieve a replication. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_replication_by_id_with_http_info(replication_id, async_req=True) >>> result = thread.get() :param async_req bool :param str replication_id: (required) :param str zap_trace_span: OpenTracing span context :return: Replication If the method is called asynchronously, returns the request thread. r �GET� Replicationr r r Tr r Nr �� _get_replication_by_id_preparer r r r! r r r r4 � s( � �z8ReplicationsService.get_replication_by_id_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) ae Retrieve a replication. This method makes an asynchronous HTTP request. :param async_req bool :param str replication_id: (required) :param str zap_trace_span: OpenTracing span context :return: Replication If the method is called asynchronously, returns the request thread. r r6 r7 r r r Tr r Nr r8 r! r r r �get_replication_by_id_async� s( � �z/ReplicationsService.get_replication_by_id_asyncc K s� t � }ddg}| �d||� d|ks0|d d kr8td��i }d|krP|d |d< g }i }d|krl|d |d< d }| j�dg�|d< |||||fS ) Nr r( r5 zTMissing the required parameter `replication_id` when calling `get_replication_by_id`r) r* r+ r, r- r2 r r r r9 � s& � �z2ReplicationsService._get_replication_by_id_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a� List all replications. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_replications(org_id, async_req=True) >>> result = thread.get() :param async_req bool :param str org_id: The organization ID. (required) :param str zap_trace_span: OpenTracing span context :param str name: :param str remote_id: :param str local_bucket_id: :return: Replications If the method is called asynchronously, returns the request thread. Tr r N)r � get_replications_with_http_info)r �org_idr r r r r �get_replications s z$ReplicationsService.get_replicationsc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� List all replications. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_replications_with_http_info(org_id, async_req=True) >>> result = thread.get() :param async_req bool :param str org_id: The organization ID. (required) :param str zap_trace_span: OpenTracing span context :param str name: :param str remote_id: :param str local_bucket_id: :return: Replications If the method is called asynchronously, returns the request thread. �/api/v2/replicationsr6 � Replicationsr r r Tr r Nr ��_get_replications_preparer r r �r r< r r" r# r$ r% r& r r r r; ! s( � �z3ReplicationsService.get_replications_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� List all replications. This method makes an asynchronous HTTP request. :param async_req bool :param str org_id: The organization ID. (required) :param str zap_trace_span: OpenTracing span context :param str name: :param str remote_id: :param str local_bucket_id: :return: Replications If the method is called asynchronously, returns the request thread. r> r6 r? r r r Tr r Nr r@ rB r r r �get_replications_asyncG s( � �z*ReplicationsService.get_replications_asyncc K s� t � }dddddg}| �d||� d|ks6|d d kr>td��i }g }d|kr`|�d|d f� d|krz|�d|d f� d|kr�|�d |d f� d|kr�|�d |d f� i }d|kr�|d |d < d }| j�d g�|d < |||||fS )Nr< r( �nameZ remote_idZlocal_bucket_idr= zGMissing the required parameter `org_id` when calling `get_replications`ZorgIDZremoteIDZ localBucketIDr* r+ r, )r. r/ r0 �appendr r1 ) r r< r r" r3 r# r$ r% r& r r r rA j s2 � �z-ReplicationsService._get_replications_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )a� Update a replication. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.patch_replication_by_id(replication_id, replication_update_request, async_req=True) >>> result = thread.get() :param async_req bool :param str replication_id: (required) :param ReplicationUpdateRequest replication_update_request: (required) :param str zap_trace_span: OpenTracing span context :param bool validate: If true, validate the updated information, but don't save it. :return: Replication If the method is called asynchronously, returns the request thread. Tr r N)r �&patch_replication_by_id_with_http_info)r r �replication_update_requestr r r r r �patch_replication_by_id� s z+ReplicationsService.patch_replication_by_idc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� Update a replication. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.patch_replication_by_id_with_http_info(replication_id, replication_update_request, async_req=True) >>> result = thread.get() :param async_req bool :param str replication_id: (required) :param ReplicationUpdateRequest replication_update_request: (required) :param str zap_trace_span: OpenTracing span context :param bool validate: If true, validate the updated information, but don't save it. :return: Replication If the method is called asynchronously, returns the request thread. r �PATCHr7 r r r Tr r Nr �� _patch_replication_by_id_preparer r r � r r rG r r" r# r$ r% r& r r r rF � s( � �z:ReplicationsService.patch_replication_by_id_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a Update a replication. This method makes an asynchronous HTTP request. :param async_req bool :param str replication_id: (required) :param ReplicationUpdateRequest replication_update_request: (required) :param str zap_trace_span: OpenTracing span context :param bool validate: If true, validate the updated information, but don't save it. :return: Replication If the method is called asynchronously, returns the request thread. r rI r7 r r r Tr r Nr rJ rL r r r � patch_replication_by_id_async� s( � �z1ReplicationsService.patch_replication_by_id_asyncc K s� t � }ddddg}| �d||� d|ks4|d d kr<td��d|ksP|d d krXtd��i }d|krp|d |d< g }d|kr�|�d|d f� i }d|kr�|d |d < d } d|kr�|d } | j�d g�|d < | j�d g�|d < ||||| fS ) Nr rG r( �validaterH zVMissing the required parameter `replication_id` when calling `patch_replication_by_id`zbMissing the required parameter `replication_update_request` when calling `patch_replication_by_id`r) r* r+ r, � Content-Type�r. r/ r0 rE r r1 Zselect_header_content_type) r r rG r r" r3 r# r$ r% r& r r r rK � s< � � ��z4ReplicationsService._patch_replication_by_id_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a� Register a new replication. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_replication(replication_creation_request, async_req=True) >>> result = thread.get() :param async_req bool :param ReplicationCreationRequest replication_creation_request: (required) :param str zap_trace_span: OpenTracing span context :param bool validate: If true, validate the replication, but don't save it. :return: Replication If the method is called asynchronously, returns the request thread. Tr r N)r � post_replication_with_http_info)r � replication_creation_requestr r r r r �post_replication s z$ReplicationsService.post_replicationc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� Register a new replication. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_replication_with_http_info(replication_creation_request, async_req=True) >>> result = thread.get() :param async_req bool :param ReplicationCreationRequest replication_creation_request: (required) :param str zap_trace_span: OpenTracing span context :param bool validate: If true, validate the replication, but don't save it. :return: Replication If the method is called asynchronously, returns the request thread. r> �POSTr7 r r r Tr r Nr ��_post_replication_preparer r r �r rR r r" r# r$ r% r& r r r rQ ( s( � �z3ReplicationsService.post_replication_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� Register a new replication. This method makes an asynchronous HTTP request. :param async_req bool :param ReplicationCreationRequest replication_creation_request: (required) :param str zap_trace_span: OpenTracing span context :param bool validate: If true, validate the replication, but don't save it. :return: Replication If the method is called asynchronously, returns the request thread. r> rT r7 r r r Tr r Nr rU rW r r r �post_replication_asyncL s( � �z*ReplicationsService.post_replication_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��i }g }d|kr\|�d|d f� i }d|krt|d |d< d }d|kr�|d }| j�dg�|d< | j�dg�|d < |||||fS ) NrR r( rN rS z]Missing the required parameter `replication_creation_request` when calling `post_replication`r* r+ r, rO rP ) r rR r r" r3 r# r$ r% r& r r r rV m s0 � ��z-ReplicationsService._post_replication_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a+ Validate a replication. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_validate_replication_by_id(replication_id, async_req=True) >>> result = thread.get() :param async_req bool :param str replication_id: (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. Tr r N)r �.post_validate_replication_by_id_with_http_infor r r r � post_validate_replication_by_id� s z3ReplicationsService.post_validate_replication_by_idc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �S ) a: Validate a replication. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_validate_replication_by_id_with_http_info(replication_id, async_req=True) >>> result = thread.get() :param async_req bool :param str replication_id: (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. �-/api/v2/replications/{replicationID}/validaterT Nr r r Tr r r ��(_post_validate_replication_by_id_preparer r r r! r r r rY � s( � �zBReplicationsService.post_validate_replication_by_id_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �I dH S ) a^ Validate a replication. This method makes an asynchronous HTTP request. :param async_req bool :param str replication_id: (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. r[ rT Nr r r Tr r r r\ r! r r r �%post_validate_replication_by_id_async� s( � �z9ReplicationsService.post_validate_replication_by_id_asyncc K s� t � }ddg}| �d||� d|ks0|d d kr8td��i }d|krP|d |d< g }i }d|krl|d |d< d }| j�dg�|d< |||||fS ) Nr r( rZ z^Missing the required parameter `replication_id` when calling `post_validate_replication_by_id`r) r* r+ r, r- r2 r r r r] � s& � �z<ReplicationsService._post_validate_replication_by_id_prepare)N) �__name__� __module__� __qualname__�__doc__r r r r' r r5 r4 r: r9 r= r; rC rA rH rF rM rK rS rQ rX rV rZ rY r^ r] � __classcell__r r r r r s4 # # &#!%"'$!!# r )rb � __future__r �reZ%influxdb_client.service._base_servicer r r r r r �<module> s
💾 Save Changes
❌ Cancel