# coding: utf-8 """ bmq 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 BMQApi(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 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/2023-06-01/bmq/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/2023-06-01/bmq/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_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/2023-06-01/bmq/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 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/2023-06-01/bmq/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/2023-06-01/bmq/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_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/2023-06-01/bmq/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 describe_available_zones(self, body, **kwargs): # noqa: E501 """describe_available_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_available_zones(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAvailableZonesRequest body: (required) :return: DescribeAvailableZonesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_available_zones_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_available_zones_with_http_info(body, **kwargs) # noqa: E501 return data def describe_available_zones_with_http_info(self, body, **kwargs): # noqa: E501 """describe_available_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_available_zones_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAvailableZonesRequest body: (required) :return: DescribeAvailableZonesResponse 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_available_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_available_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( '/DescribeAvailableZones/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeAvailableZonesResponse', # 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_group(self, body, **kwargs): # noqa: E501 """describe_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.describe_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeGroupRequest body: (required) :return: DescribeGroupResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_group_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_group_with_http_info(body, **kwargs) # noqa: E501 return data def describe_group_with_http_info(self, body, **kwargs): # noqa: E501 """describe_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.describe_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeGroupRequest body: (required) :return: DescribeGroupResponse 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_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 `describe_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( '/DescribeGroup/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeGroupResponse', # 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_in_topic(self, body, **kwargs): # noqa: E501 """describe_groups_in_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.describe_groups_in_topic(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeGroupsInTopicRequest body: (required) :return: DescribeGroupsInTopicResponse 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_in_topic_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_groups_in_topic_with_http_info(body, **kwargs) # noqa: E501 return data def describe_groups_in_topic_with_http_info(self, body, **kwargs): # noqa: E501 """describe_groups_in_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.describe_groups_in_topic_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeGroupsInTopicRequest body: (required) :return: DescribeGroupsInTopicResponse 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_in_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 `describe_groups_in_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( '/DescribeGroupsInTopic/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeGroupsInTopicResponse', # 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(self, body, **kwargs): # noqa: E501 """describe_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.describe_instance(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstanceRequest body: (required) :return: DescribeInstanceResponse 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_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_instance_with_http_info(body, **kwargs) # noqa: E501 return data def describe_instance_with_http_info(self, body, **kwargs): # noqa: E501 """describe_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.describe_instance_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstanceRequest body: (required) :return: DescribeInstanceResponse 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" % 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`") # 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( '/DescribeInstance/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeInstanceResponse', # 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_resource_stat(self, body, **kwargs): # noqa: E501 """describe_instance_resource_stat # 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_resource_stat(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstanceResourceStatRequest body: (required) :return: DescribeInstanceResourceStatResponse 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_resource_stat_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_instance_resource_stat_with_http_info(body, **kwargs) # noqa: E501 return data def describe_instance_resource_stat_with_http_info(self, body, **kwargs): # noqa: E501 """describe_instance_resource_stat # 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_resource_stat_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstanceResourceStatRequest body: (required) :return: DescribeInstanceResourceStatResponse 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_resource_stat" % 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_resource_stat`") # 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( '/DescribeInstanceResourceStat/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeInstanceResourceStatResponse', # 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_partitions_in_topic(self, body, **kwargs): # noqa: E501 """describe_partitions_in_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.describe_partitions_in_topic(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribePartitionsInTopicRequest body: (required) :return: DescribePartitionsInTopicResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_partitions_in_topic_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_partitions_in_topic_with_http_info(body, **kwargs) # noqa: E501 return data def describe_partitions_in_topic_with_http_info(self, body, **kwargs): # noqa: E501 """describe_partitions_in_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.describe_partitions_in_topic_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribePartitionsInTopicRequest body: (required) :return: DescribePartitionsInTopicResponse 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_partitions_in_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 `describe_partitions_in_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( '/DescribePartitionsInTopic/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribePartitionsInTopicResponse', # 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_subscription(self, body, **kwargs): # noqa: E501 """describe_subscription # 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_subscription(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeSubscriptionRequest body: (required) :return: DescribeSubscriptionResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_subscription_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_subscription_with_http_info(body, **kwargs) # noqa: E501 return data def describe_subscription_with_http_info(self, body, **kwargs): # noqa: E501 """describe_subscription # 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_subscription_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeSubscriptionRequest body: (required) :return: DescribeSubscriptionResponse 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_subscription" % 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_subscription`") # 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( '/DescribeSubscription/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeSubscriptionResponse', # 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(self, body, **kwargs): # noqa: E501 """describe_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.describe_topic(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicRequest body: (required) :return: DescribeTopicResponse 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_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_topic_with_http_info(body, **kwargs) # noqa: E501 return data def describe_topic_with_http_info(self, body, **kwargs): # noqa: E501 """describe_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.describe_topic_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicRequest body: (required) :return: DescribeTopicResponse 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" % 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`") # 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( '/DescribeTopic/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeTopicResponse', # 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_time_range(self, body, **kwargs): # noqa: E501 """describe_topic_time_range # 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_time_range(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicTimeRangeRequest body: (required) :return: DescribeTopicTimeRangeResponse 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_time_range_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_topic_time_range_with_http_info(body, **kwargs) # noqa: E501 return data def describe_topic_time_range_with_http_info(self, body, **kwargs): # noqa: E501 """describe_topic_time_range # 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_time_range_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicTimeRangeRequest body: (required) :return: DescribeTopicTimeRangeResponse 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_time_range" % 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_time_range`") # 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( '/DescribeTopicTimeRange/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeTopicTimeRangeResponse', # 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_in_group(self, body, **kwargs): # noqa: E501 """describe_topics_in_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.describe_topics_in_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicsInGroupRequest body: (required) :return: DescribeTopicsInGroupResponse 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_in_group_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_topics_in_group_with_http_info(body, **kwargs) # noqa: E501 return data def describe_topics_in_group_with_http_info(self, body, **kwargs): # noqa: E501 """describe_topics_in_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.describe_topics_in_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicsInGroupRequest body: (required) :return: DescribeTopicsInGroupResponse 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_in_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 `describe_topics_in_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( '/DescribeTopicsInGroup/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeTopicsInGroupResponse', # 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 disable_overlay_access(self, body, **kwargs): # noqa: E501 """disable_overlay_access # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.disable_overlay_access(body, async_req=True) >>> result = thread.get() :param async_req bool :param DisableOverlayAccessRequest body: (required) :return: DisableOverlayAccessResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.disable_overlay_access_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.disable_overlay_access_with_http_info(body, **kwargs) # noqa: E501 return data def disable_overlay_access_with_http_info(self, body, **kwargs): # noqa: E501 """disable_overlay_access # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.disable_overlay_access_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DisableOverlayAccessRequest body: (required) :return: DisableOverlayAccessResponse 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 disable_overlay_access" % 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 `disable_overlay_access`") # 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( '/DisableOverlayAccess/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DisableOverlayAccessResponse', # 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 disable_public_access(self, body, **kwargs): # noqa: E501 """disable_public_access # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.disable_public_access(body, async_req=True) >>> result = thread.get() :param async_req bool :param DisablePublicAccessRequest body: (required) :return: DisablePublicAccessResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.disable_public_access_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.disable_public_access_with_http_info(body, **kwargs) # noqa: E501 return data def disable_public_access_with_http_info(self, body, **kwargs): # noqa: E501 """disable_public_access # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.disable_public_access_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DisablePublicAccessRequest body: (required) :return: DisablePublicAccessResponse 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 disable_public_access" % 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 `disable_public_access`") # 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( '/DisablePublicAccess/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DisablePublicAccessResponse', # 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 enable_overlay_access(self, body, **kwargs): # noqa: E501 """enable_overlay_access # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.enable_overlay_access(body, async_req=True) >>> result = thread.get() :param async_req bool :param EnableOverlayAccessRequest body: (required) :return: EnableOverlayAccessResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.enable_overlay_access_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.enable_overlay_access_with_http_info(body, **kwargs) # noqa: E501 return data def enable_overlay_access_with_http_info(self, body, **kwargs): # noqa: E501 """enable_overlay_access # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.enable_overlay_access_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param EnableOverlayAccessRequest body: (required) :return: EnableOverlayAccessResponse 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 enable_overlay_access" % 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 `enable_overlay_access`") # 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( '/EnableOverlayAccess/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='EnableOverlayAccessResponse', # 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 enable_public_access(self, body, **kwargs): # noqa: E501 """enable_public_access # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.enable_public_access(body, async_req=True) >>> result = thread.get() :param async_req bool :param EnablePublicAccessRequest body: (required) :return: EnablePublicAccessResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.enable_public_access_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.enable_public_access_with_http_info(body, **kwargs) # noqa: E501 return data def enable_public_access_with_http_info(self, body, **kwargs): # noqa: E501 """enable_public_access # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.enable_public_access_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param EnablePublicAccessRequest body: (required) :return: EnablePublicAccessResponse 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 enable_public_access" % 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 `enable_public_access`") # 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( '/EnablePublicAccess/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='EnablePublicAccessResponse', # 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 group_exist(self, body, **kwargs): # noqa: E501 """group_exist # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.group_exist(body, async_req=True) >>> result = thread.get() :param async_req bool :param GroupExistRequest body: (required) :return: GroupExistResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.group_exist_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.group_exist_with_http_info(body, **kwargs) # noqa: E501 return data def group_exist_with_http_info(self, body, **kwargs): # noqa: E501 """group_exist # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.group_exist_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GroupExistRequest body: (required) :return: GroupExistResponse 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 group_exist" % 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 `group_exist`") # 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( '/GroupExist/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GroupExistResponse', # 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 list_available_security_groups_for_bmq(self, body, **kwargs): # noqa: E501 """list_available_security_groups_for_bmq # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_available_security_groups_for_bmq(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListAvailableSecurityGroupsForBMQRequest body: (required) :return: ListAvailableSecurityGroupsForBMQResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_available_security_groups_for_bmq_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_available_security_groups_for_bmq_with_http_info(body, **kwargs) # noqa: E501 return data def list_available_security_groups_for_bmq_with_http_info(self, body, **kwargs): # noqa: E501 """list_available_security_groups_for_bmq # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_available_security_groups_for_bmq_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListAvailableSecurityGroupsForBMQRequest body: (required) :return: ListAvailableSecurityGroupsForBMQResponse 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 list_available_security_groups_for_bmq" % 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 `list_available_security_groups_for_bmq`") # 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( '/ListAvailableSecurityGroupsForBMQ/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListAvailableSecurityGroupsForBMQResponse', # 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 list_available_subnets_for_bmq(self, body, **kwargs): # noqa: E501 """list_available_subnets_for_bmq # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_available_subnets_for_bmq(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListAvailableSubnetsForBMQRequest body: (required) :return: ListAvailableSubnetsForBMQResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_available_subnets_for_bmq_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_available_subnets_for_bmq_with_http_info(body, **kwargs) # noqa: E501 return data def list_available_subnets_for_bmq_with_http_info(self, body, **kwargs): # noqa: E501 """list_available_subnets_for_bmq # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_available_subnets_for_bmq_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListAvailableSubnetsForBMQRequest body: (required) :return: ListAvailableSubnetsForBMQResponse 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 list_available_subnets_for_bmq" % 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 `list_available_subnets_for_bmq`") # 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( '/ListAvailableSubnetsForBMQ/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListAvailableSubnetsForBMQResponse', # 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 list_available_vpc_for_bmq(self, body, **kwargs): # noqa: E501 """list_available_vpc_for_bmq # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_available_vpc_for_bmq(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListAvailableVPCForBMQRequest body: (required) :return: ListAvailableVPCForBMQResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_available_vpc_for_bmq_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_available_vpc_for_bmq_with_http_info(body, **kwargs) # noqa: E501 return data def list_available_vpc_for_bmq_with_http_info(self, body, **kwargs): # noqa: E501 """list_available_vpc_for_bmq # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_available_vpc_for_bmq_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListAvailableVPCForBMQRequest body: (required) :return: ListAvailableVPCForBMQResponse 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 list_available_vpc_for_bmq" % 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 `list_available_vpc_for_bmq`") # 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( '/ListAvailableVPCForBMQ/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListAvailableVPCForBMQResponse', # 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 list_instance_resource_stats(self, body, **kwargs): # noqa: E501 """list_instance_resource_stats # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_instance_resource_stats(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListInstanceResourceStatsRequest body: (required) :return: ListInstanceResourceStatsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_instance_resource_stats_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_instance_resource_stats_with_http_info(body, **kwargs) # noqa: E501 return data def list_instance_resource_stats_with_http_info(self, body, **kwargs): # noqa: E501 """list_instance_resource_stats # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_instance_resource_stats_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListInstanceResourceStatsRequest body: (required) :return: ListInstanceResourceStatsResponse 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 list_instance_resource_stats" % 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 `list_instance_resource_stats`") # 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( '/ListInstanceResourceStats/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListInstanceResourceStatsResponse', # 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 list_specifications(self, body, **kwargs): # noqa: E501 """list_specifications # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_specifications(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListSpecificationsRequest body: (required) :return: ListSpecificationsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_specifications_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_specifications_with_http_info(body, **kwargs) # noqa: E501 return data def list_specifications_with_http_info(self, body, **kwargs): # noqa: E501 """list_specifications # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_specifications_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListSpecificationsRequest body: (required) :return: ListSpecificationsResponse 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 list_specifications" % 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 `list_specifications`") # 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( '/ListSpecifications/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListSpecificationsResponse', # 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_tag(self, body, **kwargs): # noqa: E501 """modify_instance_tag # 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_tag(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceTagRequest body: (required) :return: ModifyInstanceTagResponse 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_tag_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_instance_tag_with_http_info(body, **kwargs) # noqa: E501 return data def modify_instance_tag_with_http_info(self, body, **kwargs): # noqa: E501 """modify_instance_tag # 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_tag_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceTagRequest body: (required) :return: ModifyInstanceTagResponse 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_tag" % 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_tag`") # 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( '/ModifyInstanceTag/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyInstanceTagResponse', # 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_overlay_access(self, body, **kwargs): # noqa: E501 """modify_overlay_access # 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_overlay_access(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyOverlayAccessRequest body: (required) :return: ModifyOverlayAccessResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_overlay_access_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_overlay_access_with_http_info(body, **kwargs) # noqa: E501 return data def modify_overlay_access_with_http_info(self, body, **kwargs): # noqa: E501 """modify_overlay_access # 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_overlay_access_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyOverlayAccessRequest body: (required) :return: ModifyOverlayAccessResponse 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_overlay_access" % 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_overlay_access`") # 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( '/ModifyOverlayAccess/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyOverlayAccessResponse', # 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 preview_topic_data(self, body, **kwargs): # noqa: E501 """preview_topic_data # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.preview_topic_data(body, async_req=True) >>> result = thread.get() :param async_req bool :param PreviewTopicDataRequest body: (required) :return: PreviewTopicDataResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.preview_topic_data_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.preview_topic_data_with_http_info(body, **kwargs) # noqa: E501 return data def preview_topic_data_with_http_info(self, body, **kwargs): # noqa: E501 """preview_topic_data # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.preview_topic_data_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param PreviewTopicDataRequest body: (required) :return: PreviewTopicDataResponse 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 preview_topic_data" % 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 `preview_topic_data`") # 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( '/PreviewTopicData/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='PreviewTopicDataResponse', # 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_subscription_offset(self, body, **kwargs): # noqa: E501 """reset_subscription_offset # 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_subscription_offset(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResetSubscriptionOffsetRequest body: (required) :return: ResetSubscriptionOffsetResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.reset_subscription_offset_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.reset_subscription_offset_with_http_info(body, **kwargs) # noqa: E501 return data def reset_subscription_offset_with_http_info(self, body, **kwargs): # noqa: E501 """reset_subscription_offset # 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_subscription_offset_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResetSubscriptionOffsetRequest body: (required) :return: ResetSubscriptionOffsetResponse 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_subscription_offset" % 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_subscription_offset`") # 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( '/ResetSubscriptionOffset/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ResetSubscriptionOffsetResponse', # 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 scale_up_topic(self, body, **kwargs): # noqa: E501 """scale_up_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.scale_up_topic(body, async_req=True) >>> result = thread.get() :param async_req bool :param ScaleUpTopicRequest body: (required) :return: ScaleUpTopicResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.scale_up_topic_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.scale_up_topic_with_http_info(body, **kwargs) # noqa: E501 return data def scale_up_topic_with_http_info(self, body, **kwargs): # noqa: E501 """scale_up_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.scale_up_topic_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ScaleUpTopicRequest body: (required) :return: ScaleUpTopicResponse 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 scale_up_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 `scale_up_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( '/ScaleUpTopic/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ScaleUpTopicResponse', # 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 search_groups(self, body, **kwargs): # noqa: E501 """search_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.search_groups(body, async_req=True) >>> result = thread.get() :param async_req bool :param SearchGroupsRequest body: (required) :return: SearchGroupsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.search_groups_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.search_groups_with_http_info(body, **kwargs) # noqa: E501 return data def search_groups_with_http_info(self, body, **kwargs): # noqa: E501 """search_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.search_groups_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param SearchGroupsRequest body: (required) :return: SearchGroupsResponse 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 search_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 `search_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( '/SearchGroups/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='SearchGroupsResponse', # 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 search_instances(self, body, **kwargs): # noqa: E501 """search_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.search_instances(body, async_req=True) >>> result = thread.get() :param async_req bool :param SearchInstancesRequest body: (required) :return: SearchInstancesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.search_instances_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.search_instances_with_http_info(body, **kwargs) # noqa: E501 return data def search_instances_with_http_info(self, body, **kwargs): # noqa: E501 """search_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.search_instances_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param SearchInstancesRequest body: (required) :return: SearchInstancesResponse 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 search_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 `search_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( '/SearchInstances/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='SearchInstancesResponse', # 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 search_topics(self, body, **kwargs): # noqa: E501 """search_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.search_topics(body, async_req=True) >>> result = thread.get() :param async_req bool :param SearchTopicsRequest body: (required) :return: SearchTopicsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.search_topics_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.search_topics_with_http_info(body, **kwargs) # noqa: E501 return data def search_topics_with_http_info(self, body, **kwargs): # noqa: E501 """search_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.search_topics_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param SearchTopicsRequest body: (required) :return: SearchTopicsResponse 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 search_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 `search_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( '/SearchTopics/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='SearchTopicsResponse', # 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_instance_message_retention(self, body, **kwargs): # noqa: E501 """update_instance_message_retention # 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_instance_message_retention(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateInstanceMessageRetentionRequest body: (required) :return: UpdateInstanceMessageRetentionResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.update_instance_message_retention_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.update_instance_message_retention_with_http_info(body, **kwargs) # noqa: E501 return data def update_instance_message_retention_with_http_info(self, body, **kwargs): # noqa: E501 """update_instance_message_retention # 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_instance_message_retention_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateInstanceMessageRetentionRequest body: (required) :return: UpdateInstanceMessageRetentionResponse 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_instance_message_retention" % 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_instance_message_retention`") # 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( '/UpdateInstanceMessageRetention/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='UpdateInstanceMessageRetentionResponse', # 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_topic_message_retention(self, body, **kwargs): # noqa: E501 """update_topic_message_retention # 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_topic_message_retention(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateTopicMessageRetentionRequest body: (required) :return: UpdateTopicMessageRetentionResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.update_topic_message_retention_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.update_topic_message_retention_with_http_info(body, **kwargs) # noqa: E501 return data def update_topic_message_retention_with_http_info(self, body, **kwargs): # noqa: E501 """update_topic_message_retention # 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_topic_message_retention_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateTopicMessageRetentionRequest body: (required) :return: UpdateTopicMessageRetentionResponse 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_topic_message_retention" % 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_topic_message_retention`") # 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( '/UpdateTopicMessageRetention/2023-06-01/bmq/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='UpdateTopicMessageRetentionResponse', # 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)