U wâ’iEã@s8dZddlmZddlZddlmZGdd„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)Ú _BaseServicecs‚eZdZdZd‡fdd„ Zdd„Zdd„Zd d „Zd d „Zd d„Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Z‡ZS)Ú BackupServicez‹NOTE: This class is auto generated by OpenAPI Generator. Ref: https://openapi-generator.tech Do not edit the class manually. Ncstƒ |¡dS)z/BackupService - a operation defined in OpenAPI.N)ÚsuperÚ__init__)ÚselfÚ api_client©Ú __class__©úW/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/service/backup_service.pyrszBackupService.__init__cKs2d|d<| d¡r|jf|ŽS|jf|Ž}|SdS)a-Download snapshot of metadata stored in the server's embedded KV store. Don't use with InfluxDB versions greater than InfluxDB 2.1.x.. Retrieves a snapshot of metadata stored in the server's embedded KV store. InfluxDB versions greater than 2.1.x don't include metadata stored in embedded SQL; avoid using this endpoint with versions greater than 2.1.x. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_backup_kv(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :return: file If the method is called asynchronously, returns the request thread. TÚ_return_http_data_onlyÚ async_reqN)ÚgetÚget_backup_kv_with_http_info©rÚkwargsÚdatar r r Ú get_backup_kv s    zBackupService.get_backup_kvcKsd|jf|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡d S) a<Download snapshot of metadata stored in the server's embedded KV store. Don't use with InfluxDB versions greater than InfluxDB 2.1.x.. Retrieves a snapshot of metadata stored in the server's embedded KV store. InfluxDB versions greater than 2.1.x don't include metadata stored in embedded SQL; avoid using this endpoint with versions greater than 2.1.x. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_backup_kv_with_http_info(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :return: file If the method is called asynchronously, returns the request thread. ú/api/v2/backup/kvÚGETÚfilerr Ú_preload_contentTÚ_request_timeoutÚ urlopen_kwN© ÚbodyZ post_paramsÚfilesZ response_typeZ auth_settingsrr rrZcollection_formatsr©Ú_get_backup_kv_preparerÚcall_apir©rrÚlocal_var_paramsÚ path_paramsÚ query_paramsÚ header_paramsÚ body_paramsr r r r6s( ÿ   ñz*BackupService.get_backup_kv_with_http_infocËsj|jf|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡d Id HS) a‚Download snapshot of metadata stored in the server's embedded KV store. Don't use with InfluxDB versions greater than InfluxDB 2.1.x.. Retrieves a snapshot of metadata stored in the server's embedded KV store. InfluxDB versions greater than 2.1.x don't include metadata stored in embedded SQL; avoid using this endpoint with versions greater than 2.1.x. This method makes an asynchronous HTTP request. :param async_req bool :param str zap_trace_span: OpenTracing span context :return: file If the method is called asynchronously, returns the request thread. rrrrr rTrrNrrr!r r r Úget_backup_kv_asyncYs( ÿ   ñz!BackupService.get_backup_kv_asynccKs`tƒ}dg}| d||¡i}g}i}d|kr:|d|d<d}|j ddg¡|d<|||||fS)NÚzap_trace_spanrúZap-Trace-Spanúapplication/octet-streamúapplication/jsonÚAccept©ÚlocalsÚ_check_operation_paramsrÚselect_header_accept©rrr"Ú all_paramsr#r$r%r&r r r rys ÿz$BackupService._get_backup_kv_preparecKs2d|d<| d¡r|jf|ŽS|jf|Ž}|SdS)a‰Download snapshot of all metadata in the server. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_backup_metadata(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str accept_encoding: Indicates the content encoding (usually a compression algorithm) that the client can understand. :return: MetadataBackup If the method is called asynchronously, returns the request thread. Tr rN)rÚ"get_backup_metadata_with_http_inforr r r Úget_backup_metadataŽs    z!BackupService.get_backup_metadatacKsd|jf|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡d S) a˜Download snapshot of all metadata in the server. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_backup_metadata_with_http_info(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str accept_encoding: Indicates the content encoding (usually a compression algorithm) that the client can understand. :return: MetadataBackup If the method is called asynchronously, returns the request thread. ú/api/v2/backup/metadatarÚMetadataBackuprr rTrrNr©Ú_get_backup_metadata_preparerr rr!r r r r3¤s( ÿ   ñz0BackupService.get_backup_metadata_with_http_infocËsj|jf|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡d Id HS) aØDownload snapshot of all metadata in the server. This method makes an asynchronous HTTP request. :param async_req bool :param str zap_trace_span: OpenTracing span context :param str accept_encoding: Indicates the content encoding (usually a compression algorithm) that the client can understand. :return: MetadataBackup If the method is called asynchronously, returns the request thread. r5rr6rr rTrrNrr7r!r r r Úget_backup_metadata_asyncÇs( ÿ   ñz'BackupService.get_backup_metadata_asynccKsvtƒ}ddg}| d||¡i}g}i}d|kr<|d|d<d|krP|d|d<d}|j ddg¡|d<|||||fS) Nr(Úaccept_encodingr4r)úAccept-Encodingzmultipart/mixedr+r,r-r1r r r r8çs  ÿz*BackupService._get_backup_metadata_preparecKs6d|d<| d¡r |j|f|ŽS|j|f|Ž}|SdS)awDownload snapshot of all TSM data in a shard. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_backup_shard_id(shard_id, async_req=True) >>> result = thread.get() :param async_req bool :param int shard_id: The shard ID. (required) :param str zap_trace_span: OpenTracing span context :param str accept_encoding: Indicates the content encoding (usually a compression algorithm) that the client can understand. :param datetime since: The earliest time [RFC3339 date/time format](https://docs.influxdata.com/influxdb/latest/reference/glossary/#rfc3339-timestamp) to include in the snapshot. :return: file If the method is called asynchronously, returns the request thread. Tr rN)rÚ"get_backup_shard_id_with_http_info)rÚshard_idrrr r r Úget_backup_shard_idþs  z!BackupService.get_backup_shard_idcKsf|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡d S) a†Download snapshot of all TSM data in a shard. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_backup_shard_id_with_http_info(shard_id, async_req=True) >>> result = thread.get() :param async_req bool :param int shard_id: The shard ID. (required) :param str zap_trace_span: OpenTracing span context :param str accept_encoding: Indicates the content encoding (usually a compression algorithm) that the client can understand. :param datetime since: The earliest time [RFC3339 date/time format](https://docs.influxdata.com/influxdb/latest/reference/glossary/#rfc3339-timestamp) to include in the snapshot. :return: file If the method is called asynchronously, returns the request thread. ú/api/v2/backup/shards/{shardID}rrrr rTrrNr©Ú_get_backup_shard_id_preparerr r©rr=rr"r#r$r%r&r r r r<s( ÿ   ñz0BackupService.get_backup_shard_id_with_http_infocËsl|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡d Id HS) a¼Download snapshot of all TSM data in a shard. This method makes an asynchronous HTTP request. :param async_req bool :param int shard_id: The shard ID. (required) :param str zap_trace_span: OpenTracing span context :param str accept_encoding: Indicates the content encoding (usually a compression algorithm) that the client can understand. :param datetime since: The earliest time [RFC3339 date/time format](https://docs.influxdata.com/influxdb/latest/reference/glossary/#rfc3339-timestamp) to include in the snapshot. :return: file If the method is called asynchronously, returns the request thread. r?rrrr rTrrNrr@rBr r r Úget_backup_shard_id_async;s( ÿ   ñz'BackupService.get_backup_shard_id_asyncc KsÄtƒ}ddddg}| d||¡d|ks4|ddkrzLMissing the required parameter `shard_id` when calling `get_backup_shard_id`ZshardIDr)r;r*r+r,)r.r/Ú ValueErrorÚappendrr0) rr=rr"r2r#r$r%r&r r r rA]s.  ÿ   ÿz*BackupService._get_backup_shard_id_prepare)N)Ú__name__Ú __module__Ú __qualname__Ú__doc__rrrr'rr4r3r9r8r>r<rCrAÚ __classcell__r r r r rs# # %"r)rIÚ __future__rÚreZ%influxdb_client.service._base_servicerrr r r r Ús