
    ~i`P                     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 )a   
    flink20250101

    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                   V    e Zd ZdZddZd Zd Zd Zd Zd Z	d	 Z
d
 Zd Zd Zd ZdS )FLINK20250101ApizNOTE: 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     y/root/.openclaw/workspace/.venvs/ark-sdk/lib/python3.11/site-packages/volcenginesdkflink20250101/api/flink20250101_api.py__init__zFLINK20250101Api.__init__   s!    *466J$    c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a#  cancel_application_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.cancel_application_instance(body, async_req=True)
        >>> result = thread.get()

        :param async_req bool
        :param CancelApplicationInstanceRequest body: (required)
        :return: CancelApplicationInstanceResponse
                 If the method is called asynchronously,
                 returns the request thread.
        T_return_http_data_only	async_req)get*cancel_application_instance_with_http_infor   bodykwargsdatas       r   cancel_application_instancez,FLINK20250101Api.cancel_application_instance$   s]     ,0'(::k"" 	B4B4RR6RRRDTDTTTVTTT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 )a2  cancel_application_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.cancel_application_instance_with_http_info(body, async_req=True)
        >>> result = thread.get()

        :param async_req bool
        :param CancelApplicationInstanceRequest body: (required)
        :return: CancelApplicationInstanceResponse
                 If the method is called asynchronously,
                 returns the request thread.
        r   r   r   _preload_content_request_timeoutr   zMGot an unexpected keyword argument '%s' to method cancel_application_instanceNzPMissing the required parameter `body` when calling `cancel_application_instance`application/jsonAcceptContent-TypevolcengineSignzB/CancelApplicationInstance/2025-01-01/flink/post/application_json/POST!CancelApplicationInstanceResponseT
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;FLINK20250101Api.cancel_application_instance_with_http_info9   s    X
+&&&2333,---,---fX&677 	 	HC*$$=?BC   F3KK8?1 	qvV7K7K7=f~7MopppV .K"&/"F"F #" #"h )-(R(R )" )"n% **''PRX#!='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  get_application_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.get_application_instance(body, async_req=True)
        >>> result = thread.get()

        :param async_req bool
        :param GetApplicationInstanceRequest body: (required)
        :return: GetApplicationInstanceResponse
                 If the method is called asynchronously,
                 returns the request thread.
        Tr   r   )r   'get_application_instance_with_http_infor   s       r   get_application_instancez)FLINK20250101Api.get_application_instance   s]     ,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&  get_application_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.get_application_instance_with_http_info(body, async_req=True)
        >>> result = thread.get()

        :param async_req bool
        :param GetApplicationInstanceRequest body: (required)
        :return: GetApplicationInstanceResponse
                 If the method is called asynchronously,
                 returns the request thread.
        r   r   r   r   r   r   zJGot an unexpected keyword argument '%s' to method get_application_instanceNzMMissing the required parameter `body` when calling `get_application_instance`r   r   r   r   z?/GetApplicationInstance/2025-01-01/flink/post/application_json/r    GetApplicationInstanceResponseTr"   r(   r3   s                  r   r?   z8FLINK20250101Api.get_application_instance_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% **''Mv#!:'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_application_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.list_application_instance(body, async_req=True)
        >>> result = thread.get()

        :param async_req bool
        :param ListApplicationInstanceRequest body: (required)
        :return: ListApplicationInstanceResponse
                 If the method is called asynchronously,
                 returns the request thread.
        Tr   r   )r   (list_application_instance_with_http_infor   s       r   list_application_instancez*FLINK20250101Api.list_application_instance   s]     ,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*  list_application_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.list_application_instance_with_http_info(body, async_req=True)
        >>> result = thread.get()

        :param async_req bool
        :param ListApplicationInstanceRequest body: (required)
        :return: ListApplicationInstanceResponse
                 If the method is called asynchronously,
                 returns the request thread.
        r   r   r   r   r   r   zKGot an unexpected keyword argument '%s' to method list_application_instanceNzNMissing the required parameter `body` when calling `list_application_instance`r   r   r   r   z@/ListApplicationInstance/2025-01-01/flink/post/application_json/r    ListApplicationInstanceResponseTr"   r(   r3   s                  r   rD   z9FLINK20250101Api.list_application_instance_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% **''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  restart_gws_application  # noqa: E501

        This method makes a synchronous HTTP request by default. To make an
        asynchronous HTTP request, please pass async_req=True
        >>> thread = api.restart_gws_application(body, async_req=True)
        >>> result = thread.get()

        :param async_req bool
        :param RestartGWSApplicationRequest body: (required)
        :return: RestartGWSApplicationResponse
                 If the method is called asynchronously,
                 returns the request thread.
        Tr   r   )r   &restart_gws_application_with_http_infor   s       r   restart_gws_applicationz(FLINK20250101Api.restart_gws_applicationG  s]     ,0'(::k"" 	>4>tNNvNNN@T@PPPPT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"  restart_gws_application  # noqa: E501

        This method makes a synchronous HTTP request by default. To make an
        asynchronous HTTP request, please pass async_req=True
        >>> thread = api.restart_gws_application_with_http_info(body, async_req=True)
        >>> result = thread.get()

        :param async_req bool
        :param RestartGWSApplicationRequest body: (required)
        :return: RestartGWSApplicationResponse
                 If the method is called asynchronously,
                 returns the request thread.
        r   r   r   r   r   r   zIGot an unexpected keyword argument '%s' to method restart_gws_applicationNzLMissing the required parameter `body` when calling `restart_gws_application`r   r   r   r   z>/RestartGWSApplication/2025-01-01/flink/post/application_json/r    RestartGWSApplicationResponseTr"   r(   r3   s                  r   rI   z7FLINK20250101Api.restart_gws_application_with_http_info\  s    X
+&&&2333,---,---fX&677 	 	HC*$$9;>?   F3KK8?1 	mvV7K7K7=f~7MklllV .K"&/"F"F #" #"h )-(R(R )" )"n% **''Lf#!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  start_application_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.start_application_instance(body, async_req=True)
        >>> result = thread.get()

        :param async_req bool
        :param StartApplicationInstanceRequest body: (required)
        :return: StartApplicationInstanceResponse
                 If the method is called asynchronously,
                 returns the request thread.
        Tr   r   )r   )start_application_instance_with_http_infor   s       r   start_application_instancez+FLINK20250101Api.start_application_instance  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.  start_application_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.start_application_instance_with_http_info(body, async_req=True)
        >>> result = thread.get()

        :param async_req bool
        :param StartApplicationInstanceRequest body: (required)
        :return: StartApplicationInstanceResponse
                 If the method is called asynchronously,
                 returns the request thread.
        r   r   r   r   r   r   zLGot an unexpected keyword argument '%s' to method start_application_instanceNzOMissing the required parameter `body` when calling `start_application_instance`r   r   r   r   zA/StartApplicationInstance/2025-01-01/flink/post/application_json/r     StartApplicationInstanceResponseTr"   r(   r3   s                  r   rN   z:FLINK20250101Api.start_application_instance_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% **''OQW#!<'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   r   )__name__
__module____qualname____doc__r   r   r   r@   r?   rE   rD   rJ   rI   rO   rN    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3 J3 J3r   r   )rU   
__future__r   rer+   r   objectr   rV   r   r   <module>rZ      s     ' & & & & & 				 


    o3 o3 o3 o3 o3v o3 o3 o3 o3 o3r   