From 179726e2c2f88b268b3d73af7cd37e1d384ac1c3 Mon Sep 17 00:00:00 2001 From: sdk-team Date: Wed, 3 Apr 2024 08:43:55 +0000 Subject: [PATCH] Supported use group by freedom --- VERSION | 2 +- alikafka/CMakeLists.txt | 28 ++ .../alibabacloud/alikafka/AlikafkaClient.h | 56 ++++ .../alikafka/model/CreateAclRequest.h | 9 + .../alikafka/model/CreatePrePayOrderRequest.h | 29 ++ .../alikafka/model/CreateSaslUserRequest.h | 3 + .../alikafka/model/DeleteAclRequest.h | 9 + .../alikafka/model/DeleteSaslUserRequest.h | 3 + .../alikafka/model/DescribeAclsRequest.h | 9 + .../alikafka/model/DescribeAclsResult.h | 1 + .../alikafka/model/DescribeSaslUsersResult.h | 1 + .../model/EnableAutoGroupCreationRequest.h | 48 ++++ .../model/EnableAutoGroupCreationResult.h | 55 ++++ .../model/EnableAutoTopicCreationRequest.h | 51 ++++ .../model/EnableAutoTopicCreationResult.h | 55 ++++ .../alikafka/model/GetConsumerListResult.h | 6 + .../model/GetConsumerProgressResult.h | 10 + .../alikafka/model/GetInstanceListResult.h | 25 ++ .../model/GetTopicSubscribeStatusRequest.h | 48 ++++ .../model/GetTopicSubscribeStatusResult.h | 62 +++++ .../alikafka/model/ModifyTopicRemarkRequest.h | 6 +- .../alikafka/model/QueryMessageRequest.h | 60 ++++ .../alikafka/model/QueryMessageResult.h | 74 +++++ .../alikafka/model/ReopenInstanceRequest.h | 45 +++ .../alikafka/model/ReopenInstanceResult.h | 55 ++++ .../alikafka/model/StartInstanceRequest.h | 3 + .../alikafka/model/StopInstanceRequest.h | 45 +++ .../alikafka/model/StopInstanceResult.h | 55 ++++ .../alikafka/model/UpdateTopicConfigRequest.h | 54 ++++ .../alikafka/model/UpdateTopicConfigResult.h | 57 ++++ .../model/UpgradePostPayOrderRequest.h | 7 + .../model/UpgradePrePayOrderRequest.h | 50 +++- alikafka/src/AlikafkaClient.cc | 258 +++++++++++++++++- alikafka/src/model/CreateAclRequest.cc | 27 ++ .../src/model/CreatePrePayOrderRequest.cc | 44 +++ alikafka/src/model/CreateSaslUserRequest.cc | 9 + alikafka/src/model/DeleteAclRequest.cc | 27 ++ alikafka/src/model/DeleteSaslUserRequest.cc | 9 + alikafka/src/model/DescribeAclsRequest.cc | 27 ++ alikafka/src/model/DescribeAclsResult.cc | 2 + alikafka/src/model/DescribeSaslUsersResult.cc | 2 + .../model/EnableAutoGroupCreationRequest.cc | 54 ++++ .../model/EnableAutoGroupCreationResult.cc | 65 +++++ .../model/EnableAutoTopicCreationRequest.cc | 63 +++++ .../model/EnableAutoTopicCreationResult.cc | 65 +++++ alikafka/src/model/GetConsumerListResult.cc | 21 ++ .../src/model/GetConsumerProgressResult.cc | 18 ++ alikafka/src/model/GetInstanceListResult.cc | 43 +++ .../model/GetTopicSubscribeStatusRequest.cc | 54 ++++ .../model/GetTopicSubscribeStatusResult.cc | 76 ++++++ .../src/model/ModifyTopicRemarkRequest.cc | 18 +- alikafka/src/model/QueryMessageRequest.cc | 90 ++++++ alikafka/src/model/QueryMessageResult.cc | 104 +++++++ alikafka/src/model/ReopenInstanceRequest.cc | 45 +++ alikafka/src/model/ReopenInstanceResult.cc | 65 +++++ alikafka/src/model/StartInstanceRequest.cc | 8 + alikafka/src/model/StopInstanceRequest.cc | 45 +++ alikafka/src/model/StopInstanceResult.cc | 65 +++++ .../src/model/UpdateTopicConfigRequest.cc | 72 +++++ alikafka/src/model/UpdateTopicConfigResult.cc | 72 +++++ .../src/model/UpgradePostPayOrderRequest.cc | 10 + .../src/model/UpgradePrePayOrderRequest.cc | 107 +++++--- 62 files changed, 2522 insertions(+), 64 deletions(-) create mode 100644 alikafka/include/alibabacloud/alikafka/model/EnableAutoGroupCreationRequest.h create mode 100644 alikafka/include/alibabacloud/alikafka/model/EnableAutoGroupCreationResult.h create mode 100644 alikafka/include/alibabacloud/alikafka/model/EnableAutoTopicCreationRequest.h create mode 100644 alikafka/include/alibabacloud/alikafka/model/EnableAutoTopicCreationResult.h create mode 100644 alikafka/include/alibabacloud/alikafka/model/GetTopicSubscribeStatusRequest.h create mode 100644 alikafka/include/alibabacloud/alikafka/model/GetTopicSubscribeStatusResult.h create mode 100644 alikafka/include/alibabacloud/alikafka/model/QueryMessageRequest.h create mode 100644 alikafka/include/alibabacloud/alikafka/model/QueryMessageResult.h create mode 100644 alikafka/include/alibabacloud/alikafka/model/ReopenInstanceRequest.h create mode 100644 alikafka/include/alibabacloud/alikafka/model/ReopenInstanceResult.h create mode 100644 alikafka/include/alibabacloud/alikafka/model/StopInstanceRequest.h create mode 100644 alikafka/include/alibabacloud/alikafka/model/StopInstanceResult.h create mode 100644 alikafka/include/alibabacloud/alikafka/model/UpdateTopicConfigRequest.h create mode 100644 alikafka/include/alibabacloud/alikafka/model/UpdateTopicConfigResult.h create mode 100644 alikafka/src/model/EnableAutoGroupCreationRequest.cc create mode 100644 alikafka/src/model/EnableAutoGroupCreationResult.cc create mode 100644 alikafka/src/model/EnableAutoTopicCreationRequest.cc create mode 100644 alikafka/src/model/EnableAutoTopicCreationResult.cc create mode 100644 alikafka/src/model/GetTopicSubscribeStatusRequest.cc create mode 100644 alikafka/src/model/GetTopicSubscribeStatusResult.cc create mode 100644 alikafka/src/model/QueryMessageRequest.cc create mode 100644 alikafka/src/model/QueryMessageResult.cc create mode 100644 alikafka/src/model/ReopenInstanceRequest.cc create mode 100644 alikafka/src/model/ReopenInstanceResult.cc create mode 100644 alikafka/src/model/StopInstanceRequest.cc create mode 100644 alikafka/src/model/StopInstanceResult.cc create mode 100644 alikafka/src/model/UpdateTopicConfigRequest.cc create mode 100644 alikafka/src/model/UpdateTopicConfigResult.cc diff --git a/VERSION b/VERSION index 6e890658b..4b4fce034 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -1.36.1887 \ No newline at end of file +1.36.1888 \ No newline at end of file diff --git a/alikafka/CMakeLists.txt b/alikafka/CMakeLists.txt index ce6915b17..4bc2469ae 100644 --- a/alikafka/CMakeLists.txt +++ b/alikafka/CMakeLists.txt @@ -51,6 +51,10 @@ set(alikafka_public_header_model include/alibabacloud/alikafka/model/DescribeAclsResult.h include/alibabacloud/alikafka/model/DescribeSaslUsersRequest.h include/alibabacloud/alikafka/model/DescribeSaslUsersResult.h + include/alibabacloud/alikafka/model/EnableAutoGroupCreationRequest.h + include/alibabacloud/alikafka/model/EnableAutoGroupCreationResult.h + include/alibabacloud/alikafka/model/EnableAutoTopicCreationRequest.h + include/alibabacloud/alikafka/model/EnableAutoTopicCreationResult.h include/alibabacloud/alikafka/model/GetAllInstanceIdListRequest.h include/alibabacloud/alikafka/model/GetAllInstanceIdListResult.h include/alibabacloud/alikafka/model/GetAllowedIpListRequest.h @@ -67,6 +71,8 @@ set(alikafka_public_header_model include/alibabacloud/alikafka/model/GetTopicListResult.h include/alibabacloud/alikafka/model/GetTopicStatusRequest.h include/alibabacloud/alikafka/model/GetTopicStatusResult.h + include/alibabacloud/alikafka/model/GetTopicSubscribeStatusRequest.h + include/alibabacloud/alikafka/model/GetTopicSubscribeStatusResult.h include/alibabacloud/alikafka/model/ListTagResourcesRequest.h include/alibabacloud/alikafka/model/ListTagResourcesResult.h include/alibabacloud/alikafka/model/ModifyInstanceNameRequest.h @@ -75,10 +81,16 @@ set(alikafka_public_header_model include/alibabacloud/alikafka/model/ModifyPartitionNumResult.h include/alibabacloud/alikafka/model/ModifyTopicRemarkRequest.h include/alibabacloud/alikafka/model/ModifyTopicRemarkResult.h + include/alibabacloud/alikafka/model/QueryMessageRequest.h + include/alibabacloud/alikafka/model/QueryMessageResult.h include/alibabacloud/alikafka/model/ReleaseInstanceRequest.h include/alibabacloud/alikafka/model/ReleaseInstanceResult.h + include/alibabacloud/alikafka/model/ReopenInstanceRequest.h + include/alibabacloud/alikafka/model/ReopenInstanceResult.h include/alibabacloud/alikafka/model/StartInstanceRequest.h include/alibabacloud/alikafka/model/StartInstanceResult.h + include/alibabacloud/alikafka/model/StopInstanceRequest.h + include/alibabacloud/alikafka/model/StopInstanceResult.h include/alibabacloud/alikafka/model/TagResourcesRequest.h include/alibabacloud/alikafka/model/TagResourcesResult.h include/alibabacloud/alikafka/model/UntagResourcesRequest.h @@ -89,6 +101,8 @@ set(alikafka_public_header_model include/alibabacloud/alikafka/model/UpdateConsumerOffsetResult.h include/alibabacloud/alikafka/model/UpdateInstanceConfigRequest.h include/alibabacloud/alikafka/model/UpdateInstanceConfigResult.h + include/alibabacloud/alikafka/model/UpdateTopicConfigRequest.h + include/alibabacloud/alikafka/model/UpdateTopicConfigResult.h include/alibabacloud/alikafka/model/UpgradeInstanceVersionRequest.h include/alibabacloud/alikafka/model/UpgradeInstanceVersionResult.h include/alibabacloud/alikafka/model/UpgradePostPayOrderRequest.h @@ -128,6 +142,10 @@ set(alikafka_src src/model/DescribeAclsResult.cc src/model/DescribeSaslUsersRequest.cc src/model/DescribeSaslUsersResult.cc + src/model/EnableAutoGroupCreationRequest.cc + src/model/EnableAutoGroupCreationResult.cc + src/model/EnableAutoTopicCreationRequest.cc + src/model/EnableAutoTopicCreationResult.cc src/model/GetAllInstanceIdListRequest.cc src/model/GetAllInstanceIdListResult.cc src/model/GetAllowedIpListRequest.cc @@ -144,6 +162,8 @@ set(alikafka_src src/model/GetTopicListResult.cc src/model/GetTopicStatusRequest.cc src/model/GetTopicStatusResult.cc + src/model/GetTopicSubscribeStatusRequest.cc + src/model/GetTopicSubscribeStatusResult.cc src/model/ListTagResourcesRequest.cc src/model/ListTagResourcesResult.cc src/model/ModifyInstanceNameRequest.cc @@ -152,10 +172,16 @@ set(alikafka_src src/model/ModifyPartitionNumResult.cc src/model/ModifyTopicRemarkRequest.cc src/model/ModifyTopicRemarkResult.cc + src/model/QueryMessageRequest.cc + src/model/QueryMessageResult.cc src/model/ReleaseInstanceRequest.cc src/model/ReleaseInstanceResult.cc + src/model/ReopenInstanceRequest.cc + src/model/ReopenInstanceResult.cc src/model/StartInstanceRequest.cc src/model/StartInstanceResult.cc + src/model/StopInstanceRequest.cc + src/model/StopInstanceResult.cc src/model/TagResourcesRequest.cc src/model/TagResourcesResult.cc src/model/UntagResourcesRequest.cc @@ -166,6 +192,8 @@ set(alikafka_src src/model/UpdateConsumerOffsetResult.cc src/model/UpdateInstanceConfigRequest.cc src/model/UpdateInstanceConfigResult.cc + src/model/UpdateTopicConfigRequest.cc + src/model/UpdateTopicConfigResult.cc src/model/UpgradeInstanceVersionRequest.cc src/model/UpgradeInstanceVersionResult.cc src/model/UpgradePostPayOrderRequest.cc diff --git a/alikafka/include/alibabacloud/alikafka/AlikafkaClient.h b/alikafka/include/alibabacloud/alikafka/AlikafkaClient.h index 4c3ad4466..c5711339a 100644 --- a/alikafka/include/alibabacloud/alikafka/AlikafkaClient.h +++ b/alikafka/include/alibabacloud/alikafka/AlikafkaClient.h @@ -52,6 +52,10 @@ #include "model/DescribeAclsResult.h" #include "model/DescribeSaslUsersRequest.h" #include "model/DescribeSaslUsersResult.h" +#include "model/EnableAutoGroupCreationRequest.h" +#include "model/EnableAutoGroupCreationResult.h" +#include "model/EnableAutoTopicCreationRequest.h" +#include "model/EnableAutoTopicCreationResult.h" #include "model/GetAllInstanceIdListRequest.h" #include "model/GetAllInstanceIdListResult.h" #include "model/GetAllowedIpListRequest.h" @@ -68,6 +72,8 @@ #include "model/GetTopicListResult.h" #include "model/GetTopicStatusRequest.h" #include "model/GetTopicStatusResult.h" +#include "model/GetTopicSubscribeStatusRequest.h" +#include "model/GetTopicSubscribeStatusResult.h" #include "model/ListTagResourcesRequest.h" #include "model/ListTagResourcesResult.h" #include "model/ModifyInstanceNameRequest.h" @@ -76,10 +82,16 @@ #include "model/ModifyPartitionNumResult.h" #include "model/ModifyTopicRemarkRequest.h" #include "model/ModifyTopicRemarkResult.h" +#include "model/QueryMessageRequest.h" +#include "model/QueryMessageResult.h" #include "model/ReleaseInstanceRequest.h" #include "model/ReleaseInstanceResult.h" +#include "model/ReopenInstanceRequest.h" +#include "model/ReopenInstanceResult.h" #include "model/StartInstanceRequest.h" #include "model/StartInstanceResult.h" +#include "model/StopInstanceRequest.h" +#include "model/StopInstanceResult.h" #include "model/TagResourcesRequest.h" #include "model/TagResourcesResult.h" #include "model/UntagResourcesRequest.h" @@ -90,6 +102,8 @@ #include "model/UpdateConsumerOffsetResult.h" #include "model/UpdateInstanceConfigRequest.h" #include "model/UpdateInstanceConfigResult.h" +#include "model/UpdateTopicConfigRequest.h" +#include "model/UpdateTopicConfigResult.h" #include "model/UpgradeInstanceVersionRequest.h" #include "model/UpgradeInstanceVersionResult.h" #include "model/UpgradePostPayOrderRequest.h" @@ -150,6 +164,12 @@ namespace AlibabaCloud typedef Outcome DescribeSaslUsersOutcome; typedef std::future DescribeSaslUsersOutcomeCallable; typedef std::function&)> DescribeSaslUsersAsyncHandler; + typedef Outcome EnableAutoGroupCreationOutcome; + typedef std::future EnableAutoGroupCreationOutcomeCallable; + typedef std::function&)> EnableAutoGroupCreationAsyncHandler; + typedef Outcome EnableAutoTopicCreationOutcome; + typedef std::future EnableAutoTopicCreationOutcomeCallable; + typedef std::function&)> EnableAutoTopicCreationAsyncHandler; typedef Outcome GetAllInstanceIdListOutcome; typedef std::future GetAllInstanceIdListOutcomeCallable; typedef std::function&)> GetAllInstanceIdListAsyncHandler; @@ -174,6 +194,9 @@ namespace AlibabaCloud typedef Outcome GetTopicStatusOutcome; typedef std::future GetTopicStatusOutcomeCallable; typedef std::function&)> GetTopicStatusAsyncHandler; + typedef Outcome GetTopicSubscribeStatusOutcome; + typedef std::future GetTopicSubscribeStatusOutcomeCallable; + typedef std::function&)> GetTopicSubscribeStatusAsyncHandler; typedef Outcome ListTagResourcesOutcome; typedef std::future ListTagResourcesOutcomeCallable; typedef std::function&)> ListTagResourcesAsyncHandler; @@ -186,12 +209,21 @@ namespace AlibabaCloud typedef Outcome ModifyTopicRemarkOutcome; typedef std::future ModifyTopicRemarkOutcomeCallable; typedef std::function&)> ModifyTopicRemarkAsyncHandler; + typedef Outcome QueryMessageOutcome; + typedef std::future QueryMessageOutcomeCallable; + typedef std::function&)> QueryMessageAsyncHandler; typedef Outcome ReleaseInstanceOutcome; typedef std::future ReleaseInstanceOutcomeCallable; typedef std::function&)> ReleaseInstanceAsyncHandler; + typedef Outcome ReopenInstanceOutcome; + typedef std::future ReopenInstanceOutcomeCallable; + typedef std::function&)> ReopenInstanceAsyncHandler; typedef Outcome StartInstanceOutcome; typedef std::future StartInstanceOutcomeCallable; typedef std::function&)> StartInstanceAsyncHandler; + typedef Outcome StopInstanceOutcome; + typedef std::future StopInstanceOutcomeCallable; + typedef std::function&)> StopInstanceAsyncHandler; typedef Outcome TagResourcesOutcome; typedef std::future TagResourcesOutcomeCallable; typedef std::function&)> TagResourcesAsyncHandler; @@ -207,6 +239,9 @@ namespace AlibabaCloud typedef Outcome UpdateInstanceConfigOutcome; typedef std::future UpdateInstanceConfigOutcomeCallable; typedef std::function&)> UpdateInstanceConfigAsyncHandler; + typedef Outcome UpdateTopicConfigOutcome; + typedef std::future UpdateTopicConfigOutcomeCallable; + typedef std::function&)> UpdateTopicConfigAsyncHandler; typedef Outcome UpgradeInstanceVersionOutcome; typedef std::future UpgradeInstanceVersionOutcomeCallable; typedef std::function&)> UpgradeInstanceVersionAsyncHandler; @@ -266,6 +301,12 @@ namespace AlibabaCloud DescribeSaslUsersOutcome describeSaslUsers(const Model::DescribeSaslUsersRequest &request)const; void describeSaslUsersAsync(const Model::DescribeSaslUsersRequest& request, const DescribeSaslUsersAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; DescribeSaslUsersOutcomeCallable describeSaslUsersCallable(const Model::DescribeSaslUsersRequest& request) const; + EnableAutoGroupCreationOutcome enableAutoGroupCreation(const Model::EnableAutoGroupCreationRequest &request)const; + void enableAutoGroupCreationAsync(const Model::EnableAutoGroupCreationRequest& request, const EnableAutoGroupCreationAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + EnableAutoGroupCreationOutcomeCallable enableAutoGroupCreationCallable(const Model::EnableAutoGroupCreationRequest& request) const; + EnableAutoTopicCreationOutcome enableAutoTopicCreation(const Model::EnableAutoTopicCreationRequest &request)const; + void enableAutoTopicCreationAsync(const Model::EnableAutoTopicCreationRequest& request, const EnableAutoTopicCreationAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + EnableAutoTopicCreationOutcomeCallable enableAutoTopicCreationCallable(const Model::EnableAutoTopicCreationRequest& request) const; GetAllInstanceIdListOutcome getAllInstanceIdList(const Model::GetAllInstanceIdListRequest &request)const; void getAllInstanceIdListAsync(const Model::GetAllInstanceIdListRequest& request, const GetAllInstanceIdListAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; GetAllInstanceIdListOutcomeCallable getAllInstanceIdListCallable(const Model::GetAllInstanceIdListRequest& request) const; @@ -290,6 +331,9 @@ namespace AlibabaCloud GetTopicStatusOutcome getTopicStatus(const Model::GetTopicStatusRequest &request)const; void getTopicStatusAsync(const Model::GetTopicStatusRequest& request, const GetTopicStatusAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; GetTopicStatusOutcomeCallable getTopicStatusCallable(const Model::GetTopicStatusRequest& request) const; + GetTopicSubscribeStatusOutcome getTopicSubscribeStatus(const Model::GetTopicSubscribeStatusRequest &request)const; + void getTopicSubscribeStatusAsync(const Model::GetTopicSubscribeStatusRequest& request, const GetTopicSubscribeStatusAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + GetTopicSubscribeStatusOutcomeCallable getTopicSubscribeStatusCallable(const Model::GetTopicSubscribeStatusRequest& request) const; 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; @@ -302,12 +346,21 @@ namespace AlibabaCloud ModifyTopicRemarkOutcome modifyTopicRemark(const Model::ModifyTopicRemarkRequest &request)const; void modifyTopicRemarkAsync(const Model::ModifyTopicRemarkRequest& request, const ModifyTopicRemarkAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ModifyTopicRemarkOutcomeCallable modifyTopicRemarkCallable(const Model::ModifyTopicRemarkRequest& request) const; + QueryMessageOutcome queryMessage(const Model::QueryMessageRequest &request)const; + void queryMessageAsync(const Model::QueryMessageRequest& request, const QueryMessageAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + QueryMessageOutcomeCallable queryMessageCallable(const Model::QueryMessageRequest& request) const; ReleaseInstanceOutcome releaseInstance(const Model::ReleaseInstanceRequest &request)const; void releaseInstanceAsync(const Model::ReleaseInstanceRequest& request, const ReleaseInstanceAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ReleaseInstanceOutcomeCallable releaseInstanceCallable(const Model::ReleaseInstanceRequest& request) const; + ReopenInstanceOutcome reopenInstance(const Model::ReopenInstanceRequest &request)const; + void reopenInstanceAsync(const Model::ReopenInstanceRequest& request, const ReopenInstanceAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + ReopenInstanceOutcomeCallable reopenInstanceCallable(const Model::ReopenInstanceRequest& request) const; StartInstanceOutcome startInstance(const Model::StartInstanceRequest &request)const; void startInstanceAsync(const Model::StartInstanceRequest& request, const StartInstanceAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; StartInstanceOutcomeCallable startInstanceCallable(const Model::StartInstanceRequest& request) const; + StopInstanceOutcome stopInstance(const Model::StopInstanceRequest &request)const; + void stopInstanceAsync(const Model::StopInstanceRequest& request, const StopInstanceAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + StopInstanceOutcomeCallable stopInstanceCallable(const Model::StopInstanceRequest& request) const; 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; @@ -323,6 +376,9 @@ namespace AlibabaCloud UpdateInstanceConfigOutcome updateInstanceConfig(const Model::UpdateInstanceConfigRequest &request)const; void updateInstanceConfigAsync(const Model::UpdateInstanceConfigRequest& request, const UpdateInstanceConfigAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; UpdateInstanceConfigOutcomeCallable updateInstanceConfigCallable(const Model::UpdateInstanceConfigRequest& request) const; + UpdateTopicConfigOutcome updateTopicConfig(const Model::UpdateTopicConfigRequest &request)const; + void updateTopicConfigAsync(const Model::UpdateTopicConfigRequest& request, const UpdateTopicConfigAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + UpdateTopicConfigOutcomeCallable updateTopicConfigCallable(const Model::UpdateTopicConfigRequest& request) const; UpgradeInstanceVersionOutcome upgradeInstanceVersion(const Model::UpgradeInstanceVersionRequest &request)const; void upgradeInstanceVersionAsync(const Model::UpgradeInstanceVersionRequest& request, const UpgradeInstanceVersionAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; UpgradeInstanceVersionOutcomeCallable upgradeInstanceVersionCallable(const Model::UpgradeInstanceVersionRequest& request) const; diff --git a/alikafka/include/alibabacloud/alikafka/model/CreateAclRequest.h b/alikafka/include/alibabacloud/alikafka/model/CreateAclRequest.h index 8b2857a43..f64ef6657 100644 --- a/alikafka/include/alibabacloud/alikafka/model/CreateAclRequest.h +++ b/alikafka/include/alibabacloud/alikafka/model/CreateAclRequest.h @@ -34,6 +34,8 @@ public: void setAclResourcePatternType(const std::string &aclResourcePatternType); std::string getAclResourceType() const; void setAclResourceType(const std::string &aclResourceType); + std::string getAclOperationTypes() const; + void setAclOperationTypes(const std::string &aclOperationTypes); std::string getAclOperationType() const; void setAclOperationType(const std::string &aclOperationType); std::string getAclResourceName() const; @@ -42,16 +44,23 @@ public: void setInstanceId(const std::string &instanceId); std::string getRegionId() const; void setRegionId(const std::string ®ionId); + std::string getHost() const; + void setHost(const std::string &host); + std::string getAclPermissionType() const; + void setAclPermissionType(const std::string &aclPermissionType); std::string getUsername() const; void setUsername(const std::string &username); private: std::string aclResourcePatternType_; std::string aclResourceType_; + std::string aclOperationTypes_; std::string aclOperationType_; std::string aclResourceName_; std::string instanceId_; std::string regionId_; + std::string host_; + std::string aclPermissionType_; std::string username_; }; } // namespace Model diff --git a/alikafka/include/alibabacloud/alikafka/model/CreatePrePayOrderRequest.h b/alikafka/include/alibabacloud/alikafka/model/CreatePrePayOrderRequest.h index d8d24ebc2..97dbb3e8b 100644 --- a/alikafka/include/alibabacloud/alikafka/model/CreatePrePayOrderRequest.h +++ b/alikafka/include/alibabacloud/alikafka/model/CreatePrePayOrderRequest.h @@ -28,6 +28,26 @@ namespace Alikafka { namespace Model { class ALIBABACLOUD_ALIKAFKA_EXPORT CreatePrePayOrderRequest : public RpcServiceRequest { public: + struct ConfluentConfig { + int ksqlStorage; + int controlCenterStorage; + int kafkaRestProxyReplica; + int zooKeeperReplica; + int connectCU; + int kafkaReplica; + int schemaRegistryReplica; + int kafkaCU; + int connectReplica; + int controlCenterCU; + int ksqlReplica; + int controlCenterReplica; + int kafkaStorage; + int zooKeeperStorage; + int ksqlCU; + int schemaRegistryCU; + int zooKeeperCU; + int kafkaRestProxyCU; + }; struct Tag { std::string value; std::string key; @@ -38,16 +58,22 @@ public: void setIoMax(int ioMax); int getEipMax() const; void setEipMax(int eipMax); + int getDuration() const; + void setDuration(int duration); std::string getSpecType() const; void setSpecType(const std::string &specType); std::string getResourceGroupId() const; void setResourceGroupId(const std::string &resourceGroupId); std::string getRegionId() const; void setRegionId(const std::string ®ionId); + ConfluentConfig getConfluentConfig() const; + void setConfluentConfig(const ConfluentConfig &confluentConfig); std::vector getTag() const; void setTag(const std::vector &tag); int getPartitionNum() const; void setPartitionNum(int partitionNum); + int getPaidType() const; + void setPaidType(int paidType); int getDiskSize() const; void setDiskSize(int diskSize); std::string getIoMaxSpec() const; @@ -62,11 +88,14 @@ public: private: int ioMax_; int eipMax_; + int duration_; std::string specType_; std::string resourceGroupId_; std::string regionId_; + ConfluentConfig confluentConfig_; std::vector tag_; int partitionNum_; + int paidType_; int diskSize_; std::string ioMaxSpec_; std::string diskType_; diff --git a/alikafka/include/alibabacloud/alikafka/model/CreateSaslUserRequest.h b/alikafka/include/alibabacloud/alikafka/model/CreateSaslUserRequest.h index 771a07a00..3b982c226 100644 --- a/alikafka/include/alibabacloud/alikafka/model/CreateSaslUserRequest.h +++ b/alikafka/include/alibabacloud/alikafka/model/CreateSaslUserRequest.h @@ -38,6 +38,8 @@ public: void setInstanceId(const std::string &instanceId); std::string getRegionId() const; void setRegionId(const std::string ®ionId); + std::string getMechanism() const; + void setMechanism(const std::string &mechanism); std::string getUsername() const; void setUsername(const std::string &username); @@ -46,6 +48,7 @@ private: std::string password_; std::string instanceId_; std::string regionId_; + std::string mechanism_; std::string username_; }; } // namespace Model diff --git a/alikafka/include/alibabacloud/alikafka/model/DeleteAclRequest.h b/alikafka/include/alibabacloud/alikafka/model/DeleteAclRequest.h index 0bbc1c30d..982175deb 100644 --- a/alikafka/include/alibabacloud/alikafka/model/DeleteAclRequest.h +++ b/alikafka/include/alibabacloud/alikafka/model/DeleteAclRequest.h @@ -34,6 +34,8 @@ public: void setAclResourcePatternType(const std::string &aclResourcePatternType); std::string getAclResourceType() const; void setAclResourceType(const std::string &aclResourceType); + std::string getAclOperationTypes() const; + void setAclOperationTypes(const std::string &aclOperationTypes); std::string getAclOperationType() const; void setAclOperationType(const std::string &aclOperationType); std::string getAclResourceName() const; @@ -42,16 +44,23 @@ public: void setInstanceId(const std::string &instanceId); std::string getRegionId() const; void setRegionId(const std::string ®ionId); + std::string getHost() const; + void setHost(const std::string &host); + std::string getAclPermissionType() const; + void setAclPermissionType(const std::string &aclPermissionType); std::string getUsername() const; void setUsername(const std::string &username); private: std::string aclResourcePatternType_; std::string aclResourceType_; + std::string aclOperationTypes_; std::string aclOperationType_; std::string aclResourceName_; std::string instanceId_; std::string regionId_; + std::string host_; + std::string aclPermissionType_; std::string username_; }; } // namespace Model diff --git a/alikafka/include/alibabacloud/alikafka/model/DeleteSaslUserRequest.h b/alikafka/include/alibabacloud/alikafka/model/DeleteSaslUserRequest.h index e478dab04..f10feb227 100644 --- a/alikafka/include/alibabacloud/alikafka/model/DeleteSaslUserRequest.h +++ b/alikafka/include/alibabacloud/alikafka/model/DeleteSaslUserRequest.h @@ -36,6 +36,8 @@ public: void setInstanceId(const std::string &instanceId); std::string getRegionId() const; void setRegionId(const std::string ®ionId); + std::string getMechanism() const; + void setMechanism(const std::string &mechanism); std::string getUsername() const; void setUsername(const std::string &username); @@ -43,6 +45,7 @@ private: std::string type_; std::string instanceId_; std::string regionId_; + std::string mechanism_; std::string username_; }; } // namespace Model diff --git a/alikafka/include/alibabacloud/alikafka/model/DescribeAclsRequest.h b/alikafka/include/alibabacloud/alikafka/model/DescribeAclsRequest.h index 5d93132f1..74acfee1c 100644 --- a/alikafka/include/alibabacloud/alikafka/model/DescribeAclsRequest.h +++ b/alikafka/include/alibabacloud/alikafka/model/DescribeAclsRequest.h @@ -34,21 +34,30 @@ public: void setAclResourcePatternType(const std::string &aclResourcePatternType); std::string getAclResourceType() const; void setAclResourceType(const std::string &aclResourceType); + std::string getAclOperationType() const; + void setAclOperationType(const std::string &aclOperationType); std::string getAclResourceName() const; void setAclResourceName(const std::string &aclResourceName); std::string getInstanceId() const; void setInstanceId(const std::string &instanceId); std::string getRegionId() const; void setRegionId(const std::string ®ionId); + std::string getHost() const; + void setHost(const std::string &host); + std::string getAclPermissionType() const; + void setAclPermissionType(const std::string &aclPermissionType); std::string getUsername() const; void setUsername(const std::string &username); private: std::string aclResourcePatternType_; std::string aclResourceType_; + std::string aclOperationType_; std::string aclResourceName_; std::string instanceId_; std::string regionId_; + std::string host_; + std::string aclPermissionType_; std::string username_; }; } // namespace Model diff --git a/alikafka/include/alibabacloud/alikafka/model/DescribeAclsResult.h b/alikafka/include/alibabacloud/alikafka/model/DescribeAclsResult.h index 09293f895..38d8e1e5e 100644 --- a/alikafka/include/alibabacloud/alikafka/model/DescribeAclsResult.h +++ b/alikafka/include/alibabacloud/alikafka/model/DescribeAclsResult.h @@ -38,6 +38,7 @@ namespace AlibabaCloud std::string username; std::string aclResourceType; std::string aclOperationType; + std::string aclPermissionType; std::string host; std::string aclResourcePatternType; }; diff --git a/alikafka/include/alibabacloud/alikafka/model/DescribeSaslUsersResult.h b/alikafka/include/alibabacloud/alikafka/model/DescribeSaslUsersResult.h index 73860119f..ab58f4594 100644 --- a/alikafka/include/alibabacloud/alikafka/model/DescribeSaslUsersResult.h +++ b/alikafka/include/alibabacloud/alikafka/model/DescribeSaslUsersResult.h @@ -36,6 +36,7 @@ namespace AlibabaCloud { std::string type; std::string username; + std::string mechanism; std::string password; }; diff --git a/alikafka/include/alibabacloud/alikafka/model/EnableAutoGroupCreationRequest.h b/alikafka/include/alibabacloud/alikafka/model/EnableAutoGroupCreationRequest.h new file mode 100644 index 000000000..50886135f --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/EnableAutoGroupCreationRequest.h @@ -0,0 +1,48 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOGROUPCREATIONREQUEST_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOGROUPCREATIONREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Alikafka { +namespace Model { +class ALIBABACLOUD_ALIKAFKA_EXPORT EnableAutoGroupCreationRequest : public RpcServiceRequest { +public: + EnableAutoGroupCreationRequest(); + ~EnableAutoGroupCreationRequest(); + std::string getInstanceId() const; + void setInstanceId(const std::string &instanceId); + std::string getRegionId() const; + void setRegionId(const std::string ®ionId); + bool getEnable() const; + void setEnable(bool enable); + +private: + std::string instanceId_; + std::string regionId_; + bool enable_; +}; +} // namespace Model +} // namespace Alikafka +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOGROUPCREATIONREQUEST_H_ diff --git a/alikafka/include/alibabacloud/alikafka/model/EnableAutoGroupCreationResult.h b/alikafka/include/alibabacloud/alikafka/model/EnableAutoGroupCreationResult.h new file mode 100644 index 000000000..990f0f6ba --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/EnableAutoGroupCreationResult.h @@ -0,0 +1,55 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOGROUPCREATIONRESULT_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOGROUPCREATIONRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Alikafka + { + namespace Model + { + class ALIBABACLOUD_ALIKAFKA_EXPORT EnableAutoGroupCreationResult : public ServiceResult + { + public: + + + EnableAutoGroupCreationResult(); + explicit EnableAutoGroupCreationResult(const std::string &payload); + ~EnableAutoGroupCreationResult(); + std::string getMessage()const; + int getCode()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + std::string message_; + int code_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOGROUPCREATIONRESULT_H_ \ No newline at end of file diff --git a/alikafka/include/alibabacloud/alikafka/model/EnableAutoTopicCreationRequest.h b/alikafka/include/alibabacloud/alikafka/model/EnableAutoTopicCreationRequest.h new file mode 100644 index 000000000..d866c75c3 --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/EnableAutoTopicCreationRequest.h @@ -0,0 +1,51 @@ +/* + * 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_ALIKAFKA_MODEL_ENABLEAUTOTOPICCREATIONREQUEST_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOTOPICCREATIONREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Alikafka { +namespace Model { +class ALIBABACLOUD_ALIKAFKA_EXPORT EnableAutoTopicCreationRequest : public RpcServiceRequest { +public: + EnableAutoTopicCreationRequest(); + ~EnableAutoTopicCreationRequest(); + std::string getInstanceId() const; + void setInstanceId(const std::string &instanceId); + std::string getOperate() const; + void setOperate(const std::string &operate); + std::string getRegionId() const; + void setRegionId(const std::string ®ionId); + long getPartitionNum() const; + void setPartitionNum(long partitionNum); + +private: + std::string instanceId_; + std::string operate_; + std::string regionId_; + long partitionNum_; +}; +} // namespace Model +} // namespace Alikafka +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOTOPICCREATIONREQUEST_H_ diff --git a/alikafka/include/alibabacloud/alikafka/model/EnableAutoTopicCreationResult.h b/alikafka/include/alibabacloud/alikafka/model/EnableAutoTopicCreationResult.h new file mode 100644 index 000000000..e78c21423 --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/EnableAutoTopicCreationResult.h @@ -0,0 +1,55 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOTOPICCREATIONRESULT_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOTOPICCREATIONRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Alikafka + { + namespace Model + { + class ALIBABACLOUD_ALIKAFKA_EXPORT EnableAutoTopicCreationResult : public ServiceResult + { + public: + + + EnableAutoTopicCreationResult(); + explicit EnableAutoTopicCreationResult(const std::string &payload); + ~EnableAutoTopicCreationResult(); + std::string getMessage()const; + int getCode()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + std::string message_; + int code_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_ENABLEAUTOTOPICCREATIONRESULT_H_ \ No newline at end of file diff --git a/alikafka/include/alibabacloud/alikafka/model/GetConsumerListResult.h b/alikafka/include/alibabacloud/alikafka/model/GetConsumerListResult.h index add4ea384..0a726c77b 100644 --- a/alikafka/include/alibabacloud/alikafka/model/GetConsumerListResult.h +++ b/alikafka/include/alibabacloud/alikafka/model/GetConsumerListResult.h @@ -52,6 +52,9 @@ namespace AlibabaCloud explicit GetConsumerListResult(const std::string &payload); ~GetConsumerListResult(); std::string getMessage()const; + int getPageSize()const; + int getCurrentPage()const; + long getTotal()const; std::vector getConsumerList()const; int getCode()const; bool getSuccess()const; @@ -60,6 +63,9 @@ namespace AlibabaCloud void parse(const std::string &payload); private: std::string message_; + int pageSize_; + int currentPage_; + long total_; std::vector consumerList_; int code_; bool success_; diff --git a/alikafka/include/alibabacloud/alikafka/model/GetConsumerProgressResult.h b/alikafka/include/alibabacloud/alikafka/model/GetConsumerProgressResult.h index f8c68a1eb..fc7cc81ff 100644 --- a/alikafka/include/alibabacloud/alikafka/model/GetConsumerProgressResult.h +++ b/alikafka/include/alibabacloud/alikafka/model/GetConsumerProgressResult.h @@ -48,6 +48,16 @@ namespace AlibabaCloud long totalDiff; std::string topic; }; + struct RebalanceInfoListItem + { + bool rebalanceSuccess; + long generation; + long rebalanceTimeConsuming; + long lastRebalanceTimestamp; + std::string reason; + std::string groupId; + }; + std::vector rebalanceInfoList; long lastTimestamp; std::vector topicList; long totalDiff; diff --git a/alikafka/include/alibabacloud/alikafka/model/GetInstanceListResult.h b/alikafka/include/alibabacloud/alikafka/model/GetInstanceListResult.h index 09ca1b940..bd70cd372 100644 --- a/alikafka/include/alibabacloud/alikafka/model/GetInstanceListResult.h +++ b/alikafka/include/alibabacloud/alikafka/model/GetInstanceListResult.h @@ -38,12 +38,34 @@ namespace AlibabaCloud { std::string current2OpenSourceVersion; }; + struct ConfluentConfig + { + int ksqlStorage; + int kafkaRestProxyCU; + int zooKeeperReplica; + int kafkaReplica; + int connectReplica; + int controlCenterStorage; + int schemaRegistryCU; + int kafkaCU; + int connectCU; + int ksqlCU; + int controlCenterReplica; + int ksqlReplica; + int schemaRegistryReplica; + int zooKeeperCU; + int kafkaRestProxyReplica; + int zooKeeperStorage; + int controlCenterCU; + int kafkaStorage; + }; struct TagVO { std::string value; std::string key; }; int deployType; + int reservedPublishCapacity; std::string resourceGroupId; std::string specType; int ioMax; @@ -52,9 +74,12 @@ namespace AlibabaCloud UpgradeServiceDetailInfo upgradeServiceDetailInfo; std::string saslDomainEndpoint; std::string name; + int viewInstanceStatusCode; + ConfluentConfig confluentConfig; int diskType; std::string sslDomainEndpoint; int serviceStatus; + int reservedSubscribeCapacity; int msgRetain; long expiredTime; int diskSize; diff --git a/alikafka/include/alibabacloud/alikafka/model/GetTopicSubscribeStatusRequest.h b/alikafka/include/alibabacloud/alikafka/model/GetTopicSubscribeStatusRequest.h new file mode 100644 index 000000000..9be1bbedc --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/GetTopicSubscribeStatusRequest.h @@ -0,0 +1,48 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_GETTOPICSUBSCRIBESTATUSREQUEST_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_GETTOPICSUBSCRIBESTATUSREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Alikafka { +namespace Model { +class ALIBABACLOUD_ALIKAFKA_EXPORT GetTopicSubscribeStatusRequest : public RpcServiceRequest { +public: + GetTopicSubscribeStatusRequest(); + ~GetTopicSubscribeStatusRequest(); + std::string getInstanceId() const; + void setInstanceId(const std::string &instanceId); + std::string getRegionId() const; + void setRegionId(const std::string ®ionId); + std::string getTopic() const; + void setTopic(const std::string &topic); + +private: + std::string instanceId_; + std::string regionId_; + std::string topic_; +}; +} // namespace Model +} // namespace Alikafka +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_GETTOPICSUBSCRIBESTATUSREQUEST_H_ diff --git a/alikafka/include/alibabacloud/alikafka/model/GetTopicSubscribeStatusResult.h b/alikafka/include/alibabacloud/alikafka/model/GetTopicSubscribeStatusResult.h new file mode 100644 index 000000000..4eb4c9171 --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/GetTopicSubscribeStatusResult.h @@ -0,0 +1,62 @@ +/* + * 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_ALIKAFKA_MODEL_GETTOPICSUBSCRIBESTATUSRESULT_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_GETTOPICSUBSCRIBESTATUSRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Alikafka + { + namespace Model + { + class ALIBABACLOUD_ALIKAFKA_EXPORT GetTopicSubscribeStatusResult : public ServiceResult + { + public: + struct TopicSubscribeStatus + { + std::vector consumerGroups; + std::string topic; + }; + + + GetTopicSubscribeStatusResult(); + explicit GetTopicSubscribeStatusResult(const std::string &payload); + ~GetTopicSubscribeStatusResult(); + std::string getMessage()const; + TopicSubscribeStatus getTopicSubscribeStatus()const; + int getCode()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + std::string message_; + TopicSubscribeStatus topicSubscribeStatus_; + int code_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_GETTOPICSUBSCRIBESTATUSRESULT_H_ \ No newline at end of file diff --git a/alikafka/include/alibabacloud/alikafka/model/ModifyTopicRemarkRequest.h b/alikafka/include/alibabacloud/alikafka/model/ModifyTopicRemarkRequest.h index 3f1042ea2..dd1ee473e 100644 --- a/alikafka/include/alibabacloud/alikafka/model/ModifyTopicRemarkRequest.h +++ b/alikafka/include/alibabacloud/alikafka/model/ModifyTopicRemarkRequest.h @@ -30,20 +30,20 @@ class ALIBABACLOUD_ALIKAFKA_EXPORT ModifyTopicRemarkRequest : public RpcServiceR public: ModifyTopicRemarkRequest(); ~ModifyTopicRemarkRequest(); + std::string getRemark() const; + void setRemark(const std::string &remark); std::string getInstanceId() const; void setInstanceId(const std::string &instanceId); std::string getRegionId() const; void setRegionId(const std::string ®ionId); std::string getTopic() const; void setTopic(const std::string &topic); - std::string getRemark() const; - void setRemark(const std::string &remark); private: + std::string remark_; std::string instanceId_; std::string regionId_; std::string topic_; - std::string remark_; }; } // namespace Model } // namespace Alikafka diff --git a/alikafka/include/alibabacloud/alikafka/model/QueryMessageRequest.h b/alikafka/include/alibabacloud/alikafka/model/QueryMessageRequest.h new file mode 100644 index 000000000..f0d45da0f --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/QueryMessageRequest.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_ALIKAFKA_MODEL_QUERYMESSAGEREQUEST_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_QUERYMESSAGEREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Alikafka { +namespace Model { +class ALIBABACLOUD_ALIKAFKA_EXPORT QueryMessageRequest : public RpcServiceRequest { +public: + QueryMessageRequest(); + ~QueryMessageRequest(); + std::string getOffset() const; + void setOffset(const std::string &offset); + long getBeginTime() const; + void setBeginTime(long beginTime); + std::string getInstanceId() const; + void setInstanceId(const std::string &instanceId); + std::string getPartition() const; + void setPartition(const std::string &partition); + std::string getRegionId() const; + void setRegionId(const std::string ®ionId); + std::string getTopic() const; + void setTopic(const std::string &topic); + std::string getQueryType() const; + void setQueryType(const std::string &queryType); + +private: + std::string offset_; + long beginTime_; + std::string instanceId_; + std::string partition_; + std::string regionId_; + std::string topic_; + std::string queryType_; +}; +} // namespace Model +} // namespace Alikafka +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_QUERYMESSAGEREQUEST_H_ diff --git a/alikafka/include/alibabacloud/alikafka/model/QueryMessageResult.h b/alikafka/include/alibabacloud/alikafka/model/QueryMessageResult.h new file mode 100644 index 000000000..588c517cd --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/QueryMessageResult.h @@ -0,0 +1,74 @@ +/* + * 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_ALIKAFKA_MODEL_QUERYMESSAGERESULT_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_QUERYMESSAGERESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Alikafka + { + namespace Model + { + class ALIBABACLOUD_ALIKAFKA_EXPORT QueryMessageResult : public ServiceResult + { + public: + struct MessageVO + { + long partition; + int truncatedValueSize; + bool valueTruncated; + long timestamp; + long offset; + int truncatedKeySize; + long checksum; + int serializedValueSize; + std::string value; + std::string timestampType; + bool keyTruncated; + std::string topic; + std::string key; + int serializedKeySize; + }; + + + QueryMessageResult(); + explicit QueryMessageResult(const std::string &payload); + ~QueryMessageResult(); + std::string getMessage()const; + int getCode()const; + std::vector getMessageList()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + std::string message_; + int code_; + std::vector messageList_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_QUERYMESSAGERESULT_H_ \ No newline at end of file diff --git a/alikafka/include/alibabacloud/alikafka/model/ReopenInstanceRequest.h b/alikafka/include/alibabacloud/alikafka/model/ReopenInstanceRequest.h new file mode 100644 index 000000000..6a72cdc5f --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/ReopenInstanceRequest.h @@ -0,0 +1,45 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_REOPENINSTANCEREQUEST_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_REOPENINSTANCEREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Alikafka { +namespace Model { +class ALIBABACLOUD_ALIKAFKA_EXPORT ReopenInstanceRequest : public RpcServiceRequest { +public: + ReopenInstanceRequest(); + ~ReopenInstanceRequest(); + std::string getInstanceId() const; + void setInstanceId(const std::string &instanceId); + std::string getRegionId() const; + void setRegionId(const std::string ®ionId); + +private: + std::string instanceId_; + std::string regionId_; +}; +} // namespace Model +} // namespace Alikafka +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_REOPENINSTANCEREQUEST_H_ diff --git a/alikafka/include/alibabacloud/alikafka/model/ReopenInstanceResult.h b/alikafka/include/alibabacloud/alikafka/model/ReopenInstanceResult.h new file mode 100644 index 000000000..37f29d105 --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/ReopenInstanceResult.h @@ -0,0 +1,55 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_REOPENINSTANCERESULT_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_REOPENINSTANCERESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Alikafka + { + namespace Model + { + class ALIBABACLOUD_ALIKAFKA_EXPORT ReopenInstanceResult : public ServiceResult + { + public: + + + ReopenInstanceResult(); + explicit ReopenInstanceResult(const std::string &payload); + ~ReopenInstanceResult(); + std::string getMessage()const; + int getCode()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + std::string message_; + int code_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_REOPENINSTANCERESULT_H_ \ No newline at end of file diff --git a/alikafka/include/alibabacloud/alikafka/model/StartInstanceRequest.h b/alikafka/include/alibabacloud/alikafka/model/StartInstanceRequest.h index 62dd094d4..5ad708071 100644 --- a/alikafka/include/alibabacloud/alikafka/model/StartInstanceRequest.h +++ b/alikafka/include/alibabacloud/alikafka/model/StartInstanceRequest.h @@ -30,6 +30,8 @@ class ALIBABACLOUD_ALIKAFKA_EXPORT StartInstanceRequest : public RpcServiceReque public: StartInstanceRequest(); ~StartInstanceRequest(); + std::vector getVSwitchIds() const; + void setVSwitchIds(const std::vector &vSwitchIds); std::string getSelectedZones() const; void setSelectedZones(const std::string &selectedZones); bool getIsEipInner() const; @@ -72,6 +74,7 @@ public: void setUsername(const std::string &username); private: + std::vector vSwitchIds_; std::string selectedZones_; bool isEipInner_; std::string securityGroup_; diff --git a/alikafka/include/alibabacloud/alikafka/model/StopInstanceRequest.h b/alikafka/include/alibabacloud/alikafka/model/StopInstanceRequest.h new file mode 100644 index 000000000..2b9749397 --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/StopInstanceRequest.h @@ -0,0 +1,45 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_STOPINSTANCEREQUEST_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_STOPINSTANCEREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Alikafka { +namespace Model { +class ALIBABACLOUD_ALIKAFKA_EXPORT StopInstanceRequest : public RpcServiceRequest { +public: + StopInstanceRequest(); + ~StopInstanceRequest(); + std::string getInstanceId() const; + void setInstanceId(const std::string &instanceId); + std::string getRegionId() const; + void setRegionId(const std::string ®ionId); + +private: + std::string instanceId_; + std::string regionId_; +}; +} // namespace Model +} // namespace Alikafka +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_STOPINSTANCEREQUEST_H_ diff --git a/alikafka/include/alibabacloud/alikafka/model/StopInstanceResult.h b/alikafka/include/alibabacloud/alikafka/model/StopInstanceResult.h new file mode 100644 index 000000000..e1a28360c --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/StopInstanceResult.h @@ -0,0 +1,55 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_STOPINSTANCERESULT_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_STOPINSTANCERESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Alikafka + { + namespace Model + { + class ALIBABACLOUD_ALIKAFKA_EXPORT StopInstanceResult : public ServiceResult + { + public: + + + StopInstanceResult(); + explicit StopInstanceResult(const std::string &payload); + ~StopInstanceResult(); + std::string getMessage()const; + int getCode()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + std::string message_; + int code_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_STOPINSTANCERESULT_H_ \ No newline at end of file diff --git a/alikafka/include/alibabacloud/alikafka/model/UpdateTopicConfigRequest.h b/alikafka/include/alibabacloud/alikafka/model/UpdateTopicConfigRequest.h new file mode 100644 index 000000000..2ef802ad6 --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/UpdateTopicConfigRequest.h @@ -0,0 +1,54 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef ALIBABACLOUD_ALIKAFKA_MODEL_UPDATETOPICCONFIGREQUEST_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_UPDATETOPICCONFIGREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Alikafka { +namespace Model { +class ALIBABACLOUD_ALIKAFKA_EXPORT UpdateTopicConfigRequest : public RpcServiceRequest { +public: + UpdateTopicConfigRequest(); + ~UpdateTopicConfigRequest(); + std::string getInstanceId() const; + void setInstanceId(const std::string &instanceId); + std::string getRegionId() const; + void setRegionId(const std::string ®ionId); + std::string getTopic() const; + void setTopic(const std::string &topic); + std::string getConfig() const; + void setConfig(const std::string &config); + std::string getValue() const; + void setValue(const std::string &value); + +private: + std::string instanceId_; + std::string regionId_; + std::string topic_; + std::string config_; + std::string value_; +}; +} // namespace Model +} // namespace Alikafka +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_UPDATETOPICCONFIGREQUEST_H_ diff --git a/alikafka/include/alibabacloud/alikafka/model/UpdateTopicConfigResult.h b/alikafka/include/alibabacloud/alikafka/model/UpdateTopicConfigResult.h new file mode 100644 index 000000000..dc2b7ca20 --- /dev/null +++ b/alikafka/include/alibabacloud/alikafka/model/UpdateTopicConfigResult.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_ALIKAFKA_MODEL_UPDATETOPICCONFIGRESULT_H_ +#define ALIBABACLOUD_ALIKAFKA_MODEL_UPDATETOPICCONFIGRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Alikafka + { + namespace Model + { + class ALIBABACLOUD_ALIKAFKA_EXPORT UpdateTopicConfigResult : public ServiceResult + { + public: + + + UpdateTopicConfigResult(); + explicit UpdateTopicConfigResult(const std::string &payload); + ~UpdateTopicConfigResult(); + std::string getMessage()const; + std::string getData()const; + long getCode()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + std::string message_; + std::string data_; + long code_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_ALIKAFKA_MODEL_UPDATETOPICCONFIGRESULT_H_ \ No newline at end of file diff --git a/alikafka/include/alibabacloud/alikafka/model/UpgradePostPayOrderRequest.h b/alikafka/include/alibabacloud/alikafka/model/UpgradePostPayOrderRequest.h index bd7bc279f..0e114a465 100644 --- a/alikafka/include/alibabacloud/alikafka/model/UpgradePostPayOrderRequest.h +++ b/alikafka/include/alibabacloud/alikafka/model/UpgradePostPayOrderRequest.h @@ -28,8 +28,14 @@ namespace Alikafka { namespace Model { class ALIBABACLOUD_ALIKAFKA_EXPORT UpgradePostPayOrderRequest : public RpcServiceRequest { public: + struct ServerlessConfig { + long reservedPublishCapacity; + long reservedSubscribeCapacity; + }; UpgradePostPayOrderRequest(); ~UpgradePostPayOrderRequest(); + ServerlessConfig getServerlessConfig() const; + void setServerlessConfig(const ServerlessConfig &serverlessConfig); int getDiskSize() const; void setDiskSize(int diskSize); int getIoMax() const; @@ -52,6 +58,7 @@ public: void setPartitionNum(int partitionNum); private: + ServerlessConfig serverlessConfig_; int diskSize_; int ioMax_; bool eipModel_; diff --git a/alikafka/include/alibabacloud/alikafka/model/UpgradePrePayOrderRequest.h b/alikafka/include/alibabacloud/alikafka/model/UpgradePrePayOrderRequest.h index a05a04230..ae2d9bebf 100644 --- a/alikafka/include/alibabacloud/alikafka/model/UpgradePrePayOrderRequest.h +++ b/alikafka/include/alibabacloud/alikafka/model/UpgradePrePayOrderRequest.h @@ -28,40 +28,66 @@ namespace Alikafka { namespace Model { class ALIBABACLOUD_ALIKAFKA_EXPORT UpgradePrePayOrderRequest : public RpcServiceRequest { public: + struct ConfluentConfig { + int ksqlStorage; + int controlCenterStorage; + int kafkaRestProxyReplica; + int zooKeeperReplica; + int connectCU; + int kafkaReplica; + int schemaRegistryReplica; + int kafkaCU; + int connectReplica; + int controlCenterCU; + int ksqlReplica; + int controlCenterReplica; + int kafkaStorage; + int zooKeeperStorage; + int ksqlCU; + int schemaRegistryCU; + int zooKeeperCU; + int kafkaRestProxyCU; + }; UpgradePrePayOrderRequest(); ~UpgradePrePayOrderRequest(); - int getDiskSize() const; - void setDiskSize(int diskSize); int getIoMax() const; void setIoMax(int ioMax); bool getEipModel() const; void setEipModel(bool eipModel); - std::string getIoMaxSpec() const; - void setIoMaxSpec(const std::string &ioMaxSpec); - int getTopicQuota() const; - void setTopicQuota(int topicQuota); int getEipMax() const; void setEipMax(int eipMax); std::string getSpecType() const; void setSpecType(const std::string &specType); - std::string getInstanceId() const; - void setInstanceId(const std::string &instanceId); std::string getRegionId() const; void setRegionId(const std::string ®ionId); + ConfluentConfig getConfluentConfig() const; + void setConfluentConfig(const ConfluentConfig &confluentConfig); int getPartitionNum() const; void setPartitionNum(int partitionNum); + int getPaidType() const; + void setPaidType(int paidType); + int getDiskSize() const; + void setDiskSize(int diskSize); + std::string getIoMaxSpec() const; + void setIoMaxSpec(const std::string &ioMaxSpec); + int getTopicQuota() const; + void setTopicQuota(int topicQuota); + std::string getInstanceId() const; + void setInstanceId(const std::string &instanceId); private: - int diskSize_; int ioMax_; bool eipModel_; - std::string ioMaxSpec_; - int topicQuota_; int eipMax_; std::string specType_; - std::string instanceId_; std::string regionId_; + ConfluentConfig confluentConfig_; int partitionNum_; + int paidType_; + int diskSize_; + std::string ioMaxSpec_; + int topicQuota_; + std::string instanceId_; }; } // namespace Model } // namespace Alikafka diff --git a/alikafka/src/AlikafkaClient.cc b/alikafka/src/AlikafkaClient.cc index 2812ec81e..d2e11f286 100644 --- a/alikafka/src/AlikafkaClient.cc +++ b/alikafka/src/AlikafkaClient.cc @@ -31,21 +31,21 @@ AlikafkaClient::AlikafkaClient(const Credentials &credentials, const ClientConfi RpcServiceClient(SERVICE_NAME, std::make_shared(credentials), configuration) { auto locationClient = std::make_shared(credentials, configuration); - endpointProvider_ = std::make_shared(locationClient, configuration.regionId(), SERVICE_NAME, ""); + endpointProvider_ = std::make_shared(locationClient, configuration.regionId(), SERVICE_NAME, "alikafka"); } AlikafkaClient::AlikafkaClient(const std::shared_ptr& credentialsProvider, const ClientConfiguration & configuration) : RpcServiceClient(SERVICE_NAME, credentialsProvider, configuration) { auto locationClient = std::make_shared(credentialsProvider, configuration); - endpointProvider_ = std::make_shared(locationClient, configuration.regionId(), SERVICE_NAME, ""); + endpointProvider_ = std::make_shared(locationClient, configuration.regionId(), SERVICE_NAME, "alikafka"); } AlikafkaClient::AlikafkaClient(const std::string & accessKeyId, const std::string & accessKeySecret, const ClientConfiguration & configuration) : RpcServiceClient(SERVICE_NAME, std::make_shared(accessKeyId, accessKeySecret), configuration) { auto locationClient = std::make_shared(accessKeyId, accessKeySecret, configuration); - endpointProvider_ = std::make_shared(locationClient, configuration.regionId(), SERVICE_NAME, ""); + endpointProvider_ = std::make_shared(locationClient, configuration.regionId(), SERVICE_NAME, "alikafka"); } AlikafkaClient::~AlikafkaClient() @@ -591,6 +591,78 @@ AlikafkaClient::DescribeSaslUsersOutcomeCallable AlikafkaClient::describeSaslUse return task->get_future(); } +AlikafkaClient::EnableAutoGroupCreationOutcome AlikafkaClient::enableAutoGroupCreation(const EnableAutoGroupCreationRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return EnableAutoGroupCreationOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return EnableAutoGroupCreationOutcome(EnableAutoGroupCreationResult(outcome.result())); + else + return EnableAutoGroupCreationOutcome(outcome.error()); +} + +void AlikafkaClient::enableAutoGroupCreationAsync(const EnableAutoGroupCreationRequest& request, const EnableAutoGroupCreationAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, enableAutoGroupCreation(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +AlikafkaClient::EnableAutoGroupCreationOutcomeCallable AlikafkaClient::enableAutoGroupCreationCallable(const EnableAutoGroupCreationRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->enableAutoGroupCreation(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + +AlikafkaClient::EnableAutoTopicCreationOutcome AlikafkaClient::enableAutoTopicCreation(const EnableAutoTopicCreationRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return EnableAutoTopicCreationOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return EnableAutoTopicCreationOutcome(EnableAutoTopicCreationResult(outcome.result())); + else + return EnableAutoTopicCreationOutcome(outcome.error()); +} + +void AlikafkaClient::enableAutoTopicCreationAsync(const EnableAutoTopicCreationRequest& request, const EnableAutoTopicCreationAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, enableAutoTopicCreation(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +AlikafkaClient::EnableAutoTopicCreationOutcomeCallable AlikafkaClient::enableAutoTopicCreationCallable(const EnableAutoTopicCreationRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->enableAutoTopicCreation(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + AlikafkaClient::GetAllInstanceIdListOutcome AlikafkaClient::getAllInstanceIdList(const GetAllInstanceIdListRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -879,6 +951,42 @@ AlikafkaClient::GetTopicStatusOutcomeCallable AlikafkaClient::getTopicStatusCall return task->get_future(); } +AlikafkaClient::GetTopicSubscribeStatusOutcome AlikafkaClient::getTopicSubscribeStatus(const GetTopicSubscribeStatusRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return GetTopicSubscribeStatusOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return GetTopicSubscribeStatusOutcome(GetTopicSubscribeStatusResult(outcome.result())); + else + return GetTopicSubscribeStatusOutcome(outcome.error()); +} + +void AlikafkaClient::getTopicSubscribeStatusAsync(const GetTopicSubscribeStatusRequest& request, const GetTopicSubscribeStatusAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, getTopicSubscribeStatus(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +AlikafkaClient::GetTopicSubscribeStatusOutcomeCallable AlikafkaClient::getTopicSubscribeStatusCallable(const GetTopicSubscribeStatusRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->getTopicSubscribeStatus(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + AlikafkaClient::ListTagResourcesOutcome AlikafkaClient::listTagResources(const ListTagResourcesRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -1023,6 +1131,42 @@ AlikafkaClient::ModifyTopicRemarkOutcomeCallable AlikafkaClient::modifyTopicRema return task->get_future(); } +AlikafkaClient::QueryMessageOutcome AlikafkaClient::queryMessage(const QueryMessageRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return QueryMessageOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return QueryMessageOutcome(QueryMessageResult(outcome.result())); + else + return QueryMessageOutcome(outcome.error()); +} + +void AlikafkaClient::queryMessageAsync(const QueryMessageRequest& request, const QueryMessageAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, queryMessage(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +AlikafkaClient::QueryMessageOutcomeCallable AlikafkaClient::queryMessageCallable(const QueryMessageRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->queryMessage(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + AlikafkaClient::ReleaseInstanceOutcome AlikafkaClient::releaseInstance(const ReleaseInstanceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -1059,6 +1203,42 @@ AlikafkaClient::ReleaseInstanceOutcomeCallable AlikafkaClient::releaseInstanceCa return task->get_future(); } +AlikafkaClient::ReopenInstanceOutcome AlikafkaClient::reopenInstance(const ReopenInstanceRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return ReopenInstanceOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return ReopenInstanceOutcome(ReopenInstanceResult(outcome.result())); + else + return ReopenInstanceOutcome(outcome.error()); +} + +void AlikafkaClient::reopenInstanceAsync(const ReopenInstanceRequest& request, const ReopenInstanceAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, reopenInstance(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +AlikafkaClient::ReopenInstanceOutcomeCallable AlikafkaClient::reopenInstanceCallable(const ReopenInstanceRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->reopenInstance(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + AlikafkaClient::StartInstanceOutcome AlikafkaClient::startInstance(const StartInstanceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -1095,6 +1275,42 @@ AlikafkaClient::StartInstanceOutcomeCallable AlikafkaClient::startInstanceCallab return task->get_future(); } +AlikafkaClient::StopInstanceOutcome AlikafkaClient::stopInstance(const StopInstanceRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return StopInstanceOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return StopInstanceOutcome(StopInstanceResult(outcome.result())); + else + return StopInstanceOutcome(outcome.error()); +} + +void AlikafkaClient::stopInstanceAsync(const StopInstanceRequest& request, const StopInstanceAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, stopInstance(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +AlikafkaClient::StopInstanceOutcomeCallable AlikafkaClient::stopInstanceCallable(const StopInstanceRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->stopInstance(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + AlikafkaClient::TagResourcesOutcome AlikafkaClient::tagResources(const TagResourcesRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -1275,6 +1491,42 @@ AlikafkaClient::UpdateInstanceConfigOutcomeCallable AlikafkaClient::updateInstan return task->get_future(); } +AlikafkaClient::UpdateTopicConfigOutcome AlikafkaClient::updateTopicConfig(const UpdateTopicConfigRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return UpdateTopicConfigOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return UpdateTopicConfigOutcome(UpdateTopicConfigResult(outcome.result())); + else + return UpdateTopicConfigOutcome(outcome.error()); +} + +void AlikafkaClient::updateTopicConfigAsync(const UpdateTopicConfigRequest& request, const UpdateTopicConfigAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, updateTopicConfig(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +AlikafkaClient::UpdateTopicConfigOutcomeCallable AlikafkaClient::updateTopicConfigCallable(const UpdateTopicConfigRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->updateTopicConfig(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + AlikafkaClient::UpgradeInstanceVersionOutcome AlikafkaClient::upgradeInstanceVersion(const UpgradeInstanceVersionRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); diff --git a/alikafka/src/model/CreateAclRequest.cc b/alikafka/src/model/CreateAclRequest.cc index ebc1f22e1..37ce0179c 100644 --- a/alikafka/src/model/CreateAclRequest.cc +++ b/alikafka/src/model/CreateAclRequest.cc @@ -43,6 +43,15 @@ void CreateAclRequest::setAclResourceType(const std::string &aclResourceType) { setParameter(std::string("AclResourceType"), aclResourceType); } +std::string CreateAclRequest::getAclOperationTypes() const { + return aclOperationTypes_; +} + +void CreateAclRequest::setAclOperationTypes(const std::string &aclOperationTypes) { + aclOperationTypes_ = aclOperationTypes; + setParameter(std::string("AclOperationTypes"), aclOperationTypes); +} + std::string CreateAclRequest::getAclOperationType() const { return aclOperationType_; } @@ -79,6 +88,24 @@ void CreateAclRequest::setRegionId(const std::string ®ionId) { setParameter(std::string("RegionId"), regionId); } +std::string CreateAclRequest::getHost() const { + return host_; +} + +void CreateAclRequest::setHost(const std::string &host) { + host_ = host; + setParameter(std::string("Host"), host); +} + +std::string CreateAclRequest::getAclPermissionType() const { + return aclPermissionType_; +} + +void CreateAclRequest::setAclPermissionType(const std::string &aclPermissionType) { + aclPermissionType_ = aclPermissionType; + setParameter(std::string("AclPermissionType"), aclPermissionType); +} + std::string CreateAclRequest::getUsername() const { return username_; } diff --git a/alikafka/src/model/CreatePrePayOrderRequest.cc b/alikafka/src/model/CreatePrePayOrderRequest.cc index d62a61be1..f65da0aa7 100644 --- a/alikafka/src/model/CreatePrePayOrderRequest.cc +++ b/alikafka/src/model/CreatePrePayOrderRequest.cc @@ -43,6 +43,15 @@ void CreatePrePayOrderRequest::setEipMax(int eipMax) { setParameter(std::string("EipMax"), std::to_string(eipMax)); } +int CreatePrePayOrderRequest::getDuration() const { + return duration_; +} + +void CreatePrePayOrderRequest::setDuration(int duration) { + duration_ = duration; + setParameter(std::string("Duration"), std::to_string(duration)); +} + std::string CreatePrePayOrderRequest::getSpecType() const { return specType_; } @@ -70,6 +79,32 @@ void CreatePrePayOrderRequest::setRegionId(const std::string ®ionId) { setParameter(std::string("RegionId"), regionId); } +CreatePrePayOrderRequest::ConfluentConfig CreatePrePayOrderRequest::getConfluentConfig() const { + return confluentConfig_; +} + +void CreatePrePayOrderRequest::setConfluentConfig(const CreatePrePayOrderRequest::ConfluentConfig &confluentConfig) { + confluentConfig_ = confluentConfig; + setParameter(std::string("ConfluentConfig") + ".KsqlStorage", std::to_string(confluentConfig.ksqlStorage)); + setParameter(std::string("ConfluentConfig") + ".ControlCenterStorage", std::to_string(confluentConfig.controlCenterStorage)); + setParameter(std::string("ConfluentConfig") + ".KafkaRestProxyReplica", std::to_string(confluentConfig.kafkaRestProxyReplica)); + setParameter(std::string("ConfluentConfig") + ".ZooKeeperReplica", std::to_string(confluentConfig.zooKeeperReplica)); + setParameter(std::string("ConfluentConfig") + ".ConnectCU", std::to_string(confluentConfig.connectCU)); + setParameter(std::string("ConfluentConfig") + ".KafkaReplica", std::to_string(confluentConfig.kafkaReplica)); + setParameter(std::string("ConfluentConfig") + ".SchemaRegistryReplica", std::to_string(confluentConfig.schemaRegistryReplica)); + setParameter(std::string("ConfluentConfig") + ".KafkaCU", std::to_string(confluentConfig.kafkaCU)); + setParameter(std::string("ConfluentConfig") + ".ConnectReplica", std::to_string(confluentConfig.connectReplica)); + setParameter(std::string("ConfluentConfig") + ".ControlCenterCU", std::to_string(confluentConfig.controlCenterCU)); + setParameter(std::string("ConfluentConfig") + ".KsqlReplica", std::to_string(confluentConfig.ksqlReplica)); + setParameter(std::string("ConfluentConfig") + ".ControlCenterReplica", std::to_string(confluentConfig.controlCenterReplica)); + setParameter(std::string("ConfluentConfig") + ".KafkaStorage", std::to_string(confluentConfig.kafkaStorage)); + setParameter(std::string("ConfluentConfig") + ".ZooKeeperStorage", std::to_string(confluentConfig.zooKeeperStorage)); + setParameter(std::string("ConfluentConfig") + ".KsqlCU", std::to_string(confluentConfig.ksqlCU)); + setParameter(std::string("ConfluentConfig") + ".SchemaRegistryCU", std::to_string(confluentConfig.schemaRegistryCU)); + setParameter(std::string("ConfluentConfig") + ".ZooKeeperCU", std::to_string(confluentConfig.zooKeeperCU)); + setParameter(std::string("ConfluentConfig") + ".KafkaRestProxyCU", std::to_string(confluentConfig.kafkaRestProxyCU)); +} + std::vector CreatePrePayOrderRequest::getTag() const { return tag_; } @@ -93,6 +128,15 @@ void CreatePrePayOrderRequest::setPartitionNum(int partitionNum) { setParameter(std::string("PartitionNum"), std::to_string(partitionNum)); } +int CreatePrePayOrderRequest::getPaidType() const { + return paidType_; +} + +void CreatePrePayOrderRequest::setPaidType(int paidType) { + paidType_ = paidType; + setParameter(std::string("PaidType"), std::to_string(paidType)); +} + int CreatePrePayOrderRequest::getDiskSize() const { return diskSize_; } diff --git a/alikafka/src/model/CreateSaslUserRequest.cc b/alikafka/src/model/CreateSaslUserRequest.cc index 710e0e4d0..c704cf02f 100644 --- a/alikafka/src/model/CreateSaslUserRequest.cc +++ b/alikafka/src/model/CreateSaslUserRequest.cc @@ -61,6 +61,15 @@ void CreateSaslUserRequest::setRegionId(const std::string ®ionId) { setParameter(std::string("RegionId"), regionId); } +std::string CreateSaslUserRequest::getMechanism() const { + return mechanism_; +} + +void CreateSaslUserRequest::setMechanism(const std::string &mechanism) { + mechanism_ = mechanism; + setParameter(std::string("Mechanism"), mechanism); +} + std::string CreateSaslUserRequest::getUsername() const { return username_; } diff --git a/alikafka/src/model/DeleteAclRequest.cc b/alikafka/src/model/DeleteAclRequest.cc index 5d2fabef2..e7494e3ab 100644 --- a/alikafka/src/model/DeleteAclRequest.cc +++ b/alikafka/src/model/DeleteAclRequest.cc @@ -43,6 +43,15 @@ void DeleteAclRequest::setAclResourceType(const std::string &aclResourceType) { setParameter(std::string("AclResourceType"), aclResourceType); } +std::string DeleteAclRequest::getAclOperationTypes() const { + return aclOperationTypes_; +} + +void DeleteAclRequest::setAclOperationTypes(const std::string &aclOperationTypes) { + aclOperationTypes_ = aclOperationTypes; + setParameter(std::string("AclOperationTypes"), aclOperationTypes); +} + std::string DeleteAclRequest::getAclOperationType() const { return aclOperationType_; } @@ -79,6 +88,24 @@ void DeleteAclRequest::setRegionId(const std::string ®ionId) { setParameter(std::string("RegionId"), regionId); } +std::string DeleteAclRequest::getHost() const { + return host_; +} + +void DeleteAclRequest::setHost(const std::string &host) { + host_ = host; + setParameter(std::string("Host"), host); +} + +std::string DeleteAclRequest::getAclPermissionType() const { + return aclPermissionType_; +} + +void DeleteAclRequest::setAclPermissionType(const std::string &aclPermissionType) { + aclPermissionType_ = aclPermissionType; + setParameter(std::string("AclPermissionType"), aclPermissionType); +} + std::string DeleteAclRequest::getUsername() const { return username_; } diff --git a/alikafka/src/model/DeleteSaslUserRequest.cc b/alikafka/src/model/DeleteSaslUserRequest.cc index 2c53d85ec..64d9ef004 100644 --- a/alikafka/src/model/DeleteSaslUserRequest.cc +++ b/alikafka/src/model/DeleteSaslUserRequest.cc @@ -52,6 +52,15 @@ void DeleteSaslUserRequest::setRegionId(const std::string ®ionId) { setParameter(std::string("RegionId"), regionId); } +std::string DeleteSaslUserRequest::getMechanism() const { + return mechanism_; +} + +void DeleteSaslUserRequest::setMechanism(const std::string &mechanism) { + mechanism_ = mechanism; + setParameter(std::string("Mechanism"), mechanism); +} + std::string DeleteSaslUserRequest::getUsername() const { return username_; } diff --git a/alikafka/src/model/DescribeAclsRequest.cc b/alikafka/src/model/DescribeAclsRequest.cc index 09c69555d..2927efcea 100644 --- a/alikafka/src/model/DescribeAclsRequest.cc +++ b/alikafka/src/model/DescribeAclsRequest.cc @@ -43,6 +43,15 @@ void DescribeAclsRequest::setAclResourceType(const std::string &aclResourceType) setParameter(std::string("AclResourceType"), aclResourceType); } +std::string DescribeAclsRequest::getAclOperationType() const { + return aclOperationType_; +} + +void DescribeAclsRequest::setAclOperationType(const std::string &aclOperationType) { + aclOperationType_ = aclOperationType; + setParameter(std::string("AclOperationType"), aclOperationType); +} + std::string DescribeAclsRequest::getAclResourceName() const { return aclResourceName_; } @@ -70,6 +79,24 @@ void DescribeAclsRequest::setRegionId(const std::string ®ionId) { setParameter(std::string("RegionId"), regionId); } +std::string DescribeAclsRequest::getHost() const { + return host_; +} + +void DescribeAclsRequest::setHost(const std::string &host) { + host_ = host; + setParameter(std::string("Host"), host); +} + +std::string DescribeAclsRequest::getAclPermissionType() const { + return aclPermissionType_; +} + +void DescribeAclsRequest::setAclPermissionType(const std::string &aclPermissionType) { + aclPermissionType_ = aclPermissionType; + setParameter(std::string("AclPermissionType"), aclPermissionType); +} + std::string DescribeAclsRequest::getUsername() const { return username_; } diff --git a/alikafka/src/model/DescribeAclsResult.cc b/alikafka/src/model/DescribeAclsResult.cc index df0fb6ac9..68a56598d 100644 --- a/alikafka/src/model/DescribeAclsResult.cc +++ b/alikafka/src/model/DescribeAclsResult.cc @@ -55,6 +55,8 @@ void DescribeAclsResult::parse(const std::string &payload) kafkaAclListObject.aclResourcePatternType = valueKafkaAclListKafkaAclVO["AclResourcePatternType"].asString(); if(!valueKafkaAclListKafkaAclVO["Username"].isNull()) kafkaAclListObject.username = valueKafkaAclListKafkaAclVO["Username"].asString(); + if(!valueKafkaAclListKafkaAclVO["AclPermissionType"].isNull()) + kafkaAclListObject.aclPermissionType = valueKafkaAclListKafkaAclVO["AclPermissionType"].asString(); kafkaAclList_.push_back(kafkaAclListObject); } if(!value["Code"].isNull()) diff --git a/alikafka/src/model/DescribeSaslUsersResult.cc b/alikafka/src/model/DescribeSaslUsersResult.cc index f2259e38a..30002f900 100644 --- a/alikafka/src/model/DescribeSaslUsersResult.cc +++ b/alikafka/src/model/DescribeSaslUsersResult.cc @@ -49,6 +49,8 @@ void DescribeSaslUsersResult::parse(const std::string &payload) saslUserListObject.password = valueSaslUserListSaslUserVO["Password"].asString(); if(!valueSaslUserListSaslUserVO["Username"].isNull()) saslUserListObject.username = valueSaslUserListSaslUserVO["Username"].asString(); + if(!valueSaslUserListSaslUserVO["Mechanism"].isNull()) + saslUserListObject.mechanism = valueSaslUserListSaslUserVO["Mechanism"].asString(); saslUserList_.push_back(saslUserListObject); } if(!value["Code"].isNull()) diff --git a/alikafka/src/model/EnableAutoGroupCreationRequest.cc b/alikafka/src/model/EnableAutoGroupCreationRequest.cc new file mode 100644 index 000000000..f9b82815b --- /dev/null +++ b/alikafka/src/model/EnableAutoGroupCreationRequest.cc @@ -0,0 +1,54 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +using AlibabaCloud::Alikafka::Model::EnableAutoGroupCreationRequest; + +EnableAutoGroupCreationRequest::EnableAutoGroupCreationRequest() + : RpcServiceRequest("alikafka", "2019-09-16", "EnableAutoGroupCreation") { + setMethod(HttpRequest::Method::Post); +} + +EnableAutoGroupCreationRequest::~EnableAutoGroupCreationRequest() {} + +std::string EnableAutoGroupCreationRequest::getInstanceId() const { + return instanceId_; +} + +void EnableAutoGroupCreationRequest::setInstanceId(const std::string &instanceId) { + instanceId_ = instanceId; + setParameter(std::string("InstanceId"), instanceId); +} + +std::string EnableAutoGroupCreationRequest::getRegionId() const { + return regionId_; +} + +void EnableAutoGroupCreationRequest::setRegionId(const std::string ®ionId) { + regionId_ = regionId; + setParameter(std::string("RegionId"), regionId); +} + +bool EnableAutoGroupCreationRequest::getEnable() const { + return enable_; +} + +void EnableAutoGroupCreationRequest::setEnable(bool enable) { + enable_ = enable; + setParameter(std::string("Enable"), enable ? "true" : "false"); +} + diff --git a/alikafka/src/model/EnableAutoGroupCreationResult.cc b/alikafka/src/model/EnableAutoGroupCreationResult.cc new file mode 100644 index 000000000..82871d36e --- /dev/null +++ b/alikafka/src/model/EnableAutoGroupCreationResult.cc @@ -0,0 +1,65 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include +#include + +using namespace AlibabaCloud::Alikafka; +using namespace AlibabaCloud::Alikafka::Model; + +EnableAutoGroupCreationResult::EnableAutoGroupCreationResult() : + ServiceResult() +{} + +EnableAutoGroupCreationResult::EnableAutoGroupCreationResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +EnableAutoGroupCreationResult::~EnableAutoGroupCreationResult() +{} + +void EnableAutoGroupCreationResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["Code"].isNull()) + code_ = std::stoi(value["Code"].asString()); + if(!value["Message"].isNull()) + message_ = value["Message"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + +} + +std::string EnableAutoGroupCreationResult::getMessage()const +{ + return message_; +} + +int EnableAutoGroupCreationResult::getCode()const +{ + return code_; +} + +bool EnableAutoGroupCreationResult::getSuccess()const +{ + return success_; +} + diff --git a/alikafka/src/model/EnableAutoTopicCreationRequest.cc b/alikafka/src/model/EnableAutoTopicCreationRequest.cc new file mode 100644 index 000000000..f9ae52579 --- /dev/null +++ b/alikafka/src/model/EnableAutoTopicCreationRequest.cc @@ -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. + */ + +#include + +using AlibabaCloud::Alikafka::Model::EnableAutoTopicCreationRequest; + +EnableAutoTopicCreationRequest::EnableAutoTopicCreationRequest() + : RpcServiceRequest("alikafka", "2019-09-16", "EnableAutoTopicCreation") { + setMethod(HttpRequest::Method::Post); +} + +EnableAutoTopicCreationRequest::~EnableAutoTopicCreationRequest() {} + +std::string EnableAutoTopicCreationRequest::getInstanceId() const { + return instanceId_; +} + +void EnableAutoTopicCreationRequest::setInstanceId(const std::string &instanceId) { + instanceId_ = instanceId; + setParameter(std::string("InstanceId"), instanceId); +} + +std::string EnableAutoTopicCreationRequest::getOperate() const { + return operate_; +} + +void EnableAutoTopicCreationRequest::setOperate(const std::string &operate) { + operate_ = operate; + setParameter(std::string("Operate"), operate); +} + +std::string EnableAutoTopicCreationRequest::getRegionId() const { + return regionId_; +} + +void EnableAutoTopicCreationRequest::setRegionId(const std::string ®ionId) { + regionId_ = regionId; + setParameter(std::string("RegionId"), regionId); +} + +long EnableAutoTopicCreationRequest::getPartitionNum() const { + return partitionNum_; +} + +void EnableAutoTopicCreationRequest::setPartitionNum(long partitionNum) { + partitionNum_ = partitionNum; + setParameter(std::string("PartitionNum"), std::to_string(partitionNum)); +} + diff --git a/alikafka/src/model/EnableAutoTopicCreationResult.cc b/alikafka/src/model/EnableAutoTopicCreationResult.cc new file mode 100644 index 000000000..a3c204ead --- /dev/null +++ b/alikafka/src/model/EnableAutoTopicCreationResult.cc @@ -0,0 +1,65 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include +#include + +using namespace AlibabaCloud::Alikafka; +using namespace AlibabaCloud::Alikafka::Model; + +EnableAutoTopicCreationResult::EnableAutoTopicCreationResult() : + ServiceResult() +{} + +EnableAutoTopicCreationResult::EnableAutoTopicCreationResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +EnableAutoTopicCreationResult::~EnableAutoTopicCreationResult() +{} + +void EnableAutoTopicCreationResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["Code"].isNull()) + code_ = std::stoi(value["Code"].asString()); + if(!value["Message"].isNull()) + message_ = value["Message"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + +} + +std::string EnableAutoTopicCreationResult::getMessage()const +{ + return message_; +} + +int EnableAutoTopicCreationResult::getCode()const +{ + return code_; +} + +bool EnableAutoTopicCreationResult::getSuccess()const +{ + return success_; +} + diff --git a/alikafka/src/model/GetConsumerListResult.cc b/alikafka/src/model/GetConsumerListResult.cc index 30e71bd50..2ab39c7f6 100644 --- a/alikafka/src/model/GetConsumerListResult.cc +++ b/alikafka/src/model/GetConsumerListResult.cc @@ -71,6 +71,12 @@ void GetConsumerListResult::parse(const std::string &payload) message_ = value["Message"].asString(); if(!value["Success"].isNull()) success_ = value["Success"].asString() == "true"; + if(!value["Total"].isNull()) + total_ = std::stol(value["Total"].asString()); + if(!value["PageSize"].isNull()) + pageSize_ = std::stoi(value["PageSize"].asString()); + if(!value["CurrentPage"].isNull()) + currentPage_ = std::stoi(value["CurrentPage"].asString()); } @@ -79,6 +85,21 @@ std::string GetConsumerListResult::getMessage()const return message_; } +int GetConsumerListResult::getPageSize()const +{ + return pageSize_; +} + +int GetConsumerListResult::getCurrentPage()const +{ + return currentPage_; +} + +long GetConsumerListResult::getTotal()const +{ + return total_; +} + std::vector GetConsumerListResult::getConsumerList()const { return consumerList_; diff --git a/alikafka/src/model/GetConsumerProgressResult.cc b/alikafka/src/model/GetConsumerProgressResult.cc index ff5f150db..b1e558e17 100644 --- a/alikafka/src/model/GetConsumerProgressResult.cc +++ b/alikafka/src/model/GetConsumerProgressResult.cc @@ -70,6 +70,24 @@ void GetConsumerProgressResult::parse(const std::string &payload) } consumerProgress_.topicList.push_back(topicListItemObject); } + auto allRebalanceInfoListNode = consumerProgressNode["RebalanceInfoList"]["RebalanceInfoListItem"]; + for (auto consumerProgressNodeRebalanceInfoListRebalanceInfoListItem : allRebalanceInfoListNode) + { + ConsumerProgress::RebalanceInfoListItem rebalanceInfoListItemObject; + if(!consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["Generation"].isNull()) + rebalanceInfoListItemObject.generation = std::stol(consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["Generation"].asString()); + if(!consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["LastRebalanceTimestamp"].isNull()) + rebalanceInfoListItemObject.lastRebalanceTimestamp = std::stol(consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["LastRebalanceTimestamp"].asString()); + if(!consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["Reason"].isNull()) + rebalanceInfoListItemObject.reason = consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["Reason"].asString(); + if(!consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["GroupId"].isNull()) + rebalanceInfoListItemObject.groupId = consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["GroupId"].asString(); + if(!consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["RebalanceTimeConsuming"].isNull()) + rebalanceInfoListItemObject.rebalanceTimeConsuming = std::stol(consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["RebalanceTimeConsuming"].asString()); + if(!consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["RebalanceSuccess"].isNull()) + rebalanceInfoListItemObject.rebalanceSuccess = consumerProgressNodeRebalanceInfoListRebalanceInfoListItem["RebalanceSuccess"].asString() == "true"; + consumerProgress_.rebalanceInfoList.push_back(rebalanceInfoListItemObject); + } if(!value["Code"].isNull()) code_ = std::stoi(value["Code"].asString()); if(!value["Message"].isNull()) diff --git a/alikafka/src/model/GetInstanceListResult.cc b/alikafka/src/model/GetInstanceListResult.cc index 37ef3223d..327c11a02 100644 --- a/alikafka/src/model/GetInstanceListResult.cc +++ b/alikafka/src/model/GetInstanceListResult.cc @@ -107,6 +107,12 @@ void GetInstanceListResult::parse(const std::string &payload) instanceListObject.standardZoneId = valueInstanceListInstanceVO["StandardZoneId"].asString(); if(!valueInstanceListInstanceVO["IoMaxSpec"].isNull()) instanceListObject.ioMaxSpec = valueInstanceListInstanceVO["IoMaxSpec"].asString(); + if(!valueInstanceListInstanceVO["ReservedPublishCapacity"].isNull()) + instanceListObject.reservedPublishCapacity = std::stoi(valueInstanceListInstanceVO["ReservedPublishCapacity"].asString()); + if(!valueInstanceListInstanceVO["ReservedSubscribeCapacity"].isNull()) + instanceListObject.reservedSubscribeCapacity = std::stoi(valueInstanceListInstanceVO["ReservedSubscribeCapacity"].asString()); + if(!valueInstanceListInstanceVO["ViewInstanceStatusCode"].isNull()) + instanceListObject.viewInstanceStatusCode = std::stoi(valueInstanceListInstanceVO["ViewInstanceStatusCode"].asString()); auto allTagsNode = valueInstanceListInstanceVO["Tags"]["TagVO"]; for (auto valueInstanceListInstanceVOTagsTagVO : allTagsNode) { @@ -120,6 +126,43 @@ void GetInstanceListResult::parse(const std::string &payload) auto upgradeServiceDetailInfoNode = value["UpgradeServiceDetailInfo"]; if(!upgradeServiceDetailInfoNode["Current2OpenSourceVersion"].isNull()) instanceListObject.upgradeServiceDetailInfo.current2OpenSourceVersion = upgradeServiceDetailInfoNode["Current2OpenSourceVersion"].asString(); + auto confluentConfigNode = value["ConfluentConfig"]; + if(!confluentConfigNode["KafkaCU"].isNull()) + instanceListObject.confluentConfig.kafkaCU = std::stoi(confluentConfigNode["KafkaCU"].asString()); + if(!confluentConfigNode["KafkaStorage"].isNull()) + instanceListObject.confluentConfig.kafkaStorage = std::stoi(confluentConfigNode["KafkaStorage"].asString()); + if(!confluentConfigNode["KafkaReplica"].isNull()) + instanceListObject.confluentConfig.kafkaReplica = std::stoi(confluentConfigNode["KafkaReplica"].asString()); + if(!confluentConfigNode["ZooKeeperCU"].isNull()) + instanceListObject.confluentConfig.zooKeeperCU = std::stoi(confluentConfigNode["ZooKeeperCU"].asString()); + if(!confluentConfigNode["ZooKeeperStorage"].isNull()) + instanceListObject.confluentConfig.zooKeeperStorage = std::stoi(confluentConfigNode["ZooKeeperStorage"].asString()); + if(!confluentConfigNode["ZooKeeperReplica"].isNull()) + instanceListObject.confluentConfig.zooKeeperReplica = std::stoi(confluentConfigNode["ZooKeeperReplica"].asString()); + if(!confluentConfigNode["ControlCenterCU"].isNull()) + instanceListObject.confluentConfig.controlCenterCU = std::stoi(confluentConfigNode["ControlCenterCU"].asString()); + if(!confluentConfigNode["ControlCenterStorage"].isNull()) + instanceListObject.confluentConfig.controlCenterStorage = std::stoi(confluentConfigNode["ControlCenterStorage"].asString()); + if(!confluentConfigNode["ControlCenterReplica"].isNull()) + instanceListObject.confluentConfig.controlCenterReplica = std::stoi(confluentConfigNode["ControlCenterReplica"].asString()); + if(!confluentConfigNode["SchemaRegistryCU"].isNull()) + instanceListObject.confluentConfig.schemaRegistryCU = std::stoi(confluentConfigNode["SchemaRegistryCU"].asString()); + if(!confluentConfigNode["SchemaRegistryReplica"].isNull()) + instanceListObject.confluentConfig.schemaRegistryReplica = std::stoi(confluentConfigNode["SchemaRegistryReplica"].asString()); + if(!confluentConfigNode["ConnectCU"].isNull()) + instanceListObject.confluentConfig.connectCU = std::stoi(confluentConfigNode["ConnectCU"].asString()); + if(!confluentConfigNode["ConnectReplica"].isNull()) + instanceListObject.confluentConfig.connectReplica = std::stoi(confluentConfigNode["ConnectReplica"].asString()); + if(!confluentConfigNode["KsqlCU"].isNull()) + instanceListObject.confluentConfig.ksqlCU = std::stoi(confluentConfigNode["KsqlCU"].asString()); + if(!confluentConfigNode["KsqlStorage"].isNull()) + instanceListObject.confluentConfig.ksqlStorage = std::stoi(confluentConfigNode["KsqlStorage"].asString()); + if(!confluentConfigNode["KsqlReplica"].isNull()) + instanceListObject.confluentConfig.ksqlReplica = std::stoi(confluentConfigNode["KsqlReplica"].asString()); + if(!confluentConfigNode["KafkaRestProxyCU"].isNull()) + instanceListObject.confluentConfig.kafkaRestProxyCU = std::stoi(confluentConfigNode["KafkaRestProxyCU"].asString()); + if(!confluentConfigNode["KafkaRestProxyReplica"].isNull()) + instanceListObject.confluentConfig.kafkaRestProxyReplica = std::stoi(confluentConfigNode["KafkaRestProxyReplica"].asString()); instanceList_.push_back(instanceListObject); } if(!value["Code"].isNull()) diff --git a/alikafka/src/model/GetTopicSubscribeStatusRequest.cc b/alikafka/src/model/GetTopicSubscribeStatusRequest.cc new file mode 100644 index 000000000..3a421f2b9 --- /dev/null +++ b/alikafka/src/model/GetTopicSubscribeStatusRequest.cc @@ -0,0 +1,54 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +using AlibabaCloud::Alikafka::Model::GetTopicSubscribeStatusRequest; + +GetTopicSubscribeStatusRequest::GetTopicSubscribeStatusRequest() + : RpcServiceRequest("alikafka", "2019-09-16", "GetTopicSubscribeStatus") { + setMethod(HttpRequest::Method::Post); +} + +GetTopicSubscribeStatusRequest::~GetTopicSubscribeStatusRequest() {} + +std::string GetTopicSubscribeStatusRequest::getInstanceId() const { + return instanceId_; +} + +void GetTopicSubscribeStatusRequest::setInstanceId(const std::string &instanceId) { + instanceId_ = instanceId; + setParameter(std::string("InstanceId"), instanceId); +} + +std::string GetTopicSubscribeStatusRequest::getRegionId() const { + return regionId_; +} + +void GetTopicSubscribeStatusRequest::setRegionId(const std::string ®ionId) { + regionId_ = regionId; + setParameter(std::string("RegionId"), regionId); +} + +std::string GetTopicSubscribeStatusRequest::getTopic() const { + return topic_; +} + +void GetTopicSubscribeStatusRequest::setTopic(const std::string &topic) { + topic_ = topic; + setParameter(std::string("Topic"), topic); +} + diff --git a/alikafka/src/model/GetTopicSubscribeStatusResult.cc b/alikafka/src/model/GetTopicSubscribeStatusResult.cc new file mode 100644 index 000000000..2e8f2dc29 --- /dev/null +++ b/alikafka/src/model/GetTopicSubscribeStatusResult.cc @@ -0,0 +1,76 @@ +/* + * 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::Alikafka; +using namespace AlibabaCloud::Alikafka::Model; + +GetTopicSubscribeStatusResult::GetTopicSubscribeStatusResult() : + ServiceResult() +{} + +GetTopicSubscribeStatusResult::GetTopicSubscribeStatusResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +GetTopicSubscribeStatusResult::~GetTopicSubscribeStatusResult() +{} + +void GetTopicSubscribeStatusResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + auto topicSubscribeStatusNode = value["TopicSubscribeStatus"]; + if(!topicSubscribeStatusNode["Topic"].isNull()) + topicSubscribeStatus_.topic = topicSubscribeStatusNode["Topic"].asString(); + auto allConsumerGroups = topicSubscribeStatusNode["ConsumerGroups"]["ConsumerGroups"]; + for (auto value : allConsumerGroups) + topicSubscribeStatus_.consumerGroups.push_back(value.asString()); + if(!value["Code"].isNull()) + code_ = std::stoi(value["Code"].asString()); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + if(!value["Message"].isNull()) + message_ = value["Message"].asString(); + +} + +std::string GetTopicSubscribeStatusResult::getMessage()const +{ + return message_; +} + +GetTopicSubscribeStatusResult::TopicSubscribeStatus GetTopicSubscribeStatusResult::getTopicSubscribeStatus()const +{ + return topicSubscribeStatus_; +} + +int GetTopicSubscribeStatusResult::getCode()const +{ + return code_; +} + +bool GetTopicSubscribeStatusResult::getSuccess()const +{ + return success_; +} + diff --git a/alikafka/src/model/ModifyTopicRemarkRequest.cc b/alikafka/src/model/ModifyTopicRemarkRequest.cc index ad13ba891..8a263f585 100644 --- a/alikafka/src/model/ModifyTopicRemarkRequest.cc +++ b/alikafka/src/model/ModifyTopicRemarkRequest.cc @@ -25,6 +25,15 @@ ModifyTopicRemarkRequest::ModifyTopicRemarkRequest() ModifyTopicRemarkRequest::~ModifyTopicRemarkRequest() {} +std::string ModifyTopicRemarkRequest::getRemark() const { + return remark_; +} + +void ModifyTopicRemarkRequest::setRemark(const std::string &remark) { + remark_ = remark; + setParameter(std::string("Remark"), remark); +} + std::string ModifyTopicRemarkRequest::getInstanceId() const { return instanceId_; } @@ -52,12 +61,3 @@ void ModifyTopicRemarkRequest::setTopic(const std::string &topic) { setParameter(std::string("Topic"), topic); } -std::string ModifyTopicRemarkRequest::getRemark() const { - return remark_; -} - -void ModifyTopicRemarkRequest::setRemark(const std::string &remark) { - remark_ = remark; - setParameter(std::string("Remark"), remark); -} - diff --git a/alikafka/src/model/QueryMessageRequest.cc b/alikafka/src/model/QueryMessageRequest.cc new file mode 100644 index 000000000..8088e3bd1 --- /dev/null +++ b/alikafka/src/model/QueryMessageRequest.cc @@ -0,0 +1,90 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +using AlibabaCloud::Alikafka::Model::QueryMessageRequest; + +QueryMessageRequest::QueryMessageRequest() + : RpcServiceRequest("alikafka", "2019-09-16", "QueryMessage") { + setMethod(HttpRequest::Method::Get); +} + +QueryMessageRequest::~QueryMessageRequest() {} + +std::string QueryMessageRequest::getOffset() const { + return offset_; +} + +void QueryMessageRequest::setOffset(const std::string &offset) { + offset_ = offset; + setParameter(std::string("Offset"), offset); +} + +long QueryMessageRequest::getBeginTime() const { + return beginTime_; +} + +void QueryMessageRequest::setBeginTime(long beginTime) { + beginTime_ = beginTime; + setParameter(std::string("BeginTime"), std::to_string(beginTime)); +} + +std::string QueryMessageRequest::getInstanceId() const { + return instanceId_; +} + +void QueryMessageRequest::setInstanceId(const std::string &instanceId) { + instanceId_ = instanceId; + setParameter(std::string("InstanceId"), instanceId); +} + +std::string QueryMessageRequest::getPartition() const { + return partition_; +} + +void QueryMessageRequest::setPartition(const std::string &partition) { + partition_ = partition; + setParameter(std::string("Partition"), partition); +} + +std::string QueryMessageRequest::getRegionId() const { + return regionId_; +} + +void QueryMessageRequest::setRegionId(const std::string ®ionId) { + regionId_ = regionId; + setParameter(std::string("RegionId"), regionId); +} + +std::string QueryMessageRequest::getTopic() const { + return topic_; +} + +void QueryMessageRequest::setTopic(const std::string &topic) { + topic_ = topic; + setParameter(std::string("Topic"), topic); +} + +std::string QueryMessageRequest::getQueryType() const { + return queryType_; +} + +void QueryMessageRequest::setQueryType(const std::string &queryType) { + queryType_ = queryType; + setParameter(std::string("QueryType"), queryType); +} + diff --git a/alikafka/src/model/QueryMessageResult.cc b/alikafka/src/model/QueryMessageResult.cc new file mode 100644 index 000000000..6bc693cfe --- /dev/null +++ b/alikafka/src/model/QueryMessageResult.cc @@ -0,0 +1,104 @@ +/* + * 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::Alikafka; +using namespace AlibabaCloud::Alikafka::Model; + +QueryMessageResult::QueryMessageResult() : + ServiceResult() +{} + +QueryMessageResult::QueryMessageResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +QueryMessageResult::~QueryMessageResult() +{} + +void QueryMessageResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + auto allMessageListNode = value["MessageList"]["MessageVO"]; + for (auto valueMessageListMessageVO : allMessageListNode) + { + MessageVO messageListObject; + if(!valueMessageListMessageVO["Topic"].isNull()) + messageListObject.topic = valueMessageListMessageVO["Topic"].asString(); + if(!valueMessageListMessageVO["Partition"].isNull()) + messageListObject.partition = std::stol(valueMessageListMessageVO["Partition"].asString()); + if(!valueMessageListMessageVO["Offset"].isNull()) + messageListObject.offset = std::stol(valueMessageListMessageVO["Offset"].asString()); + if(!valueMessageListMessageVO["Timestamp"].isNull()) + messageListObject.timestamp = std::stol(valueMessageListMessageVO["Timestamp"].asString()); + if(!valueMessageListMessageVO["TimestampType"].isNull()) + messageListObject.timestampType = valueMessageListMessageVO["TimestampType"].asString(); + if(!valueMessageListMessageVO["Checksum"].isNull()) + messageListObject.checksum = std::stol(valueMessageListMessageVO["Checksum"].asString()); + if(!valueMessageListMessageVO["SerializedKeySize"].isNull()) + messageListObject.serializedKeySize = std::stoi(valueMessageListMessageVO["SerializedKeySize"].asString()); + if(!valueMessageListMessageVO["SerializedValueSize"].isNull()) + messageListObject.serializedValueSize = std::stoi(valueMessageListMessageVO["SerializedValueSize"].asString()); + if(!valueMessageListMessageVO["Key"].isNull()) + messageListObject.key = valueMessageListMessageVO["Key"].asString(); + if(!valueMessageListMessageVO["Value"].isNull()) + messageListObject.value = valueMessageListMessageVO["Value"].asString(); + if(!valueMessageListMessageVO["KeyTruncated"].isNull()) + messageListObject.keyTruncated = valueMessageListMessageVO["KeyTruncated"].asString() == "true"; + if(!valueMessageListMessageVO["ValueTruncated"].isNull()) + messageListObject.valueTruncated = valueMessageListMessageVO["ValueTruncated"].asString() == "true"; + if(!valueMessageListMessageVO["TruncatedKeySize"].isNull()) + messageListObject.truncatedKeySize = std::stoi(valueMessageListMessageVO["TruncatedKeySize"].asString()); + if(!valueMessageListMessageVO["TruncatedValueSize"].isNull()) + messageListObject.truncatedValueSize = std::stoi(valueMessageListMessageVO["TruncatedValueSize"].asString()); + messageList_.push_back(messageListObject); + } + if(!value["Code"].isNull()) + code_ = std::stoi(value["Code"].asString()); + if(!value["Message"].isNull()) + message_ = value["Message"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + +} + +std::string QueryMessageResult::getMessage()const +{ + return message_; +} + +int QueryMessageResult::getCode()const +{ + return code_; +} + +std::vector QueryMessageResult::getMessageList()const +{ + return messageList_; +} + +bool QueryMessageResult::getSuccess()const +{ + return success_; +} + diff --git a/alikafka/src/model/ReopenInstanceRequest.cc b/alikafka/src/model/ReopenInstanceRequest.cc new file mode 100644 index 000000000..92fb31f45 --- /dev/null +++ b/alikafka/src/model/ReopenInstanceRequest.cc @@ -0,0 +1,45 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +using AlibabaCloud::Alikafka::Model::ReopenInstanceRequest; + +ReopenInstanceRequest::ReopenInstanceRequest() + : RpcServiceRequest("alikafka", "2019-09-16", "ReopenInstance") { + setMethod(HttpRequest::Method::Post); +} + +ReopenInstanceRequest::~ReopenInstanceRequest() {} + +std::string ReopenInstanceRequest::getInstanceId() const { + return instanceId_; +} + +void ReopenInstanceRequest::setInstanceId(const std::string &instanceId) { + instanceId_ = instanceId; + setParameter(std::string("InstanceId"), instanceId); +} + +std::string ReopenInstanceRequest::getRegionId() const { + return regionId_; +} + +void ReopenInstanceRequest::setRegionId(const std::string ®ionId) { + regionId_ = regionId; + setParameter(std::string("RegionId"), regionId); +} + diff --git a/alikafka/src/model/ReopenInstanceResult.cc b/alikafka/src/model/ReopenInstanceResult.cc new file mode 100644 index 000000000..1ad2903dd --- /dev/null +++ b/alikafka/src/model/ReopenInstanceResult.cc @@ -0,0 +1,65 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include +#include + +using namespace AlibabaCloud::Alikafka; +using namespace AlibabaCloud::Alikafka::Model; + +ReopenInstanceResult::ReopenInstanceResult() : + ServiceResult() +{} + +ReopenInstanceResult::ReopenInstanceResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +ReopenInstanceResult::~ReopenInstanceResult() +{} + +void ReopenInstanceResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["Code"].isNull()) + code_ = std::stoi(value["Code"].asString()); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + if(!value["Message"].isNull()) + message_ = value["Message"].asString(); + +} + +std::string ReopenInstanceResult::getMessage()const +{ + return message_; +} + +int ReopenInstanceResult::getCode()const +{ + return code_; +} + +bool ReopenInstanceResult::getSuccess()const +{ + return success_; +} + diff --git a/alikafka/src/model/StartInstanceRequest.cc b/alikafka/src/model/StartInstanceRequest.cc index ff54674db..db52953dc 100644 --- a/alikafka/src/model/StartInstanceRequest.cc +++ b/alikafka/src/model/StartInstanceRequest.cc @@ -25,6 +25,14 @@ StartInstanceRequest::StartInstanceRequest() StartInstanceRequest::~StartInstanceRequest() {} +std::vector StartInstanceRequest::getVSwitchIds() const { + return vSwitchIds_; +} + +void StartInstanceRequest::setVSwitchIds(const std::vector &vSwitchIds) { + vSwitchIds_ = vSwitchIds; +} + std::string StartInstanceRequest::getSelectedZones() const { return selectedZones_; } diff --git a/alikafka/src/model/StopInstanceRequest.cc b/alikafka/src/model/StopInstanceRequest.cc new file mode 100644 index 000000000..63882d36f --- /dev/null +++ b/alikafka/src/model/StopInstanceRequest.cc @@ -0,0 +1,45 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +using AlibabaCloud::Alikafka::Model::StopInstanceRequest; + +StopInstanceRequest::StopInstanceRequest() + : RpcServiceRequest("alikafka", "2019-09-16", "StopInstance") { + setMethod(HttpRequest::Method::Post); +} + +StopInstanceRequest::~StopInstanceRequest() {} + +std::string StopInstanceRequest::getInstanceId() const { + return instanceId_; +} + +void StopInstanceRequest::setInstanceId(const std::string &instanceId) { + instanceId_ = instanceId; + setParameter(std::string("InstanceId"), instanceId); +} + +std::string StopInstanceRequest::getRegionId() const { + return regionId_; +} + +void StopInstanceRequest::setRegionId(const std::string ®ionId) { + regionId_ = regionId; + setParameter(std::string("RegionId"), regionId); +} + diff --git a/alikafka/src/model/StopInstanceResult.cc b/alikafka/src/model/StopInstanceResult.cc new file mode 100644 index 000000000..cfe39f63b --- /dev/null +++ b/alikafka/src/model/StopInstanceResult.cc @@ -0,0 +1,65 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include +#include + +using namespace AlibabaCloud::Alikafka; +using namespace AlibabaCloud::Alikafka::Model; + +StopInstanceResult::StopInstanceResult() : + ServiceResult() +{} + +StopInstanceResult::StopInstanceResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +StopInstanceResult::~StopInstanceResult() +{} + +void StopInstanceResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["Code"].isNull()) + code_ = std::stoi(value["Code"].asString()); + if(!value["Message"].isNull()) + message_ = value["Message"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + +} + +std::string StopInstanceResult::getMessage()const +{ + return message_; +} + +int StopInstanceResult::getCode()const +{ + return code_; +} + +bool StopInstanceResult::getSuccess()const +{ + return success_; +} + diff --git a/alikafka/src/model/UpdateTopicConfigRequest.cc b/alikafka/src/model/UpdateTopicConfigRequest.cc new file mode 100644 index 000000000..234504309 --- /dev/null +++ b/alikafka/src/model/UpdateTopicConfigRequest.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 + +using AlibabaCloud::Alikafka::Model::UpdateTopicConfigRequest; + +UpdateTopicConfigRequest::UpdateTopicConfigRequest() + : RpcServiceRequest("alikafka", "2019-09-16", "UpdateTopicConfig") { + setMethod(HttpRequest::Method::Post); +} + +UpdateTopicConfigRequest::~UpdateTopicConfigRequest() {} + +std::string UpdateTopicConfigRequest::getInstanceId() const { + return instanceId_; +} + +void UpdateTopicConfigRequest::setInstanceId(const std::string &instanceId) { + instanceId_ = instanceId; + setParameter(std::string("InstanceId"), instanceId); +} + +std::string UpdateTopicConfigRequest::getRegionId() const { + return regionId_; +} + +void UpdateTopicConfigRequest::setRegionId(const std::string ®ionId) { + regionId_ = regionId; + setParameter(std::string("RegionId"), regionId); +} + +std::string UpdateTopicConfigRequest::getTopic() const { + return topic_; +} + +void UpdateTopicConfigRequest::setTopic(const std::string &topic) { + topic_ = topic; + setParameter(std::string("Topic"), topic); +} + +std::string UpdateTopicConfigRequest::getConfig() const { + return config_; +} + +void UpdateTopicConfigRequest::setConfig(const std::string &config) { + config_ = config; + setParameter(std::string("Config"), config); +} + +std::string UpdateTopicConfigRequest::getValue() const { + return value_; +} + +void UpdateTopicConfigRequest::setValue(const std::string &value) { + value_ = value; + setParameter(std::string("Value"), value); +} + diff --git a/alikafka/src/model/UpdateTopicConfigResult.cc b/alikafka/src/model/UpdateTopicConfigResult.cc new file mode 100644 index 000000000..632e03814 --- /dev/null +++ b/alikafka/src/model/UpdateTopicConfigResult.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::Alikafka; +using namespace AlibabaCloud::Alikafka::Model; + +UpdateTopicConfigResult::UpdateTopicConfigResult() : + ServiceResult() +{} + +UpdateTopicConfigResult::UpdateTopicConfigResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +UpdateTopicConfigResult::~UpdateTopicConfigResult() +{} + +void UpdateTopicConfigResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + if(!value["Code"].isNull()) + code_ = std::stol(value["Code"].asString()); + if(!value["Message"].isNull()) + message_ = value["Message"].asString(); + if(!value["Data"].isNull()) + data_ = value["Data"].asString(); + +} + +std::string UpdateTopicConfigResult::getMessage()const +{ + return message_; +} + +std::string UpdateTopicConfigResult::getData()const +{ + return data_; +} + +long UpdateTopicConfigResult::getCode()const +{ + return code_; +} + +bool UpdateTopicConfigResult::getSuccess()const +{ + return success_; +} + diff --git a/alikafka/src/model/UpgradePostPayOrderRequest.cc b/alikafka/src/model/UpgradePostPayOrderRequest.cc index 41180a160..1ed51e40c 100644 --- a/alikafka/src/model/UpgradePostPayOrderRequest.cc +++ b/alikafka/src/model/UpgradePostPayOrderRequest.cc @@ -25,6 +25,16 @@ UpgradePostPayOrderRequest::UpgradePostPayOrderRequest() UpgradePostPayOrderRequest::~UpgradePostPayOrderRequest() {} +UpgradePostPayOrderRequest::ServerlessConfig UpgradePostPayOrderRequest::getServerlessConfig() const { + return serverlessConfig_; +} + +void UpgradePostPayOrderRequest::setServerlessConfig(const UpgradePostPayOrderRequest::ServerlessConfig &serverlessConfig) { + serverlessConfig_ = serverlessConfig; + setParameter(std::string("ServerlessConfig") + ".ReservedPublishCapacity", std::to_string(serverlessConfig.reservedPublishCapacity)); + setParameter(std::string("ServerlessConfig") + ".ReservedSubscribeCapacity", std::to_string(serverlessConfig.reservedSubscribeCapacity)); +} + int UpgradePostPayOrderRequest::getDiskSize() const { return diskSize_; } diff --git a/alikafka/src/model/UpgradePrePayOrderRequest.cc b/alikafka/src/model/UpgradePrePayOrderRequest.cc index 81fa4e7fc..9e2e146f5 100644 --- a/alikafka/src/model/UpgradePrePayOrderRequest.cc +++ b/alikafka/src/model/UpgradePrePayOrderRequest.cc @@ -25,15 +25,6 @@ UpgradePrePayOrderRequest::UpgradePrePayOrderRequest() UpgradePrePayOrderRequest::~UpgradePrePayOrderRequest() {} -int UpgradePrePayOrderRequest::getDiskSize() const { - return diskSize_; -} - -void UpgradePrePayOrderRequest::setDiskSize(int diskSize) { - diskSize_ = diskSize; - setParameter(std::string("DiskSize"), std::to_string(diskSize)); -} - int UpgradePrePayOrderRequest::getIoMax() const { return ioMax_; } @@ -52,24 +43,6 @@ void UpgradePrePayOrderRequest::setEipModel(bool eipModel) { setParameter(std::string("EipModel"), eipModel ? "true" : "false"); } -std::string UpgradePrePayOrderRequest::getIoMaxSpec() const { - return ioMaxSpec_; -} - -void UpgradePrePayOrderRequest::setIoMaxSpec(const std::string &ioMaxSpec) { - ioMaxSpec_ = ioMaxSpec; - setParameter(std::string("IoMaxSpec"), ioMaxSpec); -} - -int UpgradePrePayOrderRequest::getTopicQuota() const { - return topicQuota_; -} - -void UpgradePrePayOrderRequest::setTopicQuota(int topicQuota) { - topicQuota_ = topicQuota; - setParameter(std::string("TopicQuota"), std::to_string(topicQuota)); -} - int UpgradePrePayOrderRequest::getEipMax() const { return eipMax_; } @@ -88,15 +61,6 @@ void UpgradePrePayOrderRequest::setSpecType(const std::string &specType) { setParameter(std::string("SpecType"), specType); } -std::string UpgradePrePayOrderRequest::getInstanceId() const { - return instanceId_; -} - -void UpgradePrePayOrderRequest::setInstanceId(const std::string &instanceId) { - instanceId_ = instanceId; - setParameter(std::string("InstanceId"), instanceId); -} - std::string UpgradePrePayOrderRequest::getRegionId() const { return regionId_; } @@ -106,6 +70,32 @@ void UpgradePrePayOrderRequest::setRegionId(const std::string ®ionId) { setParameter(std::string("RegionId"), regionId); } +UpgradePrePayOrderRequest::ConfluentConfig UpgradePrePayOrderRequest::getConfluentConfig() const { + return confluentConfig_; +} + +void UpgradePrePayOrderRequest::setConfluentConfig(const UpgradePrePayOrderRequest::ConfluentConfig &confluentConfig) { + confluentConfig_ = confluentConfig; + setParameter(std::string("ConfluentConfig") + ".KsqlStorage", std::to_string(confluentConfig.ksqlStorage)); + setParameter(std::string("ConfluentConfig") + ".ControlCenterStorage", std::to_string(confluentConfig.controlCenterStorage)); + setParameter(std::string("ConfluentConfig") + ".KafkaRestProxyReplica", std::to_string(confluentConfig.kafkaRestProxyReplica)); + setParameter(std::string("ConfluentConfig") + ".ZooKeeperReplica", std::to_string(confluentConfig.zooKeeperReplica)); + setParameter(std::string("ConfluentConfig") + ".ConnectCU", std::to_string(confluentConfig.connectCU)); + setParameter(std::string("ConfluentConfig") + ".KafkaReplica", std::to_string(confluentConfig.kafkaReplica)); + setParameter(std::string("ConfluentConfig") + ".SchemaRegistryReplica", std::to_string(confluentConfig.schemaRegistryReplica)); + setParameter(std::string("ConfluentConfig") + ".KafkaCU", std::to_string(confluentConfig.kafkaCU)); + setParameter(std::string("ConfluentConfig") + ".ConnectReplica", std::to_string(confluentConfig.connectReplica)); + setParameter(std::string("ConfluentConfig") + ".ControlCenterCU", std::to_string(confluentConfig.controlCenterCU)); + setParameter(std::string("ConfluentConfig") + ".KsqlReplica", std::to_string(confluentConfig.ksqlReplica)); + setParameter(std::string("ConfluentConfig") + ".ControlCenterReplica", std::to_string(confluentConfig.controlCenterReplica)); + setParameter(std::string("ConfluentConfig") + ".KafkaStorage", std::to_string(confluentConfig.kafkaStorage)); + setParameter(std::string("ConfluentConfig") + ".ZooKeeperStorage", std::to_string(confluentConfig.zooKeeperStorage)); + setParameter(std::string("ConfluentConfig") + ".KsqlCU", std::to_string(confluentConfig.ksqlCU)); + setParameter(std::string("ConfluentConfig") + ".SchemaRegistryCU", std::to_string(confluentConfig.schemaRegistryCU)); + setParameter(std::string("ConfluentConfig") + ".ZooKeeperCU", std::to_string(confluentConfig.zooKeeperCU)); + setParameter(std::string("ConfluentConfig") + ".KafkaRestProxyCU", std::to_string(confluentConfig.kafkaRestProxyCU)); +} + int UpgradePrePayOrderRequest::getPartitionNum() const { return partitionNum_; } @@ -115,3 +105,48 @@ void UpgradePrePayOrderRequest::setPartitionNum(int partitionNum) { setParameter(std::string("PartitionNum"), std::to_string(partitionNum)); } +int UpgradePrePayOrderRequest::getPaidType() const { + return paidType_; +} + +void UpgradePrePayOrderRequest::setPaidType(int paidType) { + paidType_ = paidType; + setParameter(std::string("PaidType"), std::to_string(paidType)); +} + +int UpgradePrePayOrderRequest::getDiskSize() const { + return diskSize_; +} + +void UpgradePrePayOrderRequest::setDiskSize(int diskSize) { + diskSize_ = diskSize; + setParameter(std::string("DiskSize"), std::to_string(diskSize)); +} + +std::string UpgradePrePayOrderRequest::getIoMaxSpec() const { + return ioMaxSpec_; +} + +void UpgradePrePayOrderRequest::setIoMaxSpec(const std::string &ioMaxSpec) { + ioMaxSpec_ = ioMaxSpec; + setParameter(std::string("IoMaxSpec"), ioMaxSpec); +} + +int UpgradePrePayOrderRequest::getTopicQuota() const { + return topicQuota_; +} + +void UpgradePrePayOrderRequest::setTopicQuota(int topicQuota) { + topicQuota_ = topicQuota; + setParameter(std::string("TopicQuota"), std::to_string(topicQuota)); +} + +std::string UpgradePrePayOrderRequest::getInstanceId() const { + return instanceId_; +} + +void UpgradePrePayOrderRequest::setInstanceId(const std::string &instanceId) { + instanceId_ = instanceId; + setParameter(std::string("InstanceId"), instanceId); +} +