diff --git a/CHANGELOG b/CHANGELOG index b2d6d4beb..33a9d23b4 100644 --- a/CHANGELOG +++ b/CHANGELOG @@ -1,3 +1,6 @@ +2021-06-24 Version: 1.36.799 +- DescribeSynchronizationJobs, DescribeSubscriptionInstances, DescribeMigrationJobs, Add InstanceCreateTime and JobCreateTime. + 2021-06-24 Version: 1.36.798 - Create Lindorm Open api. diff --git a/VERSION b/VERSION index 406a04b4b..1dabb1932 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -1.36.798 \ No newline at end of file +1.36.799 \ No newline at end of file diff --git a/dts/CMakeLists.txt b/dts/CMakeLists.txt index 6c13789b1..635b5a6cc 100644 --- a/dts/CMakeLists.txt +++ b/dts/CMakeLists.txt @@ -27,6 +27,8 @@ set(dts_public_header_model include/alibabacloud/dts/model/ConfigureMigrationJobResult.h include/alibabacloud/dts/model/ConfigureMigrationJobAlertRequest.h include/alibabacloud/dts/model/ConfigureMigrationJobAlertResult.h + include/alibabacloud/dts/model/ConfigureSubscriptionRequest.h + include/alibabacloud/dts/model/ConfigureSubscriptionResult.h include/alibabacloud/dts/model/ConfigureSubscriptionInstanceRequest.h include/alibabacloud/dts/model/ConfigureSubscriptionInstanceResult.h include/alibabacloud/dts/model/ConfigureSubscriptionInstanceAlertRequest.h @@ -37,6 +39,8 @@ set(dts_public_header_model include/alibabacloud/dts/model/ConfigureSynchronizationJobAlertResult.h include/alibabacloud/dts/model/ConfigureSynchronizationJobReplicatorCompareRequest.h include/alibabacloud/dts/model/ConfigureSynchronizationJobReplicatorCompareResult.h + include/alibabacloud/dts/model/CreateConsumerChannelRequest.h + include/alibabacloud/dts/model/CreateConsumerChannelResult.h include/alibabacloud/dts/model/CreateConsumerGroupRequest.h include/alibabacloud/dts/model/CreateConsumerGroupResult.h include/alibabacloud/dts/model/CreateDtsInstanceRequest.h @@ -49,6 +53,8 @@ set(dts_public_header_model include/alibabacloud/dts/model/CreateSubscriptionInstanceResult.h include/alibabacloud/dts/model/CreateSynchronizationJobRequest.h include/alibabacloud/dts/model/CreateSynchronizationJobResult.h + include/alibabacloud/dts/model/DeleteConsumerChannelRequest.h + include/alibabacloud/dts/model/DeleteConsumerChannelResult.h include/alibabacloud/dts/model/DeleteConsumerGroupRequest.h include/alibabacloud/dts/model/DeleteConsumerGroupResult.h include/alibabacloud/dts/model/DeleteDtsJobRequest.h @@ -63,6 +69,8 @@ set(dts_public_header_model include/alibabacloud/dts/model/DescribeCenVpcResult.h include/alibabacloud/dts/model/DescribeConnectionStatusRequest.h include/alibabacloud/dts/model/DescribeConnectionStatusResult.h + include/alibabacloud/dts/model/DescribeConsumerChannelRequest.h + include/alibabacloud/dts/model/DescribeConsumerChannelResult.h include/alibabacloud/dts/model/DescribeConsumerGroupRequest.h include/alibabacloud/dts/model/DescribeConsumerGroupResult.h include/alibabacloud/dts/model/DescribeDTSIPRequest.h @@ -71,8 +79,6 @@ set(dts_public_header_model include/alibabacloud/dts/model/DescribeDgDatabasesResult.h include/alibabacloud/dts/model/DescribeDtsJobDetailRequest.h include/alibabacloud/dts/model/DescribeDtsJobDetailResult.h - include/alibabacloud/dts/model/DescribeDtsJobLogsRequest.h - include/alibabacloud/dts/model/DescribeDtsJobLogsResult.h include/alibabacloud/dts/model/DescribeDtsJobsRequest.h include/alibabacloud/dts/model/DescribeDtsJobsResult.h include/alibabacloud/dts/model/DescribeEndpointSwitchStatusRequest.h @@ -113,6 +119,8 @@ set(dts_public_header_model include/alibabacloud/dts/model/DescribeSynchronizationObjectModifyStatusResult.h include/alibabacloud/dts/model/ListTagResourcesRequest.h include/alibabacloud/dts/model/ListTagResourcesResult.h + include/alibabacloud/dts/model/ModifyConsumerChannelRequest.h + include/alibabacloud/dts/model/ModifyConsumerChannelResult.h include/alibabacloud/dts/model/ModifyConsumerGroupPasswordRequest.h include/alibabacloud/dts/model/ModifyConsumerGroupPasswordResult.h include/alibabacloud/dts/model/ModifyConsumptionTimestampRequest.h @@ -123,12 +131,14 @@ set(dts_public_header_model include/alibabacloud/dts/model/ModifyDtsJobNameResult.h include/alibabacloud/dts/model/ModifyDtsJobPasswordRequest.h include/alibabacloud/dts/model/ModifyDtsJobPasswordResult.h + include/alibabacloud/dts/model/ModifySubscriptionRequest.h + include/alibabacloud/dts/model/ModifySubscriptionResult.h include/alibabacloud/dts/model/ModifySubscriptionObjectRequest.h include/alibabacloud/dts/model/ModifySubscriptionObjectResult.h include/alibabacloud/dts/model/ModifySynchronizationObjectRequest.h include/alibabacloud/dts/model/ModifySynchronizationObjectResult.h - include/alibabacloud/dts/model/PreviewSqlRequest.h - include/alibabacloud/dts/model/PreviewSqlResult.h + include/alibabacloud/dts/model/RenewInstanceRequest.h + include/alibabacloud/dts/model/RenewInstanceResult.h include/alibabacloud/dts/model/ReplaceInstanceRequest.h include/alibabacloud/dts/model/ReplaceInstanceResult.h include/alibabacloud/dts/model/ResetDtsJobRequest.h @@ -161,6 +171,8 @@ set(dts_public_header_model include/alibabacloud/dts/model/SwitchSynchronizationEndpointResult.h include/alibabacloud/dts/model/TagResourcesRequest.h include/alibabacloud/dts/model/TagResourcesResult.h + include/alibabacloud/dts/model/TransferInstanceClassRequest.h + include/alibabacloud/dts/model/TransferInstanceClassResult.h include/alibabacloud/dts/model/TransferPayTypeRequest.h include/alibabacloud/dts/model/TransferPayTypeResult.h include/alibabacloud/dts/model/UntagResourcesRequest.h @@ -178,6 +190,8 @@ set(dts_src src/model/ConfigureMigrationJobResult.cc src/model/ConfigureMigrationJobAlertRequest.cc src/model/ConfigureMigrationJobAlertResult.cc + src/model/ConfigureSubscriptionRequest.cc + src/model/ConfigureSubscriptionResult.cc src/model/ConfigureSubscriptionInstanceRequest.cc src/model/ConfigureSubscriptionInstanceResult.cc src/model/ConfigureSubscriptionInstanceAlertRequest.cc @@ -188,6 +202,8 @@ set(dts_src src/model/ConfigureSynchronizationJobAlertResult.cc src/model/ConfigureSynchronizationJobReplicatorCompareRequest.cc src/model/ConfigureSynchronizationJobReplicatorCompareResult.cc + src/model/CreateConsumerChannelRequest.cc + src/model/CreateConsumerChannelResult.cc src/model/CreateConsumerGroupRequest.cc src/model/CreateConsumerGroupResult.cc src/model/CreateDtsInstanceRequest.cc @@ -200,6 +216,8 @@ set(dts_src src/model/CreateSubscriptionInstanceResult.cc src/model/CreateSynchronizationJobRequest.cc src/model/CreateSynchronizationJobResult.cc + src/model/DeleteConsumerChannelRequest.cc + src/model/DeleteConsumerChannelResult.cc src/model/DeleteConsumerGroupRequest.cc src/model/DeleteConsumerGroupResult.cc src/model/DeleteDtsJobRequest.cc @@ -214,6 +232,8 @@ set(dts_src src/model/DescribeCenVpcResult.cc src/model/DescribeConnectionStatusRequest.cc src/model/DescribeConnectionStatusResult.cc + src/model/DescribeConsumerChannelRequest.cc + src/model/DescribeConsumerChannelResult.cc src/model/DescribeConsumerGroupRequest.cc src/model/DescribeConsumerGroupResult.cc src/model/DescribeDTSIPRequest.cc @@ -222,8 +242,6 @@ set(dts_src src/model/DescribeDgDatabasesResult.cc src/model/DescribeDtsJobDetailRequest.cc src/model/DescribeDtsJobDetailResult.cc - src/model/DescribeDtsJobLogsRequest.cc - src/model/DescribeDtsJobLogsResult.cc src/model/DescribeDtsJobsRequest.cc src/model/DescribeDtsJobsResult.cc src/model/DescribeEndpointSwitchStatusRequest.cc @@ -264,6 +282,8 @@ set(dts_src src/model/DescribeSynchronizationObjectModifyStatusResult.cc src/model/ListTagResourcesRequest.cc src/model/ListTagResourcesResult.cc + src/model/ModifyConsumerChannelRequest.cc + src/model/ModifyConsumerChannelResult.cc src/model/ModifyConsumerGroupPasswordRequest.cc src/model/ModifyConsumerGroupPasswordResult.cc src/model/ModifyConsumptionTimestampRequest.cc @@ -274,12 +294,14 @@ set(dts_src src/model/ModifyDtsJobNameResult.cc src/model/ModifyDtsJobPasswordRequest.cc src/model/ModifyDtsJobPasswordResult.cc + src/model/ModifySubscriptionRequest.cc + src/model/ModifySubscriptionResult.cc src/model/ModifySubscriptionObjectRequest.cc src/model/ModifySubscriptionObjectResult.cc src/model/ModifySynchronizationObjectRequest.cc src/model/ModifySynchronizationObjectResult.cc - src/model/PreviewSqlRequest.cc - src/model/PreviewSqlResult.cc + src/model/RenewInstanceRequest.cc + src/model/RenewInstanceResult.cc src/model/ReplaceInstanceRequest.cc src/model/ReplaceInstanceResult.cc src/model/ResetDtsJobRequest.cc @@ -312,6 +334,8 @@ set(dts_src src/model/SwitchSynchronizationEndpointResult.cc src/model/TagResourcesRequest.cc src/model/TagResourcesResult.cc + src/model/TransferInstanceClassRequest.cc + src/model/TransferInstanceClassResult.cc src/model/TransferPayTypeRequest.cc src/model/TransferPayTypeResult.cc src/model/UntagResourcesRequest.cc diff --git a/dts/include/alibabacloud/dts/DtsClient.h b/dts/include/alibabacloud/dts/DtsClient.h index e352ddc81..2cbfa290b 100644 --- a/dts/include/alibabacloud/dts/DtsClient.h +++ b/dts/include/alibabacloud/dts/DtsClient.h @@ -28,6 +28,8 @@ #include "model/ConfigureMigrationJobResult.h" #include "model/ConfigureMigrationJobAlertRequest.h" #include "model/ConfigureMigrationJobAlertResult.h" +#include "model/ConfigureSubscriptionRequest.h" +#include "model/ConfigureSubscriptionResult.h" #include "model/ConfigureSubscriptionInstanceRequest.h" #include "model/ConfigureSubscriptionInstanceResult.h" #include "model/ConfigureSubscriptionInstanceAlertRequest.h" @@ -38,6 +40,8 @@ #include "model/ConfigureSynchronizationJobAlertResult.h" #include "model/ConfigureSynchronizationJobReplicatorCompareRequest.h" #include "model/ConfigureSynchronizationJobReplicatorCompareResult.h" +#include "model/CreateConsumerChannelRequest.h" +#include "model/CreateConsumerChannelResult.h" #include "model/CreateConsumerGroupRequest.h" #include "model/CreateConsumerGroupResult.h" #include "model/CreateDtsInstanceRequest.h" @@ -50,6 +54,8 @@ #include "model/CreateSubscriptionInstanceResult.h" #include "model/CreateSynchronizationJobRequest.h" #include "model/CreateSynchronizationJobResult.h" +#include "model/DeleteConsumerChannelRequest.h" +#include "model/DeleteConsumerChannelResult.h" #include "model/DeleteConsumerGroupRequest.h" #include "model/DeleteConsumerGroupResult.h" #include "model/DeleteDtsJobRequest.h" @@ -64,6 +70,8 @@ #include "model/DescribeCenVpcResult.h" #include "model/DescribeConnectionStatusRequest.h" #include "model/DescribeConnectionStatusResult.h" +#include "model/DescribeConsumerChannelRequest.h" +#include "model/DescribeConsumerChannelResult.h" #include "model/DescribeConsumerGroupRequest.h" #include "model/DescribeConsumerGroupResult.h" #include "model/DescribeDTSIPRequest.h" @@ -72,8 +80,6 @@ #include "model/DescribeDgDatabasesResult.h" #include "model/DescribeDtsJobDetailRequest.h" #include "model/DescribeDtsJobDetailResult.h" -#include "model/DescribeDtsJobLogsRequest.h" -#include "model/DescribeDtsJobLogsResult.h" #include "model/DescribeDtsJobsRequest.h" #include "model/DescribeDtsJobsResult.h" #include "model/DescribeEndpointSwitchStatusRequest.h" @@ -114,6 +120,8 @@ #include "model/DescribeSynchronizationObjectModifyStatusResult.h" #include "model/ListTagResourcesRequest.h" #include "model/ListTagResourcesResult.h" +#include "model/ModifyConsumerChannelRequest.h" +#include "model/ModifyConsumerChannelResult.h" #include "model/ModifyConsumerGroupPasswordRequest.h" #include "model/ModifyConsumerGroupPasswordResult.h" #include "model/ModifyConsumptionTimestampRequest.h" @@ -124,12 +132,14 @@ #include "model/ModifyDtsJobNameResult.h" #include "model/ModifyDtsJobPasswordRequest.h" #include "model/ModifyDtsJobPasswordResult.h" +#include "model/ModifySubscriptionRequest.h" +#include "model/ModifySubscriptionResult.h" #include "model/ModifySubscriptionObjectRequest.h" #include "model/ModifySubscriptionObjectResult.h" #include "model/ModifySynchronizationObjectRequest.h" #include "model/ModifySynchronizationObjectResult.h" -#include "model/PreviewSqlRequest.h" -#include "model/PreviewSqlResult.h" +#include "model/RenewInstanceRequest.h" +#include "model/RenewInstanceResult.h" #include "model/ReplaceInstanceRequest.h" #include "model/ReplaceInstanceResult.h" #include "model/ResetDtsJobRequest.h" @@ -162,6 +172,8 @@ #include "model/SwitchSynchronizationEndpointResult.h" #include "model/TagResourcesRequest.h" #include "model/TagResourcesResult.h" +#include "model/TransferInstanceClassRequest.h" +#include "model/TransferInstanceClassResult.h" #include "model/TransferPayTypeRequest.h" #include "model/TransferPayTypeResult.h" #include "model/UntagResourcesRequest.h" @@ -188,6 +200,9 @@ namespace AlibabaCloud typedef Outcome ConfigureMigrationJobAlertOutcome; typedef std::future ConfigureMigrationJobAlertOutcomeCallable; typedef std::function&)> ConfigureMigrationJobAlertAsyncHandler; + typedef Outcome ConfigureSubscriptionOutcome; + typedef std::future ConfigureSubscriptionOutcomeCallable; + typedef std::function&)> ConfigureSubscriptionAsyncHandler; typedef Outcome ConfigureSubscriptionInstanceOutcome; typedef std::future ConfigureSubscriptionInstanceOutcomeCallable; typedef std::function&)> ConfigureSubscriptionInstanceAsyncHandler; @@ -203,6 +218,9 @@ namespace AlibabaCloud typedef Outcome ConfigureSynchronizationJobReplicatorCompareOutcome; typedef std::future ConfigureSynchronizationJobReplicatorCompareOutcomeCallable; typedef std::function&)> ConfigureSynchronizationJobReplicatorCompareAsyncHandler; + typedef Outcome CreateConsumerChannelOutcome; + typedef std::future CreateConsumerChannelOutcomeCallable; + typedef std::function&)> CreateConsumerChannelAsyncHandler; typedef Outcome CreateConsumerGroupOutcome; typedef std::future CreateConsumerGroupOutcomeCallable; typedef std::function&)> CreateConsumerGroupAsyncHandler; @@ -221,6 +239,9 @@ namespace AlibabaCloud typedef Outcome CreateSynchronizationJobOutcome; typedef std::future CreateSynchronizationJobOutcomeCallable; typedef std::function&)> CreateSynchronizationJobAsyncHandler; + typedef Outcome DeleteConsumerChannelOutcome; + typedef std::future DeleteConsumerChannelOutcomeCallable; + typedef std::function&)> DeleteConsumerChannelAsyncHandler; typedef Outcome DeleteConsumerGroupOutcome; typedef std::future DeleteConsumerGroupOutcomeCallable; typedef std::function&)> DeleteConsumerGroupAsyncHandler; @@ -242,6 +263,9 @@ namespace AlibabaCloud typedef Outcome DescribeConnectionStatusOutcome; typedef std::future DescribeConnectionStatusOutcomeCallable; typedef std::function&)> DescribeConnectionStatusAsyncHandler; + typedef Outcome DescribeConsumerChannelOutcome; + typedef std::future DescribeConsumerChannelOutcomeCallable; + typedef std::function&)> DescribeConsumerChannelAsyncHandler; typedef Outcome DescribeConsumerGroupOutcome; typedef std::future DescribeConsumerGroupOutcomeCallable; typedef std::function&)> DescribeConsumerGroupAsyncHandler; @@ -254,9 +278,6 @@ namespace AlibabaCloud typedef Outcome DescribeDtsJobDetailOutcome; typedef std::future DescribeDtsJobDetailOutcomeCallable; typedef std::function&)> DescribeDtsJobDetailAsyncHandler; - typedef Outcome DescribeDtsJobLogsOutcome; - typedef std::future DescribeDtsJobLogsOutcomeCallable; - typedef std::function&)> DescribeDtsJobLogsAsyncHandler; typedef Outcome DescribeDtsJobsOutcome; typedef std::future DescribeDtsJobsOutcomeCallable; typedef std::function&)> DescribeDtsJobsAsyncHandler; @@ -317,6 +338,9 @@ namespace AlibabaCloud typedef Outcome ListTagResourcesOutcome; typedef std::future ListTagResourcesOutcomeCallable; typedef std::function&)> ListTagResourcesAsyncHandler; + typedef Outcome ModifyConsumerChannelOutcome; + typedef std::future ModifyConsumerChannelOutcomeCallable; + typedef std::function&)> ModifyConsumerChannelAsyncHandler; typedef Outcome ModifyConsumerGroupPasswordOutcome; typedef std::future ModifyConsumerGroupPasswordOutcomeCallable; typedef std::function&)> ModifyConsumerGroupPasswordAsyncHandler; @@ -332,15 +356,18 @@ namespace AlibabaCloud typedef Outcome ModifyDtsJobPasswordOutcome; typedef std::future ModifyDtsJobPasswordOutcomeCallable; typedef std::function&)> ModifyDtsJobPasswordAsyncHandler; + typedef Outcome ModifySubscriptionOutcome; + typedef std::future ModifySubscriptionOutcomeCallable; + typedef std::function&)> ModifySubscriptionAsyncHandler; typedef Outcome ModifySubscriptionObjectOutcome; typedef std::future ModifySubscriptionObjectOutcomeCallable; typedef std::function&)> ModifySubscriptionObjectAsyncHandler; typedef Outcome ModifySynchronizationObjectOutcome; typedef std::future ModifySynchronizationObjectOutcomeCallable; typedef std::function&)> ModifySynchronizationObjectAsyncHandler; - typedef Outcome PreviewSqlOutcome; - typedef std::future PreviewSqlOutcomeCallable; - typedef std::function&)> PreviewSqlAsyncHandler; + typedef Outcome RenewInstanceOutcome; + typedef std::future RenewInstanceOutcomeCallable; + typedef std::function&)> RenewInstanceAsyncHandler; typedef Outcome ReplaceInstanceOutcome; typedef std::future ReplaceInstanceOutcomeCallable; typedef std::function&)> ReplaceInstanceAsyncHandler; @@ -389,6 +416,9 @@ namespace AlibabaCloud typedef Outcome TagResourcesOutcome; typedef std::future TagResourcesOutcomeCallable; typedef std::function&)> TagResourcesAsyncHandler; + typedef Outcome TransferInstanceClassOutcome; + typedef std::future TransferInstanceClassOutcomeCallable; + typedef std::function&)> TransferInstanceClassAsyncHandler; typedef Outcome TransferPayTypeOutcome; typedef std::future TransferPayTypeOutcomeCallable; typedef std::function&)> TransferPayTypeAsyncHandler; @@ -415,6 +445,9 @@ namespace AlibabaCloud ConfigureMigrationJobAlertOutcome configureMigrationJobAlert(const Model::ConfigureMigrationJobAlertRequest &request)const; void configureMigrationJobAlertAsync(const Model::ConfigureMigrationJobAlertRequest& request, const ConfigureMigrationJobAlertAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ConfigureMigrationJobAlertOutcomeCallable configureMigrationJobAlertCallable(const Model::ConfigureMigrationJobAlertRequest& request) const; + ConfigureSubscriptionOutcome configureSubscription(const Model::ConfigureSubscriptionRequest &request)const; + void configureSubscriptionAsync(const Model::ConfigureSubscriptionRequest& request, const ConfigureSubscriptionAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + ConfigureSubscriptionOutcomeCallable configureSubscriptionCallable(const Model::ConfigureSubscriptionRequest& request) const; ConfigureSubscriptionInstanceOutcome configureSubscriptionInstance(const Model::ConfigureSubscriptionInstanceRequest &request)const; void configureSubscriptionInstanceAsync(const Model::ConfigureSubscriptionInstanceRequest& request, const ConfigureSubscriptionInstanceAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ConfigureSubscriptionInstanceOutcomeCallable configureSubscriptionInstanceCallable(const Model::ConfigureSubscriptionInstanceRequest& request) const; @@ -430,6 +463,9 @@ namespace AlibabaCloud ConfigureSynchronizationJobReplicatorCompareOutcome configureSynchronizationJobReplicatorCompare(const Model::ConfigureSynchronizationJobReplicatorCompareRequest &request)const; void configureSynchronizationJobReplicatorCompareAsync(const Model::ConfigureSynchronizationJobReplicatorCompareRequest& request, const ConfigureSynchronizationJobReplicatorCompareAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ConfigureSynchronizationJobReplicatorCompareOutcomeCallable configureSynchronizationJobReplicatorCompareCallable(const Model::ConfigureSynchronizationJobReplicatorCompareRequest& request) const; + CreateConsumerChannelOutcome createConsumerChannel(const Model::CreateConsumerChannelRequest &request)const; + void createConsumerChannelAsync(const Model::CreateConsumerChannelRequest& request, const CreateConsumerChannelAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + CreateConsumerChannelOutcomeCallable createConsumerChannelCallable(const Model::CreateConsumerChannelRequest& request) const; CreateConsumerGroupOutcome createConsumerGroup(const Model::CreateConsumerGroupRequest &request)const; void createConsumerGroupAsync(const Model::CreateConsumerGroupRequest& request, const CreateConsumerGroupAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; CreateConsumerGroupOutcomeCallable createConsumerGroupCallable(const Model::CreateConsumerGroupRequest& request) const; @@ -448,6 +484,9 @@ namespace AlibabaCloud CreateSynchronizationJobOutcome createSynchronizationJob(const Model::CreateSynchronizationJobRequest &request)const; void createSynchronizationJobAsync(const Model::CreateSynchronizationJobRequest& request, const CreateSynchronizationJobAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; CreateSynchronizationJobOutcomeCallable createSynchronizationJobCallable(const Model::CreateSynchronizationJobRequest& request) const; + DeleteConsumerChannelOutcome deleteConsumerChannel(const Model::DeleteConsumerChannelRequest &request)const; + void deleteConsumerChannelAsync(const Model::DeleteConsumerChannelRequest& request, const DeleteConsumerChannelAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + DeleteConsumerChannelOutcomeCallable deleteConsumerChannelCallable(const Model::DeleteConsumerChannelRequest& request) const; DeleteConsumerGroupOutcome deleteConsumerGroup(const Model::DeleteConsumerGroupRequest &request)const; void deleteConsumerGroupAsync(const Model::DeleteConsumerGroupRequest& request, const DeleteConsumerGroupAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; DeleteConsumerGroupOutcomeCallable deleteConsumerGroupCallable(const Model::DeleteConsumerGroupRequest& request) const; @@ -469,6 +508,9 @@ namespace AlibabaCloud DescribeConnectionStatusOutcome describeConnectionStatus(const Model::DescribeConnectionStatusRequest &request)const; void describeConnectionStatusAsync(const Model::DescribeConnectionStatusRequest& request, const DescribeConnectionStatusAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; DescribeConnectionStatusOutcomeCallable describeConnectionStatusCallable(const Model::DescribeConnectionStatusRequest& request) const; + DescribeConsumerChannelOutcome describeConsumerChannel(const Model::DescribeConsumerChannelRequest &request)const; + void describeConsumerChannelAsync(const Model::DescribeConsumerChannelRequest& request, const DescribeConsumerChannelAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + DescribeConsumerChannelOutcomeCallable describeConsumerChannelCallable(const Model::DescribeConsumerChannelRequest& request) const; DescribeConsumerGroupOutcome describeConsumerGroup(const Model::DescribeConsumerGroupRequest &request)const; void describeConsumerGroupAsync(const Model::DescribeConsumerGroupRequest& request, const DescribeConsumerGroupAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; DescribeConsumerGroupOutcomeCallable describeConsumerGroupCallable(const Model::DescribeConsumerGroupRequest& request) const; @@ -481,9 +523,6 @@ namespace AlibabaCloud DescribeDtsJobDetailOutcome describeDtsJobDetail(const Model::DescribeDtsJobDetailRequest &request)const; void describeDtsJobDetailAsync(const Model::DescribeDtsJobDetailRequest& request, const DescribeDtsJobDetailAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; DescribeDtsJobDetailOutcomeCallable describeDtsJobDetailCallable(const Model::DescribeDtsJobDetailRequest& request) const; - DescribeDtsJobLogsOutcome describeDtsJobLogs(const Model::DescribeDtsJobLogsRequest &request)const; - void describeDtsJobLogsAsync(const Model::DescribeDtsJobLogsRequest& request, const DescribeDtsJobLogsAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; - DescribeDtsJobLogsOutcomeCallable describeDtsJobLogsCallable(const Model::DescribeDtsJobLogsRequest& request) const; DescribeDtsJobsOutcome describeDtsJobs(const Model::DescribeDtsJobsRequest &request)const; void describeDtsJobsAsync(const Model::DescribeDtsJobsRequest& request, const DescribeDtsJobsAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; DescribeDtsJobsOutcomeCallable describeDtsJobsCallable(const Model::DescribeDtsJobsRequest& request) const; @@ -544,6 +583,9 @@ namespace AlibabaCloud ListTagResourcesOutcome listTagResources(const Model::ListTagResourcesRequest &request)const; void listTagResourcesAsync(const Model::ListTagResourcesRequest& request, const ListTagResourcesAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ListTagResourcesOutcomeCallable listTagResourcesCallable(const Model::ListTagResourcesRequest& request) const; + ModifyConsumerChannelOutcome modifyConsumerChannel(const Model::ModifyConsumerChannelRequest &request)const; + void modifyConsumerChannelAsync(const Model::ModifyConsumerChannelRequest& request, const ModifyConsumerChannelAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + ModifyConsumerChannelOutcomeCallable modifyConsumerChannelCallable(const Model::ModifyConsumerChannelRequest& request) const; ModifyConsumerGroupPasswordOutcome modifyConsumerGroupPassword(const Model::ModifyConsumerGroupPasswordRequest &request)const; void modifyConsumerGroupPasswordAsync(const Model::ModifyConsumerGroupPasswordRequest& request, const ModifyConsumerGroupPasswordAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ModifyConsumerGroupPasswordOutcomeCallable modifyConsumerGroupPasswordCallable(const Model::ModifyConsumerGroupPasswordRequest& request) const; @@ -559,15 +601,18 @@ namespace AlibabaCloud ModifyDtsJobPasswordOutcome modifyDtsJobPassword(const Model::ModifyDtsJobPasswordRequest &request)const; void modifyDtsJobPasswordAsync(const Model::ModifyDtsJobPasswordRequest& request, const ModifyDtsJobPasswordAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ModifyDtsJobPasswordOutcomeCallable modifyDtsJobPasswordCallable(const Model::ModifyDtsJobPasswordRequest& request) const; + ModifySubscriptionOutcome modifySubscription(const Model::ModifySubscriptionRequest &request)const; + void modifySubscriptionAsync(const Model::ModifySubscriptionRequest& request, const ModifySubscriptionAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + ModifySubscriptionOutcomeCallable modifySubscriptionCallable(const Model::ModifySubscriptionRequest& request) const; ModifySubscriptionObjectOutcome modifySubscriptionObject(const Model::ModifySubscriptionObjectRequest &request)const; void modifySubscriptionObjectAsync(const Model::ModifySubscriptionObjectRequest& request, const ModifySubscriptionObjectAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ModifySubscriptionObjectOutcomeCallable modifySubscriptionObjectCallable(const Model::ModifySubscriptionObjectRequest& request) const; ModifySynchronizationObjectOutcome modifySynchronizationObject(const Model::ModifySynchronizationObjectRequest &request)const; void modifySynchronizationObjectAsync(const Model::ModifySynchronizationObjectRequest& request, const ModifySynchronizationObjectAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ModifySynchronizationObjectOutcomeCallable modifySynchronizationObjectCallable(const Model::ModifySynchronizationObjectRequest& request) const; - PreviewSqlOutcome previewSql(const Model::PreviewSqlRequest &request)const; - void previewSqlAsync(const Model::PreviewSqlRequest& request, const PreviewSqlAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; - PreviewSqlOutcomeCallable previewSqlCallable(const Model::PreviewSqlRequest& request) const; + RenewInstanceOutcome renewInstance(const Model::RenewInstanceRequest &request)const; + void renewInstanceAsync(const Model::RenewInstanceRequest& request, const RenewInstanceAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + RenewInstanceOutcomeCallable renewInstanceCallable(const Model::RenewInstanceRequest& request) const; ReplaceInstanceOutcome replaceInstance(const Model::ReplaceInstanceRequest &request)const; void replaceInstanceAsync(const Model::ReplaceInstanceRequest& request, const ReplaceInstanceAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ReplaceInstanceOutcomeCallable replaceInstanceCallable(const Model::ReplaceInstanceRequest& request) const; @@ -616,6 +661,9 @@ namespace AlibabaCloud TagResourcesOutcome tagResources(const Model::TagResourcesRequest &request)const; void tagResourcesAsync(const Model::TagResourcesRequest& request, const TagResourcesAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; TagResourcesOutcomeCallable tagResourcesCallable(const Model::TagResourcesRequest& request) const; + TransferInstanceClassOutcome transferInstanceClass(const Model::TransferInstanceClassRequest &request)const; + void transferInstanceClassAsync(const Model::TransferInstanceClassRequest& request, const TransferInstanceClassAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + TransferInstanceClassOutcomeCallable transferInstanceClassCallable(const Model::TransferInstanceClassRequest& request) const; TransferPayTypeOutcome transferPayType(const Model::TransferPayTypeRequest &request)const; void transferPayTypeAsync(const Model::TransferPayTypeRequest& request, const TransferPayTypeAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; TransferPayTypeOutcomeCallable transferPayTypeCallable(const Model::TransferPayTypeRequest& request) const; diff --git a/dts/include/alibabacloud/dts/model/ConfigureSubscriptionRequest.h b/dts/include/alibabacloud/dts/model/ConfigureSubscriptionRequest.h new file mode 100644 index 000000000..82831fa9f --- /dev/null +++ b/dts/include/alibabacloud/dts/model/ConfigureSubscriptionRequest.h @@ -0,0 +1,132 @@ +/* + * 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_DTS_MODEL_CONFIGURESUBSCRIPTIONREQUEST_H_ +#define ALIBABACLOUD_DTS_MODEL_CONFIGURESUBSCRIPTIONREQUEST_H_ + +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT ConfigureSubscriptionRequest : public RpcServiceRequest + { + + public: + ConfigureSubscriptionRequest(); + ~ConfigureSubscriptionRequest(); + + std::string getSourceEndpointRegion()const; + void setSourceEndpointRegion(const std::string& sourceEndpointRegion); + std::string getCheckpoint()const; + void setCheckpoint(const std::string& checkpoint); + std::string getSubscriptionInstanceVSwitchId()const; + void setSubscriptionInstanceVSwitchId(const std::string& subscriptionInstanceVSwitchId); + bool getDelayNotice()const; + void setDelayNotice(bool delayNotice); + std::string getSourceEndpointInstanceID()const; + void setSourceEndpointInstanceID(const std::string& sourceEndpointInstanceID); + std::string getSourceEndpointUserName()const; + void setSourceEndpointUserName(const std::string& sourceEndpointUserName); + std::string getSourceEndpointOwnerID()const; + void setSourceEndpointOwnerID(const std::string& sourceEndpointOwnerID); + std::string getDelayPhone()const; + void setDelayPhone(const std::string& delayPhone); + bool getSubscriptionDataTypeDML()const; + void setSubscriptionDataTypeDML(bool subscriptionDataTypeDML); + std::string getSourceEndpointDatabaseName()const; + void setSourceEndpointDatabaseName(const std::string& sourceEndpointDatabaseName); + std::string getSourceEndpointIP()const; + void setSourceEndpointIP(const std::string& sourceEndpointIP); + std::string getRegionId()const; + void setRegionId(const std::string& regionId); + std::string getErrorPhone()const; + void setErrorPhone(const std::string& errorPhone); + std::string getReserve()const; + void setReserve(const std::string& reserve); + std::string getDtsJobId()const; + void setDtsJobId(const std::string& dtsJobId); + std::string getDbList()const; + void setDbList(const std::string& dbList); + std::string getSubscriptionInstanceNetworkType()const; + void setSubscriptionInstanceNetworkType(const std::string& subscriptionInstanceNetworkType); + bool getSubscriptionDataTypeDDL()const; + void setSubscriptionDataTypeDDL(bool subscriptionDataTypeDDL); + std::string getSourceEndpointPassword()const; + void setSourceEndpointPassword(const std::string& sourceEndpointPassword); + std::string getSourceEndpointPort()const; + void setSourceEndpointPort(const std::string& sourceEndpointPort); + std::string getSubscriptionInstanceVPCId()const; + void setSubscriptionInstanceVPCId(const std::string& subscriptionInstanceVPCId); + long getDelayRuleTime()const; + void setDelayRuleTime(long delayRuleTime); + std::string getSourceEndpointInstanceType()const; + void setSourceEndpointInstanceType(const std::string& sourceEndpointInstanceType); + std::string getDtsJobName()const; + void setDtsJobName(const std::string& dtsJobName); + std::string getSourceEndpointOracleSID()const; + void setSourceEndpointOracleSID(const std::string& sourceEndpointOracleSID); + bool getErrorNotice()const; + void setErrorNotice(bool errorNotice); + std::string getSourceEndpointRole()const; + void setSourceEndpointRole(const std::string& sourceEndpointRole); + std::string getDtsInstanceId()const; + void setDtsInstanceId(const std::string& dtsInstanceId); + std::string getSourceEndpointEngineName()const; + void setSourceEndpointEngineName(const std::string& sourceEndpointEngineName); + + private: + std::string sourceEndpointRegion_; + std::string checkpoint_; + std::string subscriptionInstanceVSwitchId_; + bool delayNotice_; + std::string sourceEndpointInstanceID_; + std::string sourceEndpointUserName_; + std::string sourceEndpointOwnerID_; + std::string delayPhone_; + bool subscriptionDataTypeDML_; + std::string sourceEndpointDatabaseName_; + std::string sourceEndpointIP_; + std::string regionId_; + std::string errorPhone_; + std::string reserve_; + std::string dtsJobId_; + std::string dbList_; + std::string subscriptionInstanceNetworkType_; + bool subscriptionDataTypeDDL_; + std::string sourceEndpointPassword_; + std::string sourceEndpointPort_; + std::string subscriptionInstanceVPCId_; + long delayRuleTime_; + std::string sourceEndpointInstanceType_; + std::string dtsJobName_; + std::string sourceEndpointOracleSID_; + bool errorNotice_; + std::string sourceEndpointRole_; + std::string dtsInstanceId_; + std::string sourceEndpointEngineName_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_CONFIGURESUBSCRIPTIONREQUEST_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/ConfigureSubscriptionResult.h b/dts/include/alibabacloud/dts/model/ConfigureSubscriptionResult.h new file mode 100644 index 000000000..80510faf8 --- /dev/null +++ b/dts/include/alibabacloud/dts/model/ConfigureSubscriptionResult.h @@ -0,0 +1,61 @@ +/* + * 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_DTS_MODEL_CONFIGURESUBSCRIPTIONRESULT_H_ +#define ALIBABACLOUD_DTS_MODEL_CONFIGURESUBSCRIPTIONRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT ConfigureSubscriptionResult : public ServiceResult + { + public: + + + ConfigureSubscriptionResult(); + explicit ConfigureSubscriptionResult(const std::string &payload); + ~ConfigureSubscriptionResult(); + std::string getDtsJobId()const; + std::string getHttpStatusCode()const; + std::string getErrMessage()const; + std::string getDtsInstanceId()const; + std::string getSuccess()const; + std::string getErrCode()const; + + protected: + void parse(const std::string &payload); + private: + std::string dtsJobId_; + std::string httpStatusCode_; + std::string errMessage_; + std::string dtsInstanceId_; + std::string success_; + std::string errCode_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_CONFIGURESUBSCRIPTIONRESULT_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/CreateConsumerChannelRequest.h b/dts/include/alibabacloud/dts/model/CreateConsumerChannelRequest.h new file mode 100644 index 000000000..ae97470ff --- /dev/null +++ b/dts/include/alibabacloud/dts/model/CreateConsumerChannelRequest.h @@ -0,0 +1,63 @@ +/* + * 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_DTS_MODEL_CREATECONSUMERCHANNELREQUEST_H_ +#define ALIBABACLOUD_DTS_MODEL_CREATECONSUMERCHANNELREQUEST_H_ + +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT CreateConsumerChannelRequest : public RpcServiceRequest + { + + public: + CreateConsumerChannelRequest(); + ~CreateConsumerChannelRequest(); + + std::string getConsumerGroupName()const; + void setConsumerGroupName(const std::string& consumerGroupName); + std::string getConsumerGroupPassword()const; + void setConsumerGroupPassword(const std::string& consumerGroupPassword); + std::string getConsumerGroupUserName()const; + void setConsumerGroupUserName(const std::string& consumerGroupUserName); + std::string getRegionId()const; + void setRegionId(const std::string& regionId); + std::string getDtsJobId()const; + void setDtsJobId(const std::string& dtsJobId); + std::string getDtsInstanceId()const; + void setDtsInstanceId(const std::string& dtsInstanceId); + + private: + std::string consumerGroupName_; + std::string consumerGroupPassword_; + std::string consumerGroupUserName_; + std::string regionId_; + std::string dtsJobId_; + std::string dtsInstanceId_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_CREATECONSUMERCHANNELREQUEST_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/CreateConsumerChannelResult.h b/dts/include/alibabacloud/dts/model/CreateConsumerChannelResult.h new file mode 100644 index 000000000..c2f8afe99 --- /dev/null +++ b/dts/include/alibabacloud/dts/model/CreateConsumerChannelResult.h @@ -0,0 +1,59 @@ +/* + * 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_DTS_MODEL_CREATECONSUMERCHANNELRESULT_H_ +#define ALIBABACLOUD_DTS_MODEL_CREATECONSUMERCHANNELRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT CreateConsumerChannelResult : public ServiceResult + { + public: + + + CreateConsumerChannelResult(); + explicit CreateConsumerChannelResult(const std::string &payload); + ~CreateConsumerChannelResult(); + std::string getConsumerGroupID()const; + std::string getHttpStatusCode()const; + std::string getErrMessage()const; + std::string getSuccess()const; + std::string getErrCode()const; + + protected: + void parse(const std::string &payload); + private: + std::string consumerGroupID_; + std::string httpStatusCode_; + std::string errMessage_; + std::string success_; + std::string errCode_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_CREATECONSUMERCHANNELRESULT_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/DeleteConsumerChannelRequest.h b/dts/include/alibabacloud/dts/model/DeleteConsumerChannelRequest.h new file mode 100644 index 000000000..6a7fa7285 --- /dev/null +++ b/dts/include/alibabacloud/dts/model/DeleteConsumerChannelRequest.h @@ -0,0 +1,57 @@ +/* + * 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_DTS_MODEL_DELETECONSUMERCHANNELREQUEST_H_ +#define ALIBABACLOUD_DTS_MODEL_DELETECONSUMERCHANNELREQUEST_H_ + +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT DeleteConsumerChannelRequest : public RpcServiceRequest + { + + public: + DeleteConsumerChannelRequest(); + ~DeleteConsumerChannelRequest(); + + std::string getConsumerGroupId()const; + void setConsumerGroupId(const std::string& consumerGroupId); + std::string getRegionId()const; + void setRegionId(const std::string& regionId); + std::string getDtsJobId()const; + void setDtsJobId(const std::string& dtsJobId); + std::string getDtsInstanceId()const; + void setDtsInstanceId(const std::string& dtsInstanceId); + + private: + std::string consumerGroupId_; + std::string regionId_; + std::string dtsJobId_; + std::string dtsInstanceId_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_DELETECONSUMERCHANNELREQUEST_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/DeleteConsumerChannelResult.h b/dts/include/alibabacloud/dts/model/DeleteConsumerChannelResult.h new file mode 100644 index 000000000..1c11f8ece --- /dev/null +++ b/dts/include/alibabacloud/dts/model/DeleteConsumerChannelResult.h @@ -0,0 +1,57 @@ +/* + * 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_DTS_MODEL_DELETECONSUMERCHANNELRESULT_H_ +#define ALIBABACLOUD_DTS_MODEL_DELETECONSUMERCHANNELRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT DeleteConsumerChannelResult : public ServiceResult + { + public: + + + DeleteConsumerChannelResult(); + explicit DeleteConsumerChannelResult(const std::string &payload); + ~DeleteConsumerChannelResult(); + std::string getHttpStatusCode()const; + std::string getErrMessage()const; + std::string getSuccess()const; + std::string getErrCode()const; + + protected: + void parse(const std::string &payload); + private: + std::string httpStatusCode_; + std::string errMessage_; + std::string success_; + std::string errCode_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_DELETECONSUMERCHANNELRESULT_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/DescribeDtsJobLogsRequest.h b/dts/include/alibabacloud/dts/model/DescribeConsumerChannelRequest.h similarity index 63% rename from dts/include/alibabacloud/dts/model/DescribeDtsJobLogsRequest.h rename to dts/include/alibabacloud/dts/model/DescribeConsumerChannelRequest.h index 891d752d4..4ed1d21c4 100644 --- a/dts/include/alibabacloud/dts/model/DescribeDtsJobLogsRequest.h +++ b/dts/include/alibabacloud/dts/model/DescribeConsumerChannelRequest.h @@ -14,8 +14,8 @@ * limitations under the License. */ -#ifndef ALIBABACLOUD_DTS_MODEL_DESCRIBEDTSJOBLOGSREQUEST_H_ -#define ALIBABACLOUD_DTS_MODEL_DESCRIBEDTSJOBLOGSREQUEST_H_ +#ifndef ALIBABACLOUD_DTS_MODEL_DESCRIBECONSUMERCHANNELREQUEST_H_ +#define ALIBABACLOUD_DTS_MODEL_DESCRIBECONSUMERCHANNELREQUEST_H_ #include #include @@ -28,19 +28,13 @@ namespace AlibabaCloud { namespace Model { - class ALIBABACLOUD_DTS_EXPORT DescribeDtsJobLogsRequest : public RpcServiceRequest + class ALIBABACLOUD_DTS_EXPORT DescribeConsumerChannelRequest : public RpcServiceRequest { public: - DescribeDtsJobLogsRequest(); - ~DescribeDtsJobLogsRequest(); + DescribeConsumerChannelRequest(); + ~DescribeConsumerChannelRequest(); - long getEndTime()const; - void setEndTime(long endTime); - long getStartTime()const; - void setStartTime(long startTime); - std::string getType()const; - void setType(const std::string& type); int getPageNumber()const; void setPageNumber(int pageNumber); std::string getRegionId()const; @@ -49,21 +43,18 @@ namespace AlibabaCloud void setPageSize(int pageSize); std::string getDtsJobId()const; void setDtsJobId(const std::string& dtsJobId); - std::string getStatus()const; - void setStatus(const std::string& status); + std::string getDtsInstanceId()const; + void setDtsInstanceId(const std::string& dtsInstanceId); private: - long endTime_; - long startTime_; - std::string type_; int pageNumber_; std::string regionId_; int pageSize_; std::string dtsJobId_; - std::string status_; + std::string dtsInstanceId_; }; } } } -#endif // !ALIBABACLOUD_DTS_MODEL_DESCRIBEDTSJOBLOGSREQUEST_H_ \ No newline at end of file +#endif // !ALIBABACLOUD_DTS_MODEL_DESCRIBECONSUMERCHANNELREQUEST_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/DescribeDtsJobLogsResult.h b/dts/include/alibabacloud/dts/model/DescribeConsumerChannelResult.h similarity index 57% rename from dts/include/alibabacloud/dts/model/DescribeDtsJobLogsResult.h rename to dts/include/alibabacloud/dts/model/DescribeConsumerChannelResult.h index d4a7d13ff..eb62f114e 100644 --- a/dts/include/alibabacloud/dts/model/DescribeDtsJobLogsResult.h +++ b/dts/include/alibabacloud/dts/model/DescribeConsumerChannelResult.h @@ -14,8 +14,8 @@ * limitations under the License. */ -#ifndef ALIBABACLOUD_DTS_MODEL_DESCRIBEDTSJOBLOGSRESULT_H_ -#define ALIBABACLOUD_DTS_MODEL_DESCRIBEDTSJOBLOGSRESULT_H_ +#ifndef ALIBABACLOUD_DTS_MODEL_DESCRIBECONSUMERCHANNELRESULT_H_ +#define ALIBABACLOUD_DTS_MODEL_DESCRIBECONSUMERCHANNELRESULT_H_ #include #include @@ -29,32 +29,30 @@ namespace AlibabaCloud { namespace Model { - class ALIBABACLOUD_DTS_EXPORT DescribeDtsJobLogsResult : public ServiceResult + class ALIBABACLOUD_DTS_EXPORT DescribeConsumerChannelResult : public ServiceResult { public: - struct JobRunningLog + struct ConsumerChannel { - std::string contentKey; - std::string status; - long logDatetime; - std::vector params; - long id; - std::string jobId; + std::string consumptionCheckpoint; + std::string consumerGroupId; + std::string consumerGroupUserName; + std::string consumerGroupName; + long messageDelay; + long unconsumedData; }; - DescribeDtsJobLogsResult(); - explicit DescribeDtsJobLogsResult(const std::string &payload); - ~DescribeDtsJobLogsResult(); + DescribeConsumerChannelResult(); + explicit DescribeConsumerChannelResult(const std::string &payload); + ~DescribeConsumerChannelResult(); long getTotalRecordCount()const; int getPageRecordCount()const; int getPageNumber()const; - int getHttpStatusCode()const; - std::vector getJobRunningLogs()const; - std::string getDynamicCode()const; - std::string getDynamicMessage()const; + std::string getHttpStatusCode()const; + std::vector getConsumerChannels()const; std::string getErrMessage()const; - bool getSuccess()const; + std::string getSuccess()const; std::string getErrCode()const; protected: @@ -63,16 +61,14 @@ namespace AlibabaCloud long totalRecordCount_; int pageRecordCount_; int pageNumber_; - int httpStatusCode_; - std::vector jobRunningLogs_; - std::string dynamicCode_; - std::string dynamicMessage_; + std::string httpStatusCode_; + std::vector consumerChannels_; std::string errMessage_; - bool success_; + std::string success_; std::string errCode_; }; } } } -#endif // !ALIBABACLOUD_DTS_MODEL_DESCRIBEDTSJOBLOGSRESULT_H_ \ No newline at end of file +#endif // !ALIBABACLOUD_DTS_MODEL_DESCRIBECONSUMERCHANNELRESULT_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/DescribeMigrationJobsResult.h b/dts/include/alibabacloud/dts/model/DescribeMigrationJobsResult.h index e57f42520..bf04f45ee 100644 --- a/dts/include/alibabacloud/dts/model/DescribeMigrationJobsResult.h +++ b/dts/include/alibabacloud/dts/model/DescribeMigrationJobsResult.h @@ -101,6 +101,8 @@ namespace AlibabaCloud }; DataSynchronization dataSynchronization; Precheck precheck; + std::string instanceCreateTime; + std::string jobCreateTime; std::string migrationJobName; std::string payType; MigrationMode migrationMode; diff --git a/dts/include/alibabacloud/dts/model/DescribeSubscriptionInstanceStatusResult.h b/dts/include/alibabacloud/dts/model/DescribeSubscriptionInstanceStatusResult.h index 86b75932d..1928cc449 100644 --- a/dts/include/alibabacloud/dts/model/DescribeSubscriptionInstanceStatusResult.h +++ b/dts/include/alibabacloud/dts/model/DescribeSubscriptionInstanceStatusResult.h @@ -73,7 +73,6 @@ namespace AlibabaCloud std::string getConsumptionCheckpoint()const; std::string getSubscriptionInstanceName()const; std::string getSubscribeTopic()const; - std::string getErrorMessage1()const; std::string getConsumptionClient()const; SourceEndpoint getSourceEndpoint()const; std::string getErrorMessage()const; @@ -96,7 +95,6 @@ namespace AlibabaCloud std::string consumptionCheckpoint_; std::string subscriptionInstanceName_; std::string subscribeTopic_; - std::string errorMessage1_; std::string consumptionClient_; SourceEndpoint sourceEndpoint_; std::string errorMessage_; diff --git a/dts/include/alibabacloud/dts/model/DescribeSubscriptionInstancesResult.h b/dts/include/alibabacloud/dts/model/DescribeSubscriptionInstancesResult.h index 8e8fb504a..3a5f16a46 100644 --- a/dts/include/alibabacloud/dts/model/DescribeSubscriptionInstancesResult.h +++ b/dts/include/alibabacloud/dts/model/DescribeSubscriptionInstancesResult.h @@ -63,6 +63,8 @@ namespace AlibabaCloud }; std::string status; SubscriptionHost subscriptionHost; + std::string instanceCreateTime; + std::string jobCreateTime; std::string endTimestamp; std::string payType; std::string subscriptionInstanceID; diff --git a/dts/include/alibabacloud/dts/model/DescribeSynchronizationJobsResult.h b/dts/include/alibabacloud/dts/model/DescribeSynchronizationJobsResult.h index 5eb5a1b41..87f84cb32 100644 --- a/dts/include/alibabacloud/dts/model/DescribeSynchronizationJobsResult.h +++ b/dts/include/alibabacloud/dts/model/DescribeSynchronizationJobsResult.h @@ -115,7 +115,9 @@ namespace AlibabaCloud DataInitializationStatus dataInitializationStatus; std::vector synchronizationObjects; std::string synchronizationJobName; + std::string instanceCreateTime; std::string createTime; + std::string jobCreateTime; std::string payType; std::string delay; PrecheckStatus precheckStatus; diff --git a/dts/include/alibabacloud/dts/model/ModifyConsumerChannelRequest.h b/dts/include/alibabacloud/dts/model/ModifyConsumerChannelRequest.h new file mode 100644 index 000000000..cdbf7c4ea --- /dev/null +++ b/dts/include/alibabacloud/dts/model/ModifyConsumerChannelRequest.h @@ -0,0 +1,66 @@ +/* + * 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_DTS_MODEL_MODIFYCONSUMERCHANNELREQUEST_H_ +#define ALIBABACLOUD_DTS_MODEL_MODIFYCONSUMERCHANNELREQUEST_H_ + +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT ModifyConsumerChannelRequest : public RpcServiceRequest + { + + public: + ModifyConsumerChannelRequest(); + ~ModifyConsumerChannelRequest(); + + std::string getConsumerGroupName()const; + void setConsumerGroupName(const std::string& consumerGroupName); + std::string getConsumerGroupId()const; + void setConsumerGroupId(const std::string& consumerGroupId); + std::string getConsumerGroupPassword()const; + void setConsumerGroupPassword(const std::string& consumerGroupPassword); + std::string getConsumerGroupUserName()const; + void setConsumerGroupUserName(const std::string& consumerGroupUserName); + std::string getRegionId()const; + void setRegionId(const std::string& regionId); + std::string getDtsJobId()const; + void setDtsJobId(const std::string& dtsJobId); + std::string getDtsInstanceId()const; + void setDtsInstanceId(const std::string& dtsInstanceId); + + private: + std::string consumerGroupName_; + std::string consumerGroupId_; + std::string consumerGroupPassword_; + std::string consumerGroupUserName_; + std::string regionId_; + std::string dtsJobId_; + std::string dtsInstanceId_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_MODIFYCONSUMERCHANNELREQUEST_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/ModifyConsumerChannelResult.h b/dts/include/alibabacloud/dts/model/ModifyConsumerChannelResult.h new file mode 100644 index 000000000..cc5e08c1a --- /dev/null +++ b/dts/include/alibabacloud/dts/model/ModifyConsumerChannelResult.h @@ -0,0 +1,57 @@ +/* + * 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_DTS_MODEL_MODIFYCONSUMERCHANNELRESULT_H_ +#define ALIBABACLOUD_DTS_MODEL_MODIFYCONSUMERCHANNELRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT ModifyConsumerChannelResult : public ServiceResult + { + public: + + + ModifyConsumerChannelResult(); + explicit ModifyConsumerChannelResult(const std::string &payload); + ~ModifyConsumerChannelResult(); + std::string getHttpStatusCode()const; + std::string getErrMessage()const; + std::string getSuccess()const; + std::string getErrCode()const; + + protected: + void parse(const std::string &payload); + private: + std::string httpStatusCode_; + std::string errMessage_; + std::string success_; + std::string errCode_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_MODIFYCONSUMERCHANNELRESULT_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/ModifySubscriptionRequest.h b/dts/include/alibabacloud/dts/model/ModifySubscriptionRequest.h new file mode 100644 index 000000000..189e67c5f --- /dev/null +++ b/dts/include/alibabacloud/dts/model/ModifySubscriptionRequest.h @@ -0,0 +1,63 @@ +/* + * 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_DTS_MODEL_MODIFYSUBSCRIPTIONREQUEST_H_ +#define ALIBABACLOUD_DTS_MODEL_MODIFYSUBSCRIPTIONREQUEST_H_ + +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT ModifySubscriptionRequest : public RpcServiceRequest + { + + public: + ModifySubscriptionRequest(); + ~ModifySubscriptionRequest(); + + std::string getDbList()const; + void setDbList(const std::string& dbList); + bool getSubscriptionDataTypeDDL()const; + void setSubscriptionDataTypeDDL(bool subscriptionDataTypeDDL); + bool getSubscriptionDataTypeDML()const; + void setSubscriptionDataTypeDML(bool subscriptionDataTypeDML); + std::string getRegionId()const; + void setRegionId(const std::string& regionId); + std::string getDtsJobId()const; + void setDtsJobId(const std::string& dtsJobId); + std::string getDtsInstanceId()const; + void setDtsInstanceId(const std::string& dtsInstanceId); + + private: + std::string dbList_; + bool subscriptionDataTypeDDL_; + bool subscriptionDataTypeDML_; + std::string regionId_; + std::string dtsJobId_; + std::string dtsInstanceId_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_MODIFYSUBSCRIPTIONREQUEST_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/ModifySubscriptionResult.h b/dts/include/alibabacloud/dts/model/ModifySubscriptionResult.h new file mode 100644 index 000000000..87f62bb68 --- /dev/null +++ b/dts/include/alibabacloud/dts/model/ModifySubscriptionResult.h @@ -0,0 +1,57 @@ +/* + * 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_DTS_MODEL_MODIFYSUBSCRIPTIONRESULT_H_ +#define ALIBABACLOUD_DTS_MODEL_MODIFYSUBSCRIPTIONRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT ModifySubscriptionResult : public ServiceResult + { + public: + + + ModifySubscriptionResult(); + explicit ModifySubscriptionResult(const std::string &payload); + ~ModifySubscriptionResult(); + std::string getHttpStatusCode()const; + std::string getErrMessage()const; + std::string getSuccess()const; + std::string getErrCode()const; + + protected: + void parse(const std::string &payload); + private: + std::string httpStatusCode_; + std::string errMessage_; + std::string success_; + std::string errCode_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_MODIFYSUBSCRIPTIONRESULT_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/RenewInstanceRequest.h b/dts/include/alibabacloud/dts/model/RenewInstanceRequest.h new file mode 100644 index 000000000..af6d794f3 --- /dev/null +++ b/dts/include/alibabacloud/dts/model/RenewInstanceRequest.h @@ -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_DTS_MODEL_RENEWINSTANCEREQUEST_H_ +#define ALIBABACLOUD_DTS_MODEL_RENEWINSTANCEREQUEST_H_ + +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT RenewInstanceRequest : public RpcServiceRequest + { + + public: + RenewInstanceRequest(); + ~RenewInstanceRequest(); + + std::string getPeriod()const; + void setPeriod(const std::string& period); + std::string getBuyCount()const; + void setBuyCount(const std::string& buyCount); + std::string getRegionId()const; + void setRegionId(const std::string& regionId); + std::string getDtsJobId()const; + void setDtsJobId(const std::string& dtsJobId); + std::string getChargeType()const; + void setChargeType(const std::string& chargeType); + + private: + std::string period_; + std::string buyCount_; + std::string regionId_; + std::string dtsJobId_; + std::string chargeType_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_RENEWINSTANCEREQUEST_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/PreviewSqlResult.h b/dts/include/alibabacloud/dts/model/RenewInstanceResult.h similarity index 65% rename from dts/include/alibabacloud/dts/model/PreviewSqlResult.h rename to dts/include/alibabacloud/dts/model/RenewInstanceResult.h index ef63cfab6..4f393b8f7 100644 --- a/dts/include/alibabacloud/dts/model/PreviewSqlResult.h +++ b/dts/include/alibabacloud/dts/model/RenewInstanceResult.h @@ -14,8 +14,8 @@ * limitations under the License. */ -#ifndef ALIBABACLOUD_DTS_MODEL_PREVIEWSQLRESULT_H_ -#define ALIBABACLOUD_DTS_MODEL_PREVIEWSQLRESULT_H_ +#ifndef ALIBABACLOUD_DTS_MODEL_RENEWINSTANCERESULT_H_ +#define ALIBABACLOUD_DTS_MODEL_RENEWINSTANCERESULT_H_ #include #include @@ -29,34 +29,36 @@ namespace AlibabaCloud { namespace Model { - class ALIBABACLOUD_DTS_EXPORT PreviewSqlResult : public ServiceResult + class ALIBABACLOUD_DTS_EXPORT RenewInstanceResult : public ServiceResult { public: - PreviewSqlResult(); - explicit PreviewSqlResult(const std::string &payload); - ~PreviewSqlResult(); - std::vector getSqlList()const; - std::string getValidationException()const; + RenewInstanceResult(); + explicit RenewInstanceResult(const std::string &payload); + ~RenewInstanceResult(); + std::string getDtsJobId()const; + std::string getEndTime()const; + std::string getInstanceId()const; + std::string getChargeType()const; int getHttpStatusCode()const; - std::string getStreamGraph()const; - std::string getDynamicCode()const; std::string getDynamicMessage()const; std::string getErrMessage()const; + std::string getCode()const; bool getSuccess()const; std::string getErrCode()const; protected: void parse(const std::string &payload); private: - std::vector sqlList_; - std::string validationException_; + std::string dtsJobId_; + std::string endTime_; + std::string instanceId_; + std::string chargeType_; int httpStatusCode_; - std::string streamGraph_; - std::string dynamicCode_; std::string dynamicMessage_; std::string errMessage_; + std::string code_; bool success_; std::string errCode_; @@ -64,4 +66,4 @@ namespace AlibabaCloud } } } -#endif // !ALIBABACLOUD_DTS_MODEL_PREVIEWSQLRESULT_H_ \ No newline at end of file +#endif // !ALIBABACLOUD_DTS_MODEL_RENEWINSTANCERESULT_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/StartDtsJobRequest.h b/dts/include/alibabacloud/dts/model/StartDtsJobRequest.h index 4da29fcbe..375049708 100644 --- a/dts/include/alibabacloud/dts/model/StartDtsJobRequest.h +++ b/dts/include/alibabacloud/dts/model/StartDtsJobRequest.h @@ -35,8 +35,12 @@ namespace AlibabaCloud StartDtsJobRequest(); ~StartDtsJobRequest(); + std::string getResetCheckpoint()const; + void setResetCheckpoint(const std::string& resetCheckpoint); std::string getRegionId()const; void setRegionId(const std::string& regionId); + std::string getResumeHoldJob()const; + void setResumeHoldJob(const std::string& resumeHoldJob); std::string getDtsJobId()const; void setDtsJobId(const std::string& dtsJobId); std::string getDtsInstanceId()const; @@ -45,7 +49,9 @@ namespace AlibabaCloud void setSynchronizationDirection(const std::string& synchronizationDirection); private: + std::string resetCheckpoint_; std::string regionId_; + std::string resumeHoldJob_; std::string dtsJobId_; std::string dtsInstanceId_; std::string synchronizationDirection_; diff --git a/dts/include/alibabacloud/dts/model/PreviewSqlRequest.h b/dts/include/alibabacloud/dts/model/TransferInstanceClassRequest.h similarity index 57% rename from dts/include/alibabacloud/dts/model/PreviewSqlRequest.h rename to dts/include/alibabacloud/dts/model/TransferInstanceClassRequest.h index 955c97d48..f1e7c6e03 100644 --- a/dts/include/alibabacloud/dts/model/PreviewSqlRequest.h +++ b/dts/include/alibabacloud/dts/model/TransferInstanceClassRequest.h @@ -14,8 +14,8 @@ * limitations under the License. */ -#ifndef ALIBABACLOUD_DTS_MODEL_PREVIEWSQLREQUEST_H_ -#define ALIBABACLOUD_DTS_MODEL_PREVIEWSQLREQUEST_H_ +#ifndef ALIBABACLOUD_DTS_MODEL_TRANSFERINSTANCECLASSREQUEST_H_ +#define ALIBABACLOUD_DTS_MODEL_TRANSFERINSTANCECLASSREQUEST_H_ #include #include @@ -28,24 +28,30 @@ namespace AlibabaCloud { namespace Model { - class ALIBABACLOUD_DTS_EXPORT PreviewSqlRequest : public RpcServiceRequest + class ALIBABACLOUD_DTS_EXPORT TransferInstanceClassRequest : public RpcServiceRequest { public: - PreviewSqlRequest(); - ~PreviewSqlRequest(); + TransferInstanceClassRequest(); + ~TransferInstanceClassRequest(); - std::string getEtlCalculator()const; - void setEtlCalculator(const std::string& etlCalculator); + std::string getInstanceClass()const; + void setInstanceClass(const std::string& instanceClass); std::string getRegionId()const; void setRegionId(const std::string& regionId); + std::string getDtsJobId()const; + void setDtsJobId(const std::string& dtsJobId); + std::string getOrderType()const; + void setOrderType(const std::string& orderType); private: - std::string etlCalculator_; + std::string instanceClass_; std::string regionId_; + std::string dtsJobId_; + std::string orderType_; }; } } } -#endif // !ALIBABACLOUD_DTS_MODEL_PREVIEWSQLREQUEST_H_ \ No newline at end of file +#endif // !ALIBABACLOUD_DTS_MODEL_TRANSFERINSTANCECLASSREQUEST_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/TransferInstanceClassResult.h b/dts/include/alibabacloud/dts/model/TransferInstanceClassResult.h new file mode 100644 index 000000000..416738f12 --- /dev/null +++ b/dts/include/alibabacloud/dts/model/TransferInstanceClassResult.h @@ -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_DTS_MODEL_TRANSFERINSTANCECLASSRESULT_H_ +#define ALIBABACLOUD_DTS_MODEL_TRANSFERINSTANCECLASSRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT TransferInstanceClassResult : public ServiceResult + { + public: + + + TransferInstanceClassResult(); + explicit TransferInstanceClassResult(const std::string &payload); + ~TransferInstanceClassResult(); + std::string getDtsJobId()const; + std::string getEndTime()const; + std::string getInstanceId()const; + std::string getChargeType()const; + int getHttpStatusCode()const; + std::string getDynamicMessage()const; + std::string getErrMessage()const; + std::string getCode()const; + bool getSuccess()const; + std::string getErrCode()const; + + protected: + void parse(const std::string &payload); + private: + std::string dtsJobId_; + std::string endTime_; + std::string instanceId_; + std::string chargeType_; + int httpStatusCode_; + std::string dynamicMessage_; + std::string errMessage_; + std::string code_; + bool success_; + std::string errCode_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_TRANSFERINSTANCECLASSRESULT_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/TransferPayTypeRequest.h b/dts/include/alibabacloud/dts/model/TransferPayTypeRequest.h index 71d80d878..a66601685 100644 --- a/dts/include/alibabacloud/dts/model/TransferPayTypeRequest.h +++ b/dts/include/alibabacloud/dts/model/TransferPayTypeRequest.h @@ -39,8 +39,6 @@ namespace AlibabaCloud void setPeriod(const std::string& period); std::string getBuyCount()const; void setBuyCount(const std::string& buyCount); - std::string getInstanceClass()const; - void setInstanceClass(const std::string& instanceClass); std::string getRegionId()const; void setRegionId(const std::string& regionId); std::string getDtsJobId()const; @@ -51,7 +49,6 @@ namespace AlibabaCloud private: std::string period_; std::string buyCount_; - std::string instanceClass_; std::string regionId_; std::string dtsJobId_; std::string chargeType_; diff --git a/dts/src/DtsClient.cc b/dts/src/DtsClient.cc index 9d30e51f3..bc8ace176 100644 --- a/dts/src/DtsClient.cc +++ b/dts/src/DtsClient.cc @@ -159,6 +159,42 @@ DtsClient::ConfigureMigrationJobAlertOutcomeCallable DtsClient::configureMigrati return task->get_future(); } +DtsClient::ConfigureSubscriptionOutcome DtsClient::configureSubscription(const ConfigureSubscriptionRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return ConfigureSubscriptionOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return ConfigureSubscriptionOutcome(ConfigureSubscriptionResult(outcome.result())); + else + return ConfigureSubscriptionOutcome(outcome.error()); +} + +void DtsClient::configureSubscriptionAsync(const ConfigureSubscriptionRequest& request, const ConfigureSubscriptionAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, configureSubscription(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +DtsClient::ConfigureSubscriptionOutcomeCallable DtsClient::configureSubscriptionCallable(const ConfigureSubscriptionRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->configureSubscription(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + DtsClient::ConfigureSubscriptionInstanceOutcome DtsClient::configureSubscriptionInstance(const ConfigureSubscriptionInstanceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -339,6 +375,42 @@ DtsClient::ConfigureSynchronizationJobReplicatorCompareOutcomeCallable DtsClient return task->get_future(); } +DtsClient::CreateConsumerChannelOutcome DtsClient::createConsumerChannel(const CreateConsumerChannelRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return CreateConsumerChannelOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return CreateConsumerChannelOutcome(CreateConsumerChannelResult(outcome.result())); + else + return CreateConsumerChannelOutcome(outcome.error()); +} + +void DtsClient::createConsumerChannelAsync(const CreateConsumerChannelRequest& request, const CreateConsumerChannelAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, createConsumerChannel(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +DtsClient::CreateConsumerChannelOutcomeCallable DtsClient::createConsumerChannelCallable(const CreateConsumerChannelRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->createConsumerChannel(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + DtsClient::CreateConsumerGroupOutcome DtsClient::createConsumerGroup(const CreateConsumerGroupRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -555,6 +627,42 @@ DtsClient::CreateSynchronizationJobOutcomeCallable DtsClient::createSynchronizat return task->get_future(); } +DtsClient::DeleteConsumerChannelOutcome DtsClient::deleteConsumerChannel(const DeleteConsumerChannelRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return DeleteConsumerChannelOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return DeleteConsumerChannelOutcome(DeleteConsumerChannelResult(outcome.result())); + else + return DeleteConsumerChannelOutcome(outcome.error()); +} + +void DtsClient::deleteConsumerChannelAsync(const DeleteConsumerChannelRequest& request, const DeleteConsumerChannelAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, deleteConsumerChannel(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +DtsClient::DeleteConsumerChannelOutcomeCallable DtsClient::deleteConsumerChannelCallable(const DeleteConsumerChannelRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->deleteConsumerChannel(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + DtsClient::DeleteConsumerGroupOutcome DtsClient::deleteConsumerGroup(const DeleteConsumerGroupRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -807,6 +915,42 @@ DtsClient::DescribeConnectionStatusOutcomeCallable DtsClient::describeConnection return task->get_future(); } +DtsClient::DescribeConsumerChannelOutcome DtsClient::describeConsumerChannel(const DescribeConsumerChannelRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return DescribeConsumerChannelOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return DescribeConsumerChannelOutcome(DescribeConsumerChannelResult(outcome.result())); + else + return DescribeConsumerChannelOutcome(outcome.error()); +} + +void DtsClient::describeConsumerChannelAsync(const DescribeConsumerChannelRequest& request, const DescribeConsumerChannelAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, describeConsumerChannel(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +DtsClient::DescribeConsumerChannelOutcomeCallable DtsClient::describeConsumerChannelCallable(const DescribeConsumerChannelRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->describeConsumerChannel(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + DtsClient::DescribeConsumerGroupOutcome DtsClient::describeConsumerGroup(const DescribeConsumerGroupRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -951,42 +1095,6 @@ DtsClient::DescribeDtsJobDetailOutcomeCallable DtsClient::describeDtsJobDetailCa return task->get_future(); } -DtsClient::DescribeDtsJobLogsOutcome DtsClient::describeDtsJobLogs(const DescribeDtsJobLogsRequest &request) const -{ - auto endpointOutcome = endpointProvider_->getEndpoint(); - if (!endpointOutcome.isSuccess()) - return DescribeDtsJobLogsOutcome(endpointOutcome.error()); - - auto outcome = makeRequest(endpointOutcome.result(), request); - - if (outcome.isSuccess()) - return DescribeDtsJobLogsOutcome(DescribeDtsJobLogsResult(outcome.result())); - else - return DescribeDtsJobLogsOutcome(outcome.error()); -} - -void DtsClient::describeDtsJobLogsAsync(const DescribeDtsJobLogsRequest& request, const DescribeDtsJobLogsAsyncHandler& handler, const std::shared_ptr& context) const -{ - auto fn = [this, request, handler, context]() - { - handler(this, request, describeDtsJobLogs(request), context); - }; - - asyncExecute(new Runnable(fn)); -} - -DtsClient::DescribeDtsJobLogsOutcomeCallable DtsClient::describeDtsJobLogsCallable(const DescribeDtsJobLogsRequest &request) const -{ - auto task = std::make_shared>( - [this, request]() - { - return this->describeDtsJobLogs(request); - }); - - asyncExecute(new Runnable([task]() { (*task)(); })); - return task->get_future(); -} - DtsClient::DescribeDtsJobsOutcome DtsClient::describeDtsJobs(const DescribeDtsJobsRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -1707,6 +1815,42 @@ DtsClient::ListTagResourcesOutcomeCallable DtsClient::listTagResourcesCallable(c return task->get_future(); } +DtsClient::ModifyConsumerChannelOutcome DtsClient::modifyConsumerChannel(const ModifyConsumerChannelRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return ModifyConsumerChannelOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return ModifyConsumerChannelOutcome(ModifyConsumerChannelResult(outcome.result())); + else + return ModifyConsumerChannelOutcome(outcome.error()); +} + +void DtsClient::modifyConsumerChannelAsync(const ModifyConsumerChannelRequest& request, const ModifyConsumerChannelAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, modifyConsumerChannel(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +DtsClient::ModifyConsumerChannelOutcomeCallable DtsClient::modifyConsumerChannelCallable(const ModifyConsumerChannelRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->modifyConsumerChannel(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + DtsClient::ModifyConsumerGroupPasswordOutcome DtsClient::modifyConsumerGroupPassword(const ModifyConsumerGroupPasswordRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -1887,6 +2031,42 @@ DtsClient::ModifyDtsJobPasswordOutcomeCallable DtsClient::modifyDtsJobPasswordCa return task->get_future(); } +DtsClient::ModifySubscriptionOutcome DtsClient::modifySubscription(const ModifySubscriptionRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return ModifySubscriptionOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return ModifySubscriptionOutcome(ModifySubscriptionResult(outcome.result())); + else + return ModifySubscriptionOutcome(outcome.error()); +} + +void DtsClient::modifySubscriptionAsync(const ModifySubscriptionRequest& request, const ModifySubscriptionAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, modifySubscription(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +DtsClient::ModifySubscriptionOutcomeCallable DtsClient::modifySubscriptionCallable(const ModifySubscriptionRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->modifySubscription(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + DtsClient::ModifySubscriptionObjectOutcome DtsClient::modifySubscriptionObject(const ModifySubscriptionObjectRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -1959,36 +2139,36 @@ DtsClient::ModifySynchronizationObjectOutcomeCallable DtsClient::modifySynchroni return task->get_future(); } -DtsClient::PreviewSqlOutcome DtsClient::previewSql(const PreviewSqlRequest &request) const +DtsClient::RenewInstanceOutcome DtsClient::renewInstance(const RenewInstanceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) - return PreviewSqlOutcome(endpointOutcome.error()); + return RenewInstanceOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) - return PreviewSqlOutcome(PreviewSqlResult(outcome.result())); + return RenewInstanceOutcome(RenewInstanceResult(outcome.result())); else - return PreviewSqlOutcome(outcome.error()); + return RenewInstanceOutcome(outcome.error()); } -void DtsClient::previewSqlAsync(const PreviewSqlRequest& request, const PreviewSqlAsyncHandler& handler, const std::shared_ptr& context) const +void DtsClient::renewInstanceAsync(const RenewInstanceRequest& request, const RenewInstanceAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { - handler(this, request, previewSql(request), context); + handler(this, request, renewInstance(request), context); }; asyncExecute(new Runnable(fn)); } -DtsClient::PreviewSqlOutcomeCallable DtsClient::previewSqlCallable(const PreviewSqlRequest &request) const +DtsClient::RenewInstanceOutcomeCallable DtsClient::renewInstanceCallable(const RenewInstanceRequest &request) const { - auto task = std::make_shared>( + auto task = std::make_shared>( [this, request]() { - return this->previewSql(request); + return this->renewInstance(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); @@ -2571,6 +2751,42 @@ DtsClient::TagResourcesOutcomeCallable DtsClient::tagResourcesCallable(const Tag return task->get_future(); } +DtsClient::TransferInstanceClassOutcome DtsClient::transferInstanceClass(const TransferInstanceClassRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return TransferInstanceClassOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return TransferInstanceClassOutcome(TransferInstanceClassResult(outcome.result())); + else + return TransferInstanceClassOutcome(outcome.error()); +} + +void DtsClient::transferInstanceClassAsync(const TransferInstanceClassRequest& request, const TransferInstanceClassAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, transferInstanceClass(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +DtsClient::TransferInstanceClassOutcomeCallable DtsClient::transferInstanceClassCallable(const TransferInstanceClassRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->transferInstanceClass(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + DtsClient::TransferPayTypeOutcome DtsClient::transferPayType(const TransferPayTypeRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); diff --git a/dts/src/model/ConfigureSubscriptionRequest.cc b/dts/src/model/ConfigureSubscriptionRequest.cc new file mode 100644 index 000000000..d78213eca --- /dev/null +++ b/dts/src/model/ConfigureSubscriptionRequest.cc @@ -0,0 +1,348 @@ +/* + * 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 + +using AlibabaCloud::Dts::Model::ConfigureSubscriptionRequest; + +ConfigureSubscriptionRequest::ConfigureSubscriptionRequest() : + RpcServiceRequest("dts", "2020-01-01", "ConfigureSubscription") +{ + setMethod(HttpRequest::Method::Post); +} + +ConfigureSubscriptionRequest::~ConfigureSubscriptionRequest() +{} + +std::string ConfigureSubscriptionRequest::getSourceEndpointRegion()const +{ + return sourceEndpointRegion_; +} + +void ConfigureSubscriptionRequest::setSourceEndpointRegion(const std::string& sourceEndpointRegion) +{ + sourceEndpointRegion_ = sourceEndpointRegion; + setParameter("SourceEndpointRegion", sourceEndpointRegion); +} + +std::string ConfigureSubscriptionRequest::getCheckpoint()const +{ + return checkpoint_; +} + +void ConfigureSubscriptionRequest::setCheckpoint(const std::string& checkpoint) +{ + checkpoint_ = checkpoint; + setParameter("Checkpoint", checkpoint); +} + +std::string ConfigureSubscriptionRequest::getSubscriptionInstanceVSwitchId()const +{ + return subscriptionInstanceVSwitchId_; +} + +void ConfigureSubscriptionRequest::setSubscriptionInstanceVSwitchId(const std::string& subscriptionInstanceVSwitchId) +{ + subscriptionInstanceVSwitchId_ = subscriptionInstanceVSwitchId; + setParameter("SubscriptionInstanceVSwitchId", subscriptionInstanceVSwitchId); +} + +bool ConfigureSubscriptionRequest::getDelayNotice()const +{ + return delayNotice_; +} + +void ConfigureSubscriptionRequest::setDelayNotice(bool delayNotice) +{ + delayNotice_ = delayNotice; + setParameter("DelayNotice", delayNotice ? "true" : "false"); +} + +std::string ConfigureSubscriptionRequest::getSourceEndpointInstanceID()const +{ + return sourceEndpointInstanceID_; +} + +void ConfigureSubscriptionRequest::setSourceEndpointInstanceID(const std::string& sourceEndpointInstanceID) +{ + sourceEndpointInstanceID_ = sourceEndpointInstanceID; + setParameter("SourceEndpointInstanceID", sourceEndpointInstanceID); +} + +std::string ConfigureSubscriptionRequest::getSourceEndpointUserName()const +{ + return sourceEndpointUserName_; +} + +void ConfigureSubscriptionRequest::setSourceEndpointUserName(const std::string& sourceEndpointUserName) +{ + sourceEndpointUserName_ = sourceEndpointUserName; + setParameter("SourceEndpointUserName", sourceEndpointUserName); +} + +std::string ConfigureSubscriptionRequest::getSourceEndpointOwnerID()const +{ + return sourceEndpointOwnerID_; +} + +void ConfigureSubscriptionRequest::setSourceEndpointOwnerID(const std::string& sourceEndpointOwnerID) +{ + sourceEndpointOwnerID_ = sourceEndpointOwnerID; + setParameter("SourceEndpointOwnerID", sourceEndpointOwnerID); +} + +std::string ConfigureSubscriptionRequest::getDelayPhone()const +{ + return delayPhone_; +} + +void ConfigureSubscriptionRequest::setDelayPhone(const std::string& delayPhone) +{ + delayPhone_ = delayPhone; + setParameter("DelayPhone", delayPhone); +} + +bool ConfigureSubscriptionRequest::getSubscriptionDataTypeDML()const +{ + return subscriptionDataTypeDML_; +} + +void ConfigureSubscriptionRequest::setSubscriptionDataTypeDML(bool subscriptionDataTypeDML) +{ + subscriptionDataTypeDML_ = subscriptionDataTypeDML; + setParameter("SubscriptionDataTypeDML", subscriptionDataTypeDML ? "true" : "false"); +} + +std::string ConfigureSubscriptionRequest::getSourceEndpointDatabaseName()const +{ + return sourceEndpointDatabaseName_; +} + +void ConfigureSubscriptionRequest::setSourceEndpointDatabaseName(const std::string& sourceEndpointDatabaseName) +{ + sourceEndpointDatabaseName_ = sourceEndpointDatabaseName; + setParameter("SourceEndpointDatabaseName", sourceEndpointDatabaseName); +} + +std::string ConfigureSubscriptionRequest::getSourceEndpointIP()const +{ + return sourceEndpointIP_; +} + +void ConfigureSubscriptionRequest::setSourceEndpointIP(const std::string& sourceEndpointIP) +{ + sourceEndpointIP_ = sourceEndpointIP; + setParameter("SourceEndpointIP", sourceEndpointIP); +} + +std::string ConfigureSubscriptionRequest::getRegionId()const +{ + return regionId_; +} + +void ConfigureSubscriptionRequest::setRegionId(const std::string& regionId) +{ + regionId_ = regionId; + setParameter("RegionId", regionId); +} + +std::string ConfigureSubscriptionRequest::getErrorPhone()const +{ + return errorPhone_; +} + +void ConfigureSubscriptionRequest::setErrorPhone(const std::string& errorPhone) +{ + errorPhone_ = errorPhone; + setParameter("ErrorPhone", errorPhone); +} + +std::string ConfigureSubscriptionRequest::getReserve()const +{ + return reserve_; +} + +void ConfigureSubscriptionRequest::setReserve(const std::string& reserve) +{ + reserve_ = reserve; + setParameter("Reserve", reserve); +} + +std::string ConfigureSubscriptionRequest::getDtsJobId()const +{ + return dtsJobId_; +} + +void ConfigureSubscriptionRequest::setDtsJobId(const std::string& dtsJobId) +{ + dtsJobId_ = dtsJobId; + setParameter("DtsJobId", dtsJobId); +} + +std::string ConfigureSubscriptionRequest::getDbList()const +{ + return dbList_; +} + +void ConfigureSubscriptionRequest::setDbList(const std::string& dbList) +{ + dbList_ = dbList; + setParameter("DbList", dbList); +} + +std::string ConfigureSubscriptionRequest::getSubscriptionInstanceNetworkType()const +{ + return subscriptionInstanceNetworkType_; +} + +void ConfigureSubscriptionRequest::setSubscriptionInstanceNetworkType(const std::string& subscriptionInstanceNetworkType) +{ + subscriptionInstanceNetworkType_ = subscriptionInstanceNetworkType; + setParameter("SubscriptionInstanceNetworkType", subscriptionInstanceNetworkType); +} + +bool ConfigureSubscriptionRequest::getSubscriptionDataTypeDDL()const +{ + return subscriptionDataTypeDDL_; +} + +void ConfigureSubscriptionRequest::setSubscriptionDataTypeDDL(bool subscriptionDataTypeDDL) +{ + subscriptionDataTypeDDL_ = subscriptionDataTypeDDL; + setParameter("SubscriptionDataTypeDDL", subscriptionDataTypeDDL ? "true" : "false"); +} + +std::string ConfigureSubscriptionRequest::getSourceEndpointPassword()const +{ + return sourceEndpointPassword_; +} + +void ConfigureSubscriptionRequest::setSourceEndpointPassword(const std::string& sourceEndpointPassword) +{ + sourceEndpointPassword_ = sourceEndpointPassword; + setParameter("SourceEndpointPassword", sourceEndpointPassword); +} + +std::string ConfigureSubscriptionRequest::getSourceEndpointPort()const +{ + return sourceEndpointPort_; +} + +void ConfigureSubscriptionRequest::setSourceEndpointPort(const std::string& sourceEndpointPort) +{ + sourceEndpointPort_ = sourceEndpointPort; + setParameter("SourceEndpointPort", sourceEndpointPort); +} + +std::string ConfigureSubscriptionRequest::getSubscriptionInstanceVPCId()const +{ + return subscriptionInstanceVPCId_; +} + +void ConfigureSubscriptionRequest::setSubscriptionInstanceVPCId(const std::string& subscriptionInstanceVPCId) +{ + subscriptionInstanceVPCId_ = subscriptionInstanceVPCId; + setParameter("SubscriptionInstanceVPCId", subscriptionInstanceVPCId); +} + +long ConfigureSubscriptionRequest::getDelayRuleTime()const +{ + return delayRuleTime_; +} + +void ConfigureSubscriptionRequest::setDelayRuleTime(long delayRuleTime) +{ + delayRuleTime_ = delayRuleTime; + setParameter("DelayRuleTime", std::to_string(delayRuleTime)); +} + +std::string ConfigureSubscriptionRequest::getSourceEndpointInstanceType()const +{ + return sourceEndpointInstanceType_; +} + +void ConfigureSubscriptionRequest::setSourceEndpointInstanceType(const std::string& sourceEndpointInstanceType) +{ + sourceEndpointInstanceType_ = sourceEndpointInstanceType; + setParameter("SourceEndpointInstanceType", sourceEndpointInstanceType); +} + +std::string ConfigureSubscriptionRequest::getDtsJobName()const +{ + return dtsJobName_; +} + +void ConfigureSubscriptionRequest::setDtsJobName(const std::string& dtsJobName) +{ + dtsJobName_ = dtsJobName; + setParameter("DtsJobName", dtsJobName); +} + +std::string ConfigureSubscriptionRequest::getSourceEndpointOracleSID()const +{ + return sourceEndpointOracleSID_; +} + +void ConfigureSubscriptionRequest::setSourceEndpointOracleSID(const std::string& sourceEndpointOracleSID) +{ + sourceEndpointOracleSID_ = sourceEndpointOracleSID; + setParameter("SourceEndpointOracleSID", sourceEndpointOracleSID); +} + +bool ConfigureSubscriptionRequest::getErrorNotice()const +{ + return errorNotice_; +} + +void ConfigureSubscriptionRequest::setErrorNotice(bool errorNotice) +{ + errorNotice_ = errorNotice; + setParameter("ErrorNotice", errorNotice ? "true" : "false"); +} + +std::string ConfigureSubscriptionRequest::getSourceEndpointRole()const +{ + return sourceEndpointRole_; +} + +void ConfigureSubscriptionRequest::setSourceEndpointRole(const std::string& sourceEndpointRole) +{ + sourceEndpointRole_ = sourceEndpointRole; + setParameter("SourceEndpointRole", sourceEndpointRole); +} + +std::string ConfigureSubscriptionRequest::getDtsInstanceId()const +{ + return dtsInstanceId_; +} + +void ConfigureSubscriptionRequest::setDtsInstanceId(const std::string& dtsInstanceId) +{ + dtsInstanceId_ = dtsInstanceId; + setParameter("DtsInstanceId", dtsInstanceId); +} + +std::string ConfigureSubscriptionRequest::getSourceEndpointEngineName()const +{ + return sourceEndpointEngineName_; +} + +void ConfigureSubscriptionRequest::setSourceEndpointEngineName(const std::string& sourceEndpointEngineName) +{ + sourceEndpointEngineName_ = sourceEndpointEngineName; + setParameter("SourceEndpointEngineName", sourceEndpointEngineName); +} + diff --git a/dts/src/model/ConfigureSubscriptionResult.cc b/dts/src/model/ConfigureSubscriptionResult.cc new file mode 100644 index 000000000..3a55c07fe --- /dev/null +++ b/dts/src/model/ConfigureSubscriptionResult.cc @@ -0,0 +1,86 @@ +/* + * 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 +#include + +using namespace AlibabaCloud::Dts; +using namespace AlibabaCloud::Dts::Model; + +ConfigureSubscriptionResult::ConfigureSubscriptionResult() : + ServiceResult() +{} + +ConfigureSubscriptionResult::ConfigureSubscriptionResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +ConfigureSubscriptionResult::~ConfigureSubscriptionResult() +{} + +void ConfigureSubscriptionResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["ErrCode"].isNull()) + errCode_ = value["ErrCode"].asString(); + if(!value["ErrMessage"].isNull()) + errMessage_ = value["ErrMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString(); + if(!value["DtsJobId"].isNull()) + dtsJobId_ = value["DtsJobId"].asString(); + if(!value["DtsInstanceId"].isNull()) + dtsInstanceId_ = value["DtsInstanceId"].asString(); + if(!value["HttpStatusCode"].isNull()) + httpStatusCode_ = value["HttpStatusCode"].asString(); + +} + +std::string ConfigureSubscriptionResult::getDtsJobId()const +{ + return dtsJobId_; +} + +std::string ConfigureSubscriptionResult::getHttpStatusCode()const +{ + return httpStatusCode_; +} + +std::string ConfigureSubscriptionResult::getErrMessage()const +{ + return errMessage_; +} + +std::string ConfigureSubscriptionResult::getDtsInstanceId()const +{ + return dtsInstanceId_; +} + +std::string ConfigureSubscriptionResult::getSuccess()const +{ + return success_; +} + +std::string ConfigureSubscriptionResult::getErrCode()const +{ + return errCode_; +} + diff --git a/dts/src/model/CreateConsumerChannelRequest.cc b/dts/src/model/CreateConsumerChannelRequest.cc new file mode 100644 index 000000000..3eab5e27f --- /dev/null +++ b/dts/src/model/CreateConsumerChannelRequest.cc @@ -0,0 +1,95 @@ +/* + * 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 + +using AlibabaCloud::Dts::Model::CreateConsumerChannelRequest; + +CreateConsumerChannelRequest::CreateConsumerChannelRequest() : + RpcServiceRequest("dts", "2020-01-01", "CreateConsumerChannel") +{ + setMethod(HttpRequest::Method::Post); +} + +CreateConsumerChannelRequest::~CreateConsumerChannelRequest() +{} + +std::string CreateConsumerChannelRequest::getConsumerGroupName()const +{ + return consumerGroupName_; +} + +void CreateConsumerChannelRequest::setConsumerGroupName(const std::string& consumerGroupName) +{ + consumerGroupName_ = consumerGroupName; + setParameter("ConsumerGroupName", consumerGroupName); +} + +std::string CreateConsumerChannelRequest::getConsumerGroupPassword()const +{ + return consumerGroupPassword_; +} + +void CreateConsumerChannelRequest::setConsumerGroupPassword(const std::string& consumerGroupPassword) +{ + consumerGroupPassword_ = consumerGroupPassword; + setParameter("ConsumerGroupPassword", consumerGroupPassword); +} + +std::string CreateConsumerChannelRequest::getConsumerGroupUserName()const +{ + return consumerGroupUserName_; +} + +void CreateConsumerChannelRequest::setConsumerGroupUserName(const std::string& consumerGroupUserName) +{ + consumerGroupUserName_ = consumerGroupUserName; + setParameter("ConsumerGroupUserName", consumerGroupUserName); +} + +std::string CreateConsumerChannelRequest::getRegionId()const +{ + return regionId_; +} + +void CreateConsumerChannelRequest::setRegionId(const std::string& regionId) +{ + regionId_ = regionId; + setParameter("RegionId", regionId); +} + +std::string CreateConsumerChannelRequest::getDtsJobId()const +{ + return dtsJobId_; +} + +void CreateConsumerChannelRequest::setDtsJobId(const std::string& dtsJobId) +{ + dtsJobId_ = dtsJobId; + setParameter("DtsJobId", dtsJobId); +} + +std::string CreateConsumerChannelRequest::getDtsInstanceId()const +{ + return dtsInstanceId_; +} + +void CreateConsumerChannelRequest::setDtsInstanceId(const std::string& dtsInstanceId) +{ + dtsInstanceId_ = dtsInstanceId; + setParameter("DtsInstanceId", dtsInstanceId); +} + diff --git a/dts/src/model/CreateConsumerChannelResult.cc b/dts/src/model/CreateConsumerChannelResult.cc new file mode 100644 index 000000000..0388aa0f3 --- /dev/null +++ b/dts/src/model/CreateConsumerChannelResult.cc @@ -0,0 +1,79 @@ +/* + * 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 +#include + +using namespace AlibabaCloud::Dts; +using namespace AlibabaCloud::Dts::Model; + +CreateConsumerChannelResult::CreateConsumerChannelResult() : + ServiceResult() +{} + +CreateConsumerChannelResult::CreateConsumerChannelResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +CreateConsumerChannelResult::~CreateConsumerChannelResult() +{} + +void CreateConsumerChannelResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["ErrCode"].isNull()) + errCode_ = value["ErrCode"].asString(); + if(!value["ErrMessage"].isNull()) + errMessage_ = value["ErrMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString(); + if(!value["ConsumerGroupID"].isNull()) + consumerGroupID_ = value["ConsumerGroupID"].asString(); + if(!value["HttpStatusCode"].isNull()) + httpStatusCode_ = value["HttpStatusCode"].asString(); + +} + +std::string CreateConsumerChannelResult::getConsumerGroupID()const +{ + return consumerGroupID_; +} + +std::string CreateConsumerChannelResult::getHttpStatusCode()const +{ + return httpStatusCode_; +} + +std::string CreateConsumerChannelResult::getErrMessage()const +{ + return errMessage_; +} + +std::string CreateConsumerChannelResult::getSuccess()const +{ + return success_; +} + +std::string CreateConsumerChannelResult::getErrCode()const +{ + return errCode_; +} + diff --git a/dts/src/model/DeleteConsumerChannelRequest.cc b/dts/src/model/DeleteConsumerChannelRequest.cc new file mode 100644 index 000000000..c62a4bc1f --- /dev/null +++ b/dts/src/model/DeleteConsumerChannelRequest.cc @@ -0,0 +1,73 @@ +/* + * 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 + +using AlibabaCloud::Dts::Model::DeleteConsumerChannelRequest; + +DeleteConsumerChannelRequest::DeleteConsumerChannelRequest() : + RpcServiceRequest("dts", "2020-01-01", "DeleteConsumerChannel") +{ + setMethod(HttpRequest::Method::Post); +} + +DeleteConsumerChannelRequest::~DeleteConsumerChannelRequest() +{} + +std::string DeleteConsumerChannelRequest::getConsumerGroupId()const +{ + return consumerGroupId_; +} + +void DeleteConsumerChannelRequest::setConsumerGroupId(const std::string& consumerGroupId) +{ + consumerGroupId_ = consumerGroupId; + setParameter("ConsumerGroupId", consumerGroupId); +} + +std::string DeleteConsumerChannelRequest::getRegionId()const +{ + return regionId_; +} + +void DeleteConsumerChannelRequest::setRegionId(const std::string& regionId) +{ + regionId_ = regionId; + setParameter("RegionId", regionId); +} + +std::string DeleteConsumerChannelRequest::getDtsJobId()const +{ + return dtsJobId_; +} + +void DeleteConsumerChannelRequest::setDtsJobId(const std::string& dtsJobId) +{ + dtsJobId_ = dtsJobId; + setParameter("DtsJobId", dtsJobId); +} + +std::string DeleteConsumerChannelRequest::getDtsInstanceId()const +{ + return dtsInstanceId_; +} + +void DeleteConsumerChannelRequest::setDtsInstanceId(const std::string& dtsInstanceId) +{ + dtsInstanceId_ = dtsInstanceId; + setParameter("DtsInstanceId", dtsInstanceId); +} + diff --git a/dts/src/model/DeleteConsumerChannelResult.cc b/dts/src/model/DeleteConsumerChannelResult.cc new file mode 100644 index 000000000..3f7de69ae --- /dev/null +++ b/dts/src/model/DeleteConsumerChannelResult.cc @@ -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. + */ + +#include +#include + +using namespace AlibabaCloud::Dts; +using namespace AlibabaCloud::Dts::Model; + +DeleteConsumerChannelResult::DeleteConsumerChannelResult() : + ServiceResult() +{} + +DeleteConsumerChannelResult::DeleteConsumerChannelResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +DeleteConsumerChannelResult::~DeleteConsumerChannelResult() +{} + +void DeleteConsumerChannelResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["ErrCode"].isNull()) + errCode_ = value["ErrCode"].asString(); + if(!value["ErrMessage"].isNull()) + errMessage_ = value["ErrMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString(); + if(!value["HttpStatusCode"].isNull()) + httpStatusCode_ = value["HttpStatusCode"].asString(); + +} + +std::string DeleteConsumerChannelResult::getHttpStatusCode()const +{ + return httpStatusCode_; +} + +std::string DeleteConsumerChannelResult::getErrMessage()const +{ + return errMessage_; +} + +std::string DeleteConsumerChannelResult::getSuccess()const +{ + return success_; +} + +std::string DeleteConsumerChannelResult::getErrCode()const +{ + return errCode_; +} + diff --git a/dts/src/model/DescribeConsumerChannelRequest.cc b/dts/src/model/DescribeConsumerChannelRequest.cc new file mode 100644 index 000000000..41e4f3dfc --- /dev/null +++ b/dts/src/model/DescribeConsumerChannelRequest.cc @@ -0,0 +1,84 @@ +/* + * 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 + +using AlibabaCloud::Dts::Model::DescribeConsumerChannelRequest; + +DescribeConsumerChannelRequest::DescribeConsumerChannelRequest() : + RpcServiceRequest("dts", "2020-01-01", "DescribeConsumerChannel") +{ + setMethod(HttpRequest::Method::Post); +} + +DescribeConsumerChannelRequest::~DescribeConsumerChannelRequest() +{} + +int DescribeConsumerChannelRequest::getPageNumber()const +{ + return pageNumber_; +} + +void DescribeConsumerChannelRequest::setPageNumber(int pageNumber) +{ + pageNumber_ = pageNumber; + setParameter("PageNumber", std::to_string(pageNumber)); +} + +std::string DescribeConsumerChannelRequest::getRegionId()const +{ + return regionId_; +} + +void DescribeConsumerChannelRequest::setRegionId(const std::string& regionId) +{ + regionId_ = regionId; + setParameter("RegionId", regionId); +} + +int DescribeConsumerChannelRequest::getPageSize()const +{ + return pageSize_; +} + +void DescribeConsumerChannelRequest::setPageSize(int pageSize) +{ + pageSize_ = pageSize; + setParameter("PageSize", std::to_string(pageSize)); +} + +std::string DescribeConsumerChannelRequest::getDtsJobId()const +{ + return dtsJobId_; +} + +void DescribeConsumerChannelRequest::setDtsJobId(const std::string& dtsJobId) +{ + dtsJobId_ = dtsJobId; + setParameter("DtsJobId", dtsJobId); +} + +std::string DescribeConsumerChannelRequest::getDtsInstanceId()const +{ + return dtsInstanceId_; +} + +void DescribeConsumerChannelRequest::setDtsInstanceId(const std::string& dtsInstanceId) +{ + dtsInstanceId_ = dtsInstanceId; + setParameter("DtsInstanceId", dtsInstanceId); +} + diff --git a/dts/src/model/DescribeConsumerChannelResult.cc b/dts/src/model/DescribeConsumerChannelResult.cc new file mode 100644 index 000000000..b0ad3b4b5 --- /dev/null +++ b/dts/src/model/DescribeConsumerChannelResult.cc @@ -0,0 +1,116 @@ +/* + * 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 +#include + +using namespace AlibabaCloud::Dts; +using namespace AlibabaCloud::Dts::Model; + +DescribeConsumerChannelResult::DescribeConsumerChannelResult() : + ServiceResult() +{} + +DescribeConsumerChannelResult::DescribeConsumerChannelResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +DescribeConsumerChannelResult::~DescribeConsumerChannelResult() +{} + +void DescribeConsumerChannelResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + auto allConsumerChannelsNode = value["ConsumerChannels"]["ConsumerChannel"]; + for (auto valueConsumerChannelsConsumerChannel : allConsumerChannelsNode) + { + ConsumerChannel consumerChannelsObject; + if(!valueConsumerChannelsConsumerChannel["ConsumerGroupId"].isNull()) + consumerChannelsObject.consumerGroupId = valueConsumerChannelsConsumerChannel["ConsumerGroupId"].asString(); + if(!valueConsumerChannelsConsumerChannel["ConsumerGroupName"].isNull()) + consumerChannelsObject.consumerGroupName = valueConsumerChannelsConsumerChannel["ConsumerGroupName"].asString(); + if(!valueConsumerChannelsConsumerChannel["ConsumptionCheckpoint"].isNull()) + consumerChannelsObject.consumptionCheckpoint = valueConsumerChannelsConsumerChannel["ConsumptionCheckpoint"].asString(); + if(!valueConsumerChannelsConsumerChannel["UnconsumedData"].isNull()) + consumerChannelsObject.unconsumedData = std::stol(valueConsumerChannelsConsumerChannel["UnconsumedData"].asString()); + if(!valueConsumerChannelsConsumerChannel["MessageDelay"].isNull()) + consumerChannelsObject.messageDelay = std::stol(valueConsumerChannelsConsumerChannel["MessageDelay"].asString()); + if(!valueConsumerChannelsConsumerChannel["ConsumerGroupUserName"].isNull()) + consumerChannelsObject.consumerGroupUserName = valueConsumerChannelsConsumerChannel["ConsumerGroupUserName"].asString(); + consumerChannels_.push_back(consumerChannelsObject); + } + if(!value["ErrCode"].isNull()) + errCode_ = value["ErrCode"].asString(); + if(!value["ErrMessage"].isNull()) + errMessage_ = value["ErrMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString(); + if(!value["HttpStatusCode"].isNull()) + httpStatusCode_ = value["HttpStatusCode"].asString(); + if(!value["PageNumber"].isNull()) + pageNumber_ = std::stoi(value["PageNumber"].asString()); + if(!value["PageRecordCount"].isNull()) + pageRecordCount_ = std::stoi(value["PageRecordCount"].asString()); + if(!value["TotalRecordCount"].isNull()) + totalRecordCount_ = std::stol(value["TotalRecordCount"].asString()); + +} + +long DescribeConsumerChannelResult::getTotalRecordCount()const +{ + return totalRecordCount_; +} + +int DescribeConsumerChannelResult::getPageRecordCount()const +{ + return pageRecordCount_; +} + +int DescribeConsumerChannelResult::getPageNumber()const +{ + return pageNumber_; +} + +std::string DescribeConsumerChannelResult::getHttpStatusCode()const +{ + return httpStatusCode_; +} + +std::vector DescribeConsumerChannelResult::getConsumerChannels()const +{ + return consumerChannels_; +} + +std::string DescribeConsumerChannelResult::getErrMessage()const +{ + return errMessage_; +} + +std::string DescribeConsumerChannelResult::getSuccess()const +{ + return success_; +} + +std::string DescribeConsumerChannelResult::getErrCode()const +{ + return errCode_; +} + diff --git a/dts/src/model/DescribeDtsJobLogsRequest.cc b/dts/src/model/DescribeDtsJobLogsRequest.cc deleted file mode 100644 index 91f4ad0d4..000000000 --- a/dts/src/model/DescribeDtsJobLogsRequest.cc +++ /dev/null @@ -1,117 +0,0 @@ -/* - * 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 - -using AlibabaCloud::Dts::Model::DescribeDtsJobLogsRequest; - -DescribeDtsJobLogsRequest::DescribeDtsJobLogsRequest() : - RpcServiceRequest("dts", "2020-01-01", "DescribeDtsJobLogs") -{ - setMethod(HttpRequest::Method::Post); -} - -DescribeDtsJobLogsRequest::~DescribeDtsJobLogsRequest() -{} - -long DescribeDtsJobLogsRequest::getEndTime()const -{ - return endTime_; -} - -void DescribeDtsJobLogsRequest::setEndTime(long endTime) -{ - endTime_ = endTime; - setParameter("EndTime", std::to_string(endTime)); -} - -long DescribeDtsJobLogsRequest::getStartTime()const -{ - return startTime_; -} - -void DescribeDtsJobLogsRequest::setStartTime(long startTime) -{ - startTime_ = startTime; - setParameter("StartTime", std::to_string(startTime)); -} - -std::string DescribeDtsJobLogsRequest::getType()const -{ - return type_; -} - -void DescribeDtsJobLogsRequest::setType(const std::string& type) -{ - type_ = type; - setParameter("Type", type); -} - -int DescribeDtsJobLogsRequest::getPageNumber()const -{ - return pageNumber_; -} - -void DescribeDtsJobLogsRequest::setPageNumber(int pageNumber) -{ - pageNumber_ = pageNumber; - setParameter("PageNumber", std::to_string(pageNumber)); -} - -std::string DescribeDtsJobLogsRequest::getRegionId()const -{ - return regionId_; -} - -void DescribeDtsJobLogsRequest::setRegionId(const std::string& regionId) -{ - regionId_ = regionId; - setParameter("RegionId", regionId); -} - -int DescribeDtsJobLogsRequest::getPageSize()const -{ - return pageSize_; -} - -void DescribeDtsJobLogsRequest::setPageSize(int pageSize) -{ - pageSize_ = pageSize; - setParameter("PageSize", std::to_string(pageSize)); -} - -std::string DescribeDtsJobLogsRequest::getDtsJobId()const -{ - return dtsJobId_; -} - -void DescribeDtsJobLogsRequest::setDtsJobId(const std::string& dtsJobId) -{ - dtsJobId_ = dtsJobId; - setParameter("DtsJobId", dtsJobId); -} - -std::string DescribeDtsJobLogsRequest::getStatus()const -{ - return status_; -} - -void DescribeDtsJobLogsRequest::setStatus(const std::string& status) -{ - status_ = status; - setParameter("Status", status); -} - diff --git a/dts/src/model/DescribeDtsJobLogsResult.cc b/dts/src/model/DescribeDtsJobLogsResult.cc deleted file mode 100644 index 04cb968e5..000000000 --- a/dts/src/model/DescribeDtsJobLogsResult.cc +++ /dev/null @@ -1,131 +0,0 @@ -/* - * 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 -#include - -using namespace AlibabaCloud::Dts; -using namespace AlibabaCloud::Dts::Model; - -DescribeDtsJobLogsResult::DescribeDtsJobLogsResult() : - ServiceResult() -{} - -DescribeDtsJobLogsResult::DescribeDtsJobLogsResult(const std::string &payload) : - ServiceResult() -{ - parse(payload); -} - -DescribeDtsJobLogsResult::~DescribeDtsJobLogsResult() -{} - -void DescribeDtsJobLogsResult::parse(const std::string &payload) -{ - Json::Reader reader; - Json::Value value; - reader.parse(payload, value); - setRequestId(value["RequestId"].asString()); - auto allJobRunningLogsNode = value["JobRunningLogs"]["JobRunningLog"]; - for (auto valueJobRunningLogsJobRunningLog : allJobRunningLogsNode) - { - JobRunningLog jobRunningLogsObject; - if(!valueJobRunningLogsJobRunningLog["Id"].isNull()) - jobRunningLogsObject.id = std::stol(valueJobRunningLogsJobRunningLog["Id"].asString()); - if(!valueJobRunningLogsJobRunningLog["JobId"].isNull()) - jobRunningLogsObject.jobId = valueJobRunningLogsJobRunningLog["JobId"].asString(); - if(!valueJobRunningLogsJobRunningLog["LogDatetime"].isNull()) - jobRunningLogsObject.logDatetime = std::stol(valueJobRunningLogsJobRunningLog["LogDatetime"].asString()); - if(!valueJobRunningLogsJobRunningLog["ContentKey"].isNull()) - jobRunningLogsObject.contentKey = valueJobRunningLogsJobRunningLog["ContentKey"].asString(); - if(!valueJobRunningLogsJobRunningLog["Status"].isNull()) - jobRunningLogsObject.status = valueJobRunningLogsJobRunningLog["Status"].asString(); - auto allParams = value["Params"]["String"]; - for (auto value : allParams) - jobRunningLogsObject.params.push_back(value.asString()); - jobRunningLogs_.push_back(jobRunningLogsObject); - } - if(!value["DynamicCode"].isNull()) - dynamicCode_ = value["DynamicCode"].asString(); - if(!value["DynamicMessage"].isNull()) - dynamicMessage_ = value["DynamicMessage"].asString(); - if(!value["ErrCode"].isNull()) - errCode_ = value["ErrCode"].asString(); - if(!value["ErrMessage"].isNull()) - errMessage_ = value["ErrMessage"].asString(); - if(!value["HttpStatusCode"].isNull()) - httpStatusCode_ = std::stoi(value["HttpStatusCode"].asString()); - if(!value["Success"].isNull()) - success_ = value["Success"].asString() == "true"; - if(!value["PageNumber"].isNull()) - pageNumber_ = std::stoi(value["PageNumber"].asString()); - if(!value["PageRecordCount"].isNull()) - pageRecordCount_ = std::stoi(value["PageRecordCount"].asString()); - if(!value["TotalRecordCount"].isNull()) - totalRecordCount_ = std::stol(value["TotalRecordCount"].asString()); - -} - -long DescribeDtsJobLogsResult::getTotalRecordCount()const -{ - return totalRecordCount_; -} - -int DescribeDtsJobLogsResult::getPageRecordCount()const -{ - return pageRecordCount_; -} - -int DescribeDtsJobLogsResult::getPageNumber()const -{ - return pageNumber_; -} - -int DescribeDtsJobLogsResult::getHttpStatusCode()const -{ - return httpStatusCode_; -} - -std::vector DescribeDtsJobLogsResult::getJobRunningLogs()const -{ - return jobRunningLogs_; -} - -std::string DescribeDtsJobLogsResult::getDynamicCode()const -{ - return dynamicCode_; -} - -std::string DescribeDtsJobLogsResult::getDynamicMessage()const -{ - return dynamicMessage_; -} - -std::string DescribeDtsJobLogsResult::getErrMessage()const -{ - return errMessage_; -} - -bool DescribeDtsJobLogsResult::getSuccess()const -{ - return success_; -} - -std::string DescribeDtsJobLogsResult::getErrCode()const -{ - return errCode_; -} - diff --git a/dts/src/model/DescribeMigrationJobsResult.cc b/dts/src/model/DescribeMigrationJobsResult.cc index 93b3b36c6..9e4a6f290 100644 --- a/dts/src/model/DescribeMigrationJobsResult.cc +++ b/dts/src/model/DescribeMigrationJobsResult.cc @@ -53,6 +53,10 @@ void DescribeMigrationJobsResult::parse(const std::string &payload) migrationJobsObject.migrationJobStatus = valueMigrationJobsMigrationJob["MigrationJobStatus"].asString(); if(!valueMigrationJobsMigrationJob["PayType"].isNull()) migrationJobsObject.payType = valueMigrationJobsMigrationJob["PayType"].asString(); + if(!valueMigrationJobsMigrationJob["JobCreateTime"].isNull()) + migrationJobsObject.jobCreateTime = valueMigrationJobsMigrationJob["JobCreateTime"].asString(); + if(!valueMigrationJobsMigrationJob["InstanceCreateTime"].isNull()) + migrationJobsObject.instanceCreateTime = valueMigrationJobsMigrationJob["InstanceCreateTime"].asString(); auto allMigrationObjectNode = valueMigrationJobsMigrationJob["MigrationObject"]["SynchronousObject"]; for (auto valueMigrationJobsMigrationJobMigrationObjectSynchronousObject : allMigrationObjectNode) { diff --git a/dts/src/model/DescribeSubscriptionInstanceStatusResult.cc b/dts/src/model/DescribeSubscriptionInstanceStatusResult.cc index 9f5ecf206..170c2a065 100644 --- a/dts/src/model/DescribeSubscriptionInstanceStatusResult.cc +++ b/dts/src/model/DescribeSubscriptionInstanceStatusResult.cc @@ -95,8 +95,6 @@ void DescribeSubscriptionInstanceStatusResult::parse(const std::string &payload) success_ = value["Success"].asString(); if(!value["ErrorMessage"].isNull()) errorMessage_ = value["ErrorMessage"].asString(); - if(!value["ErrorMessage"].isNull()) - errorMessage1_ = value["ErrorMessage"].asString(); if(!value["TaskId"].isNull()) taskId_ = value["TaskId"].asString(); @@ -172,11 +170,6 @@ std::string DescribeSubscriptionInstanceStatusResult::getSubscribeTopic()const return subscribeTopic_; } -std::string DescribeSubscriptionInstanceStatusResult::getErrorMessage1()const -{ - return errorMessage1_; -} - std::string DescribeSubscriptionInstanceStatusResult::getConsumptionClient()const { return consumptionClient_; diff --git a/dts/src/model/DescribeSubscriptionInstancesResult.cc b/dts/src/model/DescribeSubscriptionInstancesResult.cc index f651ff76e..941f29d3d 100644 --- a/dts/src/model/DescribeSubscriptionInstancesResult.cc +++ b/dts/src/model/DescribeSubscriptionInstancesResult.cc @@ -63,6 +63,10 @@ void DescribeSubscriptionInstancesResult::parse(const std::string &payload) subscriptionInstancesObject.subscriptionInstanceID = valueSubscriptionInstancesSubscriptionInstance["SubscriptionInstanceID"].asString(); if(!valueSubscriptionInstancesSubscriptionInstance["SubscriptionInstanceName"].isNull()) subscriptionInstancesObject.subscriptionInstanceName = valueSubscriptionInstancesSubscriptionInstance["SubscriptionInstanceName"].asString(); + if(!valueSubscriptionInstancesSubscriptionInstance["JobCreateTime"].isNull()) + subscriptionInstancesObject.jobCreateTime = valueSubscriptionInstancesSubscriptionInstance["JobCreateTime"].asString(); + if(!valueSubscriptionInstancesSubscriptionInstance["InstanceCreateTime"].isNull()) + subscriptionInstancesObject.instanceCreateTime = valueSubscriptionInstancesSubscriptionInstance["InstanceCreateTime"].asString(); auto allSubscriptionObjectNode = valueSubscriptionInstancesSubscriptionInstance["SubscriptionObject"]["SynchronousObject"]; for (auto valueSubscriptionInstancesSubscriptionInstanceSubscriptionObjectSynchronousObject : allSubscriptionObjectNode) { diff --git a/dts/src/model/DescribeSynchronizationJobsResult.cc b/dts/src/model/DescribeSynchronizationJobsResult.cc index 805f3f4f3..cf63dea6d 100644 --- a/dts/src/model/DescribeSynchronizationJobsResult.cc +++ b/dts/src/model/DescribeSynchronizationJobsResult.cc @@ -67,6 +67,10 @@ void DescribeSynchronizationJobsResult::parse(const std::string &payload) synchronizationInstancesObject.synchronizationJobId = valueSynchronizationInstancesSynchronizationInstance["SynchronizationJobId"].asString(); if(!valueSynchronizationInstancesSynchronizationInstance["SynchronizationJobName"].isNull()) synchronizationInstancesObject.synchronizationJobName = valueSynchronizationInstancesSynchronizationInstance["SynchronizationJobName"].asString(); + if(!valueSynchronizationInstancesSynchronizationInstance["JobCreateTime"].isNull()) + synchronizationInstancesObject.jobCreateTime = valueSynchronizationInstancesSynchronizationInstance["JobCreateTime"].asString(); + if(!valueSynchronizationInstancesSynchronizationInstance["InstanceCreateTime"].isNull()) + synchronizationInstancesObject.instanceCreateTime = valueSynchronizationInstancesSynchronizationInstance["InstanceCreateTime"].asString(); auto allTagsNode = valueSynchronizationInstancesSynchronizationInstance["Tags"]["Tag"]; for (auto valueSynchronizationInstancesSynchronizationInstanceTagsTag : allTagsNode) { diff --git a/dts/src/model/ModifyConsumerChannelRequest.cc b/dts/src/model/ModifyConsumerChannelRequest.cc new file mode 100644 index 000000000..054b70559 --- /dev/null +++ b/dts/src/model/ModifyConsumerChannelRequest.cc @@ -0,0 +1,106 @@ +/* + * 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 + +using AlibabaCloud::Dts::Model::ModifyConsumerChannelRequest; + +ModifyConsumerChannelRequest::ModifyConsumerChannelRequest() : + RpcServiceRequest("dts", "2020-01-01", "ModifyConsumerChannel") +{ + setMethod(HttpRequest::Method::Post); +} + +ModifyConsumerChannelRequest::~ModifyConsumerChannelRequest() +{} + +std::string ModifyConsumerChannelRequest::getConsumerGroupName()const +{ + return consumerGroupName_; +} + +void ModifyConsumerChannelRequest::setConsumerGroupName(const std::string& consumerGroupName) +{ + consumerGroupName_ = consumerGroupName; + setParameter("ConsumerGroupName", consumerGroupName); +} + +std::string ModifyConsumerChannelRequest::getConsumerGroupId()const +{ + return consumerGroupId_; +} + +void ModifyConsumerChannelRequest::setConsumerGroupId(const std::string& consumerGroupId) +{ + consumerGroupId_ = consumerGroupId; + setParameter("ConsumerGroupId", consumerGroupId); +} + +std::string ModifyConsumerChannelRequest::getConsumerGroupPassword()const +{ + return consumerGroupPassword_; +} + +void ModifyConsumerChannelRequest::setConsumerGroupPassword(const std::string& consumerGroupPassword) +{ + consumerGroupPassword_ = consumerGroupPassword; + setParameter("ConsumerGroupPassword", consumerGroupPassword); +} + +std::string ModifyConsumerChannelRequest::getConsumerGroupUserName()const +{ + return consumerGroupUserName_; +} + +void ModifyConsumerChannelRequest::setConsumerGroupUserName(const std::string& consumerGroupUserName) +{ + consumerGroupUserName_ = consumerGroupUserName; + setParameter("ConsumerGroupUserName", consumerGroupUserName); +} + +std::string ModifyConsumerChannelRequest::getRegionId()const +{ + return regionId_; +} + +void ModifyConsumerChannelRequest::setRegionId(const std::string& regionId) +{ + regionId_ = regionId; + setParameter("RegionId", regionId); +} + +std::string ModifyConsumerChannelRequest::getDtsJobId()const +{ + return dtsJobId_; +} + +void ModifyConsumerChannelRequest::setDtsJobId(const std::string& dtsJobId) +{ + dtsJobId_ = dtsJobId; + setParameter("DtsJobId", dtsJobId); +} + +std::string ModifyConsumerChannelRequest::getDtsInstanceId()const +{ + return dtsInstanceId_; +} + +void ModifyConsumerChannelRequest::setDtsInstanceId(const std::string& dtsInstanceId) +{ + dtsInstanceId_ = dtsInstanceId; + setParameter("DtsInstanceId", dtsInstanceId); +} + diff --git a/dts/src/model/ModifyConsumerChannelResult.cc b/dts/src/model/ModifyConsumerChannelResult.cc new file mode 100644 index 000000000..a43fd0ec0 --- /dev/null +++ b/dts/src/model/ModifyConsumerChannelResult.cc @@ -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. + */ + +#include +#include + +using namespace AlibabaCloud::Dts; +using namespace AlibabaCloud::Dts::Model; + +ModifyConsumerChannelResult::ModifyConsumerChannelResult() : + ServiceResult() +{} + +ModifyConsumerChannelResult::ModifyConsumerChannelResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +ModifyConsumerChannelResult::~ModifyConsumerChannelResult() +{} + +void ModifyConsumerChannelResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["ErrCode"].isNull()) + errCode_ = value["ErrCode"].asString(); + if(!value["ErrMessage"].isNull()) + errMessage_ = value["ErrMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString(); + if(!value["HttpStatusCode"].isNull()) + httpStatusCode_ = value["HttpStatusCode"].asString(); + +} + +std::string ModifyConsumerChannelResult::getHttpStatusCode()const +{ + return httpStatusCode_; +} + +std::string ModifyConsumerChannelResult::getErrMessage()const +{ + return errMessage_; +} + +std::string ModifyConsumerChannelResult::getSuccess()const +{ + return success_; +} + +std::string ModifyConsumerChannelResult::getErrCode()const +{ + return errCode_; +} + diff --git a/dts/src/model/ModifySubscriptionRequest.cc b/dts/src/model/ModifySubscriptionRequest.cc new file mode 100644 index 000000000..e8aa094f0 --- /dev/null +++ b/dts/src/model/ModifySubscriptionRequest.cc @@ -0,0 +1,95 @@ +/* + * 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 + +using AlibabaCloud::Dts::Model::ModifySubscriptionRequest; + +ModifySubscriptionRequest::ModifySubscriptionRequest() : + RpcServiceRequest("dts", "2020-01-01", "ModifySubscription") +{ + setMethod(HttpRequest::Method::Post); +} + +ModifySubscriptionRequest::~ModifySubscriptionRequest() +{} + +std::string ModifySubscriptionRequest::getDbList()const +{ + return dbList_; +} + +void ModifySubscriptionRequest::setDbList(const std::string& dbList) +{ + dbList_ = dbList; + setParameter("DbList", dbList); +} + +bool ModifySubscriptionRequest::getSubscriptionDataTypeDDL()const +{ + return subscriptionDataTypeDDL_; +} + +void ModifySubscriptionRequest::setSubscriptionDataTypeDDL(bool subscriptionDataTypeDDL) +{ + subscriptionDataTypeDDL_ = subscriptionDataTypeDDL; + setParameter("SubscriptionDataTypeDDL", subscriptionDataTypeDDL ? "true" : "false"); +} + +bool ModifySubscriptionRequest::getSubscriptionDataTypeDML()const +{ + return subscriptionDataTypeDML_; +} + +void ModifySubscriptionRequest::setSubscriptionDataTypeDML(bool subscriptionDataTypeDML) +{ + subscriptionDataTypeDML_ = subscriptionDataTypeDML; + setParameter("SubscriptionDataTypeDML", subscriptionDataTypeDML ? "true" : "false"); +} + +std::string ModifySubscriptionRequest::getRegionId()const +{ + return regionId_; +} + +void ModifySubscriptionRequest::setRegionId(const std::string& regionId) +{ + regionId_ = regionId; + setParameter("RegionId", regionId); +} + +std::string ModifySubscriptionRequest::getDtsJobId()const +{ + return dtsJobId_; +} + +void ModifySubscriptionRequest::setDtsJobId(const std::string& dtsJobId) +{ + dtsJobId_ = dtsJobId; + setParameter("DtsJobId", dtsJobId); +} + +std::string ModifySubscriptionRequest::getDtsInstanceId()const +{ + return dtsInstanceId_; +} + +void ModifySubscriptionRequest::setDtsInstanceId(const std::string& dtsInstanceId) +{ + dtsInstanceId_ = dtsInstanceId; + setParameter("DtsInstanceId", dtsInstanceId); +} + diff --git a/dts/src/model/ModifySubscriptionResult.cc b/dts/src/model/ModifySubscriptionResult.cc new file mode 100644 index 000000000..d0f7c0623 --- /dev/null +++ b/dts/src/model/ModifySubscriptionResult.cc @@ -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. + */ + +#include +#include + +using namespace AlibabaCloud::Dts; +using namespace AlibabaCloud::Dts::Model; + +ModifySubscriptionResult::ModifySubscriptionResult() : + ServiceResult() +{} + +ModifySubscriptionResult::ModifySubscriptionResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +ModifySubscriptionResult::~ModifySubscriptionResult() +{} + +void ModifySubscriptionResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["ErrCode"].isNull()) + errCode_ = value["ErrCode"].asString(); + if(!value["ErrMessage"].isNull()) + errMessage_ = value["ErrMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString(); + if(!value["HttpStatusCode"].isNull()) + httpStatusCode_ = value["HttpStatusCode"].asString(); + +} + +std::string ModifySubscriptionResult::getHttpStatusCode()const +{ + return httpStatusCode_; +} + +std::string ModifySubscriptionResult::getErrMessage()const +{ + return errMessage_; +} + +std::string ModifySubscriptionResult::getSuccess()const +{ + return success_; +} + +std::string ModifySubscriptionResult::getErrCode()const +{ + return errCode_; +} + diff --git a/dts/src/model/PreviewSqlRequest.cc b/dts/src/model/PreviewSqlRequest.cc deleted file mode 100644 index c2445f6a2..000000000 --- a/dts/src/model/PreviewSqlRequest.cc +++ /dev/null @@ -1,51 +0,0 @@ -/* - * 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 - -using AlibabaCloud::Dts::Model::PreviewSqlRequest; - -PreviewSqlRequest::PreviewSqlRequest() : - RpcServiceRequest("dts", "2020-01-01", "PreviewSql") -{ - setMethod(HttpRequest::Method::Post); -} - -PreviewSqlRequest::~PreviewSqlRequest() -{} - -std::string PreviewSqlRequest::getEtlCalculator()const -{ - return etlCalculator_; -} - -void PreviewSqlRequest::setEtlCalculator(const std::string& etlCalculator) -{ - etlCalculator_ = etlCalculator; - setParameter("EtlCalculator", etlCalculator); -} - -std::string PreviewSqlRequest::getRegionId()const -{ - return regionId_; -} - -void PreviewSqlRequest::setRegionId(const std::string& regionId) -{ - regionId_ = regionId; - setParameter("RegionId", regionId); -} - diff --git a/dts/src/model/RenewInstanceRequest.cc b/dts/src/model/RenewInstanceRequest.cc new file mode 100644 index 000000000..2d37d88d3 --- /dev/null +++ b/dts/src/model/RenewInstanceRequest.cc @@ -0,0 +1,84 @@ +/* + * 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 + +using AlibabaCloud::Dts::Model::RenewInstanceRequest; + +RenewInstanceRequest::RenewInstanceRequest() : + RpcServiceRequest("dts", "2020-01-01", "RenewInstance") +{ + setMethod(HttpRequest::Method::Post); +} + +RenewInstanceRequest::~RenewInstanceRequest() +{} + +std::string RenewInstanceRequest::getPeriod()const +{ + return period_; +} + +void RenewInstanceRequest::setPeriod(const std::string& period) +{ + period_ = period; + setParameter("Period", period); +} + +std::string RenewInstanceRequest::getBuyCount()const +{ + return buyCount_; +} + +void RenewInstanceRequest::setBuyCount(const std::string& buyCount) +{ + buyCount_ = buyCount; + setParameter("BuyCount", buyCount); +} + +std::string RenewInstanceRequest::getRegionId()const +{ + return regionId_; +} + +void RenewInstanceRequest::setRegionId(const std::string& regionId) +{ + regionId_ = regionId; + setParameter("RegionId", regionId); +} + +std::string RenewInstanceRequest::getDtsJobId()const +{ + return dtsJobId_; +} + +void RenewInstanceRequest::setDtsJobId(const std::string& dtsJobId) +{ + dtsJobId_ = dtsJobId; + setParameter("DtsJobId", dtsJobId); +} + +std::string RenewInstanceRequest::getChargeType()const +{ + return chargeType_; +} + +void RenewInstanceRequest::setChargeType(const std::string& chargeType) +{ + chargeType_ = chargeType; + setParameter("ChargeType", chargeType); +} + diff --git a/dts/src/model/PreviewSqlResult.cc b/dts/src/model/RenewInstanceResult.cc similarity index 54% rename from dts/src/model/PreviewSqlResult.cc rename to dts/src/model/RenewInstanceResult.cc index 997e58ec2..ecb835be2 100644 --- a/dts/src/model/PreviewSqlResult.cc +++ b/dts/src/model/RenewInstanceResult.cc @@ -14,94 +14,100 @@ * limitations under the License. */ -#include +#include #include using namespace AlibabaCloud::Dts; using namespace AlibabaCloud::Dts::Model; -PreviewSqlResult::PreviewSqlResult() : +RenewInstanceResult::RenewInstanceResult() : ServiceResult() {} -PreviewSqlResult::PreviewSqlResult(const std::string &payload) : +RenewInstanceResult::RenewInstanceResult(const std::string &payload) : ServiceResult() { parse(payload); } -PreviewSqlResult::~PreviewSqlResult() +RenewInstanceResult::~RenewInstanceResult() {} -void PreviewSqlResult::parse(const std::string &payload) +void RenewInstanceResult::parse(const std::string &payload) { Json::Reader reader; Json::Value value; reader.parse(payload, value); setRequestId(value["RequestId"].asString()); - auto allSqlList = value["SqlList"]["Sql"]; - for (const auto &item : allSqlList) - sqlList_.push_back(item.asString()); - if(!value["DynamicCode"].isNull()) - dynamicCode_ = value["DynamicCode"].asString(); + if(!value["ChargeType"].isNull()) + chargeType_ = value["ChargeType"].asString(); + if(!value["Code"].isNull()) + code_ = value["Code"].asString(); + if(!value["DtsJobId"].isNull()) + dtsJobId_ = value["DtsJobId"].asString(); if(!value["DynamicMessage"].isNull()) dynamicMessage_ = value["DynamicMessage"].asString(); + if(!value["EndTime"].isNull()) + endTime_ = value["EndTime"].asString(); if(!value["ErrCode"].isNull()) errCode_ = value["ErrCode"].asString(); if(!value["ErrMessage"].isNull()) errMessage_ = value["ErrMessage"].asString(); if(!value["HttpStatusCode"].isNull()) httpStatusCode_ = std::stoi(value["HttpStatusCode"].asString()); + if(!value["InstanceId"].isNull()) + instanceId_ = value["InstanceId"].asString(); if(!value["Success"].isNull()) success_ = value["Success"].asString() == "true"; - if(!value["StreamGraph"].isNull()) - streamGraph_ = value["StreamGraph"].asString(); - if(!value["ValidationException"].isNull()) - validationException_ = value["ValidationException"].asString(); } -std::vector PreviewSqlResult::getSqlList()const +std::string RenewInstanceResult::getDtsJobId()const { - return sqlList_; + return dtsJobId_; } -std::string PreviewSqlResult::getValidationException()const +std::string RenewInstanceResult::getEndTime()const { - return validationException_; + return endTime_; } -int PreviewSqlResult::getHttpStatusCode()const +std::string RenewInstanceResult::getInstanceId()const +{ + return instanceId_; +} + +std::string RenewInstanceResult::getChargeType()const +{ + return chargeType_; +} + +int RenewInstanceResult::getHttpStatusCode()const { return httpStatusCode_; } -std::string PreviewSqlResult::getStreamGraph()const -{ - return streamGraph_; -} - -std::string PreviewSqlResult::getDynamicCode()const -{ - return dynamicCode_; -} - -std::string PreviewSqlResult::getDynamicMessage()const +std::string RenewInstanceResult::getDynamicMessage()const { return dynamicMessage_; } -std::string PreviewSqlResult::getErrMessage()const +std::string RenewInstanceResult::getErrMessage()const { return errMessage_; } -bool PreviewSqlResult::getSuccess()const +std::string RenewInstanceResult::getCode()const +{ + return code_; +} + +bool RenewInstanceResult::getSuccess()const { return success_; } -std::string PreviewSqlResult::getErrCode()const +std::string RenewInstanceResult::getErrCode()const { return errCode_; } diff --git a/dts/src/model/StartDtsJobRequest.cc b/dts/src/model/StartDtsJobRequest.cc index 26240900b..b37e5734e 100644 --- a/dts/src/model/StartDtsJobRequest.cc +++ b/dts/src/model/StartDtsJobRequest.cc @@ -27,6 +27,17 @@ StartDtsJobRequest::StartDtsJobRequest() : StartDtsJobRequest::~StartDtsJobRequest() {} +std::string StartDtsJobRequest::getResetCheckpoint()const +{ + return resetCheckpoint_; +} + +void StartDtsJobRequest::setResetCheckpoint(const std::string& resetCheckpoint) +{ + resetCheckpoint_ = resetCheckpoint; + setParameter("ResetCheckpoint", resetCheckpoint); +} + std::string StartDtsJobRequest::getRegionId()const { return regionId_; @@ -38,6 +49,17 @@ void StartDtsJobRequest::setRegionId(const std::string& regionId) setParameter("RegionId", regionId); } +std::string StartDtsJobRequest::getResumeHoldJob()const +{ + return resumeHoldJob_; +} + +void StartDtsJobRequest::setResumeHoldJob(const std::string& resumeHoldJob) +{ + resumeHoldJob_ = resumeHoldJob; + setParameter("ResumeHoldJob", resumeHoldJob); +} + std::string StartDtsJobRequest::getDtsJobId()const { return dtsJobId_; diff --git a/dts/src/model/TransferInstanceClassRequest.cc b/dts/src/model/TransferInstanceClassRequest.cc new file mode 100644 index 000000000..e3e9641aa --- /dev/null +++ b/dts/src/model/TransferInstanceClassRequest.cc @@ -0,0 +1,73 @@ +/* + * 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 + +using AlibabaCloud::Dts::Model::TransferInstanceClassRequest; + +TransferInstanceClassRequest::TransferInstanceClassRequest() : + RpcServiceRequest("dts", "2020-01-01", "TransferInstanceClass") +{ + setMethod(HttpRequest::Method::Post); +} + +TransferInstanceClassRequest::~TransferInstanceClassRequest() +{} + +std::string TransferInstanceClassRequest::getInstanceClass()const +{ + return instanceClass_; +} + +void TransferInstanceClassRequest::setInstanceClass(const std::string& instanceClass) +{ + instanceClass_ = instanceClass; + setParameter("InstanceClass", instanceClass); +} + +std::string TransferInstanceClassRequest::getRegionId()const +{ + return regionId_; +} + +void TransferInstanceClassRequest::setRegionId(const std::string& regionId) +{ + regionId_ = regionId; + setParameter("RegionId", regionId); +} + +std::string TransferInstanceClassRequest::getDtsJobId()const +{ + return dtsJobId_; +} + +void TransferInstanceClassRequest::setDtsJobId(const std::string& dtsJobId) +{ + dtsJobId_ = dtsJobId; + setParameter("DtsJobId", dtsJobId); +} + +std::string TransferInstanceClassRequest::getOrderType()const +{ + return orderType_; +} + +void TransferInstanceClassRequest::setOrderType(const std::string& orderType) +{ + orderType_ = orderType; + setParameter("OrderType", orderType); +} + diff --git a/dts/src/model/TransferInstanceClassResult.cc b/dts/src/model/TransferInstanceClassResult.cc new file mode 100644 index 000000000..be9057036 --- /dev/null +++ b/dts/src/model/TransferInstanceClassResult.cc @@ -0,0 +1,114 @@ +/* + * 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 +#include + +using namespace AlibabaCloud::Dts; +using namespace AlibabaCloud::Dts::Model; + +TransferInstanceClassResult::TransferInstanceClassResult() : + ServiceResult() +{} + +TransferInstanceClassResult::TransferInstanceClassResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +TransferInstanceClassResult::~TransferInstanceClassResult() +{} + +void TransferInstanceClassResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["Code"].isNull()) + code_ = value["Code"].asString(); + if(!value["DynamicMessage"].isNull()) + dynamicMessage_ = value["DynamicMessage"].asString(); + if(!value["ErrCode"].isNull()) + errCode_ = value["ErrCode"].asString(); + if(!value["ErrMessage"].isNull()) + errMessage_ = value["ErrMessage"].asString(); + if(!value["HttpStatusCode"].isNull()) + httpStatusCode_ = std::stoi(value["HttpStatusCode"].asString()); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + if(!value["DtsJobId"].isNull()) + dtsJobId_ = value["DtsJobId"].asString(); + if(!value["InstanceId"].isNull()) + instanceId_ = value["InstanceId"].asString(); + if(!value["ChargeType"].isNull()) + chargeType_ = value["ChargeType"].asString(); + if(!value["EndTime"].isNull()) + endTime_ = value["EndTime"].asString(); + +} + +std::string TransferInstanceClassResult::getDtsJobId()const +{ + return dtsJobId_; +} + +std::string TransferInstanceClassResult::getEndTime()const +{ + return endTime_; +} + +std::string TransferInstanceClassResult::getInstanceId()const +{ + return instanceId_; +} + +std::string TransferInstanceClassResult::getChargeType()const +{ + return chargeType_; +} + +int TransferInstanceClassResult::getHttpStatusCode()const +{ + return httpStatusCode_; +} + +std::string TransferInstanceClassResult::getDynamicMessage()const +{ + return dynamicMessage_; +} + +std::string TransferInstanceClassResult::getErrMessage()const +{ + return errMessage_; +} + +std::string TransferInstanceClassResult::getCode()const +{ + return code_; +} + +bool TransferInstanceClassResult::getSuccess()const +{ + return success_; +} + +std::string TransferInstanceClassResult::getErrCode()const +{ + return errCode_; +} + diff --git a/dts/src/model/TransferPayTypeRequest.cc b/dts/src/model/TransferPayTypeRequest.cc index 1b76ac360..9cab1a409 100644 --- a/dts/src/model/TransferPayTypeRequest.cc +++ b/dts/src/model/TransferPayTypeRequest.cc @@ -49,17 +49,6 @@ void TransferPayTypeRequest::setBuyCount(const std::string& buyCount) setParameter("BuyCount", buyCount); } -std::string TransferPayTypeRequest::getInstanceClass()const -{ - return instanceClass_; -} - -void TransferPayTypeRequest::setInstanceClass(const std::string& instanceClass) -{ - instanceClass_ = instanceClass; - setParameter("InstanceClass", instanceClass); -} - std::string TransferPayTypeRequest::getRegionId()const { return regionId_;