diff --git a/.claude/rules/core-classes.md b/.claude/rules/core-classes.md index b43b99f0..de7e5df4 100644 --- a/.claude/rules/core-classes.md +++ b/.claude/rules/core-classes.md @@ -111,4 +111,4 @@ paths: - `ChunkAccumulator` — batches data for efficient flush; owns the execution write path (chunks → buffers → flush scheduler → `ClickHouseExecutionStore.insertExecutionBatch`). - `WriteBuffer` — bounded ring buffer for async flush - `BufferedLogEntry` — log entry wrapper with metadata -- `MergedExecution`, `TaggedDiagram` — tagged ingestion records. `TaggedDiagram` carries `(instanceId, applicationId, environment, graph)` — env is resolved from the agent registry in the controller and stamped on the ClickHouse `route_diagrams` row. (`TaggedExecution` still lives in the package as a leftover but has no callers since the legacy PG ingest path was retired.) +- `MergedExecution`, `TaggedDiagram` — tagged ingestion records. `TaggedDiagram` carries `(instanceId, applicationId, environment, graph)` — env is resolved from the agent registry in the controller and stamped on the ClickHouse `route_diagrams` row. diff --git a/cameleer-server-core/src/main/java/com/cameleer/server/core/ingestion/TaggedExecution.java b/cameleer-server-core/src/main/java/com/cameleer/server/core/ingestion/TaggedExecution.java deleted file mode 100644 index 13d56c8a..00000000 --- a/cameleer-server-core/src/main/java/com/cameleer/server/core/ingestion/TaggedExecution.java +++ /dev/null @@ -1,11 +0,0 @@ -package com.cameleer.server.core.ingestion; - -import com.cameleer.common.model.RouteExecution; - -/** - * Pairs a {@link RouteExecution} with the authenticated agent identity. - *
- * The agent ID is extracted from the SecurityContext in the controller layer - * and carried through the write buffer so the flush scheduler can persist it. - */ -public record TaggedExecution(String instanceId, RouteExecution execution) {}