| # Licensed to the Apache Software Foundation (ASF) under one or more |
| # contributor license agreements. See the NOTICE file distributed with |
| # this work for additional information regarding copyright ownership. |
| # The ASF licenses this file to You under the Apache License, Version 2.0 |
| # (the "License"); you may not use this file except in compliance with |
| # the License. You may obtain a copy of the License at |
| # |
| # http://www.apache.org/licenses/LICENSE-2.0 |
| # |
| # Unless required by applicable law or agreed to in writing, software |
| # distributed under the License is distributed on an "AS IS" BASIS, |
| # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| # See the License for the specific language governing permissions and |
| # limitations under the License. |
| |
| # coding: utf-8 |
| |
| """ |
| Submarine API |
| |
| The Submarine REST API allows you to access Submarine resources such as, experiments, environments and notebooks. The API is hosted under the /v1 path on the Submarine server. For example, to list experiments on a server hosted at http://localhost:8080, access http://localhost:8080/api/v1/experiment/ # noqa: E501 |
| |
| The version of the OpenAPI document: 0.8.0 |
| Contact: dev@submarine.apache.org |
| Generated by: https://openapi-generator.tech |
| """ |
| |
| |
| from __future__ import absolute_import |
| |
| import re # noqa: F401 |
| |
| # python 2 and python 3 compatibility library |
| import six |
| |
| from submarine.client.api_client import ApiClient |
| from submarine.client.exceptions import ApiTypeError, ApiValueError # noqa: F401 |
| |
| |
| class AuthApi(object): |
| """NOTE: This class is auto generated by OpenAPI Generator |
| Ref: https://openapi-generator.tech |
| |
| Do not edit the class manually. |
| """ |
| |
| def __init__(self, api_client=None): |
| if api_client is None: |
| api_client = ApiClient() |
| self.api_client = api_client |
| |
| def token(self, **kwargs): # noqa: E501 |
| """Get submarine user token # noqa: E501 |
| |
| Return user token by username and password # noqa: E501 |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.token(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param LoginParam login_param: |
| :param _preload_content: if False, the urllib3.HTTPResponse object will |
| be returned without reading/decoding response |
| data. Default is True. |
| :param _request_timeout: timeout setting for this request. If one |
| number provided, it will be total request |
| timeout. It can also be a pair (tuple) of |
| (connection, read) timeouts. |
| :return: str |
| If the method is called asynchronously, |
| returns the request thread. |
| """ |
| kwargs['_return_http_data_only'] = True |
| return self.token_with_http_info(**kwargs) # noqa: E501 |
| |
| def token_with_http_info(self, **kwargs): # noqa: E501 |
| """Get submarine user token # noqa: E501 |
| |
| Return user token by username and password # noqa: E501 |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.token_with_http_info(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param LoginParam login_param: |
| :param _return_http_data_only: response data without head status code |
| and headers |
| :param _preload_content: if False, the urllib3.HTTPResponse object will |
| be returned without reading/decoding response |
| data. Default is True. |
| :param _request_timeout: timeout setting for this request. If one |
| number provided, it will be total request |
| timeout. It can also be a pair (tuple) of |
| (connection, read) timeouts. |
| :return: tuple(str, status_code(int), headers(HTTPHeaderDict)) |
| If the method is called asynchronously, |
| returns the request thread. |
| """ |
| |
| local_var_params = locals() |
| |
| all_params = ['login_param'] |
| all_params.extend(['async_req', '_return_http_data_only', '_preload_content', '_request_timeout']) |
| |
| for key, val in six.iteritems(local_var_params['kwargs']): |
| if key not in all_params: |
| raise ApiTypeError("Got an unexpected keyword argument '%s' to method token" % key) |
| local_var_params[key] = val |
| del local_var_params['kwargs'] |
| |
| collection_formats = {} |
| |
| path_params = {} |
| |
| query_params = [] |
| |
| header_params = {} |
| |
| form_params = [] |
| local_var_files = {} |
| |
| body_params = None |
| if 'login_param' in local_var_params: |
| body_params = local_var_params['login_param'] |
| # HTTP header `Accept` |
| header_params['Accept'] = self.api_client.select_header_accept(['application/json']) # noqa: E501 |
| |
| # HTTP header `Content-Type` |
| header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 |
| ['application/json'] |
| ) # noqa: E501 |
| |
| # Authentication setting |
| auth_settings = [] # noqa: E501 |
| |
| return self.api_client.call_api( |
| '/auth/token', |
| 'POST', |
| path_params, |
| query_params, |
| header_params, |
| body=body_params, |
| post_params=form_params, |
| files=local_var_files, |
| response_type='str', # noqa: E501 |
| auth_settings=auth_settings, |
| async_req=local_var_params.get('async_req'), |
| _return_http_data_only=local_var_params.get('_return_http_data_only'), # noqa: E501 |
| _preload_content=local_var_params.get('_preload_content', True), |
| _request_timeout=local_var_params.get('_request_timeout'), |
| collection_formats=collection_formats, |
| ) |