self/monitoring
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: self:68c8099aafe0877c11e94e81b0ea2eeeec2bd909
Branches Tags
self:master
self:prod
self:dev
..
compare: self:c8c7f63fdf7bdc7b04aed83a411c0492d1154df3
Branches Tags
self:prod
self:dev
self:master

No commits in common. "68c8099aafe0877c11e94e81b0ea2eeeec2bd909" and "c8c7f63fdf7bdc7b04aed83a411c0492d1154df3" have entirely different histories.
68c8099aaf ... c8c7f63fdf

1 changed files with 6 additions and 2 deletions
Show Stats Expand all files Collapse all files

8
app/storage/clickhouse/client.go
View File

@ -53,7 +53,11 @@ func connect() (*driver.Conn, error) {
} }
func Migrate() error { func Migrate() error {
rows, err := Connection.Query( rows, err := Connection.Query(context.TODO(), "SELECT 1")
if err != nil {
log.Fatal("Query failed:", err)
}
rows, err = Connection.Query(
context.TODO(), context.TODO(),
`CREATE TABLE IF NOT EXISTS endpoints ( `CREATE TABLE IF NOT EXISTS endpoints (
timestamp DateTime, timestamp DateTime,
@ -61,7 +65,7 @@ func Migrate() error {
endpoint LowCardinality(String), endpoint LowCardinality(String),
status_code UInt16, status_code UInt16,
response_time_ms UInt32, response_time_ms UInt32,
request_method LowCardinality(String) request_method LowCardinality(String),
) )
ENGINE = MergeTree ENGINE = MergeTree
PARTITION BY toYYYYMM(timestamp) PARTITION BY toYYYYMM(timestamp)