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

Compare commits

base: self:02d5631c4dc092c6eeca5efd01eb144b4463427a
Branches Tags
self:master
self:prod
self:dev
..
compare: self:e791890ea5ed2b3dadccf795e8594426263992ef
Branches Tags
self:prod
self:master
self:dev

No commits in common. "02d5631c4dc092c6eeca5efd01eb144b4463427a" and "e791890ea5ed2b3dadccf795e8594426263992ef" have entirely different histories.
02d5631c4d ... e791890ea5

1 changed files with 1 additions and 7 deletions
Show Stats Expand all files Collapse all files

8
app/routers/take.go
View File

@ -3,11 +3,9 @@ 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"
) )
@ -26,19 +24,15 @@ 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"),
strconv.Itoa(latency), 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
} }