third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: optimize WorkerLogReportEvent

Browse Source
This commit is contained in:
tjq 2022-09-12 11:58:56 +08:00
parent 2db0f05feb
commit 5450ac00db
2 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/handler/AbWorkerRequestHandler.java
View File

@ -95,7 +95,8 @@ public abstract class AbWorkerRequestHandler implements IWorkerRequestHandler {
public void processWorkerLogReport(WorkerLogReportReq req) {
WorkerLogReportEvent event = new WorkerLogReportEvent()
.setWorkerAddress(req.getWorkerAddress());
.setWorkerAddress(req.getWorkerAddress())
.setLogNum(req.getInstanceLogContents().size());
try {
processWorkerLogReport0(req, event);
event.setStatus(WorkerLogReportEvent.Status.SUCCESS);

10
powerjob-server/powerjob-server-monitor/src/tech/powerjob/server/monitor/events/w2s/WorkerLogReportEvent.java
View File

@ -18,6 +18,14 @@ public class WorkerLogReportEvent implements Event {
private String workerAddress;
/**
* 日志条数
*/
private long logNum;
/**
* 日志大小，用于统计 IO 压力
*/
private long logSize;
private Status status;
@ -35,6 +43,6 @@ public class WorkerLogReportEvent implements Event {
@Override
public String message() {
return SJ.MONITOR_JOINER.join(workerAddress, logSize, status);
return SJ.MONITOR_JOINER.join(workerAddress, logNum, logSize, status);
}
}