
    ~i$                    J    d Z ddlmZ ddlZddlZddlZ G d de          ZdS )z
    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
    )absolute_importNc                      e Zd ZdZdLdZd Zd Zd Zd Zd Z	d	 Z
d
 Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Z d  Z!d! Z"d" Z#d# Z$d$ Z%d% Z&d& Z'd' Z(d( Z)d) Z*d* Z+d+ Z,d, Z-d- Z.d. Z/d/ Z0d0 Z1d1 Z2d2 Z3d3 Z4d4 Z5d5 Z6d6 Z7d7 Z8d8 Z9d9 Z:d: Z;d; Z<d< Z=d= Z>d> Z?d? Z@d@ ZAdA ZBdB ZCdC ZDdD ZEdE ZFdF ZGdG ZHdH ZIdI ZJdJ ZKdK ZLdS )MBMQApizNOTE: 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
    Nc                 >    |t          j                    }|| _        d S N)volcenginesdkcore	ApiClient
api_client)selfr
   s     e/root/.openclaw/workspace/.venvs/ark-sdk/lib/python3.11/site-packages/volcenginesdkbmq/api/bmq_api.py__init__zBMQApi.__init__   s!    *466J$    c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        T_return_http_data_only	async_req)getcreate_group_with_http_infor   bodykwargsdatas       r   create_groupzBMQApi.create_group$   ]     ,0'(::k"" 	343DCCFCCC5T5dEEfEETKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   _preload_content_request_timeoutr   z>Got an unexpected keyword argument '%s' to method create_groupNzAMissing the required parameter `body` when calling `create_group`application/jsonAcceptContent-TypevolcengineSignz2/CreateGroup/2023-06-01/bmq/post/application_json/POSTCreateGroupResponseT
r   post_paramsfilesresponse_typeauth_settingsr   r   r   r   collection_formatsappendlocalssix	iteritems	TypeErrorr
   client_side_validation
