# coding: utf-8 """ kafka No description provided (generated by Swagger Codegen https://github.com/swagger-api/swagger-codegen) # noqa: E501 OpenAPI spec version: common-version Generated by: https://github.com/swagger-api/swagger-codegen.git """ from __future__ import absolute_import import re # noqa: F401 # python 2 and python 3 compatibility library import six import volcenginesdkcore class KAFKAApi(object): """NOTE: This class is auto generated by the swagger code generator program. Do not edit the class manually. Ref: https://github.com/swagger-api/swagger-codegen """ def __init__(self, api_client=None): if api_client is None: api_client = volcenginesdkcore.ApiClient() self.api_client = api_client def add_tags_to_resource(self, body, **kwargs): # noqa: E501 """add_tags_to_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.add_tags_to_resource(body, async_req=True) >>> result = thread.get() :param async_req bool :param AddTagsToResourceRequest body: (required) :return: AddTagsToResourceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.add_tags_to_resource_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.add_tags_to_resource_with_http_info(body, **kwargs) # noqa: E501 return data def add_tags_to_resource_with_http_info(self, body, **kwargs): # noqa: E501 """add_tags_to_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.add_tags_to_resource_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param AddTagsToResourceRequest body: (required) :return: AddTagsToResourceResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method add_tags_to_resource" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `add_tags_to_resource`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/AddTagsToResource/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='AddTagsToResourceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def associate_allow_list(self, body, **kwargs): # noqa: E501 """associate_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.associate_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param AssociateAllowListRequest body: (required) :return: AssociateAllowListResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.associate_allow_list_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.associate_allow_list_with_http_info(body, **kwargs) # noqa: E501 return data def associate_allow_list_with_http_info(self, body, **kwargs): # noqa: E501 """associate_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.associate_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param AssociateAllowListRequest body: (required) :return: AssociateAllowListResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method associate_allow_list" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `associate_allow_list`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/AssociateAllowList/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='AssociateAllowListResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def create_acl(self, body, **kwargs): # noqa: E501 """create_acl # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_acl(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateAclRequest body: (required) :return: CreateAclResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_acl_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_acl_with_http_info(body, **kwargs) # noqa: E501 return data def create_acl_with_http_info(self, body, **kwargs): # noqa: E501 """create_acl # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_acl_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateAclRequest body: (required) :return: CreateAclResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method create_acl" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `create_acl`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CreateAcl/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateAclResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def create_allow_list(self, body, **kwargs): # noqa: E501 """create_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateAllowListRequest body: (required) :return: CreateAllowListResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_allow_list_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_allow_list_with_http_info(body, **kwargs) # noqa: E501 return data def create_allow_list_with_http_info(self, body, **kwargs): # noqa: E501 """create_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateAllowListRequest body: (required) :return: CreateAllowListResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method create_allow_list" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `create_allow_list`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CreateAllowList/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateAllowListResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def create_group(self, body, **kwargs): # noqa: E501 """create_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateGroupRequest body: (required) :return: CreateGroupResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_group_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_group_with_http_info(body, **kwargs) # noqa: E501 return data def create_group_with_http_info(self, body, **kwargs): # noqa: E501 """create_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateGroupRequest body: (required) :return: CreateGroupResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method create_group" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `create_group`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CreateGroup/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateGroupResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def create_instance(self, body, **kwargs): # noqa: E501 """create_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_instance(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateInstanceRequest body: (required) :return: CreateInstanceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_instance_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_instance_with_http_info(body, **kwargs) # noqa: E501 return data def create_instance_with_http_info(self, body, **kwargs): # noqa: E501 """create_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_instance_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateInstanceRequest body: (required) :return: CreateInstanceResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method create_instance" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `create_instance`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CreateInstance/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateInstanceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def create_migrate_sub_tasks(self, body, **kwargs): # noqa: E501 """create_migrate_sub_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_migrate_sub_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateMigrateSubTasksRequest body: (required) :return: CreateMigrateSubTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_migrate_sub_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_migrate_sub_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def create_migrate_sub_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """create_migrate_sub_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_migrate_sub_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateMigrateSubTasksRequest body: (required) :return: CreateMigrateSubTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method create_migrate_sub_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `create_migrate_sub_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CreateMigrateSubTasks/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateMigrateSubTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def create_public_address(self, body, **kwargs): # noqa: E501 """create_public_address # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_public_address(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreatePublicAddressRequest body: (required) :return: CreatePublicAddressResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_public_address_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_public_address_with_http_info(body, **kwargs) # noqa: E501 return data def create_public_address_with_http_info(self, body, **kwargs): # noqa: E501 """create_public_address # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_public_address_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreatePublicAddressRequest body: (required) :return: CreatePublicAddressResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method create_public_address" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `create_public_address`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CreatePublicAddress/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreatePublicAddressResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def create_topic(self, body, **kwargs): # noqa: E501 """create_topic # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_topic(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateTopicRequest body: (required) :return: CreateTopicResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_topic_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_topic_with_http_info(body, **kwargs) # noqa: E501 return data def create_topic_with_http_info(self, body, **kwargs): # noqa: E501 """create_topic # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_topic_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateTopicRequest body: (required) :return: CreateTopicResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method create_topic" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `create_topic`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CreateTopic/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateTopicResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def create_user(self, body, **kwargs): # noqa: E501 """create_user # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_user(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateUserRequest body: (required) :return: CreateUserResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_user_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_user_with_http_info(body, **kwargs) # noqa: E501 return data def create_user_with_http_info(self, body, **kwargs): # noqa: E501 """create_user # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_user_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateUserRequest body: (required) :return: CreateUserResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method create_user" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `create_user`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CreateUser/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateUserResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_acl(self, body, **kwargs): # noqa: E501 """delete_acl # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_acl(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteAclRequest body: (required) :return: DeleteAclResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_acl_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_acl_with_http_info(body, **kwargs) # noqa: E501 return data def delete_acl_with_http_info(self, body, **kwargs): # noqa: E501 """delete_acl # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_acl_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteAclRequest body: (required) :return: DeleteAclResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method delete_acl" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `delete_acl`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteAcl/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteAclResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_allow_list(self, body, **kwargs): # noqa: E501 """delete_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteAllowListRequest body: (required) :return: DeleteAllowListResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_allow_list_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_allow_list_with_http_info(body, **kwargs) # noqa: E501 return data def delete_allow_list_with_http_info(self, body, **kwargs): # noqa: E501 """delete_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteAllowListRequest body: (required) :return: DeleteAllowListResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method delete_allow_list" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `delete_allow_list`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteAllowList/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteAllowListResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_group(self, body, **kwargs): # noqa: E501 """delete_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteGroupRequest body: (required) :return: DeleteGroupResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_group_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_group_with_http_info(body, **kwargs) # noqa: E501 return data def delete_group_with_http_info(self, body, **kwargs): # noqa: E501 """delete_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteGroupRequest body: (required) :return: DeleteGroupResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method delete_group" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `delete_group`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteGroup/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteGroupResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_instance(self, body, **kwargs): # noqa: E501 """delete_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_instance(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteInstanceRequest body: (required) :return: DeleteInstanceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_instance_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_instance_with_http_info(body, **kwargs) # noqa: E501 return data def delete_instance_with_http_info(self, body, **kwargs): # noqa: E501 """delete_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_instance_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteInstanceRequest body: (required) :return: DeleteInstanceResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method delete_instance" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `delete_instance`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteInstance/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteInstanceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_public_address(self, body, **kwargs): # noqa: E501 """delete_public_address # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_public_address(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeletePublicAddressRequest body: (required) :return: DeletePublicAddressResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_public_address_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_public_address_with_http_info(body, **kwargs) # noqa: E501 return data def delete_public_address_with_http_info(self, body, **kwargs): # noqa: E501 """delete_public_address # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_public_address_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeletePublicAddressRequest body: (required) :return: DeletePublicAddressResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method delete_public_address" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `delete_public_address`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeletePublicAddress/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeletePublicAddressResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_topic(self, body, **kwargs): # noqa: E501 """delete_topic # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_topic(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteTopicRequest body: (required) :return: DeleteTopicResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_topic_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_topic_with_http_info(body, **kwargs) # noqa: E501 return data def delete_topic_with_http_info(self, body, **kwargs): # noqa: E501 """delete_topic # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_topic_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteTopicRequest body: (required) :return: DeleteTopicResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method delete_topic" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `delete_topic`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteTopic/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteTopicResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_user(self, body, **kwargs): # noqa: E501 """delete_user # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_user(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteUserRequest body: (required) :return: DeleteUserResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_user_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_user_with_http_info(body, **kwargs) # noqa: E501 return data def delete_user_with_http_info(self, body, **kwargs): # noqa: E501 """delete_user # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_user_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteUserRequest body: (required) :return: DeleteUserResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method delete_user" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `delete_user`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteUser/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteUserResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_acls(self, body, **kwargs): # noqa: E501 """describe_acls # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_acls(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAclsRequest body: (required) :return: DescribeAclsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_acls_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_acls_with_http_info(body, **kwargs) # noqa: E501 return data def describe_acls_with_http_info(self, body, **kwargs): # noqa: E501 """describe_acls # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_acls_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAclsRequest body: (required) :return: DescribeAclsResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_acls" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_acls`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeAcls/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeAclsResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_allow_list_detail(self, body, **kwargs): # noqa: E501 """describe_allow_list_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_allow_list_detail(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAllowListDetailRequest body: (required) :return: DescribeAllowListDetailResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_allow_list_detail_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_allow_list_detail_with_http_info(body, **kwargs) # noqa: E501 return data def describe_allow_list_detail_with_http_info(self, body, **kwargs): # noqa: E501 """describe_allow_list_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_allow_list_detail_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAllowListDetailRequest body: (required) :return: DescribeAllowListDetailResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_allow_list_detail" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_allow_list_detail`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeAllowListDetail/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeAllowListDetailResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_allow_lists(self, body, **kwargs): # noqa: E501 """describe_allow_lists # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_allow_lists(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAllowListsRequest body: (required) :return: DescribeAllowListsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_allow_lists_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_allow_lists_with_http_info(body, **kwargs) # noqa: E501 return data def describe_allow_lists_with_http_info(self, body, **kwargs): # noqa: E501 """describe_allow_lists # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_allow_lists_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAllowListsRequest body: (required) :return: DescribeAllowListsResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_allow_lists" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_allow_lists`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeAllowLists/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeAllowListsResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_availability_zones(self, body, **kwargs): # noqa: E501 """describe_availability_zones # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_availability_zones(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAvailabilityZonesRequest body: (required) :return: DescribeAvailabilityZonesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_availability_zones_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_availability_zones_with_http_info(body, **kwargs) # noqa: E501 return data def describe_availability_zones_with_http_info(self, body, **kwargs): # noqa: E501 """describe_availability_zones # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_availability_zones_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAvailabilityZonesRequest body: (required) :return: DescribeAvailabilityZonesResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_availability_zones" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_availability_zones`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeAvailabilityZones/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeAvailabilityZonesResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_consumed_partitions(self, body, **kwargs): # noqa: E501 """describe_consumed_partitions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_partitions(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedPartitionsRequest body: (required) :return: DescribeConsumedPartitionsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_consumed_partitions_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_consumed_partitions_with_http_info(body, **kwargs) # noqa: E501 return data def describe_consumed_partitions_with_http_info(self, body, **kwargs): # noqa: E501 """describe_consumed_partitions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_partitions_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedPartitionsRequest body: (required) :return: DescribeConsumedPartitionsResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_consumed_partitions" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_consumed_partitions`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeConsumedPartitions/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeConsumedPartitionsResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_consumed_topics(self, body, **kwargs): # noqa: E501 """describe_consumed_topics # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_topics(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedTopicsRequest body: (required) :return: DescribeConsumedTopicsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_consumed_topics_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_consumed_topics_with_http_info(body, **kwargs) # noqa: E501 return data def describe_consumed_topics_with_http_info(self, body, **kwargs): # noqa: E501 """describe_consumed_topics # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_topics_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedTopicsRequest body: (required) :return: DescribeConsumedTopicsResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_consumed_topics" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_consumed_topics`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeConsumedTopics/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeConsumedTopicsResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_groups(self, body, **kwargs): # noqa: E501 """describe_groups # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_groups(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeGroupsRequest body: (required) :return: DescribeGroupsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_groups_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_groups_with_http_info(body, **kwargs) # noqa: E501 return data def describe_groups_with_http_info(self, body, **kwargs): # noqa: E501 """describe_groups # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_groups_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeGroupsRequest body: (required) :return: DescribeGroupsResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_groups" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_groups`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeGroups/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeGroupsResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_instance_detail(self, body, **kwargs): # noqa: E501 """describe_instance_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_instance_detail(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstanceDetailRequest body: (required) :return: DescribeInstanceDetailResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_instance_detail_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_instance_detail_with_http_info(body, **kwargs) # noqa: E501 return data def describe_instance_detail_with_http_info(self, body, **kwargs): # noqa: E501 """describe_instance_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_instance_detail_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstanceDetailRequest body: (required) :return: DescribeInstanceDetailResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_instance_detail" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_instance_detail`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeInstanceDetail/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeInstanceDetailResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_instances(self, body, **kwargs): # noqa: E501 """describe_instances # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_instances(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstancesRequest body: (required) :return: DescribeInstancesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_instances_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_instances_with_http_info(body, **kwargs) # noqa: E501 return data def describe_instances_with_http_info(self, body, **kwargs): # noqa: E501 """describe_instances # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_instances_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstancesRequest body: (required) :return: DescribeInstancesResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_instances" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_instances`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeInstances/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeInstancesResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_regions(self, body, **kwargs): # noqa: E501 """describe_regions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_regions(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeRegionsRequest body: (required) :return: DescribeRegionsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_regions_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_regions_with_http_info(body, **kwargs) # noqa: E501 return data def describe_regions_with_http_info(self, body, **kwargs): # noqa: E501 """describe_regions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_regions_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeRegionsRequest body: (required) :return: DescribeRegionsResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_regions" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_regions`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeRegions/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeRegionsResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_tags_by_resource(self, body, **kwargs): # noqa: E501 """describe_tags_by_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_tags_by_resource(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTagsByResourceRequest body: (required) :return: DescribeTagsByResourceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_tags_by_resource_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_tags_by_resource_with_http_info(body, **kwargs) # noqa: E501 return data def describe_tags_by_resource_with_http_info(self, body, **kwargs): # noqa: E501 """describe_tags_by_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_tags_by_resource_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTagsByResourceRequest body: (required) :return: DescribeTagsByResourceResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_tags_by_resource" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_tags_by_resource`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeTagsByResource/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeTagsByResourceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_topic_access_policies(self, body, **kwargs): # noqa: E501 """describe_topic_access_policies # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_access_policies(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicAccessPoliciesRequest body: (required) :return: DescribeTopicAccessPoliciesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_topic_access_policies_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_topic_access_policies_with_http_info(body, **kwargs) # noqa: E501 return data def describe_topic_access_policies_with_http_info(self, body, **kwargs): # noqa: E501 """describe_topic_access_policies # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_access_policies_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicAccessPoliciesRequest body: (required) :return: DescribeTopicAccessPoliciesResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_topic_access_policies" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_topic_access_policies`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeTopicAccessPolicies/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeTopicAccessPoliciesResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_topic_parameters(self, body, **kwargs): # noqa: E501 """describe_topic_parameters # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_parameters(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicParametersRequest body: (required) :return: DescribeTopicParametersResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_topic_parameters_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_topic_parameters_with_http_info(body, **kwargs) # noqa: E501 return data def describe_topic_parameters_with_http_info(self, body, **kwargs): # noqa: E501 """describe_topic_parameters # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_parameters_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicParametersRequest body: (required) :return: DescribeTopicParametersResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_topic_parameters" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_topic_parameters`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeTopicParameters/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeTopicParametersResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_topic_partitions(self, body, **kwargs): # noqa: E501 """describe_topic_partitions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_partitions(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicPartitionsRequest body: (required) :return: DescribeTopicPartitionsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_topic_partitions_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_topic_partitions_with_http_info(body, **kwargs) # noqa: E501 return data def describe_topic_partitions_with_http_info(self, body, **kwargs): # noqa: E501 """describe_topic_partitions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_partitions_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicPartitionsRequest body: (required) :return: DescribeTopicPartitionsResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_topic_partitions" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_topic_partitions`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeTopicPartitions/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeTopicPartitionsResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_topics(self, body, **kwargs): # noqa: E501 """describe_topics # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topics(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicsRequest body: (required) :return: DescribeTopicsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_topics_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_topics_with_http_info(body, **kwargs) # noqa: E501 return data def describe_topics_with_http_info(self, body, **kwargs): # noqa: E501 """describe_topics # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topics_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicsRequest body: (required) :return: DescribeTopicsResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_topics" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_topics`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeTopics/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeTopicsResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_users(self, body, **kwargs): # noqa: E501 """describe_users # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_users(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeUsersRequest body: (required) :return: DescribeUsersResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_users_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_users_with_http_info(body, **kwargs) # noqa: E501 return data def describe_users_with_http_info(self, body, **kwargs): # noqa: E501 """describe_users # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_users_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeUsersRequest body: (required) :return: DescribeUsersResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_users" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_users`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeUsers/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeUsersResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def disassociate_allow_list(self, body, **kwargs): # noqa: E501 """disassociate_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.disassociate_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param DisassociateAllowListRequest body: (required) :return: DisassociateAllowListResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.disassociate_allow_list_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.disassociate_allow_list_with_http_info(body, **kwargs) # noqa: E501 return data def disassociate_allow_list_with_http_info(self, body, **kwargs): # noqa: E501 """disassociate_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.disassociate_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DisassociateAllowListRequest body: (required) :return: DisassociateAllowListResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method disassociate_allow_list" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `disassociate_allow_list`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DisassociateAllowList/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DisassociateAllowListResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_allow_list(self, body, **kwargs): # noqa: E501 """modify_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyAllowListRequest body: (required) :return: ModifyAllowListResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_allow_list_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_allow_list_with_http_info(body, **kwargs) # noqa: E501 return data def modify_allow_list_with_http_info(self, body, **kwargs): # noqa: E501 """modify_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyAllowListRequest body: (required) :return: ModifyAllowListResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_allow_list" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_allow_list`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyAllowList/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyAllowListResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_group(self, body, **kwargs): # noqa: E501 """modify_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyGroupRequest body: (required) :return: ModifyGroupResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_group_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_group_with_http_info(body, **kwargs) # noqa: E501 return data def modify_group_with_http_info(self, body, **kwargs): # noqa: E501 """modify_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyGroupRequest body: (required) :return: ModifyGroupResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_group" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_group`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyGroup/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyGroupResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_instance_attributes(self, body, **kwargs): # noqa: E501 """modify_instance_attributes # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_attributes(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceAttributesRequest body: (required) :return: ModifyInstanceAttributesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_instance_attributes_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_instance_attributes_with_http_info(body, **kwargs) # noqa: E501 return data def modify_instance_attributes_with_http_info(self, body, **kwargs): # noqa: E501 """modify_instance_attributes # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_attributes_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceAttributesRequest body: (required) :return: ModifyInstanceAttributesResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_instance_attributes" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_instance_attributes`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyInstanceAttributes/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyInstanceAttributesResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_instance_charge_type(self, body, **kwargs): # noqa: E501 """modify_instance_charge_type # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_charge_type(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceChargeTypeRequest body: (required) :return: ModifyInstanceChargeTypeResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_instance_charge_type_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_instance_charge_type_with_http_info(body, **kwargs) # noqa: E501 return data def modify_instance_charge_type_with_http_info(self, body, **kwargs): # noqa: E501 """modify_instance_charge_type # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_charge_type_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceChargeTypeRequest body: (required) :return: ModifyInstanceChargeTypeResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_instance_charge_type" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_instance_charge_type`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyInstanceChargeType/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyInstanceChargeTypeResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_instance_parameters(self, body, **kwargs): # noqa: E501 """modify_instance_parameters # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_parameters(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceParametersRequest body: (required) :return: ModifyInstanceParametersResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_instance_parameters_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_instance_parameters_with_http_info(body, **kwargs) # noqa: E501 return data def modify_instance_parameters_with_http_info(self, body, **kwargs): # noqa: E501 """modify_instance_parameters # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_parameters_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceParametersRequest body: (required) :return: ModifyInstanceParametersResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_instance_parameters" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_instance_parameters`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyInstanceParameters/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyInstanceParametersResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_instance_spec(self, body, **kwargs): # noqa: E501 """modify_instance_spec # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_spec(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceSpecRequest body: (required) :return: ModifyInstanceSpecResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_instance_spec_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_instance_spec_with_http_info(body, **kwargs) # noqa: E501 return data def modify_instance_spec_with_http_info(self, body, **kwargs): # noqa: E501 """modify_instance_spec # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_spec_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceSpecRequest body: (required) :return: ModifyInstanceSpecResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_instance_spec" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_instance_spec`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyInstanceSpec/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyInstanceSpecResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_topic_access_policies(self, body, **kwargs): # noqa: E501 """modify_topic_access_policies # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_access_policies(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicAccessPoliciesRequest body: (required) :return: ModifyTopicAccessPoliciesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_topic_access_policies_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_topic_access_policies_with_http_info(body, **kwargs) # noqa: E501 return data def modify_topic_access_policies_with_http_info(self, body, **kwargs): # noqa: E501 """modify_topic_access_policies # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_access_policies_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicAccessPoliciesRequest body: (required) :return: ModifyTopicAccessPoliciesResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_topic_access_policies" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_topic_access_policies`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyTopicAccessPolicies/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyTopicAccessPoliciesResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_topic_attributes(self, body, **kwargs): # noqa: E501 """modify_topic_attributes # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_attributes(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicAttributesRequest body: (required) :return: ModifyTopicAttributesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_topic_attributes_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_topic_attributes_with_http_info(body, **kwargs) # noqa: E501 return data def modify_topic_attributes_with_http_info(self, body, **kwargs): # noqa: E501 """modify_topic_attributes # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_attributes_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicAttributesRequest body: (required) :return: ModifyTopicAttributesResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_topic_attributes" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_topic_attributes`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyTopicAttributes/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyTopicAttributesResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_topic_parameters(self, body, **kwargs): # noqa: E501 """modify_topic_parameters # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_parameters(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicParametersRequest body: (required) :return: ModifyTopicParametersResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_topic_parameters_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_topic_parameters_with_http_info(body, **kwargs) # noqa: E501 return data def modify_topic_parameters_with_http_info(self, body, **kwargs): # noqa: E501 """modify_topic_parameters # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_parameters_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicParametersRequest body: (required) :return: ModifyTopicParametersResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_topic_parameters" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_topic_parameters`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyTopicParameters/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyTopicParametersResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_user_authority(self, body, **kwargs): # noqa: E501 """modify_user_authority # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_user_authority(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyUserAuthorityRequest body: (required) :return: ModifyUserAuthorityResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_user_authority_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_user_authority_with_http_info(body, **kwargs) # noqa: E501 return data def modify_user_authority_with_http_info(self, body, **kwargs): # noqa: E501 """modify_user_authority # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_user_authority_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyUserAuthorityRequest body: (required) :return: ModifyUserAuthorityResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_user_authority" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_user_authority`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyUserAuthority/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyUserAuthorityResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def query_message_by_timestamp(self, body, **kwargs): # noqa: E501 """query_message_by_timestamp # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_message_by_timestamp(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageByTimestampRequest body: (required) :return: QueryMessageByTimestampResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.query_message_by_timestamp_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.query_message_by_timestamp_with_http_info(body, **kwargs) # noqa: E501 return data def query_message_by_timestamp_with_http_info(self, body, **kwargs): # noqa: E501 """query_message_by_timestamp # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_message_by_timestamp_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageByTimestampRequest body: (required) :return: QueryMessageByTimestampResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method query_message_by_timestamp" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `query_message_by_timestamp`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/QueryMessageByTimestamp/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='QueryMessageByTimestampResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def remove_tags_from_resource(self, body, **kwargs): # noqa: E501 """remove_tags_from_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.remove_tags_from_resource(body, async_req=True) >>> result = thread.get() :param async_req bool :param RemoveTagsFromResourceRequest body: (required) :return: RemoveTagsFromResourceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.remove_tags_from_resource_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.remove_tags_from_resource_with_http_info(body, **kwargs) # noqa: E501 return data def remove_tags_from_resource_with_http_info(self, body, **kwargs): # noqa: E501 """remove_tags_from_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.remove_tags_from_resource_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param RemoveTagsFromResourceRequest body: (required) :return: RemoveTagsFromResourceResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method remove_tags_from_resource" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `remove_tags_from_resource`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/RemoveTagsFromResource/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='RemoveTagsFromResourceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def reset_consumed_offsets(self, body, **kwargs): # noqa: E501 """reset_consumed_offsets # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.reset_consumed_offsets(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResetConsumedOffsetsRequest body: (required) :return: ResetConsumedOffsetsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.reset_consumed_offsets_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.reset_consumed_offsets_with_http_info(body, **kwargs) # noqa: E501 return data def reset_consumed_offsets_with_http_info(self, body, **kwargs): # noqa: E501 """reset_consumed_offsets # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.reset_consumed_offsets_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResetConsumedOffsetsRequest body: (required) :return: ResetConsumedOffsetsResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method reset_consumed_offsets" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `reset_consumed_offsets`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ResetConsumedOffsets/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ResetConsumedOffsetsResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def update_migrate_task_status(self, body, **kwargs): # noqa: E501 """update_migrate_task_status # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_migrate_task_status(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateMigrateTaskStatusRequest body: (required) :return: UpdateMigrateTaskStatusResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.update_migrate_task_status_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.update_migrate_task_status_with_http_info(body, **kwargs) # noqa: E501 return data def update_migrate_task_status_with_http_info(self, body, **kwargs): # noqa: E501 """update_migrate_task_status # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_migrate_task_status_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateMigrateTaskStatusRequest body: (required) :return: UpdateMigrateTaskStatusResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method update_migrate_task_status" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `update_migrate_task_status`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/UpdateMigrateTaskStatus/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='UpdateMigrateTaskStatusResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def verify_migrate_sub_tasks(self, body, **kwargs): # noqa: E501 """verify_migrate_sub_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.verify_migrate_sub_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param VerifyMigrateSubTasksRequest body: (required) :return: VerifyMigrateSubTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.verify_migrate_sub_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.verify_migrate_sub_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def verify_migrate_sub_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """verify_migrate_sub_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.verify_migrate_sub_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param VerifyMigrateSubTasksRequest body: (required) :return: VerifyMigrateSubTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method verify_migrate_sub_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `verify_migrate_sub_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/VerifyMigrateSubTasks/2022-05-01/kafka/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='VerifyMigrateSubTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats)