feat(db): add ClickHouse batchwriter framework and skill

Introduce internal/db/batchwriter as a reusable generic buffered writer
for per-domain ClickHouse flush pipelines, with unit tests and default
batch tuning aligned with audit log ingestion.

Add clickhouse-batchwriter agent skill and cross-references in AGENTS.md
and database-migration. Business layers are not wired yet.
This commit is contained in:
ryan
2026-06-19 17:10:24 +08:00
parent 00593742c3
commit a98d266278
9 changed files with 731 additions and 4 deletions
+8 -2
View File
@@ -29,11 +29,17 @@ func dbType() string {
return "PostgreSQL"
}
const (
dialectSqlite = "sqlite3"
dialectPostgres = "postgres"
cascadeSuffix = " CASCADE"
)
func gooseDialect() string {
if !config.Config.Database.Enabled {
return "sqlite3"
return dialectSqlite
}
return "postgres"
return dialectPostgres
}
func migrationDir() string {