From ecd9c35233f324bbbc4654048dfb374546d2a75c Mon Sep 17 00:00:00 2001 From: Viktor Lofgren Date: Sat, 13 Jan 2024 13:28:02 +0100 Subject: [PATCH] (control) Clean up the event log * Generate fewer uninteresting event messages. * Display fewer irrelevant fields in the overview table. --- .../java/nu/marginalia/service/control/ServiceEventLog.java | 2 +- .../src/main/java/nu/marginalia/service/server/Service.java | 2 +- .../java/nu/marginalia/control/actor/ControlActorService.java | 4 +++- .../templates/control/partials/events-table-summary.hdb | 4 ---- .../java/nu/marginalia/actor/ExecutorActorControlService.java | 4 +++- .../src/main/java/nu/marginalia/process/ProcessService.java | 1 + 6 files changed, 9 insertions(+), 8 deletions(-) diff --git a/code/common/service/src/main/java/nu/marginalia/service/control/ServiceEventLog.java b/code/common/service/src/main/java/nu/marginalia/service/control/ServiceEventLog.java index f5f6e90b3..d57689179 100644 --- a/code/common/service/src/main/java/nu/marginalia/service/control/ServiceEventLog.java +++ b/code/common/service/src/main/java/nu/marginalia/service/control/ServiceEventLog.java @@ -33,7 +33,7 @@ public ServiceEventLog(HikariDataSource dataSource, logger.info("Starting service {} instance {}", serviceName, instanceUuid); - logEvent("START", "Service starting"); + logEvent("SVC-START", serviceName); } public void logEvent(String type, String message) { diff --git a/code/common/service/src/main/java/nu/marginalia/service/server/Service.java b/code/common/service/src/main/java/nu/marginalia/service/server/Service.java index 26c13a585..604d19412 100644 --- a/code/common/service/src/main/java/nu/marginalia/service/server/Service.java +++ b/code/common/service/src/main/java/nu/marginalia/service/server/Service.java @@ -60,7 +60,7 @@ public Service(BaseServiceParams params, initialization.addCallback(params.heartbeat::start); initialization.addCallback(messageQueueInbox::start); - initialization.addCallback(() -> params.eventLog.logEvent("SVC-INIT", "")); + initialization.addCallback(() -> params.eventLog.logEvent("SVC-INIT", serviceName + ":" + config.node())); if (!initialization.isReady() && ! initialized ) { initialized = true; diff --git a/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/ControlActorService.java b/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/ControlActorService.java index 5a15b3459..766cf23c2 100644 --- a/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/ControlActorService.java +++ b/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/ControlActorService.java @@ -59,7 +59,9 @@ private void register(ControlActor process, ActorPrototype graph) { } private void logStateChange(ControlActor process, String state) { - eventLog.logEvent("FSM-STATE-CHANGE", process.id() + " -> " + state); + if ("ERROR".equals(state)) { + eventLog.logEvent("FSM-ERROR", process.id()); + } } public void startFrom(ControlActor process, String state) throws Exception { diff --git a/code/services-core/control-service/src/main/resources/templates/control/partials/events-table-summary.hdb b/code/services-core/control-service/src/main/resources/templates/control/partials/events-table-summary.hdb index 66e68d3a1..32d2ec678 100644 --- a/code/services-core/control-service/src/main/resources/templates/control/partials/events-table-summary.hdb +++ b/code/services-core/control-service/src/main/resources/templates/control/partials/events-table-summary.hdb @@ -2,16 +2,12 @@ - - {{#each events}} - - diff --git a/code/services-core/executor-service/src/main/java/nu/marginalia/actor/ExecutorActorControlService.java b/code/services-core/executor-service/src/main/java/nu/marginalia/actor/ExecutorActorControlService.java index b3d62e74b..c9c8bf6d9 100644 --- a/code/services-core/executor-service/src/main/java/nu/marginalia/actor/ExecutorActorControlService.java +++ b/code/services-core/executor-service/src/main/java/nu/marginalia/actor/ExecutorActorControlService.java @@ -79,7 +79,9 @@ private void register(ExecutorActor process, RecordActorPrototype graph) { } private void logStateChange(ExecutorActor process, String state) { - eventLog.logEvent("FSM-STATE-CHANGE", process.id() + " -> " + state); + if ("ERROR".equals(state)) { + eventLog.logEvent("FSM-ERROR", process.id()); + } } public void start(ExecutorActor process) throws Exception { diff --git a/code/services-core/executor-service/src/main/java/nu/marginalia/process/ProcessService.java b/code/services-core/executor-service/src/main/java/nu/marginalia/process/ProcessService.java index 2d065962c..aadfa6259 100644 --- a/code/services-core/executor-service/src/main/java/nu/marginalia/process/ProcessService.java +++ b/code/services-core/executor-service/src/main/java/nu/marginalia/process/ProcessService.java @@ -87,6 +87,7 @@ public boolean trigger(ProcessId processId, String... parameters) throws Excepti processes.put(processId, process); } + eventLog.logEvent("PROCESS-START", processId.toString()); try { new Thread(new ProcessLogStderr(process)).start(); new Thread(new ProcessLogStdout(process)).start();
Service NameInstance Event Time Type Message
{{serviceName}}{{{readableUUID instanceFull}}} {{eventTime}} {{eventType}} {{eventMessage}}