fizzgate/fizz-gateway-node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add peak rps to flow stat

Browse Source
This commit is contained in:
hongqiaowei
2021-07-08 14:26:54 +08:00
committed by linwaiwai
parent f0f0599d9c
commit 520e06f6a3
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
fizz-core/src/main/java/we/config/FlowStatSchedConfig.java
View File

@@ -72,6 +72,7 @@ public class FlowStatSchedConfig extends SchedConfig {
private static final String _sourceIp = "\"sourceIp\":";
private static final String _service = "\"service\":";
private static final String _path = "\"path\":";
private static final String _peakRps = "\"peakRps\":";
private static final String parentResourceList = "$prl";
@@ -183,12 +184,18 @@ public class FlowStatSchedConfig extends SchedConfig {
StringBuilder b = ThreadContext.getStringBuilder();
long timeWin = w.getStartTime();
BigDecimal rps = w.getRps();
double qps;
BigDecimal peakRps = w.getPeakRps();
double qps, pRps;
if (rps == null) {
qps = 0.00;
} else {
qps = rps.doubleValue();
}
if (peakRps == null) {
pRps = 0.00;
} else {
pRps = peakRps.doubleValue();
}
// AtomicLong totalBlockRequests = resourceTimeWindow2totalBlockRequestsMap.get(resource + timeWin);
// long tbrs = (totalBlockRequests == null ? w.getBlockRequests() : w.getBlockRequests() + totalBlockRequests.longValue());
@@ -231,6 +238,7 @@ public class FlowStatSchedConfig extends SchedConfig {
b.append(_completeReqs); b.append(w.getCompReqs()); b.append(Constants.Symbol.COMMA);
b.append(_peakConcurrents); b.append(w.getPeakConcurrentReqeusts()); b.append(Constants.Symbol.COMMA);
b.append(_reqPerSec); b.append(qps); b.append(Constants.Symbol.COMMA);
b.append(_peakRps); b.append(pRps); b.append(Constants.Symbol.COMMA);
b.append(_blockReqs); b.append(w.getBlockRequests()); b.append(Constants.Symbol.COMMA);
b.append(_totalBlockReqs); b.append(tbrs); b.append(Constants.Symbol.COMMA);
b.append(_errors); b.append(w.getErrors()); b.append(Constants.Symbol.COMMA);