Fixed bugs for ListUserDefinedEventSources
This commit is contained in:
@@ -435,6 +435,7 @@ public:
|
||||
struct Source {
|
||||
struct SourceMQTTParameters {
|
||||
std::string instanceId;
|
||||
std::string bodyDataType;
|
||||
std::string regionId;
|
||||
std::string topic;
|
||||
};
|
||||
@@ -493,6 +494,7 @@ public:
|
||||
std::string regionId;
|
||||
std::string vSwitchIds;
|
||||
std::string vpcId;
|
||||
std::string valueDataType;
|
||||
std::string securityGroupId;
|
||||
std::string topic;
|
||||
std::string offsetReset;
|
||||
|
||||
@@ -76,6 +76,7 @@ namespace AlibabaCloud
|
||||
std::string vSwitchIds;
|
||||
std::string network;
|
||||
std::string securityGroupId;
|
||||
std::string valueDataType;
|
||||
std::string regionId;
|
||||
std::string topic;
|
||||
std::string consumerGroup;
|
||||
|
||||
@@ -123,7 +123,7 @@ namespace AlibabaCloud
|
||||
};
|
||||
std::string nextToken;
|
||||
std::vector<EventSourceListItem> eventSourceList;
|
||||
float total;
|
||||
int total;
|
||||
};
|
||||
|
||||
|
||||
|
||||
@@ -397,6 +397,7 @@ public:
|
||||
std::string regionId;
|
||||
std::string vSwitchIds;
|
||||
std::string vpcId;
|
||||
std::string valueDataType;
|
||||
std::string securityGroupId;
|
||||
std::string topic;
|
||||
std::string offsetReset;
|
||||
|
||||
@@ -255,6 +255,7 @@ CreateEventStreamingRequest::Source CreateEventStreamingRequest::getSource() con
|
||||
void CreateEventStreamingRequest::setSource(const CreateEventStreamingRequest::Source &source) {
|
||||
source_ = source;
|
||||
setBodyParameter(std::string("Source") + ".SourceMQTTParameters.InstanceId", source.sourceMQTTParameters.instanceId);
|
||||
setBodyParameter(std::string("Source") + ".SourceMQTTParameters.BodyDataType", source.sourceMQTTParameters.bodyDataType);
|
||||
setBodyParameter(std::string("Source") + ".SourceMQTTParameters.RegionId", source.sourceMQTTParameters.regionId);
|
||||
setBodyParameter(std::string("Source") + ".SourceMQTTParameters.Topic", source.sourceMQTTParameters.topic);
|
||||
setBodyParameter(std::string("Source") + ".SourceRocketMQParameters.FilterSql", source.sourceRocketMQParameters.filterSql);
|
||||
@@ -298,6 +299,7 @@ void CreateEventStreamingRequest::setSource(const CreateEventStreamingRequest::S
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.RegionId", source.sourceKafkaParameters.regionId);
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.VSwitchIds", source.sourceKafkaParameters.vSwitchIds);
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.VpcId", source.sourceKafkaParameters.vpcId);
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.ValueDataType", source.sourceKafkaParameters.valueDataType);
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.SecurityGroupId", source.sourceKafkaParameters.securityGroupId);
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.Topic", source.sourceKafkaParameters.topic);
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.OffsetReset", source.sourceKafkaParameters.offsetReset);
|
||||
|
||||
@@ -127,6 +127,8 @@ void GetEventStreamingResult::parse(const std::string &payload)
|
||||
data_.source.sourceKafkaParameters.vSwitchIds = sourceKafkaParametersNode["VSwitchIds"].asString();
|
||||
if(!sourceKafkaParametersNode["SecurityGroupId"].isNull())
|
||||
data_.source.sourceKafkaParameters.securityGroupId = sourceKafkaParametersNode["SecurityGroupId"].asString();
|
||||
if(!sourceKafkaParametersNode["ValueDataType"].isNull())
|
||||
data_.source.sourceKafkaParameters.valueDataType = sourceKafkaParametersNode["ValueDataType"].asString();
|
||||
auto sourceMQTTParametersNode = sourceNode["SourceMQTTParameters"];
|
||||
if(!sourceMQTTParametersNode["RegionId"].isNull())
|
||||
data_.source.sourceMQTTParameters.regionId = sourceMQTTParametersNode["RegionId"].asString();
|
||||
|
||||
@@ -43,7 +43,7 @@ void ListUserDefinedEventSourcesResult::parse(const std::string &payload)
|
||||
if(!dataNode["NextToken"].isNull())
|
||||
data_.nextToken = dataNode["NextToken"].asString();
|
||||
if(!dataNode["Total"].isNull())
|
||||
data_.total = std::stof(dataNode["Total"].asString());
|
||||
data_.total = std::stoi(dataNode["Total"].asString());
|
||||
auto allEventSourceListNode = dataNode["EventSourceList"]["eventSourceListItem"];
|
||||
for (auto dataNodeEventSourceListeventSourceListItem : allEventSourceListNode)
|
||||
{
|
||||
|
||||
@@ -247,6 +247,7 @@ void UpdateEventStreamingRequest::setSource(const UpdateEventStreamingRequest::S
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.RegionId", source.sourceKafkaParameters.regionId);
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.VSwitchIds", source.sourceKafkaParameters.vSwitchIds);
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.VpcId", source.sourceKafkaParameters.vpcId);
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.ValueDataType", source.sourceKafkaParameters.valueDataType);
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.SecurityGroupId", source.sourceKafkaParameters.securityGroupId);
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.Topic", source.sourceKafkaParameters.topic);
|
||||
setBodyParameter(std::string("Source") + ".SourceKafkaParameters.OffsetReset", source.sourceKafkaParameters.offsetReset);
|
||||
|
||||
Reference in New Issue
Block a user