app/routers/metrics/endpoint.go

@@ -17,7 +17,7 @@ func AddEndpointMetric (r *http.Request) (interface{}, int) {
 
 	err = endpoints.AddEndpointMetric(body)
 	if err != nil {
-		log.Print(err.Error())
+		log.Printf(err.Error())
 		return nil, http.StatusInternalServerError
 	}
 

app/storage/clickhouse/client.go

@@ -3,7 +3,6 @@ package storage
 import (
 	"context"
 	"fmt"
-	"log"
 	"os"
 
 	"github.com/ClickHouse/clickhouse-go/v2"
@@ -21,10 +20,6 @@ func Connect() error {
 	return nil
 }
 
-func Close() {
-	Connection.Close()
-}
-
 func connect() (*driver.Conn, error) {
 	var (
 		ctx = context.Background()
@@ -51,26 +46,3 @@ func connect() (*driver.Conn, error) {
 	}
 	return &conn, nil
 }
-
-func Migrate() error {
-	rows, err := Connection.Query(
-		context.TODO(), 
-		`CREATE TABLE IF NOT EXISTS endpoints (
-			timestamp        DateTime,
-			service_name     LowCardinality(String),
-			endpoint         LowCardinality(String),
-			status_code      UInt16,
-			response_time_ms UInt32,
-			request_method   LowCardinality(String),
-		)
-		ENGINE = MergeTree
-		PARTITION BY toYYYYMM(timestamp)
-		ORDER BY (service_name, endpoint, request_method, timestamp)`,
-	)
-    if err != nil {
-        log.Fatal(err)
-		return err
-    }
-    defer rows.Close()
-	return nil
-}

app/storage/clickhouse/tables/endpoints.go

@@ -3,13 +3,12 @@ package storage
 import (
 	"context"
 	client "monitoring/app/storage/clickhouse"
-	"time"
 
 	"github.com/ClickHouse/clickhouse-go/v2/lib/driver"
 )
 
 type EndpointMetric struct {
-	Timestamp time.Time `json:"timestamp"`
+	Timestamp int `json:"timestamp"`
 	Service string `json:"service"`
 	Endpoint string `json:"endpoint"`
 	StatusCode int `json:"status_code"`

main.go

@@ -33,7 +33,6 @@ func main() {
 	if err != nil {
 		panic(err)
 	}
-	defer client.Close()
 
 	http.HandleFunc("/api/v1/metrics/endpoint", handlerWrapper(endpoint.AddEndpointMetric))
 	log.Printf("Server started")