diff --git a/app/storage/clickhouse/client.go b/app/storage/clickhouse/client.go index 5c1e37a..f2f067e 100644 --- a/app/storage/clickhouse/client.go +++ b/app/storage/clickhouse/client.go @@ -91,5 +91,24 @@ func Migrate() error { log.Fatal(err) return err } + + err = Connection.Exec( + context.TODO(), + `CREATE TABLE IF NOT EXISTS increments ( + timestamp DateTime, + service LowCardinality(String), + environment LowCardinality(String), + name LowCardinality(String), + count UInt16 + ) + ENGINE = MergeTree + PARTITION BY toYYYYMM(timestamp) + ORDER BY (service, environment, name, timestamp);`, + ) + if err != nil { + log.Fatal(err) + return err + } + return nil }