app/routers/take.go

@@ -3,9 +3,11 @@ package routers
 import (
 	"bytes"
 	"fmt"
+	"log"
 	"net/http"
 	"os"
 	tasks "queues-go/app/storage/mongo/collections"
+	"strconv"
 	"sync"
 	"time"
 )
@@ -24,15 +26,19 @@ var MutexMap map[string]*sync.Mutex
 
 func sendLatency(timestamp time.Time, latency int) error {
 	loc, _ := time.LoadLocation("Europe/Moscow")
+
 	s := fmt.Sprintf(
 		`{"timestamp":"%s","service":"queues","environment":"%s","name":"latency","count":%s}`,
 		timestamp.In(loc).Format("2006-01-02T15:04:05Z"),
 		os.Getenv("STAGE"),
-		latency,
+		strconv.Itoa(latency),
 	)
 	data := []byte(s)
 	r := bytes.NewReader(data)
 	_, err := http.Post("http://monitoring:1237/api/v1/metrics/increment", "application/json", r)
+	if err != nil {
+		log.Printf("ERROR %s", err.Error())
+	}
 	return err
 }