|
|
@@ -40,109 +40,95 @@ void OnsConsumerStatusResult::parse(const std::string &payload)
|
|
|
reader.parse(payload, value);
|
|
|
setRequestId(value["RequestId"].asString());
|
|
|
auto dataNode = value["Data"];
|
|
|
- if(!dataNode["Online"].isNull())
|
|
|
- data_.online = dataNode["Online"].asString() == "true";
|
|
|
- if(!dataNode["TotalDiff"].isNull())
|
|
|
- data_.totalDiff = std::stol(dataNode["TotalDiff"].asString());
|
|
|
if(!dataNode["ConsumeTps"].isNull())
|
|
|
data_.consumeTps = std::stof(dataNode["ConsumeTps"].asString());
|
|
|
- if(!dataNode["LastTimestamp"].isNull())
|
|
|
- data_.lastTimestamp = std::stol(dataNode["LastTimestamp"].asString());
|
|
|
- if(!dataNode["DelayTime"].isNull())
|
|
|
- data_.delayTime = std::stol(dataNode["DelayTime"].asString());
|
|
|
if(!dataNode["ConsumeModel"].isNull())
|
|
|
data_.consumeModel = dataNode["ConsumeModel"].asString();
|
|
|
+ if(!dataNode["TotalDiff"].isNull())
|
|
|
+ data_.totalDiff = std::stol(dataNode["TotalDiff"].asString());
|
|
|
+ if(!dataNode["InstanceId"].isNull())
|
|
|
+ data_.instanceId = dataNode["InstanceId"].asString();
|
|
|
if(!dataNode["SubscriptionSame"].isNull())
|
|
|
data_.subscriptionSame = dataNode["SubscriptionSame"].asString() == "true";
|
|
|
+ if(!dataNode["DelayTime"].isNull())
|
|
|
+ data_.delayTime = std::stol(dataNode["DelayTime"].asString());
|
|
|
+ if(!dataNode["LastTimestamp"].isNull())
|
|
|
+ data_.lastTimestamp = std::stol(dataNode["LastTimestamp"].asString());
|
|
|
+ if(!dataNode["Online"].isNull())
|
|
|
+ data_.online = dataNode["Online"].asString() == "true";
|
|
|
if(!dataNode["RebalanceOK"].isNull())
|
|
|
data_.rebalanceOK = dataNode["RebalanceOK"].asString() == "true";
|
|
|
- if(!dataNode["InstanceId"].isNull())
|
|
|
- data_.instanceId = dataNode["InstanceId"].asString();
|
|
|
auto allConnectionSetNode = dataNode["ConnectionSet"]["ConnectionDo"];
|
|
|
for (auto dataNodeConnectionSetConnectionDo : allConnectionSetNode)
|
|
|
{
|
|
|
Data::ConnectionDo connectionDoObject;
|
|
|
- if(!dataNodeConnectionSetConnectionDo["ClientId"].isNull())
|
|
|
- connectionDoObject.clientId = dataNodeConnectionSetConnectionDo["ClientId"].asString();
|
|
|
+ if(!dataNodeConnectionSetConnectionDo["RemoteIP"].isNull())
|
|
|
+ connectionDoObject.remoteIP = dataNodeConnectionSetConnectionDo["RemoteIP"].asString();
|
|
|
+ if(!dataNodeConnectionSetConnectionDo["Version"].isNull())
|
|
|
+ connectionDoObject.version = dataNodeConnectionSetConnectionDo["Version"].asString();
|
|
|
if(!dataNodeConnectionSetConnectionDo["ClientAddr"].isNull())
|
|
|
connectionDoObject.clientAddr = dataNodeConnectionSetConnectionDo["ClientAddr"].asString();
|
|
|
if(!dataNodeConnectionSetConnectionDo["Language"].isNull())
|
|
|
connectionDoObject.language = dataNodeConnectionSetConnectionDo["Language"].asString();
|
|
|
- if(!dataNodeConnectionSetConnectionDo["Version"].isNull())
|
|
|
- connectionDoObject.version = dataNodeConnectionSetConnectionDo["Version"].asString();
|
|
|
- if(!dataNodeConnectionSetConnectionDo["RemoteIP"].isNull())
|
|
|
- connectionDoObject.remoteIP = dataNodeConnectionSetConnectionDo["RemoteIP"].asString();
|
|
|
+ if(!dataNodeConnectionSetConnectionDo["ClientId"].isNull())
|
|
|
+ connectionDoObject.clientId = dataNodeConnectionSetConnectionDo["ClientId"].asString();
|
|
|
data_.connectionSet.push_back(connectionDoObject);
|
|
|
}
|
|
|
- auto allDetailInTopicListNode = dataNode["DetailInTopicList"]["DetailInTopicDo"];
|
|
|
- for (auto dataNodeDetailInTopicListDetailInTopicDo : allDetailInTopicListNode)
|
|
|
- {
|
|
|
- Data::DetailInTopicDo detailInTopicDoObject;
|
|
|
- if(!dataNodeDetailInTopicListDetailInTopicDo["Topic"].isNull())
|
|
|
- detailInTopicDoObject.topic = dataNodeDetailInTopicListDetailInTopicDo["Topic"].asString();
|
|
|
- if(!dataNodeDetailInTopicListDetailInTopicDo["TotalDiff"].isNull())
|
|
|
- detailInTopicDoObject.totalDiff = std::stol(dataNodeDetailInTopicListDetailInTopicDo["TotalDiff"].asString());
|
|
|
- if(!dataNodeDetailInTopicListDetailInTopicDo["LastTimestamp"].isNull())
|
|
|
- detailInTopicDoObject.lastTimestamp = std::stol(dataNodeDetailInTopicListDetailInTopicDo["LastTimestamp"].asString());
|
|
|
- if(!dataNodeDetailInTopicListDetailInTopicDo["DelayTime"].isNull())
|
|
|
- detailInTopicDoObject.delayTime = std::stol(dataNodeDetailInTopicListDetailInTopicDo["DelayTime"].asString());
|
|
|
- data_.detailInTopicList.push_back(detailInTopicDoObject);
|
|
|
- }
|
|
|
auto allConsumerConnectionInfoListNode = dataNode["ConsumerConnectionInfoList"]["ConsumerConnectionInfoDo"];
|
|
|
for (auto dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo : allConsumerConnectionInfoListNode)
|
|
|
{
|
|
|
Data::ConsumerConnectionInfoDo consumerConnectionInfoDoObject;
|
|
|
+ if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ConsumeModel"].isNull())
|
|
|
+ consumerConnectionInfoDoObject.consumeModel = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ConsumeModel"].asString();
|
|
|
+ if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["LastTimeStamp"].isNull())
|
|
|
+ consumerConnectionInfoDoObject.lastTimeStamp = std::stol(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["LastTimeStamp"].asString());
|
|
|
+ if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["StartTimeStamp"].isNull())
|
|
|
+ consumerConnectionInfoDoObject.startTimeStamp = std::stol(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["StartTimeStamp"].asString());
|
|
|
+ if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Language"].isNull())
|
|
|
+ consumerConnectionInfoDoObject.language = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Language"].asString();
|
|
|
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ClientId"].isNull())
|
|
|
consumerConnectionInfoDoObject.clientId = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ClientId"].asString();
|
|
|
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Connection"].isNull())
|
|
|
consumerConnectionInfoDoObject.connection = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Connection"].asString();
|
|
|
- if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Language"].isNull())
|
|
|
- consumerConnectionInfoDoObject.language = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Language"].asString();
|
|
|
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Version"].isNull())
|
|
|
consumerConnectionInfoDoObject.version = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Version"].asString();
|
|
|
- if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ConsumeModel"].isNull())
|
|
|
- consumerConnectionInfoDoObject.consumeModel = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ConsumeModel"].asString();
|
|
|
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ConsumeType"].isNull())
|
|
|
consumerConnectionInfoDoObject.consumeType = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ConsumeType"].asString();
|
|
|
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ThreadCount"].isNull())
|
|
|
consumerConnectionInfoDoObject.threadCount = std::stoi(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ThreadCount"].asString());
|
|
|
- if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["StartTimeStamp"].isNull())
|
|
|
- consumerConnectionInfoDoObject.startTimeStamp = std::stol(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["StartTimeStamp"].asString());
|
|
|
- if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["LastTimeStamp"].isNull())
|
|
|
- consumerConnectionInfoDoObject.lastTimeStamp = std::stol(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["LastTimeStamp"].asString());
|
|
|
- auto allSubscriptionSetNode = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["SubscriptionSet"]["SubscriptionData"];
|
|
|
- for (auto dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData : allSubscriptionSetNode)
|
|
|
- {
|
|
|
- Data::ConsumerConnectionInfoDo::SubscriptionData subscriptionSetObject;
|
|
|
- if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData["Topic"].isNull())
|
|
|
- subscriptionSetObject.topic = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData["Topic"].asString();
|
|
|
- if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData["SubString"].isNull())
|
|
|
- subscriptionSetObject.subString = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData["SubString"].asString();
|
|
|
- if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData["SubVersion"].isNull())
|
|
|
- subscriptionSetObject.subVersion = std::stol(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData["SubVersion"].asString());
|
|
|
- auto allTagsSet = value["TagsSet"]["Tag"];
|
|
|
- for (auto value : allTagsSet)
|
|
|
- subscriptionSetObject.tagsSet.push_back(value.asString());
|
|
|
- consumerConnectionInfoDoObject.subscriptionSet.push_back(subscriptionSetObject);
|
|
|
- }
|
|
|
auto allRunningDataListNode = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["RunningDataList"]["ConsumerRunningDataDo"];
|
|
|
for (auto dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo : allRunningDataListNode)
|
|
|
{
|
|
|
Data::ConsumerConnectionInfoDo::ConsumerRunningDataDo runningDataListObject;
|
|
|
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["GroupId"].isNull())
|
|
|
runningDataListObject.groupId = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["GroupId"].asString();
|
|
|
- if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["Topic"].isNull())
|
|
|
- runningDataListObject.topic = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["Topic"].asString();
|
|
|
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["Rt"].isNull())
|
|
|
runningDataListObject.rt = std::stof(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["Rt"].asString());
|
|
|
+ if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["Topic"].isNull())
|
|
|
+ runningDataListObject.topic = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["Topic"].asString();
|
|
|
+ if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["FailedCountPerHour"].isNull())
|
|
|
+ runningDataListObject.failedCountPerHour = std::stol(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["FailedCountPerHour"].asString());
|
|
|
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["OkTps"].isNull())
|
|
|
runningDataListObject.okTps = std::stof(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["OkTps"].asString());
|
|
|
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["FailedTps"].isNull())
|
|
|
runningDataListObject.failedTps = std::stof(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["FailedTps"].asString());
|
|
|
- if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["FailedCountPerHour"].isNull())
|
|
|
- runningDataListObject.failedCountPerHour = std::stol(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoRunningDataListConsumerRunningDataDo["FailedCountPerHour"].asString());
|
|
|
consumerConnectionInfoDoObject.runningDataList.push_back(runningDataListObject);
|
|
|
}
|
|
|
+ auto allSubscriptionSetNode = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["SubscriptionSet"]["SubscriptionData"];
|
|
|
+ for (auto dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData : allSubscriptionSetNode)
|
|
|
+ {
|
|
|
+ Data::ConsumerConnectionInfoDo::SubscriptionData subscriptionSetObject;
|
|
|
+ if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData["SubString"].isNull())
|
|
|
+ subscriptionSetObject.subString = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData["SubString"].asString();
|
|
|
+ if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData["SubVersion"].isNull())
|
|
|
+ subscriptionSetObject.subVersion = std::stol(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData["SubVersion"].asString());
|
|
|
+ if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData["Topic"].isNull())
|
|
|
+ subscriptionSetObject.topic = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoSubscriptionSetSubscriptionData["Topic"].asString();
|
|
|
+ auto allTagsSet = value["TagsSet"]["Tag"];
|
|
|
+ for (auto value : allTagsSet)
|
|
|
+ subscriptionSetObject.tagsSet.push_back(value.asString());
|
|
|
+ consumerConnectionInfoDoObject.subscriptionSet.push_back(subscriptionSetObject);
|
|
|
+ }
|
|
|
auto allJstackNode = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Jstack"]["ThreadTrackDo"];
|
|
|
for (auto dataNodeConsumerConnectionInfoListConsumerConnectionInfoDoJstackThreadTrackDo : allJstackNode)
|
|
|
{
|
|
|
@@ -156,6 +142,20 @@ void OnsConsumerStatusResult::parse(const std::string &payload)
|
|
|
}
|
|
|
data_.consumerConnectionInfoList.push_back(consumerConnectionInfoDoObject);
|
|
|
}
|
|
|
+ auto allDetailInTopicListNode = dataNode["DetailInTopicList"]["DetailInTopicDo"];
|
|
|
+ for (auto dataNodeDetailInTopicListDetailInTopicDo : allDetailInTopicListNode)
|
|
|
+ {
|
|
|
+ Data::DetailInTopicDo detailInTopicDoObject;
|
|
|
+ if(!dataNodeDetailInTopicListDetailInTopicDo["DelayTime"].isNull())
|
|
|
+ detailInTopicDoObject.delayTime = std::stol(dataNodeDetailInTopicListDetailInTopicDo["DelayTime"].asString());
|
|
|
+ if(!dataNodeDetailInTopicListDetailInTopicDo["TotalDiff"].isNull())
|
|
|
+ detailInTopicDoObject.totalDiff = std::stol(dataNodeDetailInTopicListDetailInTopicDo["TotalDiff"].asString());
|
|
|
+ if(!dataNodeDetailInTopicListDetailInTopicDo["LastTimestamp"].isNull())
|
|
|
+ detailInTopicDoObject.lastTimestamp = std::stol(dataNodeDetailInTopicListDetailInTopicDo["LastTimestamp"].asString());
|
|
|
+ if(!dataNodeDetailInTopicListDetailInTopicDo["Topic"].isNull())
|
|
|
+ detailInTopicDoObject.topic = dataNodeDetailInTopicListDetailInTopicDo["Topic"].asString();
|
|
|
+ data_.detailInTopicList.push_back(detailInTopicDoObject);
|
|
|
+ }
|
|
|
if(!value["HelpUrl"].isNull())
|
|
|
helpUrl_ = value["HelpUrl"].asString();
|
|
|
|