1585346868/aliyun-openapi-cpp-sdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Supported ListTaskFlow, ListTaskFlowInstance, GetTaskInstanceRelation, GetLhSpaceByName, DeleteLakeHouseSpace, DeleteTaskFlow API.

Browse Source
This commit is contained in:
sdk-team
2022-03-31 08:46:41 +00:00
parent cffe37f2e6
commit 692eef0b24
31 changed files with 1818 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
dms-enterprise/CMakeLists.txt
View File

@@ -65,6 +65,8 @@ set(dms-enterprise_public_header_model
include/alibabacloud/dms-enterprise/model/CreateUploadOSSFileJobResult.h
include/alibabacloud/dms-enterprise/model/DeleteInstanceRequest.h
include/alibabacloud/dms-enterprise/model/DeleteInstanceResult.h
include/alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceRequest.h
include/alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceResult.h
include/alibabacloud/dms-enterprise/model/DeleteLhMembersRequest.h
include/alibabacloud/dms-enterprise/model/DeleteLhMembersResult.h
include/alibabacloud/dms-enterprise/model/DeleteLogicDatabaseRequest.h
@@ -75,6 +77,8 @@ set(dms-enterprise_public_header_model
include/alibabacloud/dms-enterprise/model/DeleteProxyResult.h
include/alibabacloud/dms-enterprise/model/DeleteProxyAccessRequest.h
include/alibabacloud/dms-enterprise/model/DeleteProxyAccessResult.h
include/alibabacloud/dms-enterprise/model/DeleteTaskFlowRequest.h
include/alibabacloud/dms-enterprise/model/DeleteTaskFlowResult.h
include/alibabacloud/dms-enterprise/model/DeleteUserRequest.h
include/alibabacloud/dms-enterprise/model/DeleteUserResult.h
include/alibabacloud/dms-enterprise/model/DisableUserRequest.h
@@ -115,6 +119,8 @@ set(dms-enterprise_public_header_model
include/alibabacloud/dms-enterprise/model/GetDatabaseResult.h
include/alibabacloud/dms-enterprise/model/GetInstanceRequest.h
include/alibabacloud/dms-enterprise/model/GetInstanceResult.h
include/alibabacloud/dms-enterprise/model/GetLhSpaceByNameRequest.h
include/alibabacloud/dms-enterprise/model/GetLhSpaceByNameResult.h
include/alibabacloud/dms-enterprise/model/GetLogicDatabaseRequest.h
include/alibabacloud/dms-enterprise/model/GetLogicDatabaseResult.h
include/alibabacloud/dms-enterprise/model/GetMetaTableColumnRequest.h
@@ -149,6 +155,8 @@ set(dms-enterprise_public_header_model
include/alibabacloud/dms-enterprise/model/GetTableDBTopologyResult.h
include/alibabacloud/dms-enterprise/model/GetTableTopologyRequest.h
include/alibabacloud/dms-enterprise/model/GetTableTopologyResult.h
include/alibabacloud/dms-enterprise/model/GetTaskInstanceRelationRequest.h
include/alibabacloud/dms-enterprise/model/GetTaskInstanceRelationResult.h
include/alibabacloud/dms-enterprise/model/GetUserRequest.h
include/alibabacloud/dms-enterprise/model/GetUserResult.h
include/alibabacloud/dms-enterprise/model/GetUserActiveTenantRequest.h
@@ -211,6 +219,10 @@ set(dms-enterprise_public_header_model
include/alibabacloud/dms-enterprise/model/ListStandardGroupsResult.h
include/alibabacloud/dms-enterprise/model/ListTablesRequest.h
include/alibabacloud/dms-enterprise/model/ListTablesResult.h
include/alibabacloud/dms-enterprise/model/ListTaskFlowRequest.h
include/alibabacloud/dms-enterprise/model/ListTaskFlowResult.h
include/alibabacloud/dms-enterprise/model/ListTaskFlowInstanceRequest.h
include/alibabacloud/dms-enterprise/model/ListTaskFlowInstanceResult.h
include/alibabacloud/dms-enterprise/model/ListUserPermissionsRequest.h
include/alibabacloud/dms-enterprise/model/ListUserPermissionsResult.h
include/alibabacloud/dms-enterprise/model/ListUserTenantsRequest.h
@@ -302,6 +314,8 @@ set(dms-enterprise_src
src/model/CreateUploadOSSFileJobResult.cc
src/model/DeleteInstanceRequest.cc
src/model/DeleteInstanceResult.cc
src/model/DeleteLakeHouseSpaceRequest.cc
src/model/DeleteLakeHouseSpaceResult.cc
src/model/DeleteLhMembersRequest.cc
src/model/DeleteLhMembersResult.cc
src/model/DeleteLogicDatabaseRequest.cc
@@ -312,6 +326,8 @@ set(dms-enterprise_src
src/model/DeleteProxyResult.cc
src/model/DeleteProxyAccessRequest.cc
src/model/DeleteProxyAccessResult.cc
src/model/DeleteTaskFlowRequest.cc
src/model/DeleteTaskFlowResult.cc
src/model/DeleteUserRequest.cc
src/model/DeleteUserResult.cc
src/model/DisableUserRequest.cc
@@ -352,6 +368,8 @@ set(dms-enterprise_src
src/model/GetDatabaseResult.cc
src/model/GetInstanceRequest.cc
src/model/GetInstanceResult.cc
src/model/GetLhSpaceByNameRequest.cc
src/model/GetLhSpaceByNameResult.cc
src/model/GetLogicDatabaseRequest.cc
src/model/GetLogicDatabaseResult.cc
src/model/GetMetaTableColumnRequest.cc
@@ -386,6 +404,8 @@ set(dms-enterprise_src
src/model/GetTableDBTopologyResult.cc
src/model/GetTableTopologyRequest.cc
src/model/GetTableTopologyResult.cc
src/model/GetTaskInstanceRelationRequest.cc
src/model/GetTaskInstanceRelationResult.cc
src/model/GetUserRequest.cc
src/model/GetUserResult.cc
src/model/GetUserActiveTenantRequest.cc
@@ -448,6 +468,10 @@ set(dms-enterprise_src
src/model/ListStandardGroupsResult.cc
src/model/ListTablesRequest.cc
src/model/ListTablesResult.cc
src/model/ListTaskFlowRequest.cc
src/model/ListTaskFlowResult.cc
src/model/ListTaskFlowInstanceRequest.cc
src/model/ListTaskFlowInstanceResult.cc
src/model/ListUserPermissionsRequest.cc
src/model/ListUserPermissionsResult.cc
src/model/ListUserTenantsRequest.cc

48
dms-enterprise/include/alibabacloud/dms-enterprise/Dms_enterpriseClient.h
View File

@@ -66,6 +66,8 @@
#include "model/CreateUploadOSSFileJobResult.h"
#include "model/DeleteInstanceRequest.h"
#include "model/DeleteInstanceResult.h"
#include "model/DeleteLakeHouseSpaceRequest.h"
#include "model/DeleteLakeHouseSpaceResult.h"
#include "model/DeleteLhMembersRequest.h"
#include "model/DeleteLhMembersResult.h"
#include "model/DeleteLogicDatabaseRequest.h"
@@ -76,6 +78,8 @@
#include "model/DeleteProxyResult.h"
#include "model/DeleteProxyAccessRequest.h"
#include "model/DeleteProxyAccessResult.h"
#include "model/DeleteTaskFlowRequest.h"
#include "model/DeleteTaskFlowResult.h"
#include "model/DeleteUserRequest.h"
#include "model/DeleteUserResult.h"
#include "model/DisableUserRequest.h"
@@ -116,6 +120,8 @@
#include "model/GetDatabaseResult.h"
#include "model/GetInstanceRequest.h"
#include "model/GetInstanceResult.h"
#include "model/GetLhSpaceByNameRequest.h"
#include "model/GetLhSpaceByNameResult.h"
#include "model/GetLogicDatabaseRequest.h"
#include "model/GetLogicDatabaseResult.h"
#include "model/GetMetaTableColumnRequest.h"
@@ -150,6 +156,8 @@
#include "model/GetTableDBTopologyResult.h"
#include "model/GetTableTopologyRequest.h"
#include "model/GetTableTopologyResult.h"
#include "model/GetTaskInstanceRelationRequest.h"
#include "model/GetTaskInstanceRelationResult.h"
#include "model/GetUserRequest.h"
#include "model/GetUserResult.h"
#include "model/GetUserActiveTenantRequest.h"
@@ -212,6 +220,10 @@
#include "model/ListStandardGroupsResult.h"
#include "model/ListTablesRequest.h"
#include "model/ListTablesResult.h"
#include "model/ListTaskFlowRequest.h"
#include "model/ListTaskFlowResult.h"
#include "model/ListTaskFlowInstanceRequest.h"
#include "model/ListTaskFlowInstanceResult.h"
#include "model/ListUserPermissionsRequest.h"
#include "model/ListUserPermissionsResult.h"
#include "model/ListUserTenantsRequest.h"
@@ -331,6 +343,9 @@ namespace AlibabaCloud
typedef Outcome<Error, Model::DeleteInstanceResult> DeleteInstanceOutcome;
typedef std::future<DeleteInstanceOutcome> DeleteInstanceOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::DeleteInstanceRequest&, const DeleteInstanceOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> DeleteInstanceAsyncHandler;
typedef Outcome<Error, Model::DeleteLakeHouseSpaceResult> DeleteLakeHouseSpaceOutcome;
typedef std::future<DeleteLakeHouseSpaceOutcome> DeleteLakeHouseSpaceOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::DeleteLakeHouseSpaceRequest&, const DeleteLakeHouseSpaceOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> DeleteLakeHouseSpaceAsyncHandler;
typedef Outcome<Error, Model::DeleteLhMembersResult> DeleteLhMembersOutcome;
typedef std::future<DeleteLhMembersOutcome> DeleteLhMembersOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::DeleteLhMembersRequest&, const DeleteLhMembersOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> DeleteLhMembersAsyncHandler;
@@ -346,6 +361,9 @@ namespace AlibabaCloud
typedef Outcome<Error, Model::DeleteProxyAccessResult> DeleteProxyAccessOutcome;
typedef std::future<DeleteProxyAccessOutcome> DeleteProxyAccessOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::DeleteProxyAccessRequest&, const DeleteProxyAccessOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> DeleteProxyAccessAsyncHandler;
typedef Outcome<Error, Model::DeleteTaskFlowResult> DeleteTaskFlowOutcome;
typedef std::future<DeleteTaskFlowOutcome> DeleteTaskFlowOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::DeleteTaskFlowRequest&, const DeleteTaskFlowOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> DeleteTaskFlowAsyncHandler;
typedef Outcome<Error, Model::DeleteUserResult> DeleteUserOutcome;
typedef std::future<DeleteUserOutcome> DeleteUserOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::DeleteUserRequest&, const DeleteUserOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> DeleteUserAsyncHandler;
@@ -406,6 +424,9 @@ namespace AlibabaCloud
typedef Outcome<Error, Model::GetInstanceResult> GetInstanceOutcome;
typedef std::future<GetInstanceOutcome> GetInstanceOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::GetInstanceRequest&, const GetInstanceOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetInstanceAsyncHandler;
typedef Outcome<Error, Model::GetLhSpaceByNameResult> GetLhSpaceByNameOutcome;
typedef std::future<GetLhSpaceByNameOutcome> GetLhSpaceByNameOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::GetLhSpaceByNameRequest&, const GetLhSpaceByNameOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetLhSpaceByNameAsyncHandler;
typedef Outcome<Error, Model::GetLogicDatabaseResult> GetLogicDatabaseOutcome;
typedef std::future<GetLogicDatabaseOutcome> GetLogicDatabaseOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::GetLogicDatabaseRequest&, const GetLogicDatabaseOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetLogicDatabaseAsyncHandler;
@@ -457,6 +478,9 @@ namespace AlibabaCloud
typedef Outcome<Error, Model::GetTableTopologyResult> GetTableTopologyOutcome;
typedef std::future<GetTableTopologyOutcome> GetTableTopologyOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::GetTableTopologyRequest&, const GetTableTopologyOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetTableTopologyAsyncHandler;
typedef Outcome<Error, Model::GetTaskInstanceRelationResult> GetTaskInstanceRelationOutcome;
typedef std::future<GetTaskInstanceRelationOutcome> GetTaskInstanceRelationOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::GetTaskInstanceRelationRequest&, const GetTaskInstanceRelationOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetTaskInstanceRelationAsyncHandler;
typedef Outcome<Error, Model::GetUserResult> GetUserOutcome;
typedef std::future<GetUserOutcome> GetUserOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::GetUserRequest&, const GetUserOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetUserAsyncHandler;
@@ -550,6 +574,12 @@ namespace AlibabaCloud
typedef Outcome<Error, Model::ListTablesResult> ListTablesOutcome;
typedef std::future<ListTablesOutcome> ListTablesOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::ListTablesRequest&, const ListTablesOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListTablesAsyncHandler;
typedef Outcome<Error, Model::ListTaskFlowResult> ListTaskFlowOutcome;
typedef std::future<ListTaskFlowOutcome> ListTaskFlowOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::ListTaskFlowRequest&, const ListTaskFlowOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListTaskFlowAsyncHandler;
typedef Outcome<Error, Model::ListTaskFlowInstanceResult> ListTaskFlowInstanceOutcome;
typedef std::future<ListTaskFlowInstanceOutcome> ListTaskFlowInstanceOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::ListTaskFlowInstanceRequest&, const ListTaskFlowInstanceOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListTaskFlowInstanceAsyncHandler;
typedef Outcome<Error, Model::ListUserPermissionsResult> ListUserPermissionsOutcome;
typedef std::future<ListUserPermissionsOutcome> ListUserPermissionsOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::ListUserPermissionsRequest&, const ListUserPermissionsOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListUserPermissionsAsyncHandler;
@@ -687,6 +717,9 @@ namespace AlibabaCloud
DeleteInstanceOutcome deleteInstance(const Model::DeleteInstanceRequest &request)const;
void deleteInstanceAsync(const Model::DeleteInstanceRequest& request, const DeleteInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
DeleteInstanceOutcomeCallable deleteInstanceCallable(const Model::DeleteInstanceRequest& request) const;
DeleteLakeHouseSpaceOutcome deleteLakeHouseSpace(const Model::DeleteLakeHouseSpaceRequest &request)const;
void deleteLakeHouseSpaceAsync(const Model::DeleteLakeHouseSpaceRequest& request, const DeleteLakeHouseSpaceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
DeleteLakeHouseSpaceOutcomeCallable deleteLakeHouseSpaceCallable(const Model::DeleteLakeHouseSpaceRequest& request) const;
DeleteLhMembersOutcome deleteLhMembers(const Model::DeleteLhMembersRequest &request)const;
void deleteLhMembersAsync(const Model::DeleteLhMembersRequest& request, const DeleteLhMembersAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
DeleteLhMembersOutcomeCallable deleteLhMembersCallable(const Model::DeleteLhMembersRequest& request) const;
@@ -702,6 +735,9 @@ namespace AlibabaCloud
DeleteProxyAccessOutcome deleteProxyAccess(const Model::DeleteProxyAccessRequest &request)const;
void deleteProxyAccessAsync(const Model::DeleteProxyAccessRequest& request, const DeleteProxyAccessAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
DeleteProxyAccessOutcomeCallable deleteProxyAccessCallable(const Model::DeleteProxyAccessRequest& request) const;
DeleteTaskFlowOutcome deleteTaskFlow(const Model::DeleteTaskFlowRequest &request)const;
void deleteTaskFlowAsync(const Model::DeleteTaskFlowRequest& request, const DeleteTaskFlowAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
DeleteTaskFlowOutcomeCallable deleteTaskFlowCallable(const Model::DeleteTaskFlowRequest& request) const;
DeleteUserOutcome deleteUser(const Model::DeleteUserRequest &request)const;
void deleteUserAsync(const Model::DeleteUserRequest& request, const DeleteUserAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
DeleteUserOutcomeCallable deleteUserCallable(const Model::DeleteUserRequest& request) const;
@@ -762,6 +798,9 @@ namespace AlibabaCloud
GetInstanceOutcome getInstance(const Model::GetInstanceRequest &request)const;
void getInstanceAsync(const Model::GetInstanceRequest& request, const GetInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
GetInstanceOutcomeCallable getInstanceCallable(const Model::GetInstanceRequest& request) const;
GetLhSpaceByNameOutcome getLhSpaceByName(const Model::GetLhSpaceByNameRequest &request)const;
void getLhSpaceByNameAsync(const Model::GetLhSpaceByNameRequest& request, const GetLhSpaceByNameAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
GetLhSpaceByNameOutcomeCallable getLhSpaceByNameCallable(const Model::GetLhSpaceByNameRequest& request) const;
GetLogicDatabaseOutcome getLogicDatabase(const Model::GetLogicDatabaseRequest &request)const;
void getLogicDatabaseAsync(const Model::GetLogicDatabaseRequest& request, const GetLogicDatabaseAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
GetLogicDatabaseOutcomeCallable getLogicDatabaseCallable(const Model::GetLogicDatabaseRequest& request) const;
@@ -813,6 +852,9 @@ namespace AlibabaCloud
GetTableTopologyOutcome getTableTopology(const Model::GetTableTopologyRequest &request)const;
void getTableTopologyAsync(const Model::GetTableTopologyRequest& request, const GetTableTopologyAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
GetTableTopologyOutcomeCallable getTableTopologyCallable(const Model::GetTableTopologyRequest& request) const;
GetTaskInstanceRelationOutcome getTaskInstanceRelation(const Model::GetTaskInstanceRelationRequest &request)const;
void getTaskInstanceRelationAsync(const Model::GetTaskInstanceRelationRequest& request, const GetTaskInstanceRelationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
GetTaskInstanceRelationOutcomeCallable getTaskInstanceRelationCallable(const Model::GetTaskInstanceRelationRequest& request) const;
GetUserOutcome getUser(const Model::GetUserRequest &request)const;
void getUserAsync(const Model::GetUserRequest& request, const GetUserAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
GetUserOutcomeCallable getUserCallable(const Model::GetUserRequest& request) const;
@@ -906,6 +948,12 @@ namespace AlibabaCloud
ListTablesOutcome listTables(const Model::ListTablesRequest &request)const;
void listTablesAsync(const Model::ListTablesRequest& request, const ListTablesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
ListTablesOutcomeCallable listTablesCallable(const Model::ListTablesRequest& request) const;
ListTaskFlowOutcome listTaskFlow(const Model::ListTaskFlowRequest &request)const;
void listTaskFlowAsync(const Model::ListTaskFlowRequest& request, const ListTaskFlowAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
ListTaskFlowOutcomeCallable listTaskFlowCallable(const Model::ListTaskFlowRequest& request) const;
ListTaskFlowInstanceOutcome listTaskFlowInstance(const Model::ListTaskFlowInstanceRequest &request)const;
void listTaskFlowInstanceAsync(const Model::ListTaskFlowInstanceRequest& request, const ListTaskFlowInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
ListTaskFlowInstanceOutcomeCallable listTaskFlowInstanceCallable(const Model::ListTaskFlowInstanceRequest& request) const;
ListUserPermissionsOutcome listUserPermissions(const Model::ListUserPermissionsRequest &request)const;
void listUserPermissionsAsync(const Model::ListUserPermissionsRequest& request, const ListUserPermissionsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
ListUserPermissionsOutcomeCallable listUserPermissionsCallable(const Model::ListUserPermissionsRequest& request) const;

3
dms-enterprise/include/alibabacloud/dms-enterprise/model/CreateLakeHouseSpaceRequest.h
View File

@@ -34,8 +34,6 @@ public:
void setSpaceName(const std::string &spaceName);
std::string getDescription() const;
void setDescription(const std::string &description);
long getUserId() const;
void setUserId(long userId);
long getTid() const;
void setTid(long tid);
std::string getMode() const;
@@ -52,7 +50,6 @@ public:
private:
std::string spaceName_;
std::string description_;
long userId_;
long tid_;
std::string mode_;
std::string dwDbType_;

45
dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceRequest.h Normal file
View File

@@ -0,0 +1,45 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETELAKEHOUSESPACEREQUEST_H_
#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETELAKEHOUSESPACEREQUEST_H_
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <string>
#include <vector>
#include <map>
namespace AlibabaCloud {
namespace Dms_enterprise {
namespace Model {
class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT DeleteLakeHouseSpaceRequest : public RpcServiceRequest {
public:
DeleteLakeHouseSpaceRequest();
~DeleteLakeHouseSpaceRequest();
long getSpaceId() const;
void setSpaceId(long spaceId);
long getTid() const;
void setTid(long tid);
private:
long spaceId_;
long tid_;
};
} // namespace Model
} // namespace Dms_enterprise
} // namespace AlibabaCloud
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETELAKEHOUSESPACEREQUEST_H_

55
dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceResult.h Normal file
View File

@@ -0,0 +1,55 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETELAKEHOUSESPACERESULT_H_
#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETELAKEHOUSESPACERESULT_H_
#include <string>
#include <vector>
#include <utility>
#include <alibabacloud/core/ServiceResult.h>
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
namespace AlibabaCloud
{
namespace Dms_enterprise
{
namespace Model
{
class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT DeleteLakeHouseSpaceResult : public ServiceResult
{
public:
DeleteLakeHouseSpaceResult();
explicit DeleteLakeHouseSpaceResult(const std::string &payload);
~DeleteLakeHouseSpaceResult();
std::string getErrorCode()const;
std::string getErrorMessage()const;
bool getSuccess()const;
protected:
void parse(const std::string &payload);
private:
std::string errorCode_;
std::string errorMessage_;
bool success_;
};
}
}
}
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETELAKEHOUSESPACERESULT_H_

45
dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteTaskFlowRequest.h Normal file
View File

@@ -0,0 +1,45 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETETASKFLOWREQUEST_H_
#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETETASKFLOWREQUEST_H_
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <string>
#include <vector>
#include <map>
namespace AlibabaCloud {
namespace Dms_enterprise {
namespace Model {
class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT DeleteTaskFlowRequest : public RpcServiceRequest {
public:
DeleteTaskFlowRequest();
~DeleteTaskFlowRequest();
long getDagId() const;
void setDagId(long dagId);
long getTid() const;
void setTid(long tid);
private:
long dagId_;
long tid_;
};
} // namespace Model
} // namespace Dms_enterprise
} // namespace AlibabaCloud
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETETASKFLOWREQUEST_H_

55
dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteTaskFlowResult.h Normal file
View File

@@ -0,0 +1,55 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETETASKFLOWRESULT_H_
#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETETASKFLOWRESULT_H_
#include <string>
#include <vector>
#include <utility>
#include <alibabacloud/core/ServiceResult.h>
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
namespace AlibabaCloud
{
namespace Dms_enterprise
{
namespace Model
{
class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT DeleteTaskFlowResult : public ServiceResult
{
public:
DeleteTaskFlowResult();
explicit DeleteTaskFlowResult(const std::string &payload);
~DeleteTaskFlowResult();
std::string getErrorCode()const;
std::string getErrorMessage()const;
bool getSuccess()const;
protected:
void parse(const std::string &payload);
private:
std::string errorCode_;
std::string errorMessage_;
bool success_;
};
}
}
}
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETETASKFLOWRESULT_H_

45
dms-enterprise/include/alibabacloud/dms-enterprise/model/GetLhSpaceByNameRequest.h Normal file
View File

@@ -0,0 +1,45 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETLHSPACEBYNAMEREQUEST_H_
#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETLHSPACEBYNAMEREQUEST_H_
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <string>
#include <vector>
#include <map>
namespace AlibabaCloud {
namespace Dms_enterprise {
namespace Model {
class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetLhSpaceByNameRequest : public RpcServiceRequest {
public:
GetLhSpaceByNameRequest();
~GetLhSpaceByNameRequest();
std::string getSpaceName() const;
void setSpaceName(const std::string &spaceName);
long getTid() const;
void setTid(long tid);
private:
std::string spaceName_;
long tid_;
};
} // namespace Model
} // namespace Dms_enterprise
} // namespace AlibabaCloud
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETLHSPACEBYNAMEREQUEST_H_

71
dms-enterprise/include/alibabacloud/dms-enterprise/model/GetLhSpaceByNameResult.h Normal file
View File

@@ -0,0 +1,71 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETLHSPACEBYNAMERESULT_H_
#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETLHSPACEBYNAMERESULT_H_
#include <string>
#include <vector>
#include <utility>
#include <alibabacloud/core/ServiceResult.h>
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
namespace AlibabaCloud
{
namespace Dms_enterprise
{
namespace Model
{
class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetLhSpaceByNameResult : public ServiceResult
{
public:
struct LakehouseSpace
{
std::string tenantId;
bool isDeleted;
std::string description;
std::string spaceName;
std::string creatorId;
int mode;
long id;
std::string spaceConfig;
std::string dbType;
int devDbId;
int prodDbId;
};
GetLhSpaceByNameResult();
explicit GetLhSpaceByNameResult(const std::string &payload);
~GetLhSpaceByNameResult();
LakehouseSpace getLakehouseSpace()const;
std::string getErrorCode()const;
std::string getErrorMessage()const;
bool getSuccess()const;
protected:
void parse(const std::string &payload);
private:
LakehouseSpace lakehouseSpace_;
std::string errorCode_;
std::string errorMessage_;
bool success_;
};
}
}
}
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETLHSPACEBYNAMERESULT_H_

48
dms-enterprise/include/alibabacloud/dms-enterprise/model/GetTaskInstanceRelationRequest.h Normal file
View File

@@ -0,0 +1,48 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETTASKINSTANCERELATIONREQUEST_H_
#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETTASKINSTANCERELATIONREQUEST_H_
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <string>
#include <vector>
#include <map>
namespace AlibabaCloud {
namespace Dms_enterprise {
namespace Model {
class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetTaskInstanceRelationRequest : public RpcServiceRequest {
public:
GetTaskInstanceRelationRequest();
~GetTaskInstanceRelationRequest();
long getDagId() const;
void setDagId(long dagId);
long getTid() const;
void setTid(long tid);
long getDagInstanceId() const;
void setDagInstanceId(long dagInstanceId);
private:
long dagId_;
long tid_;
long dagInstanceId_;
};
} // namespace Model
} // namespace Dms_enterprise
} // namespace AlibabaCloud
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETTASKINSTANCERELATIONREQUEST_H_

69
dms-enterprise/include/alibabacloud/dms-enterprise/model/GetTaskInstanceRelationResult.h Normal file
View File

@@ -0,0 +1,69 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETTASKINSTANCERELATIONRESULT_H_
#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETTASKINSTANCERELATIONRESULT_H_
#include <string>
#include <vector>
#include <utility>
#include <alibabacloud/core/ServiceResult.h>
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
namespace AlibabaCloud
{
namespace Dms_enterprise
{
namespace Model
{
class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetTaskInstanceRelationResult : public ServiceResult
{
public:
struct Node
{
int status;
std::string message;
std::string endTime;
std::string nodeName;
long executeTime;
int nodeType;
long nodeId;
long id;
std::string businessTime;
};
GetTaskInstanceRelationResult();
explicit GetTaskInstanceRelationResult(const std::string &payload);
~GetTaskInstanceRelationResult();
std::vector<Node> getNodeList()const;
std::string getErrorCode()const;
std::string getErrorMessage()const;
bool getSuccess()const;
protected:
void parse(const std::string &payload);
private:
std::vector<Node> nodeList_;
std::string errorCode_;
std::string errorMessage_;
bool success_;
};
}
}
}
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETTASKINSTANCERELATIONRESULT_H_

60
dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowInstanceRequest.h Normal file
View File

@@ -0,0 +1,60 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWINSTANCEREQUEST_H_
#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWINSTANCEREQUEST_H_
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <string>
#include <vector>
#include <map>
namespace AlibabaCloud {
namespace Dms_enterprise {
namespace Model {
class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT ListTaskFlowInstanceRequest : public RpcServiceRequest {
public:
ListTaskFlowInstanceRequest();
~ListTaskFlowInstanceRequest();
int getTriggerType() const;
void setTriggerType(int triggerType);
long getDagId() const;
void setDagId(long dagId);
long getTid() const;
void setTid(long tid);
int getPageSize() const;
void setPageSize(int pageSize);
int getPageIndex() const;
void setPageIndex(int pageIndex);
std::string getStartTimeBegin() const;
void setStartTimeBegin(const std::string &startTimeBegin);
std::string getStartTimeEnd() const;
void setStartTimeEnd(const std::string &startTimeEnd);
private:
int triggerType_;
long dagId_;
long tid_;
int pageSize_;
int pageIndex_;
std::string startTimeBegin_;
std::string startTimeEnd_;
};
} // namespace Model
} // namespace Dms_enterprise
} // namespace AlibabaCloud
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWINSTANCEREQUEST_H_

72
dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowInstanceResult.h Normal file
View File

@@ -0,0 +1,72 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWINSTANCERESULT_H_
#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWINSTANCERESULT_H_
#include <string>
#include <vector>
#include <utility>
#include <alibabacloud/core/ServiceResult.h>
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
namespace AlibabaCloud
{
namespace Dms_enterprise
{
namespace Model
{
class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT ListTaskFlowInstanceResult : public ServiceResult
{
public:
struct DAGInstance
{
int status;
int triggerType;
long historyDagId;
std::string ownerName;
std::string endTime;
std::string message;
long id;
std::string dagName;
std::string businessTime;
std::string dagId;
};
ListTaskFlowInstanceResult();
explicit ListTaskFlowInstanceResult(const std::string &payload);
~ListTaskFlowInstanceResult();
int getTotalCount()const;
std::vector<DAGInstance> getDAGInstanceList()const;
std::string getErrorCode()const;
std::string getErrorMessage()const;
bool getSuccess()const;
protected:
void parse(const std::string &payload);
private:
int totalCount_;
std::vector<DAGInstance> dAGInstanceList_;
std::string errorCode_;
std::string errorMessage_;
bool success_;
};
}
}
}
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWINSTANCERESULT_H_

48
dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowRequest.h Normal file
View File

@@ -0,0 +1,48 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWREQUEST_H_
#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWREQUEST_H_
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <string>
#include <vector>
#include <map>
namespace AlibabaCloud {
namespace Dms_enterprise {
namespace Model {
class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT ListTaskFlowRequest : public RpcServiceRequest {
public:
ListTaskFlowRequest();
~ListTaskFlowRequest();
long getDagId() const;
void setDagId(long dagId);
long getTid() const;
void setTid(long tid);
long getDagInstanceId() const;
void setDagInstanceId(long dagInstanceId);
private:
long dagId_;
long tid_;
long dagInstanceId_;
};
} // namespace Model
} // namespace Dms_enterprise
} // namespace AlibabaCloud
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWREQUEST_H_

68
dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowResult.h Normal file
View File

@@ -0,0 +1,68 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWRESULT_H_
#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWRESULT_H_
#include <string>
#include <vector>
#include <utility>
#include <alibabacloud/core/ServiceResult.h>
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
namespace AlibabaCloud
{
namespace Dms_enterprise
{
namespace Model
{
class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT ListTaskFlowResult : public ServiceResult
{
public:
struct DAGInstance
{
int status;
int latestInstanceStatus;
std::string latestInstanceTime;
std::string creatorId;
long deployId;
long id;
std::string creatorNickName;
std::string dagOwnerNickName;
};
ListTaskFlowResult();
explicit ListTaskFlowResult(const std::string &payload);
~ListTaskFlowResult();
std::vector<DAGInstance> getTaskFlowList()const;
std::string getErrorCode()const;
std::string getErrorMessage()const;
bool getSuccess()const;
protected:
void parse(const std::string &payload);
private:
std::vector<DAGInstance> taskFlowList_;
std::string errorCode_;
std::string errorMessage_;
bool success_;
};
}
}
}
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWRESULT_H_

216
dms-enterprise/src/Dms-enterpriseClient.cc
View File

@@ -843,6 +843,42 @@ Dms_enterpriseClient::DeleteInstanceOutcomeCallable Dms_enterpriseClient::delete
return task->get_future();
}
Dms_enterpriseClient::DeleteLakeHouseSpaceOutcome Dms_enterpriseClient::deleteLakeHouseSpace(const DeleteLakeHouseSpaceRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DeleteLakeHouseSpaceOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DeleteLakeHouseSpaceOutcome(DeleteLakeHouseSpaceResult(outcome.result()));
else
return DeleteLakeHouseSpaceOutcome(outcome.error());
}
void Dms_enterpriseClient::deleteLakeHouseSpaceAsync(const DeleteLakeHouseSpaceRequest& request, const DeleteLakeHouseSpaceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, deleteLakeHouseSpace(request), context);
};
asyncExecute(new Runnable(fn));
}
Dms_enterpriseClient::DeleteLakeHouseSpaceOutcomeCallable Dms_enterpriseClient::deleteLakeHouseSpaceCallable(const DeleteLakeHouseSpaceRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DeleteLakeHouseSpaceOutcome()>>(
[this, request]()
{
return this->deleteLakeHouseSpace(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
Dms_enterpriseClient::DeleteLhMembersOutcome Dms_enterpriseClient::deleteLhMembers(const DeleteLhMembersRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -1023,6 +1059,42 @@ Dms_enterpriseClient::DeleteProxyAccessOutcomeCallable Dms_enterpriseClient::del
return task->get_future();
}
Dms_enterpriseClient::DeleteTaskFlowOutcome Dms_enterpriseClient::deleteTaskFlow(const DeleteTaskFlowRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DeleteTaskFlowOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DeleteTaskFlowOutcome(DeleteTaskFlowResult(outcome.result()));
else
return DeleteTaskFlowOutcome(outcome.error());
}
void Dms_enterpriseClient::deleteTaskFlowAsync(const DeleteTaskFlowRequest& request, const DeleteTaskFlowAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, deleteTaskFlow(request), context);
};
asyncExecute(new Runnable(fn));
}
Dms_enterpriseClient::DeleteTaskFlowOutcomeCallable Dms_enterpriseClient::deleteTaskFlowCallable(const DeleteTaskFlowRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DeleteTaskFlowOutcome()>>(
[this, request]()
{
return this->deleteTaskFlow(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
Dms_enterpriseClient::DeleteUserOutcome Dms_enterpriseClient::deleteUser(const DeleteUserRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -1743,6 +1815,42 @@ Dms_enterpriseClient::GetInstanceOutcomeCallable Dms_enterpriseClient::getInstan
return task->get_future();
}
Dms_enterpriseClient::GetLhSpaceByNameOutcome Dms_enterpriseClient::getLhSpaceByName(const GetLhSpaceByNameRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return GetLhSpaceByNameOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return GetLhSpaceByNameOutcome(GetLhSpaceByNameResult(outcome.result()));
else
return GetLhSpaceByNameOutcome(outcome.error());
}
void Dms_enterpriseClient::getLhSpaceByNameAsync(const GetLhSpaceByNameRequest& request, const GetLhSpaceByNameAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, getLhSpaceByName(request), context);
};
asyncExecute(new Runnable(fn));
}
Dms_enterpriseClient::GetLhSpaceByNameOutcomeCallable Dms_enterpriseClient::getLhSpaceByNameCallable(const GetLhSpaceByNameRequest &request) const
{
auto task = std::make_shared<std::packaged_task<GetLhSpaceByNameOutcome()>>(
[this, request]()
{
return this->getLhSpaceByName(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
Dms_enterpriseClient::GetLogicDatabaseOutcome Dms_enterpriseClient::getLogicDatabase(const GetLogicDatabaseRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -2355,6 +2463,42 @@ Dms_enterpriseClient::GetTableTopologyOutcomeCallable Dms_enterpriseClient::getT
return task->get_future();
}
Dms_enterpriseClient::GetTaskInstanceRelationOutcome Dms_enterpriseClient::getTaskInstanceRelation(const GetTaskInstanceRelationRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return GetTaskInstanceRelationOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return GetTaskInstanceRelationOutcome(GetTaskInstanceRelationResult(outcome.result()));
else
return GetTaskInstanceRelationOutcome(outcome.error());
}
void Dms_enterpriseClient::getTaskInstanceRelationAsync(const GetTaskInstanceRelationRequest& request, const GetTaskInstanceRelationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, getTaskInstanceRelation(request), context);
};
asyncExecute(new Runnable(fn));
}
Dms_enterpriseClient::GetTaskInstanceRelationOutcomeCallable Dms_enterpriseClient::getTaskInstanceRelationCallable(const GetTaskInstanceRelationRequest &request) const
{
auto task = std::make_shared<std::packaged_task<GetTaskInstanceRelationOutcome()>>(
[this, request]()
{
return this->getTaskInstanceRelation(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
Dms_enterpriseClient::GetUserOutcome Dms_enterpriseClient::getUser(const GetUserRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -3471,6 +3615,78 @@ Dms_enterpriseClient::ListTablesOutcomeCallable Dms_enterpriseClient::listTables
return task->get_future();
}
Dms_enterpriseClient::ListTaskFlowOutcome Dms_enterpriseClient::listTaskFlow(const ListTaskFlowRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ListTaskFlowOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ListTaskFlowOutcome(ListTaskFlowResult(outcome.result()));
else
return ListTaskFlowOutcome(outcome.error());
}
void Dms_enterpriseClient::listTaskFlowAsync(const ListTaskFlowRequest& request, const ListTaskFlowAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, listTaskFlow(request), context);
};
asyncExecute(new Runnable(fn));
}
Dms_enterpriseClient::ListTaskFlowOutcomeCallable Dms_enterpriseClient::listTaskFlowCallable(const ListTaskFlowRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ListTaskFlowOutcome()>>(
[this, request]()
{
return this->listTaskFlow(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
Dms_enterpriseClient::ListTaskFlowInstanceOutcome Dms_enterpriseClient::listTaskFlowInstance(const ListTaskFlowInstanceRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ListTaskFlowInstanceOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ListTaskFlowInstanceOutcome(ListTaskFlowInstanceResult(outcome.result()));
else
return ListTaskFlowInstanceOutcome(outcome.error());
}
void Dms_enterpriseClient::listTaskFlowInstanceAsync(const ListTaskFlowInstanceRequest& request, const ListTaskFlowInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, listTaskFlowInstance(request), context);
};
asyncExecute(new Runnable(fn));
}
Dms_enterpriseClient::ListTaskFlowInstanceOutcomeCallable Dms_enterpriseClient::listTaskFlowInstanceCallable(const ListTaskFlowInstanceRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ListTaskFlowInstanceOutcome()>>(
[this, request]()
{
return this->listTaskFlowInstance(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
Dms_enterpriseClient::ListUserPermissionsOutcome Dms_enterpriseClient::listUserPermissions(const ListUserPermissionsRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();

9
dms-enterprise/src/model/CreateLakeHouseSpaceRequest.cc
View File

@@ -43,15 +43,6 @@ void CreateLakeHouseSpaceRequest::setDescription(const std::string &description)
setParameter(std::string("Description"), description);
}
long CreateLakeHouseSpaceRequest::getUserId() const {
return userId_;
}
void CreateLakeHouseSpaceRequest::setUserId(long userId) {
userId_ = userId;
setParameter(std::string("UserId"), std::to_string(userId));
}
long CreateLakeHouseSpaceRequest::getTid() const {
return tid_;
}

45
dms-enterprise/src/model/DeleteLakeHouseSpaceRequest.cc Normal file
View File

@@ -0,0 +1,45 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#include <alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceRequest.h>
using AlibabaCloud::Dms_enterprise::Model::DeleteLakeHouseSpaceRequest;
DeleteLakeHouseSpaceRequest::DeleteLakeHouseSpaceRequest()
: RpcServiceRequest("dms-enterprise", "2018-11-01", "DeleteLakeHouseSpace") {
setMethod(HttpRequest::Method::Post);
}
DeleteLakeHouseSpaceRequest::~DeleteLakeHouseSpaceRequest() {}
long DeleteLakeHouseSpaceRequest::getSpaceId() const {
return spaceId_;
}
void DeleteLakeHouseSpaceRequest::setSpaceId(long spaceId) {
spaceId_ = spaceId;
setParameter(std::string("SpaceId"), std::to_string(spaceId));
}
long DeleteLakeHouseSpaceRequest::getTid() const {
return tid_;
}
void DeleteLakeHouseSpaceRequest::setTid(long tid) {
tid_ = tid;
setParameter(std::string("Tid"), std::to_string(tid));
}

65
dms-enterprise/src/model/DeleteLakeHouseSpaceResult.cc Normal file
View File

@@ -0,0 +1,65 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#include <alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceResult.h>
#include <json/json.h>
using namespace AlibabaCloud::Dms_enterprise;
using namespace AlibabaCloud::Dms_enterprise::Model;
DeleteLakeHouseSpaceResult::DeleteLakeHouseSpaceResult() :
ServiceResult()
{}
DeleteLakeHouseSpaceResult::DeleteLakeHouseSpaceResult(const std::string &payload) :
ServiceResult()
{
parse(payload);
}
DeleteLakeHouseSpaceResult::~DeleteLakeHouseSpaceResult()
{}
void DeleteLakeHouseSpaceResult::parse(const std::string &payload)
{
Json::Reader reader;
Json::Value value;
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
if(!value["ErrorCode"].isNull())
errorCode_ = value["ErrorCode"].asString();
if(!value["ErrorMessage"].isNull())
errorMessage_ = value["ErrorMessage"].asString();
if(!value["Success"].isNull())
success_ = value["Success"].asString() == "true";
}
std::string DeleteLakeHouseSpaceResult::getErrorCode()const
{
return errorCode_;
}
std::string DeleteLakeHouseSpaceResult::getErrorMessage()const
{
return errorMessage_;
}
bool DeleteLakeHouseSpaceResult::getSuccess()const
{
return success_;
}

45
dms-enterprise/src/model/DeleteTaskFlowRequest.cc Normal file
View File

@@ -0,0 +1,45 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#include <alibabacloud/dms-enterprise/model/DeleteTaskFlowRequest.h>
using AlibabaCloud::Dms_enterprise::Model::DeleteTaskFlowRequest;
DeleteTaskFlowRequest::DeleteTaskFlowRequest()
: RpcServiceRequest("dms-enterprise", "2018-11-01", "DeleteTaskFlow") {
setMethod(HttpRequest::Method::Post);
}
DeleteTaskFlowRequest::~DeleteTaskFlowRequest() {}
long DeleteTaskFlowRequest::getDagId() const {
return dagId_;
}
void DeleteTaskFlowRequest::setDagId(long dagId) {
dagId_ = dagId;
setParameter(std::string("DagId"), std::to_string(dagId));
}
long DeleteTaskFlowRequest::getTid() const {
return tid_;
}
void DeleteTaskFlowRequest::setTid(long tid) {
tid_ = tid;
setParameter(std::string("Tid"), std::to_string(tid));
}

65
dms-enterprise/src/model/DeleteTaskFlowResult.cc Normal file
View File

@@ -0,0 +1,65 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#include <alibabacloud/dms-enterprise/model/DeleteTaskFlowResult.h>
#include <json/json.h>
using namespace AlibabaCloud::Dms_enterprise;
using namespace AlibabaCloud::Dms_enterprise::Model;
DeleteTaskFlowResult::DeleteTaskFlowResult() :
ServiceResult()
{}
DeleteTaskFlowResult::DeleteTaskFlowResult(const std::string &payload) :
ServiceResult()
{
parse(payload);
}
DeleteTaskFlowResult::~DeleteTaskFlowResult()
{}
void DeleteTaskFlowResult::parse(const std::string &payload)
{
Json::Reader reader;
Json::Value value;
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
if(!value["ErrorCode"].isNull())
errorCode_ = value["ErrorCode"].asString();
if(!value["ErrorMessage"].isNull())
errorMessage_ = value["ErrorMessage"].asString();
if(!value["Success"].isNull())
success_ = value["Success"].asString() == "true";
}
std::string DeleteTaskFlowResult::getErrorCode()const
{
return errorCode_;
}
std::string DeleteTaskFlowResult::getErrorMessage()const
{
return errorMessage_;
}
bool DeleteTaskFlowResult::getSuccess()const
{
return success_;
}

45
dms-enterprise/src/model/GetLhSpaceByNameRequest.cc Normal file
View File

@@ -0,0 +1,45 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#include <alibabacloud/dms-enterprise/model/GetLhSpaceByNameRequest.h>
using AlibabaCloud::Dms_enterprise::Model::GetLhSpaceByNameRequest;
GetLhSpaceByNameRequest::GetLhSpaceByNameRequest()
: RpcServiceRequest("dms-enterprise", "2018-11-01", "GetLhSpaceByName") {
setMethod(HttpRequest::Method::Post);
}
GetLhSpaceByNameRequest::~GetLhSpaceByNameRequest() {}
std::string GetLhSpaceByNameRequest::getSpaceName() const {
return spaceName_;
}
void GetLhSpaceByNameRequest::setSpaceName(const std::string &spaceName) {
spaceName_ = spaceName;
setParameter(std::string("SpaceName"), spaceName);
}
long GetLhSpaceByNameRequest::getTid() const {
return tid_;
}
void GetLhSpaceByNameRequest::setTid(long tid) {
tid_ = tid;
setParameter(std::string("Tid"), std::to_string(tid));
}

93
dms-enterprise/src/model/GetLhSpaceByNameResult.cc Normal file
View File

@@ -0,0 +1,93 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#include <alibabacloud/dms-enterprise/model/GetLhSpaceByNameResult.h>
#include <json/json.h>
using namespace AlibabaCloud::Dms_enterprise;
using namespace AlibabaCloud::Dms_enterprise::Model;
GetLhSpaceByNameResult::GetLhSpaceByNameResult() :
ServiceResult()
{}
GetLhSpaceByNameResult::GetLhSpaceByNameResult(const std::string &payload) :
ServiceResult()
{
parse(payload);
}
GetLhSpaceByNameResult::~GetLhSpaceByNameResult()
{}
void GetLhSpaceByNameResult::parse(const std::string &payload)
{
Json::Reader reader;
Json::Value value;
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
auto lakehouseSpaceNode = value["LakehouseSpace"];
if(!lakehouseSpaceNode["Id"].isNull())
lakehouseSpace_.id = std::stol(lakehouseSpaceNode["Id"].asString());
if(!lakehouseSpaceNode["SpaceName"].isNull())
lakehouseSpace_.spaceName = lakehouseSpaceNode["SpaceName"].asString();
if(!lakehouseSpaceNode["CreatorId"].isNull())
lakehouseSpace_.creatorId = lakehouseSpaceNode["CreatorId"].asString();
if(!lakehouseSpaceNode["TenantId"].isNull())
lakehouseSpace_.tenantId = lakehouseSpaceNode["TenantId"].asString();
if(!lakehouseSpaceNode["Description"].isNull())
lakehouseSpace_.description = lakehouseSpaceNode["Description"].asString();
if(!lakehouseSpaceNode["Mode"].isNull())
lakehouseSpace_.mode = std::stoi(lakehouseSpaceNode["Mode"].asString());
if(!lakehouseSpaceNode["DbType"].isNull())
lakehouseSpace_.dbType = lakehouseSpaceNode["DbType"].asString();
if(!lakehouseSpaceNode["SpaceConfig"].isNull())
lakehouseSpace_.spaceConfig = lakehouseSpaceNode["SpaceConfig"].asString();
if(!lakehouseSpaceNode["DevDbId"].isNull())
lakehouseSpace_.devDbId = std::stoi(lakehouseSpaceNode["DevDbId"].asString());
if(!lakehouseSpaceNode["ProdDbId"].isNull())
lakehouseSpace_.prodDbId = std::stoi(lakehouseSpaceNode["ProdDbId"].asString());
if(!lakehouseSpaceNode["IsDeleted"].isNull())
lakehouseSpace_.isDeleted = lakehouseSpaceNode["IsDeleted"].asString() == "true";
if(!value["ErrorCode"].isNull())
errorCode_ = value["ErrorCode"].asString();
if(!value["ErrorMessage"].isNull())
errorMessage_ = value["ErrorMessage"].asString();
if(!value["Success"].isNull())
success_ = value["Success"].asString() == "true";
}
GetLhSpaceByNameResult::LakehouseSpace GetLhSpaceByNameResult::getLakehouseSpace()const
{
return lakehouseSpace_;
}
std::string GetLhSpaceByNameResult::getErrorCode()const
{
return errorCode_;
}
std::string GetLhSpaceByNameResult::getErrorMessage()const
{
return errorMessage_;
}
bool GetLhSpaceByNameResult::getSuccess()const
{
return success_;
}

54
dms-enterprise/src/model/GetTaskInstanceRelationRequest.cc Normal file
View File

@@ -0,0 +1,54 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#include <alibabacloud/dms-enterprise/model/GetTaskInstanceRelationRequest.h>
using AlibabaCloud::Dms_enterprise::Model::GetTaskInstanceRelationRequest;
GetTaskInstanceRelationRequest::GetTaskInstanceRelationRequest()
: RpcServiceRequest("dms-enterprise", "2018-11-01", "GetTaskInstanceRelation") {
setMethod(HttpRequest::Method::Post);
}
GetTaskInstanceRelationRequest::~GetTaskInstanceRelationRequest() {}
long GetTaskInstanceRelationRequest::getDagId() const {
return dagId_;
}
void GetTaskInstanceRelationRequest::setDagId(long dagId) {
dagId_ = dagId;
setParameter(std::string("DagId"), std::to_string(dagId));
}
long GetTaskInstanceRelationRequest::getTid() const {
return tid_;
}
void GetTaskInstanceRelationRequest::setTid(long tid) {
tid_ = tid;
setParameter(std::string("Tid"), std::to_string(tid));
}
long GetTaskInstanceRelationRequest::getDagInstanceId() const {
return dagInstanceId_;
}
void GetTaskInstanceRelationRequest::setDagInstanceId(long dagInstanceId) {
dagInstanceId_ = dagInstanceId;
setParameter(std::string("DagInstanceId"), std::to_string(dagInstanceId));
}

94
dms-enterprise/src/model/GetTaskInstanceRelationResult.cc Normal file
View File

@@ -0,0 +1,94 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#include <alibabacloud/dms-enterprise/model/GetTaskInstanceRelationResult.h>
#include <json/json.h>
using namespace AlibabaCloud::Dms_enterprise;
using namespace AlibabaCloud::Dms_enterprise::Model;
GetTaskInstanceRelationResult::GetTaskInstanceRelationResult() :
ServiceResult()
{}
GetTaskInstanceRelationResult::GetTaskInstanceRelationResult(const std::string &payload) :
ServiceResult()
{
parse(payload);
}
GetTaskInstanceRelationResult::~GetTaskInstanceRelationResult()
{}
void GetTaskInstanceRelationResult::parse(const std::string &payload)
{
Json::Reader reader;
Json::Value value;
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
auto allNodeListNode = value["NodeList"]["Node"];
for (auto valueNodeListNode : allNodeListNode)
{
Node nodeListObject;
if(!valueNodeListNode["Id"].isNull())
nodeListObject.id = std::stol(valueNodeListNode["Id"].asString());
if(!valueNodeListNode["NodeId"].isNull())
nodeListObject.nodeId = std::stol(valueNodeListNode["NodeId"].asString());
if(!valueNodeListNode["NodeName"].isNull())
nodeListObject.nodeName = valueNodeListNode["NodeName"].asString();
if(!valueNodeListNode["NodeType"].isNull())
nodeListObject.nodeType = std::stoi(valueNodeListNode["NodeType"].asString());
if(!valueNodeListNode["BusinessTime"].isNull())
nodeListObject.businessTime = valueNodeListNode["BusinessTime"].asString();
if(!valueNodeListNode["Status"].isNull())
nodeListObject.status = std::stoi(valueNodeListNode["Status"].asString());
if(!valueNodeListNode["Message"].isNull())
nodeListObject.message = valueNodeListNode["Message"].asString();
if(!valueNodeListNode["ExecuteTime"].isNull())
nodeListObject.executeTime = std::stol(valueNodeListNode["ExecuteTime"].asString());
if(!valueNodeListNode["EndTime"].isNull())
nodeListObject.endTime = valueNodeListNode["EndTime"].asString();
nodeList_.push_back(nodeListObject);
}
if(!value["ErrorCode"].isNull())
errorCode_ = value["ErrorCode"].asString();
if(!value["ErrorMessage"].isNull())
errorMessage_ = value["ErrorMessage"].asString();
if(!value["Success"].isNull())
success_ = value["Success"].asString() == "true";
}
std::vector<GetTaskInstanceRelationResult::Node> GetTaskInstanceRelationResult::getNodeList()const
{
return nodeList_;
}
std::string GetTaskInstanceRelationResult::getErrorCode()const
{
return errorCode_;
}
std::string GetTaskInstanceRelationResult::getErrorMessage()const
{
return errorMessage_;
}
bool GetTaskInstanceRelationResult::getSuccess()const
{
return success_;
}

90
dms-enterprise/src/model/ListTaskFlowInstanceRequest.cc Normal file
View File

@@ -0,0 +1,90 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#include <alibabacloud/dms-enterprise/model/ListTaskFlowInstanceRequest.h>
using AlibabaCloud::Dms_enterprise::Model::ListTaskFlowInstanceRequest;
ListTaskFlowInstanceRequest::ListTaskFlowInstanceRequest()
: RpcServiceRequest("dms-enterprise", "2018-11-01", "ListTaskFlowInstance") {
setMethod(HttpRequest::Method::Post);
}
ListTaskFlowInstanceRequest::~ListTaskFlowInstanceRequest() {}
int ListTaskFlowInstanceRequest::getTriggerType() const {
return triggerType_;
}
void ListTaskFlowInstanceRequest::setTriggerType(int triggerType) {
triggerType_ = triggerType;
setParameter(std::string("TriggerType"), std::to_string(triggerType));
}
long ListTaskFlowInstanceRequest::getDagId() const {
return dagId_;
}
void ListTaskFlowInstanceRequest::setDagId(long dagId) {
dagId_ = dagId;
setParameter(std::string("DagId"), std::to_string(dagId));
}
long ListTaskFlowInstanceRequest::getTid() const {
return tid_;
}
void ListTaskFlowInstanceRequest::setTid(long tid) {
tid_ = tid;
setParameter(std::string("Tid"), std::to_string(tid));
}
int ListTaskFlowInstanceRequest::getPageSize() const {
return pageSize_;
}
void ListTaskFlowInstanceRequest::setPageSize(int pageSize) {
pageSize_ = pageSize;
setParameter(std::string("PageSize"), std::to_string(pageSize));
}
int ListTaskFlowInstanceRequest::getPageIndex() const {
return pageIndex_;
}
void ListTaskFlowInstanceRequest::setPageIndex(int pageIndex) {
pageIndex_ = pageIndex;
setParameter(std::string("PageIndex"), std::to_string(pageIndex));
}
std::string ListTaskFlowInstanceRequest::getStartTimeBegin() const {
return startTimeBegin_;
}
void ListTaskFlowInstanceRequest::setStartTimeBegin(const std::string &startTimeBegin) {
startTimeBegin_ = startTimeBegin;
setParameter(std::string("StartTimeBegin"), startTimeBegin);
}
std::string ListTaskFlowInstanceRequest::getStartTimeEnd() const {
return startTimeEnd_;
}
void ListTaskFlowInstanceRequest::setStartTimeEnd(const std::string &startTimeEnd) {
startTimeEnd_ = startTimeEnd;
setParameter(std::string("StartTimeEnd"), startTimeEnd);
}

103
dms-enterprise/src/model/ListTaskFlowInstanceResult.cc Normal file
View File

@@ -0,0 +1,103 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#include <alibabacloud/dms-enterprise/model/ListTaskFlowInstanceResult.h>
#include <json/json.h>
using namespace AlibabaCloud::Dms_enterprise;
using namespace AlibabaCloud::Dms_enterprise::Model;
ListTaskFlowInstanceResult::ListTaskFlowInstanceResult() :
ServiceResult()
{}
ListTaskFlowInstanceResult::ListTaskFlowInstanceResult(const std::string &payload) :
ServiceResult()
{
parse(payload);
}
ListTaskFlowInstanceResult::~ListTaskFlowInstanceResult()
{}
void ListTaskFlowInstanceResult::parse(const std::string &payload)
{
Json::Reader reader;
Json::Value value;
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
auto allDAGInstanceListNode = value["DAGInstanceList"]["DAGInstance"];
for (auto valueDAGInstanceListDAGInstance : allDAGInstanceListNode)
{
DAGInstance dAGInstanceListObject;
if(!valueDAGInstanceListDAGInstance["Id"].isNull())
dAGInstanceListObject.id = std::stol(valueDAGInstanceListDAGInstance["Id"].asString());
if(!valueDAGInstanceListDAGInstance["BusinessTime"].isNull())
dAGInstanceListObject.businessTime = valueDAGInstanceListDAGInstance["BusinessTime"].asString();
if(!valueDAGInstanceListDAGInstance["EndTime"].isNull())
dAGInstanceListObject.endTime = valueDAGInstanceListDAGInstance["EndTime"].asString();
if(!valueDAGInstanceListDAGInstance["DagId"].isNull())
dAGInstanceListObject.dagId = valueDAGInstanceListDAGInstance["DagId"].asString();
if(!valueDAGInstanceListDAGInstance["TriggerType"].isNull())
dAGInstanceListObject.triggerType = std::stoi(valueDAGInstanceListDAGInstance["TriggerType"].asString());
if(!valueDAGInstanceListDAGInstance["Status"].isNull())
dAGInstanceListObject.status = std::stoi(valueDAGInstanceListDAGInstance["Status"].asString());
if(!valueDAGInstanceListDAGInstance["Message"].isNull())
dAGInstanceListObject.message = valueDAGInstanceListDAGInstance["Message"].asString();
if(!valueDAGInstanceListDAGInstance["HistoryDagId"].isNull())
dAGInstanceListObject.historyDagId = std::stol(valueDAGInstanceListDAGInstance["HistoryDagId"].asString());
if(!valueDAGInstanceListDAGInstance["DagName"].isNull())
dAGInstanceListObject.dagName = valueDAGInstanceListDAGInstance["DagName"].asString();
if(!valueDAGInstanceListDAGInstance["OwnerName"].isNull())
dAGInstanceListObject.ownerName = valueDAGInstanceListDAGInstance["OwnerName"].asString();
dAGInstanceList_.push_back(dAGInstanceListObject);
}
if(!value["ErrorCode"].isNull())
errorCode_ = value["ErrorCode"].asString();
if(!value["ErrorMessage"].isNull())
errorMessage_ = value["ErrorMessage"].asString();
if(!value["Success"].isNull())
success_ = value["Success"].asString() == "true";
if(!value["TotalCount"].isNull())
totalCount_ = std::stoi(value["TotalCount"].asString());
}
int ListTaskFlowInstanceResult::getTotalCount()const
{
return totalCount_;
}
std::vector<ListTaskFlowInstanceResult::DAGInstance> ListTaskFlowInstanceResult::getDAGInstanceList()const
{
return dAGInstanceList_;
}
std::string ListTaskFlowInstanceResult::getErrorCode()const
{
return errorCode_;
}
std::string ListTaskFlowInstanceResult::getErrorMessage()const
{
return errorMessage_;
}
bool ListTaskFlowInstanceResult::getSuccess()const
{
return success_;
}

54
dms-enterprise/src/model/ListTaskFlowRequest.cc Normal file
View File

@@ -0,0 +1,54 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#include <alibabacloud/dms-enterprise/model/ListTaskFlowRequest.h>
using AlibabaCloud::Dms_enterprise::Model::ListTaskFlowRequest;
ListTaskFlowRequest::ListTaskFlowRequest()
: RpcServiceRequest("dms-enterprise", "2018-11-01", "ListTaskFlow") {
setMethod(HttpRequest::Method::Post);
}
ListTaskFlowRequest::~ListTaskFlowRequest() {}
long ListTaskFlowRequest::getDagId() const {
return dagId_;
}
void ListTaskFlowRequest::setDagId(long dagId) {
dagId_ = dagId;
setParameter(std::string("DagId"), std::to_string(dagId));
}
long ListTaskFlowRequest::getTid() const {
return tid_;
}
void ListTaskFlowRequest::setTid(long tid) {
tid_ = tid;
setParameter(std::string("Tid"), std::to_string(tid));
}
long ListTaskFlowRequest::getDagInstanceId() const {
return dagInstanceId_;
}
void ListTaskFlowRequest::setDagInstanceId(long dagInstanceId) {
dagInstanceId_ = dagInstanceId;
setParameter(std::string("DagInstanceId"), std::to_string(dagInstanceId));
}

92
dms-enterprise/src/model/ListTaskFlowResult.cc Normal file
View File

@@ -0,0 +1,92 @@
/*
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
*
* Licensed 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.
*/
#include <alibabacloud/dms-enterprise/model/ListTaskFlowResult.h>
#include <json/json.h>
using namespace AlibabaCloud::Dms_enterprise;
using namespace AlibabaCloud::Dms_enterprise::Model;
ListTaskFlowResult::ListTaskFlowResult() :
ServiceResult()
{}
ListTaskFlowResult::ListTaskFlowResult(const std::string &payload) :
ServiceResult()
{
parse(payload);
}
ListTaskFlowResult::~ListTaskFlowResult()
{}
void ListTaskFlowResult::parse(const std::string &payload)
{
Json::Reader reader;
Json::Value value;
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
auto allTaskFlowListNode = value["TaskFlowList"]["DAGInstance"];
for (auto valueTaskFlowListDAGInstance : allTaskFlowListNode)
{
DAGInstance taskFlowListObject;
if(!valueTaskFlowListDAGInstance["Id"].isNull())
taskFlowListObject.id = std::stol(valueTaskFlowListDAGInstance["Id"].asString());
if(!valueTaskFlowListDAGInstance["CreatorId"].isNull())
taskFlowListObject.creatorId = valueTaskFlowListDAGInstance["CreatorId"].asString();
if(!valueTaskFlowListDAGInstance["CreatorNickName"].isNull())
taskFlowListObject.creatorNickName = valueTaskFlowListDAGInstance["CreatorNickName"].asString();
if(!valueTaskFlowListDAGInstance["DagOwnerNickName"].isNull())
taskFlowListObject.dagOwnerNickName = valueTaskFlowListDAGInstance["DagOwnerNickName"].asString();
if(!valueTaskFlowListDAGInstance["DeployId"].isNull())
taskFlowListObject.deployId = std::stol(valueTaskFlowListDAGInstance["DeployId"].asString());
if(!valueTaskFlowListDAGInstance["Status"].isNull())
taskFlowListObject.status = std::stoi(valueTaskFlowListDAGInstance["Status"].asString());
if(!valueTaskFlowListDAGInstance["LatestInstanceStatus"].isNull())
taskFlowListObject.latestInstanceStatus = std::stoi(valueTaskFlowListDAGInstance["LatestInstanceStatus"].asString());
if(!valueTaskFlowListDAGInstance["LatestInstanceTime"].isNull())
taskFlowListObject.latestInstanceTime = valueTaskFlowListDAGInstance["LatestInstanceTime"].asString();
taskFlowList_.push_back(taskFlowListObject);
}
if(!value["ErrorCode"].isNull())
errorCode_ = value["ErrorCode"].asString();
if(!value["ErrorMessage"].isNull())
errorMessage_ = value["ErrorMessage"].asString();
if(!value["Success"].isNull())
success_ = value["Success"].asString() == "true";
}
std::vector<ListTaskFlowResult::DAGInstance> ListTaskFlowResult::getTaskFlowList()const
{
return taskFlowList_;
}
std::string ListTaskFlowResult::getErrorCode()const
{
return errorCode_;
}
std::string ListTaskFlowResult::getErrorMessage()const
{
return errorMessage_;
}
bool ListTaskFlowResult::getSuccess()const
{
return success_;
}