app/routers/metrics/increment.go

@@ -1,25 +0,0 @@
-package routers
-
-import (
-	"encoding/json"
-	"log"
-	increments "monitoring/app/storage/clickhouse/tables"
-	"net/http"
-)
-
-func AddIncrementMetric(r *http.Request) (interface{}, int) {
-	d := json.NewDecoder(r.Body)
-	body := increments.IncrementMetric{}
-	err := d.Decode(&body)
-	if err != nil {
-		return nil, http.StatusBadRequest
-	}
-
-	err = increments.AddIncrementMetric(body)
-	if err != nil {
-		log.Print(err.Error())
-		return nil, http.StatusInternalServerError
-	}
-
-	return nil, http.StatusAccepted
-}

app/storage/clickhouse/client.go

@@ -91,24 +91,5 @@ 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
 }

app/storage/clickhouse/tables/increments.go

@@ -1,34 +0,0 @@
-package storage
-
-import (
-	"context"
-	"time"
-)
-
-type IncrementMetric struct {
-	Timestamp   time.Time `json:"timestamp"`
-	Service     string    `json:"service"`
-	Environment string    `json:"environment"`
-	Name        string    `json:"name"`
-	Count       int       `json:"count"`
-}
-
-func AddIncrementMetric(metric IncrementMetric) error {
-	batch, err := connection().PrepareBatch(context.Background(), "INSERT INTO increments")
-	if err != nil {
-		return err
-	}
-
-	err = batch.Append(
-		metric.Timestamp,
-		metric.Service,
-		metric.Environment,
-		metric.Name,
-		metric.Count,
-	)
-	if err != nil {
-		return err
-	}
-
-	return batch.Send()
-}

main.go

@@ -4,7 +4,6 @@ import (
 	"encoding/json"
 	"log"
 	endpoint "monitoring/app/routers/metrics"
-	increment "monitoring/app/routers/metrics"
 	task "monitoring/app/routers/metrics"
 	client "monitoring/app/storage/clickhouse"
 	"net/http"
@@ -44,7 +43,6 @@ func main() {
 
 	http.HandleFunc("/api/v1/metrics/endpoint", handlerWrapper(endpoint.AddEndpointMetric))
 	http.HandleFunc("/api/v1/metrics/task", handlerWrapper(task.AddTaskMetric))
-	http.HandleFunc("/api/v1/metrics/increment", handlerWrapper(increment.AddIncrementMetric))
 	log.Printf("Server started")
 	http.ListenAndServe(":1237", nil)
 }