From 06c6f53bbc247985db45be32bb9f9c75443b01e7 Mon Sep 17 00:00:00 2001 From: hsiegeln <37154749+hsiegeln@users.noreply.github.com> Date: Tue, 21 Apr 2026 23:33:26 +0200 Subject: [PATCH] refactor(ingestion): remove unused TaggedExecution record No callers after the legacy PG ingestion path was retired in 0f635576. core-classes.md updated to drop the leftover note. Co-Authored-By: Claude Opus 4.7 (1M context) --- .claude/rules/core-classes.md | 2 +- .../server/core/ingestion/TaggedExecution.java | 11 ----------- 2 files changed, 1 insertion(+), 12 deletions(-) delete mode 100644 cameleer-server-core/src/main/java/com/cameleer/server/core/ingestion/TaggedExecution.java 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) {}