U wiB@s8dZddlmZddlZddlmZGdddeZdS)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) _BaseServicecseZdZdZdufdd ZddZddZd d Zd d Zd dZ ddZ ddZ ddZ ddZ ddZddZddZddZdd Zd!d"Zd#d$Zd%d&Zd'd(Zd)d*Zd+d,Zd-d.Zd/d0Zd1d2Zd3d4Zd5d6Zd7d8Zd9d:Zd;d<Z d=d>Z!d?d@Z"dAdBZ#dCdDZ$dEdFZ%dGdHZ&dIdJZ'dKdLZ(dMdNZ)dOdPZ*dQdRZ+dSdTZ,dUdVZ-dWdXZ.dYdZZ/d[d\Z0d]d^Z1d_d`Z2dadbZ3dcddZ4dedfZ5dgdhZ6didjZ7dkdlZ8dmdnZ9dodpZ:dqdrZ;dsdtZ<Z=S)vTelegrafsServicezNOTE: This class is auto generated by OpenAPI Generator. Ref: https://openapi-generator.tech Do not edit the class manually. Ncst|dS)z2TelegrafsService - a operation defined in OpenAPI.N)super__init__)self api_client __class__Z/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/service/telegrafs_service.pyrszTelegrafsService.__init__cKs6d|d<|dr |j|f|S|j|f|}|SdS)aADelete a Telegraf configuration. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_telegrafs_id(telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf configuration 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_telegrafs_id_with_http_infor telegraf_idkwargsdatar r r delete_telegrafs_id s  z$TelegrafsService.delete_telegrafs_idcKsf|j|f|\}}}}}|jjdd||||gidg|d|d|dd|di|d dd S) aPDelete a Telegraf configuration. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_telegrafs_id_with_http_info(telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf configuration ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. /api/v2/telegrafs/{telegrafID}DELETENrr _preload_contentT_request_timeout urlopen_kw bodyZ post_paramsfilesZ response_typeZ auth_settingsrr rrZcollection_formatsr_delete_telegrafs_id_preparercall_apirrrrlocal_var_params path_params query_params header_params body_paramsr r r r6s(   z3TelegrafsService.delete_telegrafs_id_with_http_infocsl|j|f|\}}}}}|jjdd||||gidg|d|d|dd|di|d dd IdHS) aDelete a Telegraf configuration. This method makes an asynchronous HTTP request. :param async_req bool :param str telegraf_id: The Telegraf configuration ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. rrNrr rTrrrrr!r r r delete_telegrafs_id_asyncYs(   z*TelegrafsService.delete_telegrafs_id_asyncc Kst}ddg}|d||d|ks0|ddkr8tdi}d|krP|d|d<g}i}d|krl|d|d<d}|jdg|d<|||||fS) Nrzap_trace_spanrzOMissing the required parameter `telegraf_id` when calling `delete_telegrafs_id` telegrafIDZap-Trace-Spanapplication/jsonAcceptlocals_check_operation_params ValueErrorrselect_header_accept rrrr" all_paramsr#r$r%r&r r r rys&   z-TelegrafsService._delete_telegrafs_id_preparecKs:d|d<|dr"|j||f|S|j||f|}|SdS)aDelete a label from a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_telegrafs_id_labels_id(telegraf_id, label_id, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param str label_id: The label ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. Tr rN)r,delete_telegrafs_id_labels_id_with_http_info)rrlabel_idrrr r r delete_telegrafs_id_labels_ids  z.TelegrafsService.delete_telegrafs_id_labels_idc Ksh|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d dd S) aDelete a label from a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_telegrafs_id_labels_id_with_http_info(telegraf_id, label_id, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param str label_id: The label ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. //api/v2/telegrafs/{telegrafID}/labels/{labelID}rNrr rTrrr&_delete_telegrafs_id_labels_id_preparerr r rrr5rr"r#r$r%r&r r r r4s(   z=TelegrafsService.delete_telegrafs_id_labels_id_with_http_infoc sn|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d dd IdHS) aDelete a label from a Telegraf config. This method makes an asynchronous HTTP request. :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param str label_id: The label ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. r7rNrr rTrrrr8r:r r r #delete_telegrafs_id_labels_id_asyncs(   z4TelegrafsService.delete_telegrafs_id_labels_id_asyncc Kst}dddg}|d||d|ks2|ddkr:tdd|ksN|ddkrVtdi}d|krn|d|d<d|kr|d|d<g}i}d|kr|d|d <d} |jd g|d <||||| fS) Nrr5r(r6zYMissing the required parameter `telegraf_id` when calling `delete_telegrafs_id_labels_id`zVMissing the required parameter `label_id` when calling `delete_telegrafs_id_labels_id`r)ZlabelIDr*r+r,r-) rrr5rr"r3r#r$r%r&r r r r9s2      z7TelegrafsService._delete_telegrafs_id_labels_id_preparecKs:d|d<|dr"|j||f|S|j||f|}|SdS)aRemove a member from a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_telegrafs_id_members_id(user_id, telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str user_id: The ID of the member to remove. (required) :param str telegraf_id: The Telegraf config ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. Tr rN)r-delete_telegrafs_id_members_id_with_http_inforuser_idrrrr r r delete_telegrafs_id_members_ids  z/TelegrafsService.delete_telegrafs_id_members_idc Ksh|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d dd S) aRemove a member from a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_telegrafs_id_members_id_with_http_info(user_id, telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str user_id: The ID of the member to remove. (required) :param str telegraf_id: The Telegraf config ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. //api/v2/telegrafs/{telegrafID}/members/{userID}rNrr rTrrr'_delete_telegrafs_id_members_id_preparerr r rr>rrr"r#r$r%r&r r r r<(s(   z>TelegrafsService.delete_telegrafs_id_members_id_with_http_infoc sn|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d dd IdHS) aRemove a member from a Telegraf config. This method makes an asynchronous HTTP request. :param async_req bool :param str user_id: The ID of the member to remove. (required) :param str telegraf_id: The Telegraf config ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. r@rNrr rTrrrrArCr r r $delete_telegrafs_id_members_id_asyncLs(   z5TelegrafsService.delete_telegrafs_id_members_id_asyncc Kst}dddg}|d||d|ks2|ddkr:tdd|ksN|ddkrVtdi}d|krn|d|d<d|kr|d|d<g}i}d|kr|d|d <d} |jd g|d <||||| fS) Nr>rr(r?zVMissing the required parameter `user_id` when calling `delete_telegrafs_id_members_id`zZMissing the required parameter `telegraf_id` when calling `delete_telegrafs_id_members_id`userIDr)r*r+r,r- rr>rrr"r3r#r$r%r&r r r rBms2      z8TelegrafsService._delete_telegrafs_id_members_id_preparecKs:d|d<|dr"|j||f|S|j||f|}|SdS)aRemove an owner from a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_telegrafs_id_owners_id(user_id, telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str user_id: The ID of the owner to remove. (required) :param str telegraf_id: The Telegraf config ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. Tr rN)r,delete_telegrafs_id_owners_id_with_http_infor=r r r delete_telegrafs_id_owners_ids  z.TelegrafsService.delete_telegrafs_id_owners_idc Ksh|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d dd S) aRemove an owner from a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_telegrafs_id_owners_id_with_http_info(user_id, telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str user_id: The ID of the owner to remove. (required) :param str telegraf_id: The Telegraf config ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. ./api/v2/telegrafs/{telegrafID}/owners/{userID}rNrr rTrrr&_delete_telegrafs_id_owners_id_preparerr rrCr r r rGs(   z=TelegrafsService.delete_telegrafs_id_owners_id_with_http_infoc sn|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d dd IdHS) aRemove an owner from a Telegraf config. This method makes an asynchronous HTTP request. :param async_req bool :param str user_id: The ID of the owner to remove. (required) :param str telegraf_id: The Telegraf config ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. rIrNrr rTrrrrJrCr r r #delete_telegrafs_id_owners_id_asyncs(   z4TelegrafsService.delete_telegrafs_id_owners_id_asyncc Kst}dddg}|d||d|ks2|ddkr:tdd|ksN|ddkrVtdi}d|krn|d|d<d|kr|d|d<g}i}d|kr|d|d <d} |jd g|d <||||| fS) Nr>rr(rHzUMissing the required parameter `user_id` when calling `delete_telegrafs_id_owners_id`zYMissing the required parameter `telegraf_id` when calling `delete_telegrafs_id_owners_id`rEr)r*r+r,r-rFr r r rKs2      z7TelegrafsService._delete_telegrafs_id_owners_id_preparecKs2d|d<|dr|jf|S|jf|}|SdS)a9List all Telegraf configurations. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_telegrafs(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str org_id: The organization ID the Telegraf config belongs to. :return: Telegrafs If the method is called asynchronously, returns the request thread. Tr rN)rget_telegrafs_with_http_info)rrrr r r get_telegrafs s    zTelegrafsService.get_telegrafscKsd|jf|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d S) aHList all Telegraf configurations. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_telegrafs_with_http_info(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str org_id: The organization ID the Telegraf config belongs to. :return: Telegrafs If the method is called asynchronously, returns the request thread. /api/v2/telegrafsGET Telegrafsrr rTrrNr_get_telegrafs_preparerr rrrr"r#r$r%r&r r r rM!s(   z-TelegrafsService.get_telegrafs_with_http_infocsj|jf|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d Id HS) aList all Telegraf configurations. This method makes an asynchronous HTTP request. :param async_req bool :param str zap_trace_span: OpenTracing span context :param str org_id: The organization ID the Telegraf config belongs to. :return: Telegrafs If the method is called asynchronously, returns the request thread. rOrPrQrr rTrrNrrRrTr r r get_telegrafs_asyncDs(   z$TelegrafsService.get_telegrafs_asynccKszt}ddg}|d||i}g}d|kr>|d|dfi}d|krV|d|d<d}|jdg|d<|||||fS)Nr(Zorg_idrNZorgIDr*r+r,)r.r/appendrr1)rrr"r3r#r$r%r&r r r rSds z'TelegrafsService._get_telegrafs_preparecKs6d|d<|dr |j|f|S|j|f|}|SdS)aZRetrieve a Telegraf configuration. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_telegrafs_id(telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf configuration ID. (required) :param str zap_trace_span: OpenTracing span context :param str accept: :return: str If the method is called asynchronously, returns the request thread. Tr rN)rget_telegrafs_id_with_http_inforr r r get_telegrafs_id{s  z!TelegrafsService.get_telegrafs_idcKsf|j|f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d S) aiRetrieve a Telegraf configuration. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_telegrafs_id_with_http_info(telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf configuration ID. (required) :param str zap_trace_span: OpenTracing span context :param str accept: :return: str If the method is called asynchronously, returns the request thread. rrPstrrr rTrrNr_get_telegrafs_id_preparerr rr!r r r rWs(   z0TelegrafsService.get_telegrafs_id_with_http_infocsl|j|f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d Id HS) aRetrieve a Telegraf configuration. This method makes an asynchronous HTTP request. :param async_req bool :param str telegraf_id: The Telegraf configuration ID. (required) :param str zap_trace_span: OpenTracing span context :param str accept: :return: str If the method is called asynchronously, returns the request thread. rrPrYrr rTrrNrrZr!r r r get_telegrafs_id_asyncs(   z'TelegrafsService.get_telegrafs_id_asyncc Kst}dddg}|d||d|ks2|ddkr:tdi}d|krR|d|d<g}i}d|krn|d|d<d|kr|d|d<d}|jd d d g|d<|||||fS) Nrr(acceptrXzLMissing the required parameter `telegraf_id` when calling `get_telegrafs_id`r)r*r,zapplication/tomlr+zapplication/octet-streamr-r2r r r r[s*     z*TelegrafsService._get_telegrafs_id_preparecKs6d|d<|dr |j|f|S|j|f|}|SdS)aNList all labels for a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_telegrafs_id_labels(telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param str zap_trace_span: OpenTracing span context :return: LabelsResponse If the method is called asynchronously, returns the request thread. Tr rN)r&get_telegrafs_id_labels_with_http_inforr r r get_telegrafs_id_labelss  z(TelegrafsService.get_telegrafs_id_labelscKsf|j|f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d S) a]List all labels for a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_telegrafs_id_labels_with_http_info(telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param str zap_trace_span: OpenTracing span context :return: LabelsResponse If the method is called asynchronously, returns the request thread. %/api/v2/telegrafs/{telegrafID}/labelsrPLabelsResponserr rTrrNr _get_telegrafs_id_labels_preparerr rr!r r r r^ s(   z7TelegrafsService.get_telegrafs_id_labels_with_http_infocsl|j|f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d Id HS) aList all labels for a Telegraf config. This method makes an asynchronous HTTP request. :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param str zap_trace_span: OpenTracing span context :return: LabelsResponse If the method is called asynchronously, returns the request thread. r`rPrarr rTrrNrrbr!r r r get_telegrafs_id_labels_async-s(   z.TelegrafsService.get_telegrafs_id_labels_asyncc Kst}ddg}|d||d|ks0|ddkr8tdi}d|krP|d|d<g}i}d|krl|d|d<d}|jdg|d<|||||fS) Nrr(r_zSMissing the required parameter `telegraf_id` when calling `get_telegrafs_id_labels`r)r*r+r,r-r2r r r rcMs&   z1TelegrafsService._get_telegrafs_id_labels_preparecKs6d|d<|dr |j|f|S|j|f|}|SdS)afList all users with member privileges for a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_telegrafs_id_members(telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceMembers If the method is called asynchronously, returns the request thread. Tr rN)r'get_telegrafs_id_members_with_http_inforr r r get_telegrafs_id_membershs  z)TelegrafsService.get_telegrafs_id_memberscKsf|j|f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d S) auList all users with member privileges for a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_telegrafs_id_members_with_http_info(telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceMembers If the method is called asynchronously, returns the request thread. &/api/v2/telegrafs/{telegrafID}/membersrPResourceMembersrr rTrrNr!_get_telegrafs_id_members_preparerr rr!r r r re~s(   z8TelegrafsService.get_telegrafs_id_members_with_http_infocsl|j|f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d Id HS) aList all users with member privileges for a Telegraf config. This method makes an asynchronous HTTP request. :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceMembers If the method is called asynchronously, returns the request thread. rgrPrhrr rTrrNrrir!r r r get_telegrafs_id_members_asyncs(   z/TelegrafsService.get_telegrafs_id_members_asyncc Kst}ddg}|d||d|ks0|ddkr8tdi}d|krP|d|d<g}i}d|krl|d|d<d}|jdg|d<|||||fS) Nrr(rfzTMissing the required parameter `telegraf_id` when calling `get_telegrafs_id_members`r)r*r+r,r-r2r r r rjs&   z2TelegrafsService._get_telegrafs_id_members_preparecKs6d|d<|dr |j|f|S|j|f|}|SdS)a[List all owners of a Telegraf configuration. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_telegrafs_id_owners(telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf configuration ID. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceOwners If the method is called asynchronously, returns the request thread. Tr rN)r&get_telegrafs_id_owners_with_http_inforr r r get_telegrafs_id_ownerss  z(TelegrafsService.get_telegrafs_id_ownerscKsf|j|f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d S) ajList all owners of a Telegraf configuration. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_telegrafs_id_owners_with_http_info(telegraf_id, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf configuration ID. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceOwners If the method is called asynchronously, returns the request thread. %/api/v2/telegrafs/{telegrafID}/ownersrPResourceOwnersrr rTrrNr _get_telegrafs_id_owners_preparerr rr!r r r rls(   z7TelegrafsService.get_telegrafs_id_owners_with_http_infocsl|j|f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d Id HS) aList all owners of a Telegraf configuration. This method makes an asynchronous HTTP request. :param async_req bool :param str telegraf_id: The Telegraf configuration ID. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceOwners If the method is called asynchronously, returns the request thread. rnrProrr rTrrNrrpr!r r r get_telegrafs_id_owners_asyncs(   z.TelegrafsService.get_telegrafs_id_owners_asyncc Kst}ddg}|d||d|ks0|ddkr8tdi}d|krP|d|d<g}i}d|krl|d|d<d}|jdg|d<|||||fS) Nrr(rmzSMissing the required parameter `telegraf_id` when calling `get_telegrafs_id_owners`r)r*r+r,r-r2r r r rq5s&   z1TelegrafsService._get_telegrafs_id_owners_preparecKs6d|d<|dr |j|f|S|j|f|}|SdS)alCreate a Telegraf configuration. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_telegrafs(telegraf_plugin_request, async_req=True) >>> result = thread.get() :param async_req bool :param TelegrafPluginRequest telegraf_plugin_request: Telegraf configuration to create (required) :param str zap_trace_span: OpenTracing span context :return: Telegraf If the method is called asynchronously, returns the request thread. Tr rN)rpost_telegrafs_with_http_info)rtelegraf_plugin_requestrrr r r post_telegrafsPs  zTelegrafsService.post_telegrafscKsf|j|f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d S) a{Create a Telegraf configuration. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_telegrafs_with_http_info(telegraf_plugin_request, async_req=True) >>> result = thread.get() :param async_req bool :param TelegrafPluginRequest telegraf_plugin_request: Telegraf configuration to create (required) :param str zap_trace_span: OpenTracing span context :return: Telegraf If the method is called asynchronously, returns the request thread. rOPOSTTelegrafrr rTrrNr_post_telegrafs_preparerr rrrtrr"r#r$r%r&r r r rsfs(   z.TelegrafsService.post_telegrafs_with_http_infocsl|j|f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d Id HS) aCreate a Telegraf configuration. This method makes an asynchronous HTTP request. :param async_req bool :param TelegrafPluginRequest telegraf_plugin_request: Telegraf configuration to create (required) :param str zap_trace_span: OpenTracing span context :return: Telegraf If the method is called asynchronously, returns the request thread. rOrvrwrr rTrrNrrxrzr r r post_telegrafs_asyncs(   z%TelegrafsService.post_telegrafs_asyncc Kst}ddg}|d||d|ks0|ddkr8tdi}g}i}d|krX|d|d<d}d|krl|d}|jdg|d<|jdg|d<|||||fS) Nrtr(ruzVMissing the required parameter `telegraf_plugin_request` when calling `post_telegrafs`r*r+r, Content-Typer.r/r0rr1Zselect_header_content_type) rrtrr"r3r#r$r%r&r r r rys,  z(TelegrafsService._post_telegrafs_preparecKs:d|d<|dr"|j||f|S|j||f|}|SdS)aAdd a label to a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_telegrafs_id_labels(telegraf_id, label_mapping, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param LabelMapping label_mapping: Label to add (required) :param str zap_trace_span: OpenTracing span context :return: LabelResponse If the method is called asynchronously, returns the request thread. Tr rN)r'post_telegrafs_id_labels_with_http_info)rr label_mappingrrr r r post_telegrafs_id_labelss  z)TelegrafsService.post_telegrafs_id_labelsc Ksh|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d S) aAdd a label to a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_telegrafs_id_labels_with_http_info(telegraf_id, label_mapping, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param LabelMapping label_mapping: Label to add (required) :param str zap_trace_span: OpenTracing span context :return: LabelResponse If the method is called asynchronously, returns the request thread. r`rv LabelResponserr rTrrNr!_post_telegrafs_id_labels_preparerr r rrrrr"r#r$r%r&r r r r~s(   z8TelegrafsService.post_telegrafs_id_labels_with_http_infoc sn|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d Id HS) aAdd a label to a Telegraf config. This method makes an asynchronous HTTP request. :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param LabelMapping label_mapping: Label to add (required) :param str zap_trace_span: OpenTracing span context :return: LabelResponse If the method is called asynchronously, returns the request thread. r`rvrrr rTrrNrrrr r r post_telegrafs_id_labels_asyncs(   z/TelegrafsService.post_telegrafs_id_labels_asyncc Kst}dddg}|d||d|ks2|ddkr:tdd|ksN|ddkrVtdi}d|krn|d|d<g}i}d|kr|d|d<d} d|kr|d} |jd g|d <|jd g|d <||||| fS) Nrrr(rzTMissing the required parameter `telegraf_id` when calling `post_telegrafs_id_labels`zVMissing the required parameter `label_mapping` when calling `post_telegrafs_id_labels`r)r*r+r,r|r}) rrrrr"r3r#r$r%r&r r r r$s8     z2TelegrafsService._post_telegrafs_id_labels_preparecKs:d|d<|dr"|j||f|S|j||f|}|SdS)aAdd a member to a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_telegrafs_id_members(telegraf_id, add_resource_member_request_body, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param AddResourceMemberRequestBody add_resource_member_request_body: User to add as member (required) :param str zap_trace_span: OpenTracing span context :return: ResourceMember If the method is called asynchronously, returns the request thread. Tr rN)r(post_telegrafs_id_members_with_http_inforr add_resource_member_request_bodyrrr r r post_telegrafs_id_membersIs  z*TelegrafsService.post_telegrafs_id_membersc Ksh|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d S) aAdd a member to a Telegraf config. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_telegrafs_id_members_with_http_info(telegraf_id, add_resource_member_request_body, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param AddResourceMemberRequestBody add_resource_member_request_body: User to add as member (required) :param str zap_trace_span: OpenTracing span context :return: ResourceMember If the method is called asynchronously, returns the request thread. rgrvResourceMemberrr rTrrNr"_post_telegrafs_id_members_preparerr r rrrrr"r#r$r%r&r r r r`s(   z9TelegrafsService.post_telegrafs_id_members_with_http_infoc sn|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d Id HS) aAdd a member to a Telegraf config. This method makes an asynchronous HTTP request. :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param AddResourceMemberRequestBody add_resource_member_request_body: User to add as member (required) :param str zap_trace_span: OpenTracing span context :return: ResourceMember If the method is called asynchronously, returns the request thread. rgrvrrr rTrrNrrrr r r post_telegrafs_id_members_asyncs(   z0TelegrafsService.post_telegrafs_id_members_asyncc Kst}dddg}|d||d|ks2|ddkr:tdd|ksN|ddkrVtdi}d|krn|d|d<g}i}d|kr|d|d<d} d|kr|d} |jd g|d <|jd g|d <||||| fS) Nrrr(rzUMissing the required parameter `telegraf_id` when calling `post_telegrafs_id_members`zjMissing the required parameter `add_resource_member_request_body` when calling `post_telegrafs_id_members`r)r*r+r,r|r} rrrrr"r3r#r$r%r&r r r rs8     z3TelegrafsService._post_telegrafs_id_members_preparecKs:d|d<|dr"|j||f|S|j||f|}|SdS)aAdd an owner to a Telegraf configuration. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_telegrafs_id_owners(telegraf_id, add_resource_member_request_body, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf configuration ID. (required) :param AddResourceMemberRequestBody add_resource_member_request_body: User to add as owner (required) :param str zap_trace_span: OpenTracing span context :return: ResourceOwner If the method is called asynchronously, returns the request thread. Tr rN)r'post_telegrafs_id_owners_with_http_inforr r r post_telegrafs_id_ownerss  z)TelegrafsService.post_telegrafs_id_ownersc Ksh|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d S) aAdd an owner to a Telegraf configuration. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_telegrafs_id_owners_with_http_info(telegraf_id, add_resource_member_request_body, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf configuration ID. (required) :param AddResourceMemberRequestBody add_resource_member_request_body: User to add as owner (required) :param str zap_trace_span: OpenTracing span context :return: ResourceOwner If the method is called asynchronously, returns the request thread. rnrv ResourceOwnerrr rTrrNr!_post_telegrafs_id_owners_preparerr rrr r r rs(   z8TelegrafsService.post_telegrafs_id_owners_with_http_infoc sn|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d Id HS) aAdd an owner to a Telegraf configuration. This method makes an asynchronous HTTP request. :param async_req bool :param str telegraf_id: The Telegraf configuration ID. (required) :param AddResourceMemberRequestBody add_resource_member_request_body: User to add as owner (required) :param str zap_trace_span: OpenTracing span context :return: ResourceOwner If the method is called asynchronously, returns the request thread. rnrvrrr rTrrNrrrr r r post_telegrafs_id_owners_asyncs(   z/TelegrafsService.post_telegrafs_id_owners_asyncc Kst}dddg}|d||d|ks2|ddkr:tdd|ksN|ddkrVtdi}d|krn|d|d<g}i}d|kr|d|d<d} d|kr|d} |jd g|d <|jd g|d <||||| fS) Nrrr(rzTMissing the required parameter `telegraf_id` when calling `post_telegrafs_id_owners`ziMissing the required parameter `add_resource_member_request_body` when calling `post_telegrafs_id_owners`r)r*r+r,r|r}rr r r r&s8     z2TelegrafsService._post_telegrafs_id_owners_preparecKs:d|d<|dr"|j||f|S|j||f|}|SdS)aUpdate a Telegraf configuration. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.put_telegrafs_id(telegraf_id, telegraf_plugin_request, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param TelegrafPluginRequest telegraf_plugin_request: Telegraf configuration update to apply (required) :param str zap_trace_span: OpenTracing span context :return: Telegraf If the method is called asynchronously, returns the request thread. Tr rN)rput_telegrafs_id_with_http_info)rrrtrrr r r put_telegrafs_idKs  z!TelegrafsService.put_telegrafs_idc Ksh|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d S) aUpdate a Telegraf configuration. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.put_telegrafs_id_with_http_info(telegraf_id, telegraf_plugin_request, async_req=True) >>> result = thread.get() :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param TelegrafPluginRequest telegraf_plugin_request: Telegraf configuration update to apply (required) :param str zap_trace_span: OpenTracing span context :return: Telegraf If the method is called asynchronously, returns the request thread. rPUTrwrr rTrrNr_put_telegrafs_id_preparerr r rrrtrr"r#r$r%r&r r r rbs(   z0TelegrafsService.put_telegrafs_id_with_http_infoc sn|j||f|\}}}}}|jjdd||||gidg|d|d|dd|di|d d d Id HS) aUpdate a Telegraf configuration. This method makes an asynchronous HTTP request. :param async_req bool :param str telegraf_id: The Telegraf config ID. (required) :param TelegrafPluginRequest telegraf_plugin_request: Telegraf configuration update to apply (required) :param str zap_trace_span: OpenTracing span context :return: Telegraf If the method is called asynchronously, returns the request thread. rrrwrr rTrrNrrrr r r put_telegrafs_id_asyncs(   z'TelegrafsService.put_telegrafs_id_asyncc Kst}dddg}|d||d|ks2|ddkr:tdd|ksN|ddkrVtdi}d|krn|d|d<g}i}d|kr|d|d<d} d|kr|d} |jd g|d <|jd g|d <||||| fS) Nrrtr(rzLMissing the required parameter `telegraf_id` when calling `put_telegrafs_id`zXMissing the required parameter `telegraf_plugin_request` when calling `put_telegrafs_id`r)r*r+r,r|r}) rrrtrr"r3r#r$r%r&r r r rs8     z*TelegrafsService._put_telegrafs_id_prepare)N)>__name__ __module__ __qualname____doc__rrrr'rr6r4r;r9r?r<rDrBrHrGrLrKrNrMrUrSrXrWr\r[r_r^rdrcrfrerkrjrmrlrrrqrursr{ryrr~rrrrrrrrrrrrrr __classcell__r r r r rst# $!!$!!$!!# $!# # # # $!%$!%$!%$!r)r __future__rreZ%influxdb_client.service._base_servicerrr r r r s