refactor: cleaner abstractions across MQ / KV / ClickHouse (incl. CH connection pooling) #246

Activity

1. EricAndrechek

   added

   enhancementNew feature or requestNew feature or request

   area/apiHTTP handlers, routing, middlewareHTTP handlers, routing, middleware

   area/infraCI, build, deploy, Docker, releaseCI, build, deploy, Docker, release

   on Jun 4, 2026
2. github-project-automation

   moved this to Backlog in WaveHouse Task Boardon Jun 4, 2026
3. github-project-automation

   added this to WaveHouse Task Boardon Jun 4, 2026
4. coderabbitai commented on Jun 4, 2026

   

   coderabbitaiBot

   on Jun 4, 2026 – with coderabbitai

   More actions

   🔗 Related PRs

   #164 - refactor(ingest)!: insert-only pipeline; mutations via /v1/query [merged]

   ---

   📝 Issue Planner

   _{Check the box below or use the @coderabbitai plan command to generate an implementation plan and prompts that you can use with your favorite coding assistant.}

   • Create Plan

   ---

   🧪 Issue enrichment is currently in open beta.

   You can configure auto-planning by selecting labels in the issue_enrichment configuration.

   To disable automatic issue enrichment, add the following to your .coderabbit.yaml:

   issue_enrichment:
     auto_enrich:
       enabled: false

   💬 Have feedback or questions? Drop into our discord!
5. github-actions

   added

   area/observabilityMetrics, logs, traces, health, profilingMetrics, logs, traces, health, profiling

   area/ingestIngest pipeline (Bento, batching, DLQ)Ingest pipeline (Bento, batching, DLQ)

   on Jun 4, 2026
6. coderabbitai

   added

   area/cacheLocal / shared / tiered cachingLocal / shared / tiered caching

   area/pipesNamed query pipesNamed query pipes

   area/queryStructured query AST, SQL builderStructured query AST, SQL builder

   on Jun 4, 2026
7. EricAndrechek commented on Oct 8, 2026

   

   EricAndrechek

   on Oct 8, 2026

   MemberAuthor

   More actions

   Closing: the goals of this umbrella have landed. MQ, coordination, cache and dedupe sit behind interfaces (mq.Broker, coord.Coordinator, cache.Cache, dedupe.Deduplicator), with each implementation chosen in one place in internal/app/wire.go (#618). ClickHouse access is pooled per connection tuple, with per-pool sizes and a clickhouse.max_total_conns ceiling (internal/chconn, #603), and the process lifecycle is owned by internal/app (#585). Pool in-use/idle/wait metrics are item 16 of #94, and the executeCHQuery and internal/api refactors continue on #171 and #146.
8. EricAndrechek

   closed this as completedon Oct 8, 2026