self/queues-go
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix
All checks were successful
Deploy Prod / Deploy prod (pull_request) Successful in 11s
Details
Deploy Dev / Build (pull_request) Successful in 40s
Details
Deploy Dev / Push (pull_request) Successful in 34s
Details
Deploy Dev / Deploy dev (pull_request) Successful in 13s
Details
Deploy Prod / Build (pull_request) Successful in 41s
Details
Deploy Prod / Push (pull_request) Successful in 26s
Details

Browse Source
This commit is contained in:
Egor Matveev 2025-06-15 23:00:45 +03:00
parent 3cdc41f864
commit 357418c66c
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
app/routers/take.go
View File

@ -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
}