diff --git a/cameleer3-server-core/src/main/java/com/cameleer3/server/core/indexing/ExecutionUpdatedEvent.java b/cameleer3-server-core/src/main/java/com/cameleer3/server/core/indexing/ExecutionUpdatedEvent.java new file mode 100644 index 00000000..08488fab --- /dev/null +++ b/cameleer3-server-core/src/main/java/com/cameleer3/server/core/indexing/ExecutionUpdatedEvent.java @@ -0,0 +1,5 @@ +package com.cameleer3.server.core.indexing; + +import java.time.Instant; + +public record ExecutionUpdatedEvent(String executionId, Instant startTime) {} diff --git a/cameleer3-server-core/src/main/java/com/cameleer3/server/core/storage/model/ExecutionDocument.java b/cameleer3-server-core/src/main/java/com/cameleer3/server/core/storage/model/ExecutionDocument.java new file mode 100644 index 00000000..6822088a --- /dev/null +++ b/cameleer3-server-core/src/main/java/com/cameleer3/server/core/storage/model/ExecutionDocument.java @@ -0,0 +1,19 @@ +package com.cameleer3.server.core.storage.model; + +import java.time.Instant; +import java.util.List; + +public record ExecutionDocument( + String executionId, String routeId, String agentId, String groupName, + String status, String correlationId, String exchangeId, + Instant startTime, Instant endTime, Long durationMs, + String errorMessage, String errorStacktrace, + List processors +) { + public record ProcessorDoc( + String processorId, String processorType, String status, + String errorMessage, String errorStacktrace, + String inputBody, String outputBody, + String inputHeaders, String outputHeaders + ) {} +}