Rosti/node-api
3
0
Fork 0
Code Issues 2 Pull Requests Actions Projects Releases 12 Wiki Activity

Metric for stats elapsed time
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Adam Štrauch 2022-05-06 18:59:58 +02:00
parent 68121fda15
commit 02ebfb8eea
Signed by: cx
GPG Key ID: 018304FFA8988F8D
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
handlers.go
View File

@ -430,6 +430,10 @@ func metricsHandler(c echo.Context) error {
metrics += fmt.Sprintf("rosti_node_memory_index{hostname=\"%s\"} %f\n", hostname, node.MemoryIndex) metrics += fmt.Sprintf("rosti_node_memory_index{hostname=\"%s\"} %f\n", hostname, node.MemoryIndex)
metrics += fmt.Sprintf("rosti_node_sold_memory{hostname=\"%s\"} %d\n", hostname, node.SoldMemory) metrics += fmt.Sprintf("rosti_node_sold_memory{hostname=\"%s\"} %d\n", hostname, node.SoldMemory)
if elapsedMetric != -1 {
metrics += fmt.Sprintf("rosti_node_stats_time_elapsed{hostname=\"%s\"} %d\n", hostname, elapsedMetric)
}
apps, err := processor.List(true) apps, err := processor.List(true)
if err != nil { if err != nil {
return c.JSONPretty(http.StatusInternalServerError, Message{Message: err.Error()}, JSONIndent) return c.JSONPretty(http.StatusInternalServerError, Message{Message: err.Error()}, JSONIndent)

6
main.go
View File

@ -22,6 +22,8 @@ var nc *nats.Conn
var snapshotProcessor apps.SnapshotProcessor var snapshotProcessor apps.SnapshotProcessor
var nodeProcessor node.Processor var nodeProcessor node.Processor
var elapsedMetric int // time elapsed while loading stats about apps
func _init() { func _init() {
var err error var err error
@ -58,6 +60,9 @@ func _init() {
nodeProcessor = node.Processor{ nodeProcessor = node.Processor{
DB: common.GetDBConnection(), DB: common.GetDBConnection(),
} }
// Reset elapsed stats
elapsedMetric = -1
} }
func main() { func main() {
@ -89,6 +94,7 @@ func main() {
log.Println("LOOP ERROR:", err.Error()) log.Println("LOOP ERROR:", err.Error())
} }
elapsed := time.Since(start) elapsed := time.Since(start)
elapsedMetric = int(elapsed)
log.Printf("Stats gathering elapsed time: %.2fs\n", elapsed.Seconds()) log.Printf("Stats gathering elapsed time: %.2fs\n", elapsed.Seconds())
time.Sleep(300 * time.Second) time.Sleep(300 * time.Second)
} }