Support collect logs to kafka.

This commit is contained in:
sdk-team
2022-03-15 06:26:55 +00:00
parent b3e7020b42
commit 40ea7cd46c
18 changed files with 428 additions and 307 deletions

View File

@@ -94,6 +94,17 @@ void CreateApplicationRequest::setEnvs(const std::string& envs)
setParameter("Envs", envs);
}
std::string CreateApplicationRequest::getKafkaInstanceId()const
{
return kafkaInstanceId_;
}
void CreateApplicationRequest::setKafkaInstanceId(const std::string& kafkaInstanceId)
{
kafkaInstanceId_ = kafkaInstanceId;
setParameter("KafkaInstanceId", kafkaInstanceId);
}
std::string CreateApplicationRequest::getPhpPECLExtensions()const
{
return phpPECLExtensions_;
@@ -193,6 +204,17 @@ void CreateApplicationRequest::setOssMountDescs(const std::string& ossMountDescs
setBodyParameter("OssMountDescs", ossMountDescs);
}
std::string CreateApplicationRequest::getKafkaEndpoint()const
{
return kafkaEndpoint_;
}
void CreateApplicationRequest::setKafkaEndpoint(const std::string& kafkaEndpoint)
{
kafkaEndpoint_ = kafkaEndpoint;
setParameter("KafkaEndpoint", kafkaEndpoint);
}
std::string CreateApplicationRequest::getPreStop()const
{
return preStop_;
@@ -303,6 +325,17 @@ void CreateApplicationRequest::setSlsConfigs(const std::string& slsConfigs)
setParameter("SlsConfigs", slsConfigs);
}
bool CreateApplicationRequest::getOpenCollectToKafka()const
{
return openCollectToKafka_;
}
void CreateApplicationRequest::setOpenCollectToKafka(bool openCollectToKafka)
{
openCollectToKafka_ = openCollectToKafka;
setParameter("OpenCollectToKafka", openCollectToKafka ? "true" : "false");
}
std::string CreateApplicationRequest::getCommandArgs()const
{
return commandArgs_;
@@ -512,6 +545,17 @@ void CreateApplicationRequest::setAppDescription(const std::string& appDescripti
setParameter("AppDescription", appDescription);
}
std::string CreateApplicationRequest::getKafkaLogfileConfig()const
{
return kafkaLogfileConfig_;
}
void CreateApplicationRequest::setKafkaLogfileConfig(const std::string& kafkaLogfileConfig)
{
kafkaLogfileConfig_ = kafkaLogfileConfig;
setParameter("KafkaLogfileConfig", kafkaLogfileConfig);
}
std::string CreateApplicationRequest::getAcrInstanceId()const
{
return acrInstanceId_;

View File

@@ -39,17 +39,6 @@ void DeployApplicationRequest::setNasId(const std::string& nasId)
setParameter("NasId", nasId);
}
std::string DeployApplicationRequest::getWebContainer()const
{
return webContainer_;
}
void DeployApplicationRequest::setWebContainer(const std::string& webContainer)
{
webContainer_ = webContainer;
setParameter("WebContainer", webContainer);
}
std::string DeployApplicationRequest::getJarStartArgs()const
{
return jarStartArgs_;
@@ -61,6 +50,237 @@ void DeployApplicationRequest::setJarStartArgs(const std::string& jarStartArgs)
setParameter("JarStartArgs", jarStartArgs);
}
std::string DeployApplicationRequest::getOssAkSecret()const
{
return ossAkSecret_;
}
void DeployApplicationRequest::setOssAkSecret(const std::string& ossAkSecret)
{
ossAkSecret_ = ossAkSecret;
setBodyParameter("OssAkSecret", ossAkSecret);
}
std::string DeployApplicationRequest::getMountHost()const
{
return mountHost_;
}
void DeployApplicationRequest::setMountHost(const std::string& mountHost)
{
mountHost_ = mountHost;
setParameter("MountHost", mountHost);
}
int DeployApplicationRequest::getBatchWaitTime()const
{
return batchWaitTime_;
}
void DeployApplicationRequest::setBatchWaitTime(int batchWaitTime)
{
batchWaitTime_ = batchWaitTime;
setParameter("BatchWaitTime", std::to_string(batchWaitTime));
}
std::string DeployApplicationRequest::getEnvs()const
{
return envs_;
}
void DeployApplicationRequest::setEnvs(const std::string& envs)
{
envs_ = envs;
setParameter("Envs", envs);
}
std::string DeployApplicationRequest::getKafkaInstanceId()const
{
return kafkaInstanceId_;
}
void DeployApplicationRequest::setKafkaInstanceId(const std::string& kafkaInstanceId)
{
kafkaInstanceId_ = kafkaInstanceId;
setParameter("KafkaInstanceId", kafkaInstanceId);
}
std::string DeployApplicationRequest::getPhpPECLExtensions()const
{
return phpPECLExtensions_;
}
void DeployApplicationRequest::setPhpPECLExtensions(const std::string& phpPECLExtensions)
{
phpPECLExtensions_ = phpPECLExtensions;
setBodyParameter("PhpPECLExtensions", phpPECLExtensions);
}
std::string DeployApplicationRequest::getPhpArmsConfigLocation()const
{
return phpArmsConfigLocation_;
}
void DeployApplicationRequest::setPhpArmsConfigLocation(const std::string& phpArmsConfigLocation)
{
phpArmsConfigLocation_ = phpArmsConfigLocation;
setParameter("PhpArmsConfigLocation", phpArmsConfigLocation);
}
std::string DeployApplicationRequest::getCustomHostAlias()const
{
return customHostAlias_;
}
void DeployApplicationRequest::setCustomHostAlias(const std::string& customHostAlias)
{
customHostAlias_ = customHostAlias;
setParameter("CustomHostAlias", customHostAlias);
}
std::string DeployApplicationRequest::getJarStartOptions()const
{
return jarStartOptions_;
}
void DeployApplicationRequest::setJarStartOptions(const std::string& jarStartOptions)
{
jarStartOptions_ = jarStartOptions;
setParameter("JarStartOptions", jarStartOptions);
}
std::string DeployApplicationRequest::getConfigMapMountDesc()const
{
return configMapMountDesc_;
}
void DeployApplicationRequest::setConfigMapMountDesc(const std::string& configMapMountDesc)
{
configMapMountDesc_ = configMapMountDesc;
setBodyParameter("ConfigMapMountDesc", configMapMountDesc);
}
std::string DeployApplicationRequest::getOssMountDescs()const
{
return ossMountDescs_;
}
void DeployApplicationRequest::setOssMountDescs(const std::string& ossMountDescs)
{
ossMountDescs_ = ossMountDescs;
setBodyParameter("OssMountDescs", ossMountDescs);
}
std::string DeployApplicationRequest::getKafkaEndpoint()const
{
return kafkaEndpoint_;
}
void DeployApplicationRequest::setKafkaEndpoint(const std::string& kafkaEndpoint)
{
kafkaEndpoint_ = kafkaEndpoint;
setParameter("KafkaEndpoint", kafkaEndpoint);
}
std::string DeployApplicationRequest::getPreStop()const
{
return preStop_;
}
void DeployApplicationRequest::setPreStop(const std::string& preStop)
{
preStop_ = preStop;
setParameter("PreStop", preStop);
}
std::string DeployApplicationRequest::getUpdateStrategy()const
{
return updateStrategy_;
}
void DeployApplicationRequest::setUpdateStrategy(const std::string& updateStrategy)
{
updateStrategy_ = updateStrategy;
setParameter("UpdateStrategy", updateStrategy);
}
std::string DeployApplicationRequest::getChangeOrderDesc()const
{
return changeOrderDesc_;
}
void DeployApplicationRequest::setChangeOrderDesc(const std::string& changeOrderDesc)
{
changeOrderDesc_ = changeOrderDesc;
setParameter("ChangeOrderDesc", changeOrderDesc);
}
int DeployApplicationRequest::getMinReadyInstanceRatio()const
{
return minReadyInstanceRatio_;
}
void DeployApplicationRequest::setMinReadyInstanceRatio(int minReadyInstanceRatio)
{
minReadyInstanceRatio_ = minReadyInstanceRatio;
setParameter("MinReadyInstanceRatio", std::to_string(minReadyInstanceRatio));
}
bool DeployApplicationRequest::getAutoEnableApplicationScalingRule()const
{
return autoEnableApplicationScalingRule_;
}
void DeployApplicationRequest::setAutoEnableApplicationScalingRule(bool autoEnableApplicationScalingRule)
{
autoEnableApplicationScalingRule_ = autoEnableApplicationScalingRule;
setParameter("AutoEnableApplicationScalingRule", autoEnableApplicationScalingRule ? "true" : "false");
}
std::string DeployApplicationRequest::getPostStart()const
{
return postStart_;
}
void DeployApplicationRequest::setPostStart(const std::string& postStart)
{
postStart_ = postStart;
setParameter("PostStart", postStart);
}
std::string DeployApplicationRequest::getPhpExtensions()const
{
return phpExtensions_;
}
void DeployApplicationRequest::setPhpExtensions(const std::string& phpExtensions)
{
phpExtensions_ = phpExtensions;
setBodyParameter("PhpExtensions", phpExtensions);
}
bool DeployApplicationRequest::getAssociateEip()const
{
return associateEip_;
}
void DeployApplicationRequest::setAssociateEip(bool associateEip)
{
associateEip_ = associateEip;
setBodyParameter("AssociateEip", associateEip ? "true" : "false");
}
std::string DeployApplicationRequest::getWebContainer()const
{
return webContainer_;
}
void DeployApplicationRequest::setWebContainer(const std::string& webContainer)
{
webContainer_ = webContainer;
setParameter("WebContainer", webContainer);
}
std::string DeployApplicationRequest::getEnableAhas()const
{
return enableAhas_;
@@ -83,15 +303,15 @@ void DeployApplicationRequest::setSlsConfigs(const std::string& slsConfigs)
setParameter("SlsConfigs", slsConfigs);
}
std::string DeployApplicationRequest::getOssAkSecret()const
bool DeployApplicationRequest::getOpenCollectToKafka()const
{
return ossAkSecret_;
return openCollectToKafka_;
}
void DeployApplicationRequest::setOssAkSecret(const std::string& ossAkSecret)
void DeployApplicationRequest::setOpenCollectToKafka(bool openCollectToKafka)
{
ossAkSecret_ = ossAkSecret;
setBodyParameter("OssAkSecret", ossAkSecret);
openCollectToKafka_ = openCollectToKafka;
setParameter("OpenCollectToKafka", openCollectToKafka ? "true" : "false");
}
std::string DeployApplicationRequest::getCommandArgs()const
@@ -138,28 +358,6 @@ void DeployApplicationRequest::setTimezone(const std::string& timezone)
setParameter("Timezone", timezone);
}
std::string DeployApplicationRequest::getMountHost()const
{
return mountHost_;
}
void DeployApplicationRequest::setMountHost(const std::string& mountHost)
{
mountHost_ = mountHost;
setParameter("MountHost", mountHost);
}
int DeployApplicationRequest::getBatchWaitTime()const
{
return batchWaitTime_;
}
void DeployApplicationRequest::setBatchWaitTime(int batchWaitTime)
{
batchWaitTime_ = batchWaitTime;
setParameter("BatchWaitTime", std::to_string(batchWaitTime));
}
std::string DeployApplicationRequest::getOssAkId()const
{
return ossAkId_;
@@ -182,39 +380,6 @@ void DeployApplicationRequest::setLiveness(const std::string& liveness)
setParameter("Liveness", liveness);
}
std::string DeployApplicationRequest::getEnvs()const
{
return envs_;
}
void DeployApplicationRequest::setEnvs(const std::string& envs)
{
envs_ = envs;
setParameter("Envs", envs);
}
std::string DeployApplicationRequest::getPhpPECLExtensions()const
{
return phpPECLExtensions_;
}
void DeployApplicationRequest::setPhpPECLExtensions(const std::string& phpPECLExtensions)
{
phpPECLExtensions_ = phpPECLExtensions;
setBodyParameter("PhpPECLExtensions", phpPECLExtensions);
}
std::string DeployApplicationRequest::getPhpArmsConfigLocation()const
{
return phpArmsConfigLocation_;
}
void DeployApplicationRequest::setPhpArmsConfigLocation(const std::string& phpArmsConfigLocation)
{
phpArmsConfigLocation_ = phpArmsConfigLocation;
setParameter("PhpArmsConfigLocation", phpArmsConfigLocation);
}
std::string DeployApplicationRequest::getPackageVersion()const
{
return packageVersion_;
@@ -237,17 +402,6 @@ void DeployApplicationRequest::setTomcatConfig(const std::string& tomcatConfig)
setParameter("TomcatConfig", tomcatConfig);
}
std::string DeployApplicationRequest::getCustomHostAlias()const
{
return customHostAlias_;
}
void DeployApplicationRequest::setCustomHostAlias(const std::string& customHostAlias)
{
customHostAlias_ = customHostAlias;
setParameter("CustomHostAlias", customHostAlias);
}
std::string DeployApplicationRequest::getWarStartOptions()const
{
return warStartOptions_;
@@ -259,17 +413,6 @@ void DeployApplicationRequest::setWarStartOptions(const std::string& warStartOpt
setParameter("WarStartOptions", warStartOptions);
}
std::string DeployApplicationRequest::getJarStartOptions()const
{
return jarStartOptions_;
}
void DeployApplicationRequest::setJarStartOptions(const std::string& jarStartOptions)
{
jarStartOptions_ = jarStartOptions;
setParameter("JarStartOptions", jarStartOptions);
}
std::string DeployApplicationRequest::getEdasContainerVersion()const
{
return edasContainerVersion_;
@@ -303,28 +446,6 @@ void DeployApplicationRequest::setTerminationGracePeriodSeconds(int terminationG
setParameter("TerminationGracePeriodSeconds", std::to_string(terminationGracePeriodSeconds));
}
std::string DeployApplicationRequest::getConfigMapMountDesc()const
{
return configMapMountDesc_;
}
void DeployApplicationRequest::setConfigMapMountDesc(const std::string& configMapMountDesc)
{
configMapMountDesc_ = configMapMountDesc;
setBodyParameter("ConfigMapMountDesc", configMapMountDesc);
}
std::string DeployApplicationRequest::getOssMountDescs()const
{
return ossMountDescs_;
}
void DeployApplicationRequest::setOssMountDescs(const std::string& ossMountDescs)
{
ossMountDescs_ = ossMountDescs;
setBodyParameter("OssMountDescs", ossMountDescs);
}
std::string DeployApplicationRequest::getPhpConfig()const
{
return phpConfig_;
@@ -336,17 +457,6 @@ void DeployApplicationRequest::setPhpConfig(const std::string& phpConfig)
setBodyParameter("PhpConfig", phpConfig);
}
std::string DeployApplicationRequest::getPreStop()const
{
return preStop_;
}
void DeployApplicationRequest::setPreStop(const std::string& preStop)
{
preStop_ = preStop;
setParameter("PreStop", preStop);
}
bool DeployApplicationRequest::getEnableGreyTagRoute()const
{
return enableGreyTagRoute_;
@@ -369,17 +479,6 @@ void DeployApplicationRequest::setCommand(const std::string& command)
setParameter("Command", command);
}
std::string DeployApplicationRequest::getUpdateStrategy()const
{
return updateStrategy_;
}
void DeployApplicationRequest::setUpdateStrategy(const std::string& updateStrategy)
{
updateStrategy_ = updateStrategy;
setParameter("UpdateStrategy", updateStrategy);
}
std::string DeployApplicationRequest::getMountDesc()const
{
return mountDesc_;
@@ -413,15 +512,15 @@ void DeployApplicationRequest::setMinReadyInstances(int minReadyInstances)
setParameter("MinReadyInstances", std::to_string(minReadyInstances));
}
std::string DeployApplicationRequest::getChangeOrderDesc()const
std::string DeployApplicationRequest::getKafkaLogfileConfig()const
{
return changeOrderDesc_;
return kafkaLogfileConfig_;
}
void DeployApplicationRequest::setChangeOrderDesc(const std::string& changeOrderDesc)
void DeployApplicationRequest::setKafkaLogfileConfig(const std::string& kafkaLogfileConfig)
{
changeOrderDesc_ = changeOrderDesc;
setParameter("ChangeOrderDesc", changeOrderDesc);
kafkaLogfileConfig_ = kafkaLogfileConfig;
setParameter("KafkaLogfileConfig", kafkaLogfileConfig);
}
std::string DeployApplicationRequest::getAcrInstanceId()const
@@ -457,17 +556,6 @@ void DeployApplicationRequest::setImageUrl(const std::string& imageUrl)
setParameter("ImageUrl", imageUrl);
}
int DeployApplicationRequest::getMinReadyInstanceRatio()const
{
return minReadyInstanceRatio_;
}
void DeployApplicationRequest::setMinReadyInstanceRatio(int minReadyInstanceRatio)
{
minReadyInstanceRatio_ = minReadyInstanceRatio;
setParameter("MinReadyInstanceRatio", std::to_string(minReadyInstanceRatio));
}
std::string DeployApplicationRequest::getPhp()const
{
return php_;
@@ -479,17 +567,6 @@ void DeployApplicationRequest::setPhp(const std::string& php)
setBodyParameter("Php", php);
}
bool DeployApplicationRequest::getAutoEnableApplicationScalingRule()const
{
return autoEnableApplicationScalingRule_;
}
void DeployApplicationRequest::setAutoEnableApplicationScalingRule(bool autoEnableApplicationScalingRule)
{
autoEnableApplicationScalingRule_ = autoEnableApplicationScalingRule;
setParameter("AutoEnableApplicationScalingRule", autoEnableApplicationScalingRule ? "true" : "false");
}
std::string DeployApplicationRequest::getPhpConfigLocation()const
{
return phpConfigLocation_;
@@ -501,36 +578,3 @@ void DeployApplicationRequest::setPhpConfigLocation(const std::string& phpConfig
setParameter("PhpConfigLocation", phpConfigLocation);
}
std::string DeployApplicationRequest::getPostStart()const
{
return postStart_;
}
void DeployApplicationRequest::setPostStart(const std::string& postStart)
{
postStart_ = postStart;
setParameter("PostStart", postStart);
}
std::string DeployApplicationRequest::getPhpExtensions()const
{
return phpExtensions_;
}
void DeployApplicationRequest::setPhpExtensions(const std::string& phpExtensions)
{
phpExtensions_ = phpExtensions;
setBodyParameter("PhpExtensions", phpExtensions);
}
bool DeployApplicationRequest::getAssociateEip()const
{
return associateEip_;
}
void DeployApplicationRequest::setAssociateEip(bool associateEip)
{
associateEip_ = associateEip;
setBodyParameter("AssociateEip", associateEip ? "true" : "false");
}

View File

@@ -146,6 +146,8 @@ void DescribeApplicationConfigResult::parse(const std::string &payload)
data_.acrAssumeRoleArn = dataNode["AcrAssumeRoleArn"].asString();
if(!dataNode["AssociateEip"].isNull())
data_.associateEip = dataNode["AssociateEip"].asString() == "true";
if(!dataNode["KafkaConfigs"].isNull())
data_.kafkaConfigs = dataNode["KafkaConfigs"].asString();
auto allConfigMapMountDescNode = dataNode["ConfigMapMountDesc"]["ConfigMapMountDescItem"];
for (auto dataNodeConfigMapMountDescConfigMapMountDescItem : allConfigMapMountDescNode)
{

View File

@@ -72,6 +72,8 @@ void DescribeApplicationInstancesResult::parse(const std::string &payload)
instanceObject.packageVersion = dataNodeInstancesInstance["PackageVersion"].asString();
if(!dataNodeInstancesInstance["Eip"].isNull())
instanceObject.eip = dataNodeInstancesInstance["Eip"].asString();
if(!dataNodeInstancesInstance["FinishTimeStamp"].isNull())
instanceObject.finishTimeStamp = std::stol(dataNodeInstancesInstance["FinishTimeStamp"].asString());
data_.instances.push_back(instanceObject);
}
if(!value["Message"].isNull())

View File

@@ -74,6 +74,8 @@ void DescribeChangeOrderResult::parse(const std::string &payload)
data_._auto = dataNode["Auto"].asString() == "true";
if(!dataNode["CurrentPipelineId"].isNull())
data_.currentPipelineId = dataNode["CurrentPipelineId"].asString();
if(!dataNode["AppId"].isNull())
data_.appId = dataNode["AppId"].asString();
auto allPipelinesNode = dataNode["Pipelines"]["Pipeline"];
for (auto dataNodePipelinesPipeline : allPipelinesNode)
{

View File

@@ -40,16 +40,18 @@ void DescribeGreyTagRouteResult::parse(const std::string &payload)
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
auto dataNode = value["Data"];
if(!dataNode["Description"].isNull())
data_.description = dataNode["Description"].asString();
if(!dataNode["GreyTagRouteId"].isNull())
data_.greyTagRouteId = std::stol(dataNode["GreyTagRouteId"].asString());
if(!dataNode["Name"].isNull())
data_.name = dataNode["Name"].asString();
if(!dataNode["Description"].isNull())
data_.description = dataNode["Description"].asString();
if(!dataNode["CreateTime"].isNull())
data_.createTime = std::stol(dataNode["CreateTime"].asString());
if(!dataNode["UpdateTime"].isNull())
data_.updateTime = std::stol(dataNode["UpdateTime"].asString());
if(!dataNode["Name"].isNull())
data_.name = dataNode["Name"].asString();
if(!dataNode["AppId"].isNull())
data_.appId = dataNode["AppId"].asString();
auto allScRulesNode = dataNode["ScRules"]["scRule"];
for (auto dataNodeScRulesscRule : allScRulesNode)
{
@@ -62,20 +64,20 @@ void DescribeGreyTagRouteResult::parse(const std::string &payload)
for (auto dataNodeScRulesscRuleitemsitem : allitemsNode)
{
Data::ScRule::Item itemsObject;
if(!dataNodeScRulesscRuleitemsitem["name"].isNull())
itemsObject.name = dataNodeScRulesscRuleitemsitem["name"].asString();
if(!dataNodeScRulesscRuleitemsitem["index"].isNull())
itemsObject.index = std::stoi(dataNodeScRulesscRuleitemsitem["index"].asString());
if(!dataNodeScRulesscRuleitemsitem["expr"].isNull())
itemsObject.expr = dataNodeScRulesscRuleitemsitem["expr"].asString();
if(!dataNodeScRulesscRuleitemsitem["type"].isNull())
itemsObject.type = dataNodeScRulesscRuleitemsitem["type"].asString();
if(!dataNodeScRulesscRuleitemsitem["cond"].isNull())
itemsObject.cond = dataNodeScRulesscRuleitemsitem["cond"].asString();
if(!dataNodeScRulesscRuleitemsitem["value"].isNull())
itemsObject.value = dataNodeScRulesscRuleitemsitem["value"].asString();
if(!dataNodeScRulesscRuleitemsitem["operator"].isNull())
itemsObject._operator = dataNodeScRulesscRuleitemsitem["operator"].asString();
if(!dataNodeScRulesscRuleitemsitem["value"].isNull())
itemsObject.value = dataNodeScRulesscRuleitemsitem["value"].asString();
if(!dataNodeScRulesscRuleitemsitem["cond"].isNull())
itemsObject.cond = dataNodeScRulesscRuleitemsitem["cond"].asString();
if(!dataNodeScRulesscRuleitemsitem["type"].isNull())
itemsObject.type = dataNodeScRulesscRuleitemsitem["type"].asString();
if(!dataNodeScRulesscRuleitemsitem["name"].isNull())
itemsObject.name = dataNodeScRulesscRuleitemsitem["name"].asString();
scRuleObject.items.push_back(itemsObject);
}
data_.scRules.push_back(scRuleObject);
@@ -84,34 +86,34 @@ void DescribeGreyTagRouteResult::parse(const std::string &payload)
for (auto dataNodeDubboRulesdubboRule : allDubboRulesNode)
{
Data::DubboRule dubboRuleObject;
if(!dataNodeDubboRulesdubboRule["condition"].isNull())
dubboRuleObject.condition = dataNodeDubboRulesdubboRule["condition"].asString();
if(!dataNodeDubboRulesdubboRule["methodName"].isNull())
dubboRuleObject.methodName = dataNodeDubboRulesdubboRule["methodName"].asString();
if(!dataNodeDubboRulesdubboRule["serviceName"].isNull())
dubboRuleObject.serviceName = dataNodeDubboRulesdubboRule["serviceName"].asString();
if(!dataNodeDubboRulesdubboRule["version"].isNull())
dubboRuleObject.version = dataNodeDubboRulesdubboRule["version"].asString();
if(!dataNodeDubboRulesdubboRule["group"].isNull())
dubboRuleObject.group = dataNodeDubboRulesdubboRule["group"].asString();
if(!dataNodeDubboRulesdubboRule["version"].isNull())
dubboRuleObject.version = dataNodeDubboRulesdubboRule["version"].asString();
if(!dataNodeDubboRulesdubboRule["methodName"].isNull())
dubboRuleObject.methodName = dataNodeDubboRulesdubboRule["methodName"].asString();
if(!dataNodeDubboRulesdubboRule["condition"].isNull())
dubboRuleObject.condition = dataNodeDubboRulesdubboRule["condition"].asString();
auto allitems1Node = dataNodeDubboRulesdubboRule["items"]["item"];
for (auto dataNodeDubboRulesdubboRuleitemsitem : allitems1Node)
{
Data::DubboRule::Item2 items1Object;
if(!dataNodeDubboRulesdubboRuleitemsitem["name"].isNull())
items1Object.name = dataNodeDubboRulesdubboRuleitemsitem["name"].asString();
if(!dataNodeDubboRulesdubboRuleitemsitem["index"].isNull())
items1Object.index = std::stoi(dataNodeDubboRulesdubboRuleitemsitem["index"].asString());
if(!dataNodeDubboRulesdubboRuleitemsitem["expr"].isNull())
items1Object.expr = dataNodeDubboRulesdubboRuleitemsitem["expr"].asString();
if(!dataNodeDubboRulesdubboRuleitemsitem["type"].isNull())
items1Object.type = dataNodeDubboRulesdubboRuleitemsitem["type"].asString();
if(!dataNodeDubboRulesdubboRuleitemsitem["cond"].isNull())
items1Object.cond = dataNodeDubboRulesdubboRuleitemsitem["cond"].asString();
if(!dataNodeDubboRulesdubboRuleitemsitem["value"].isNull())
items1Object.value = dataNodeDubboRulesdubboRuleitemsitem["value"].asString();
if(!dataNodeDubboRulesdubboRuleitemsitem["operator"].isNull())
items1Object._operator = dataNodeDubboRulesdubboRuleitemsitem["operator"].asString();
if(!dataNodeDubboRulesdubboRuleitemsitem["value"].isNull())
items1Object.value = dataNodeDubboRulesdubboRuleitemsitem["value"].asString();
if(!dataNodeDubboRulesdubboRuleitemsitem["cond"].isNull())
items1Object.cond = dataNodeDubboRulesdubboRuleitemsitem["cond"].asString();
if(!dataNodeDubboRulesdubboRuleitemsitem["type"].isNull())
items1Object.type = dataNodeDubboRulesdubboRuleitemsitem["type"].asString();
if(!dataNodeDubboRulesdubboRuleitemsitem["name"].isNull())
items1Object.name = dataNodeDubboRulesdubboRuleitemsitem["name"].asString();
dubboRuleObject.items1.push_back(items1Object);
}
data_.dubboRules.push_back(dubboRuleObject);

View File

@@ -42,42 +42,42 @@ void DescribeNamespacesResult::parse(const std::string &payload)
auto dataNode = value["Data"];
if(!dataNode["CurrentPage"].isNull())
data_.currentPage = std::stoi(dataNode["CurrentPage"].asString());
if(!dataNode["PageSize"].isNull())
data_.pageSize = std::stoi(dataNode["PageSize"].asString());
if(!dataNode["TotalSize"].isNull())
data_.totalSize = std::stoi(dataNode["TotalSize"].asString());
if(!dataNode["PageSize"].isNull())
data_.pageSize = std::stoi(dataNode["PageSize"].asString());
auto allNamespacesNode = dataNode["Namespaces"]["Namespace"];
for (auto dataNodeNamespacesNamespace : allNamespacesNode)
{
Data::_Namespace _namespaceObject;
if(!dataNodeNamespacesNamespace["NamespaceDescription"].isNull())
_namespaceObject.namespaceDescription = dataNodeNamespacesNamespace["NamespaceDescription"].asString();
if(!dataNodeNamespacesNamespace["AccessKey"].isNull())
_namespaceObject.accessKey = dataNodeNamespacesNamespace["AccessKey"].asString();
if(!dataNodeNamespacesNamespace["AddressServerHost"].isNull())
_namespaceObject.addressServerHost = dataNodeNamespacesNamespace["AddressServerHost"].asString();
if(!dataNodeNamespacesNamespace["SecretKey"].isNull())
_namespaceObject.secretKey = dataNodeNamespacesNamespace["SecretKey"].asString();
if(!dataNodeNamespacesNamespace["NamespaceId"].isNull())
_namespaceObject.namespaceId = dataNodeNamespacesNamespace["NamespaceId"].asString();
if(!dataNodeNamespacesNamespace["AddressServerHost"].isNull())
_namespaceObject.addressServerHost = dataNodeNamespacesNamespace["AddressServerHost"].asString();
if(!dataNodeNamespacesNamespace["NamespaceName"].isNull())
_namespaceObject.namespaceName = dataNodeNamespacesNamespace["NamespaceName"].asString();
if(!dataNodeNamespacesNamespace["TenantId"].isNull())
_namespaceObject.tenantId = dataNodeNamespacesNamespace["TenantId"].asString();
if(!dataNodeNamespacesNamespace["RegionId"].isNull())
_namespaceObject.regionId = dataNodeNamespacesNamespace["RegionId"].asString();
if(!dataNodeNamespacesNamespace["NamespaceId"].isNull())
_namespaceObject.namespaceId = dataNodeNamespacesNamespace["NamespaceId"].asString();
if(!dataNodeNamespacesNamespace["NamespaceName"].isNull())
_namespaceObject.namespaceName = dataNodeNamespacesNamespace["NamespaceName"].asString();
if(!dataNodeNamespacesNamespace["NamespaceDescription"].isNull())
_namespaceObject.namespaceDescription = dataNodeNamespacesNamespace["NamespaceDescription"].asString();
data_.namespaces.push_back(_namespaceObject);
}
if(!value["Code"].isNull())
code_ = value["Code"].asString();
if(!value["ErrorCode"].isNull())
errorCode_ = value["ErrorCode"].asString();
if(!value["Message"].isNull())
message_ = value["Message"].asString();
if(!value["Success"].isNull())
success_ = value["Success"].asString() == "true";
if(!value["TraceId"].isNull())
traceId_ = value["TraceId"].asString();
if(!value["ErrorCode"].isNull())
errorCode_ = value["ErrorCode"].asString();
if(!value["Code"].isNull())
code_ = value["Code"].asString();
if(!value["Success"].isNull())
success_ = value["Success"].asString() == "true";
}

View File

@@ -63,14 +63,10 @@ void ListAppServicesPageResult::parse(const std::string &payload)
resultObject.instanceNum = std::stol(valueDataDataItemResultMscAgentServiceResponse["InstanceNum"].asString());
if(!valueDataDataItemResultMscAgentServiceResponse["EdasAppId"].isNull())
resultObject.edasAppId = valueDataDataItemResultMscAgentServiceResponse["EdasAppId"].asString();
if(!valueDataDataItemResultMscAgentServiceResponse["GmtModifyTime"].isNull())
resultObject.gmtModifyTime = valueDataDataItemResultMscAgentServiceResponse["GmtModifyTime"].asString();
if(!valueDataDataItemResultMscAgentServiceResponse["ServiceName"].isNull())
resultObject.serviceName = valueDataDataItemResultMscAgentServiceResponse["ServiceName"].asString();
if(!valueDataDataItemResultMscAgentServiceResponse["Group"].isNull())
resultObject.group = valueDataDataItemResultMscAgentServiceResponse["Group"].asString();
if(!valueDataDataItemResultMscAgentServiceResponse["ClusterName"].isNull())
resultObject.clusterName = valueDataDataItemResultMscAgentServiceResponse["ClusterName"].asString();
dataObject.result.push_back(resultObject);
}
data_.push_back(dataObject);