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

Merge pull request 'fix' (#34) from master into dev

Browse Source 
Reviewed-on: https://gitea.chocomarsh.com/self/queues-go/pulls/34
This commit is contained in:
emmatveev 2025-06-15 23:01:10 +03:00
commit 02d5631c4d
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 ( import (
"bytes" "bytes"
"fmt" "fmt"
"log"
"net/http" "net/http"
"os" "os"
tasks "queues-go/app/storage/mongo/collections" tasks "queues-go/app/storage/mongo/collections"
"strconv"
"sync" "sync"
"time" "time"
) )
@ -24,15 +26,19 @@ var MutexMap map[string]*sync.Mutex
func sendLatency(timestamp time.Time, latency int) error { func sendLatency(timestamp time.Time, latency int) error {
loc, _ := time.LoadLocation("Europe/Moscow") loc, _ := time.LoadLocation("Europe/Moscow")
s := fmt.Sprintf( s := fmt.Sprintf(
`{"timestamp":"%s","service":"queues","environment":"%s","name":"latency","count":%s}`, `{"timestamp":"%s","service":"queues","environment":"%s","name":"latency","count":%s}`,
timestamp.In(loc).Format("2006-01-02T15:04:05Z"), timestamp.In(loc).Format("2006-01-02T15:04:05Z"),
os.Getenv("STAGE"), os.Getenv("STAGE"),
latency, strconv.Itoa(latency),
) )
data := []byte(s) data := []byte(s)
r := bytes.NewReader(data) r := bytes.NewReader(data)
_, err := http.Post("http://monitoring:1237/api/v1/metrics/increment", "application/json", r) _, err := http.Post("http://monitoring:1237/api/v1/metrics/increment", "application/json", r)
if err != nil {
log.Printf("ERROR %s", err.Error())
}
return err return err
} }