djb-eapim/eapim-online
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

400 성공시 성공으로 변경

Browse Source
This commit is contained in:
pksup
2026-01-15 09:45:47 +09:00
parent cfb1c7c692
commit 7079ce69a0
2 changed files with 14 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/eactive/eai/custom/statistics/collector/HourStatsAggregator.java
+7 -3
View File
@@ -22,6 +22,7 @@ public class HourStatsAggregator {
// 건수 메트릭 // 건수 메트릭
private final AtomicLong totalCnt = new AtomicLong(0); private final AtomicLong totalCnt = new AtomicLong(0);
private final AtomicLong successCnt = new AtomicLong(0);
private final AtomicLong timeoutCnt = new AtomicLong(0); private final AtomicLong timeoutCnt = new AtomicLong(0);
private final AtomicLong systemErrCnt = new AtomicLong(0); private final AtomicLong systemErrCnt = new AtomicLong(0);
private final AtomicLong bizErrCnt = new AtomicLong(0); private final AtomicLong bizErrCnt = new AtomicLong(0);
@@ -67,7 +68,11 @@ public class HourStatsAggregator {
} }
// 로그 시퀀스 400: 응답시간 및 에러 타입 기록 // 로그 시퀀스 400: 응답시간 및 에러 타입 기록
else if (logSeq == 400) { else if (logSeq == 400) {
if (!event.isSuccess()) { // 성공 여부 카운트
if (event.isSuccess()) {
successCnt.incrementAndGet();
} else {
// 에러 유형별 카운트
switch (event.getErrorType()) { switch (event.getErrorType()) {
case TIMEOUT: case TIMEOUT:
timeoutCnt.incrementAndGet(); timeoutCnt.incrementAndGet();
@@ -185,11 +190,10 @@ public class HourStatsAggregator {
// 건수 메트릭 // 건수 메트릭
long total = totalCnt.get(); long total = totalCnt.get();
long success = successCnt.get();
long timeout = timeoutCnt.get(); long timeout = timeoutCnt.get();
long systemErr = systemErrCnt.get(); long systemErr = systemErrCnt.get();
long bizErr = bizErrCnt.get(); long bizErr = bizErrCnt.get();
long success = total - (timeout + systemErr + bizErr);
success = Math.max(0, success); // 음수 방지
stats.setTotalCnt(total); stats.setTotalCnt(total);
stats.setSuccessCnt(success); stats.setSuccessCnt(success);
src/main/java/com/eactive/eai/custom/statistics/collector/MinuteStatsAggregator.java
+7 -3
View File
@@ -22,6 +22,7 @@ public class MinuteStatsAggregator {
// 건수 메트릭 // 건수 메트릭
private final AtomicLong totalCnt = new AtomicLong(0); private final AtomicLong totalCnt = new AtomicLong(0);
private final AtomicLong successCnt = new AtomicLong(0);
private final AtomicLong timeoutCnt = new AtomicLong(0); private final AtomicLong timeoutCnt = new AtomicLong(0);
private final AtomicLong systemErrCnt = new AtomicLong(0); private final AtomicLong systemErrCnt = new AtomicLong(0);
private final AtomicLong bizErrCnt = new AtomicLong(0); private final AtomicLong bizErrCnt = new AtomicLong(0);
@@ -67,7 +68,11 @@ public class MinuteStatsAggregator {
} }
// 로그 시퀀스 400: 응답시간 및 에러 타입 기록 // 로그 시퀀스 400: 응답시간 및 에러 타입 기록
else if (logSeq == 400) { else if (logSeq == 400) {
if (!event.isSuccess()) { // 성공 여부 카운트
if (event.isSuccess()) {
successCnt.incrementAndGet();
} else {
// 에러 유형별 카운트
switch (event.getErrorType()) { switch (event.getErrorType()) {
case TIMEOUT: case TIMEOUT:
timeoutCnt.incrementAndGet(); timeoutCnt.incrementAndGet();
@@ -185,11 +190,10 @@ public class MinuteStatsAggregator {
// 건수 메트릭 // 건수 메트릭
long total = totalCnt.get(); long total = totalCnt.get();
long success = successCnt.get();
long timeout = timeoutCnt.get(); long timeout = timeoutCnt.get();
long systemErr = systemErrCnt.get(); long systemErr = systemErrCnt.get();
long bizErr = bizErrCnt.get(); long bizErr = bizErrCnt.get();
long success = total - (timeout + systemErr + bizErr);
success = Math.max(0, success); // 음수 방지
stats.setTotalCnt(total); stats.setTotalCnt(total);
stats.setSuccessCnt(success); stats.setSuccessCnt(success);