ValueErrorselect_header_acceptselect_header_content_typecall_apir   r   r   r   
all_paramsparamskeyvalr(   path_paramsquery_paramsheader_paramsform_paramslocal_var_filesbody_paramsr'   s                  r   r   z"BMQApi.create_group_with_http_info9       X
+&&&2333,---,---fX&677 	 	HC*$$.034   F3KK8?1 	bvV7K7K7=f~7M`aaaV .K"&/"F"F #" #"h )-(R(R )" )"n% **''@&#!/'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   create_instance_with_http_infor   s       r   create_instancezBMQApi.create_instance   ]     ,0'(::k"" 	646tFFvFFF8T8HHHHTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zAGot an unexpected keyword argument '%s' to method create_instanceNzDMissing the required parameter `body` when calling `create_instance`r   r   r   r    z5/CreateInstance/2023-06-01/bmq/post/application_json/r!   CreateInstanceResponseTr#   r)   r4   s                  r   rA   z%BMQApi.create_instance_with_http_info       X
+&&&2333,---,---fX&677 	 	HC*$$1367   F3KK8?1 	evV7K7K7=f~7McdddV .K"&/"F"F #" #"h )-(R(R )" )"n% **''CV#!2'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   create_topic_with_http_infor   s       r   create_topiczBMQApi.create_topic   r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   z>Got an unexpected keyword argument '%s' to method create_topicNzAMissing the required parameter `body` when calling `create_topic`r   r   r   r    z2/CreateTopic/2023-06-01/bmq/post/application_json/r!   CreateTopicResponseTr#   r)   r4   s                  r   rH   z"BMQApi.create_topic_with_http_info   r?   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   delete_group_with_http_infor   s       r   delete_groupzBMQApi.delete_groupG  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   z>Got an unexpected keyword argument '%s' to method delete_groupNzAMissing the required parameter `body` when calling `delete_group`r   r   r   r    z2/DeleteGroup/2023-06-01/bmq/post/application_json/r!   DeleteGroupResponseTr#   r)   r4   s                  r   rM   z"BMQApi.delete_group_with_http_info\  r?   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   delete_instance_with_http_infor   s       r   delete_instancezBMQApi.delete_instance  rC   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zAGot an unexpected keyword argument '%s' to method delete_instanceNzDMissing the required parameter `body` when calling `delete_instance`r   r   r   r    z5/DeleteInstance/2023-06-01/bmq/post/application_json/r!   DeleteInstanceResponseTr#   r)   r4   s                  r   rR   z%BMQApi.delete_instance_with_http_info  rF   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   delete_topic_with_http_infor   s       r   delete_topiczBMQApi.delete_topic	  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   z>Got an unexpected keyword argument '%s' to method delete_topicNzAMissing the required parameter `body` when calling `delete_topic`r   r   r   r    z2/DeleteTopic/2023-06-01/bmq/post/application_json/r!   DeleteTopicResponseTr#   r)   r4   s                  r   rW   z"BMQApi.delete_topic_with_http_info  r?   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   'describe_available_zones_with_http_infor   s       r   describe_available_zoneszBMQApi.describe_available_zonesj  ]     ,0'(::k"" 	?4?OOOOOATA$QQ&QQTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a&  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.
        r   r   r   r   r   r   zJGot an unexpected keyword argument '%s' to method describe_available_zonesNzMMissing the required parameter `body` when calling `describe_available_zones`r   r   r   r    z=/DescribeAvailableZones/2023-06-01/bmq/post/application_json/r!   DescribeAvailableZonesResponseTr#   r)   r4   s                  r   r\   z.BMQApi.describe_available_zones_with_http_info  s    X
+&&&2333,---,---fX&677 	 	HC*$$:<?@   F3KK8?1 	nvV7K7K7=f~7MlmmmV .K"&/"F"F #" #"h )-(R(R )" )"n% **''KV#!:'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   describe_group_with_http_infor   s       r   describe_groupzBMQApi.describe_group  ]     ,0'(::k"" 	545dEEfEEE7T7GGGGTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a   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.
        r   r   r   r   r   r   z@Got an unexpected keyword argument '%s' to method describe_groupNzCMissing the required parameter `body` when calling `describe_group`r   r   r   r    z4/DescribeGroup/2023-06-01/bmq/post/application_json/r!   DescribeGroupResponseTr#   r)   r4   s                  r   rb   z$BMQApi.describe_group_with_http_info      X
+&&&2333,---,---fX&677 	 	HC*$$0256   F3KK8?1 	dvV7K7K7=f~7MbcccV .K"&/"F"F #" #"h )-(R(R )" )"n% **''BF#!1'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   'describe_groups_in_topic_with_http_infor   s       r   describe_groups_in_topiczBMQApi.describe_groups_in_topic,  r^   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a$  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.
        r   r   r   r   r   r   zJGot an unexpected keyword argument '%s' to method describe_groups_in_topicNzMMissing the required parameter `body` when calling `describe_groups_in_topic`r   r   r   r    z</DescribeGroupsInTopic/2023-06-01/bmq/post/application_json/r!   DescribeGroupsInTopicResponseTr#   r)   r4   s                  r   ri   z.BMQApi.describe_groups_in_topic_with_http_infoA      X
+&&&2333,---,---fX&677 	 	HC*$$:<?@   F3KK8?1 	nvV7K7K7=f~7MlmmmV .K"&/"F"F #" #"h )-(R(R )" )"n% **''JF#!9'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r    describe_instance_with_http_infor   s       r   describe_instancezBMQApi.describe_instance  s]     ,0'(::k"" 	848HHHHH:T:4JJ6JJTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zCGot an unexpected keyword argument '%s' to method describe_instanceNzFMissing the required parameter `body` when calling `describe_instance`r   r   r   r    z7/DescribeInstance/2023-06-01/bmq/post/application_json/r!   DescribeInstanceResponseTr#   r)   r4   s                  r   ro   z'BMQApi.describe_instance_with_http_info  s    X
+&&&2333,---,---fX&677 	 	HC*$$3589   F3KK8?1 	gvV7K7K7=f~7MefffV .K"&/"F"F #" #"h )-(R(R )" )"n% **''Ev#!4'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a1  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.
        Tr   r   )r   .describe_instance_resource_stat_with_http_infor   s       r   describe_instance_resource_statz&BMQApi.describe_instance_resource_stat  s^     ,0'(::k"" 	F4FtVVvVVVHTHXXQWXXTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a@  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.
        r   r   r   r   r   r   zQGot an unexpected keyword argument '%s' to method describe_instance_resource_statNzTMissing the required parameter `body` when calling `describe_instance_resource_stat`r   r   r   r    zC/DescribeInstanceResourceStat/2023-06-01/bmq/post/application_json/r!   $DescribeInstanceResourceStatResponseTr#   r)   r4   s                  r   rt   z5BMQApi.describe_instance_resource_stat_with_http_info  s    X
+&&&2333,---,---fX&677 	 	HC*$$ACFG   F3KK8?1 	uvV7K7K7=f~7MstttV .K"&/"F"F #" #"h )-(R(R )" )"n% **''QSY#!@'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a%  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.
        Tr   r   )r   +describe_partitions_in_topic_with_http_infor   s       r   describe_partitions_in_topicz#BMQApi.describe_partitions_in_topicO  ]     ,0'(::k"" 	C4CDSSFSSSETEdUUfUUTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a4  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.
        r   r   r   r   r   r   zNGot an unexpected keyword argument '%s' to method describe_partitions_in_topicNzQMissing the required parameter `body` when calling `describe_partitions_in_topic`r   r   r   r    z@/DescribePartitionsInTopic/2023-06-01/bmq/post/application_json/r!   !DescribePartitionsInTopicResponseTr#   r)   r4   s                  r   ry   z2BMQApi.describe_partitions_in_topic_with_http_infod      X
+&&&2333,---,---fX&677 	 	HC*$$>@CD   F3KK8?1 	rvV7K7K7=f~7MpqqqV .K"&/"F"F #" #"h )-(R(R )" )"n% **''NPV#!='jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   $describe_subscription_with_http_infor   s       r   describe_subscriptionzBMQApi.describe_subscription  ]     ,0'(::k"" 	<4<TLLVLLL>T>tNNvNNTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zGGot an unexpected keyword argument '%s' to method describe_subscriptionNzJMissing the required parameter `body` when calling `describe_subscription`r   r   r   r    z;/DescribeSubscription/2023-06-01/bmq/post/application_json/r!   DescribeSubscriptionResponseTr#   r)   r4   s                  r   r   z+BMQApi.describe_subscription_with_http_info  s    X
+&&&2333,---,---fX&677 	 	HC*$$79<=   F3KK8?1 	kvV7K7K7=f~7MijjjV .K"&/"F"F #" #"h )-(R(R )" )"n% **''I6#!8'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   describe_topic_with_http_infor   s       r   describe_topiczBMQApi.describe_topic  rd   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a   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.
        r   r   r   r   r   r   z@Got an unexpected keyword argument '%s' to method describe_topicNzCMissing the required parameter `body` when calling `describe_topic`r   r   r   r    z4/DescribeTopic/2023-06-01/bmq/post/application_json/r!   DescribeTopicResponseTr#   r)   r4   s                  r   r   z$BMQApi.describe_topic_with_http_info&  rg   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   (describe_topic_time_range_with_http_infor   s       r   describe_topic_time_rangez BMQApi.describe_topic_time_ranger  ]     ,0'(::k"" 	@4@PPPPPBTB4RR6RRTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a(  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.
        r   r   r   r   r   r   zKGot an unexpected keyword argument '%s' to method describe_topic_time_rangeNzNMissing the required parameter `body` when calling `describe_topic_time_range`r   r   r   r    z=/DescribeTopicTimeRange/2023-06-01/bmq/post/application_json/r!   DescribeTopicTimeRangeResponseTr#   r)   r4   s                  r   r   z/BMQApi.describe_topic_time_range_with_http_info  s    X
+&&&2333,---,---fX&677 	 	HC*$$;=@A   F3KK8?1 	ovV7K7K7=f~7MmnnnV .K"&/"F"F #" #"h )-(R(R )" )"n% **''KV#!:'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   'describe_topics_in_group_with_http_infor   s       r   describe_topics_in_groupzBMQApi.describe_topics_in_group  r^   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a$  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.
        r   r   r   r   r   r   zJGot an unexpected keyword argument '%s' to method describe_topics_in_groupNzMMissing the required parameter `body` when calling `describe_topics_in_group`r   r   r   r    z</DescribeTopicsInGroup/2023-06-01/bmq/post/application_json/r!   DescribeTopicsInGroupResponseTr#   r)   r4   s                  r   r   z.BMQApi.describe_topics_in_group_with_http_info  rm   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   %disable_overlay_access_with_http_infor   s       r   disable_overlay_accesszBMQApi.disable_overlay_access4  s]     ,0'(::k"" 	=4=dMMfMMM?T?OOOOTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zHGot an unexpected keyword argument '%s' to method disable_overlay_accessNzKMissing the required parameter `body` when calling `disable_overlay_access`r   r   r   r    z;/DisableOverlayAccess/2023-06-01/bmq/post/application_json/r!   DisableOverlayAccessResponseTr#   r)   r4   s                  r   r   z,BMQApi.disable_overlay_access_with_http_infoI  s    X
+&&&2333,---,---fX&677 	 	HC*$$8:=>   F3KK8?1 	lvV7K7K7=f~7MjkkkV .K"&/"F"F #" #"h )-(R(R )" )"n% **''I6#!8'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   $disable_public_access_with_http_infor   s       r   disable_public_accesszBMQApi.disable_public_access  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zGGot an unexpected keyword argument '%s' to method disable_public_accessNzJMissing the required parameter `body` when calling `disable_public_access`r   r   r   r    z:/DisablePublicAccess/2023-06-01/bmq/post/application_json/r!   DisablePublicAccessResponseTr#   r)   r4   s                  r   r   z+BMQApi.disable_public_access_with_http_info      X
+&&&2333,---,---fX&677 	 	HC*$$79<=   F3KK8?1 	kvV7K7K7=f~7MijjjV .K"&/"F"F #" #"h )-(R(R )" )"n% **''H&#!7'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   $enable_overlay_access_with_http_infor   s       r   enable_overlay_accesszBMQApi.enable_overlay_access  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zGGot an unexpected keyword argument '%s' to method enable_overlay_accessNzJMissing the required parameter `body` when calling `enable_overlay_access`r   r   r   r    z:/EnableOverlayAccess/2023-06-01/bmq/post/application_json/r!   EnableOverlayAccessResponseTr#   r)   r4   s                  r   r   z+BMQApi.enable_overlay_access_with_http_info  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   #enable_public_access_with_http_infor   s       r   enable_public_accesszBMQApi.enable_public_accessW  s]     ,0'(::k"" 	;4;DKKFKKK=T=dMMfMMTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zFGot an unexpected keyword argument '%s' to method enable_public_accessNzIMissing the required parameter `body` when calling `enable_public_access`r   r   r   r    z9/EnablePublicAccess/2023-06-01/bmq/post/application_json/r!   EnablePublicAccessResponseTr#   r)   r4   s                  r   r   z*BMQApi.enable_public_access_with_http_infol  s    X
+&&&2333,---,---fX&677 	 	HC*$$68;<   F3KK8?1 	jvV7K7K7=f~7MhiiiV .K"&/"F"F #" #"h )-(R(R )" )"n% **''G#!6'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   group_exist_with_http_infor   s       r   group_existzBMQApi.group_exist  s]     ,0'(::k"" 	2424BB6BBB4T4TDDVDDTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   z=Got an unexpected keyword argument '%s' to method group_existNz@Missing the required parameter `body` when calling `group_exist`r   r   r   r    z1/GroupExist/2023-06-01/bmq/post/application_json/r!   GroupExistResponseTr#   r)   r4   s                  r   r   z!BMQApi.group_exist_with_http_info  s    X
+&&&2333,---,---fX&677 	 	HC*$$-/23   F3KK8?1 	avV7K7K7=f~7M_```V .K"&/"F"F #" #"h )-(R(R )" )"n% **''?#!.'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )aI  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.
        Tr   r   )r   5list_available_security_groups_for_bmq_with_http_infor   s       r   &list_available_security_groups_for_bmqz-BMQApi.list_available_security_groups_for_bmq  s`     ,0'(::k"" 	M4Md]]V\]]]OTOPT__X^__TKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )aX  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.
        r   r   r   r   r   r   zXGot an unexpected keyword argument '%s' to method list_available_security_groups_for_bmqNz[Missing the required parameter `body` when calling `list_available_security_groups_for_bmq`r   r   r   r    zH/ListAvailableSecurityGroupsForBMQ/2023-06-01/bmq/post/application_json/r!   )ListAvailableSecurityGroupsForBMQResponseTr#   r)   r4   s                  r   r   z<BMQApi.list_available_security_groups_for_bmq_with_http_info.  s    X
+&&&2333,---,---fX&677 	 	HC*$$HJMN   F3KK8?1 	|vV7K7K7=f~7Mz{{{V .K"&/"F"F #" #"h )-(R(R )" )"n% **''VX^#!E'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a+  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.
        Tr   r   )r   -list_available_subnets_for_bmq_with_http_infor   s       r   list_available_subnets_for_bmqz%BMQApi.list_available_subnets_for_bmqz  ^     ,0'(::k"" 	E4EdUUfUUUGTGWWPVWWTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a:  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.
        r   r   r   r   r   r   zPGot an unexpected keyword argument '%s' to method list_available_subnets_for_bmqNzSMissing the required parameter `body` when calling `list_available_subnets_for_bmq`r   r   r   r    zA/ListAvailableSubnetsForBMQ/2023-06-01/bmq/post/application_json/r!   "ListAvailableSubnetsForBMQResponseTr#   r)   r4   s                  r   r   z4BMQApi.list_available_subnets_for_bmq_with_http_info  s    X
+&&&2333,---,---fX&677 	 	HC*$$@BEF   F3KK8?1 	tvV7K7K7=f~7MrsssV .K"&/"F"F #" #"h )-(R(R )" )"n% **''OQW#!>'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   )list_available_vpc_for_bmq_with_http_infor   s       r   list_available_vpc_for_bmqz!BMQApi.list_available_vpc_for_bmq  s]     ,0'(::k"" 	A4A$QQ&QQQCTCDSSFSSTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a*  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.
        r   r   r   r   r   r   zLGot an unexpected keyword argument '%s' to method list_available_vpc_for_bmqNzOMissing the required parameter `body` when calling `list_available_vpc_for_bmq`r   r   r   r    z=/ListAvailableVPCForBMQ/2023-06-01/bmq/post/application_json/r!   ListAvailableVPCForBMQResponseTr#   r)   r4   s                  r   r   z0BMQApi.list_available_vpc_for_bmq_with_http_info  s    X
+&&&2333,---,---fX&677 	 	HC*$$<>AB   F3KK8?1 	pvV7K7K7=f~7MnoooV .K"&/"F"F #" #"h )-(R(R )" )"n% **''KV#!:'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a%  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.
        Tr   r   )r   +list_instance_resource_stats_with_http_infor   s       r   list_instance_resource_statsz#BMQApi.list_instance_resource_stats<	  r{   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a4  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.
        r   r   r   r   r   r   zNGot an unexpected keyword argument '%s' to method list_instance_resource_statsNzQMissing the required parameter `body` when calling `list_instance_resource_stats`r   r   r   r    z@/ListInstanceResourceStats/2023-06-01/bmq/post/application_json/r!   !ListInstanceResourceStatsResponseTr#   r)   r4   s                  r   r   z2BMQApi.list_instance_resource_stats_with_http_infoQ	  r~   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   "list_specifications_with_http_infor   s       r   list_specificationszBMQApi.list_specifications	  ]     ,0'(::k"" 	:4:4JJ6JJJ<T<TLLVLLTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zEGot an unexpected keyword argument '%s' to method list_specificationsNzHMissing the required parameter `body` when calling `list_specifications`r   r   r   r    z9/ListSpecifications/2023-06-01/bmq/post/application_json/r!   ListSpecificationsResponseTr#   r)   r4   s                  r   r   z)BMQApi.list_specifications_with_http_info	  s    X
+&&&2333,---,---fX&677 	 	HC*$$57:;   F3KK8?1 	ivV7K7K7=f~7MghhhV .K"&/"F"F #" #"h )-(R(R )" )"n% **''G#!6'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   "modify_instance_tag_with_http_infor   s       r   modify_instance_tagzBMQApi.modify_instance_tag	  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zEGot an unexpected keyword argument '%s' to method modify_instance_tagNzHMissing the required parameter `body` when calling `modify_instance_tag`r   r   r   r    z8/ModifyInstanceTag/2023-06-01/bmq/post/application_json/r!   ModifyInstanceTagResponseTr#   r)   r4   s                  r   r   z)BMQApi.modify_instance_tag_with_http_info
  s    X
+&&&2333,---,---fX&677 	 	HC*$$57:;   F3KK8?1 	ivV7K7K7=f~7MghhhV .K"&/"F"F #" #"h )-(R(R )" )"n% **''F#!5'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   $modify_overlay_access_with_http_infor   s       r   modify_overlay_accesszBMQApi.modify_overlay_access_
  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zGGot an unexpected keyword argument '%s' to method modify_overlay_accessNzJMissing the required parameter `body` when calling `modify_overlay_access`r   r   r   r    z:/ModifyOverlayAccess/2023-06-01/bmq/post/application_json/r!   ModifyOverlayAccessResponseTr#   r)   r4   s                  r   r   z+BMQApi.modify_overlay_access_with_http_infot
  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   !preview_topic_data_with_http_infor   s       r   preview_topic_datazBMQApi.preview_topic_data
  s]     ,0'(::k"" 	949$II&III;T;DKKFKKTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zDGot an unexpected keyword argument '%s' to method preview_topic_dataNzGMissing the required parameter `body` when calling `preview_topic_data`r   r   r   r    z7/PreviewTopicData/2023-06-01/bmq/post/application_json/r!   PreviewTopicDataResponseTr#   r)   r4   s                  r   r   z(BMQApi.preview_topic_data_with_http_info
  s    X
+&&&2333,---,---fX&677 	 	HC*$$469:   F3KK8?1 	hvV7K7K7=f~7MfgggV .K"&/"F"F #" #"h )-(R(R )" )"n% **''Ev#!4'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   (reset_subscription_offset_with_http_infor   s       r   reset_subscription_offsetz BMQApi.reset_subscription_offset!  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a*  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.
        r   r   r   r   r   r   zKGot an unexpected keyword argument '%s' to method reset_subscription_offsetNzNMissing the required parameter `body` when calling `reset_subscription_offset`r   r   r   r    z>/ResetSubscriptionOffset/2023-06-01/bmq/post/application_json/r!   ResetSubscriptionOffsetResponseTr#   r)   r4   s                  r   r   z/BMQApi.reset_subscription_offset_with_http_info6  s    X
+&&&2333,---,---fX&677 	 	HC*$$;=@A   F3KK8?1 	ovV7K7K7=f~7MmnnnV .K"&/"F"F #" #"h )-(R(R )" )"n% **''Lf#!;'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   scale_up_topic_with_http_infor   s       r   scale_up_topiczBMQApi.scale_up_topic  rd   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   z@Got an unexpected keyword argument '%s' to method scale_up_topicNzCMissing the required parameter `body` when calling `scale_up_topic`r   r   r   r    z3/ScaleUpTopic/2023-06-01/bmq/post/application_json/r!   ScaleUpTopicResponseTr#   r)   r4   s                  r   r   z$BMQApi.scale_up_topic_with_http_info  s    X
+&&&2333,---,---fX&677 	 	HC*$$0256   F3KK8?1 	dvV7K7K7=f~7MbcccV .K"&/"F"F #" #"h )-(R(R )" )"n% **''A6#!0'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   search_groups_with_http_infor   s       r   search_groupszBMQApi.search_groups  ]     ,0'(::k"" 	444TDDVDDD6T6tFFvFFTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   z?Got an unexpected keyword argument '%s' to method search_groupsNzBMissing the required parameter `body` when calling `search_groups`r   r   r   r    z3/SearchGroups/2023-06-01/bmq/post/application_json/r!   SearchGroupsResponseTr#   r)   r4   s                  r   r   z#BMQApi.search_groups_with_http_info      X
+&&&2333,---,---fX&677 	 	HC*$$/145   F3KK8?1 	cvV7K7K7=f~7MabbbV .K"&/"F"F #" #"h )-(R(R )" )"n% **''A6#!0'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   search_instances_with_http_infor   s       r   search_instanceszBMQApi.search_instancesD  s]     ,0'(::k"" 	747GGGGG9T9$II&IITKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zBGot an unexpected keyword argument '%s' to method search_instancesNzEMissing the required parameter `body` when calling `search_instances`r   r   r   r    z6/SearchInstances/2023-06-01/bmq/post/application_json/r!   SearchInstancesResponseTr#   r)   r4   s                  r   r   z&BMQApi.search_instances_with_http_infoY  s    X
+&&&2333,---,---fX&677 	 	HC*$$2478   F3KK8?1 	fvV7K7K7=f~7MdeeeV .K"&/"F"F #" #"h )-(R(R )" )"n% **''Df#!3'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   search_topics_with_http_infor   s       r   search_topicszBMQApi.search_topics  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   z?Got an unexpected keyword argument '%s' to method search_topicsNzBMissing the required parameter `body` when calling `search_topics`r   r   r   r    z3/SearchTopics/2023-06-01/bmq/post/application_json/r!   SearchTopicsResponseTr#   r)   r4   s                  r   r   z#BMQApi.search_topics_with_http_info  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a9  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.
        Tr   r   )r   0update_instance_message_retention_with_http_infor   s       r   !update_instance_message_retentionz(BMQApi.update_instance_message_retention  s_     ,0'(::k"" 	H4HXXQWXXXJTJ4ZZSYZZTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )aH  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.
        r   r   r   r   r   r   zSGot an unexpected keyword argument '%s' to method update_instance_message_retentionNzVMissing the required parameter `body` when calling `update_instance_message_retention`r   r   r   r    zE/UpdateInstanceMessageRetention/2023-06-01/bmq/post/application_json/r!   &UpdateInstanceMessageRetentionResponseTr#   r)   r4   s                  r   r   z7BMQApi.update_instance_message_retention_with_http_info  s    X
+&&&2333,---,---fX&677 	 	HC*$$CEHI   F3KK8?1 	wvV7K7K7=f~7MuvvvV .K"&/"F"F #" #"h )-(R(R )" )"n% **''SU[#!B'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a-  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.
        Tr   r   )r   -update_topic_message_retention_with_http_infor   s       r   update_topic_message_retentionz%BMQApi.update_topic_message_retentiong  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a<  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.
        r   r   r   r   r   r   zPGot an unexpected keyword argument '%s' to method update_topic_message_retentionNzSMissing the required parameter `body` when calling `update_topic_message_retention`r   r   r   r    zB/UpdateTopicMessageRetention/2023-06-01/bmq/post/application_json/r!   #UpdateTopicMessageRetentionResponseTr#   r)   r4   s                  r   r   z4BMQApi.update_topic_message_retention_with_http_info|  s    X
+&&&2333,---,---fX&677 	 	HC*$$@BEF   F3KK8?1 	tvV7K7K7=f~7MrsssV .K"&/"F"F #" #"h )-(R(R )" )"n% **''PRX#!?'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   r   )M__name__
__module____qualname____doc__r   r   r   rB   rA   rI   rH   rN   rM   rS   rR   rX   rW   r]   r\   rc   rb   rj   ri   rp   ro   ru   rt   rz   ry   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r    r   r   r   r      s        % % % %
  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3 J3 J3r   r   )r  
__future__r   rer,   r   objectr   r  r   r   <module>r     s     ' & & & & & 				 


    n63 n63 n63 n63 n63V n63 n63 n63 n63 n63r   