feat: add ExecutionDocument model and ExecutionUpdatedEvent
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
@@ -0,0 +1,5 @@
|
||||
package com.cameleer3.server.core.indexing;
|
||||
|
||||
import java.time.Instant;
|
||||
|
||||
public record ExecutionUpdatedEvent(String executionId, Instant startTime) {}
|
||||
@@ -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<ProcessorDoc> processors
|
||||
) {
|
||||
public record ProcessorDoc(
|
||||
String processorId, String processorType, String status,
|
||||
String errorMessage, String errorStacktrace,
|
||||
String inputBody, String outputBody,
|
||||
String inputHeaders, String outputHeaders
|
||||
) {}
|
||||
}
|
||||
Reference in New Issue
Block a user