erik/converge
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

moved prometheus to its own package.

Browse Source
This commit is contained in:
Erik Brakkee 2024-08-17 10:17:47 +02:00
parent 7ab213c34e
commit a12416cd21
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
cmd/converge/converge.go
View File

@ -5,6 +5,7 @@ import (
"fmt" "fmt"
"git.wamblee.org/converge/pkg/models" "git.wamblee.org/converge/pkg/models"
"git.wamblee.org/converge/pkg/server/matchmaker" "git.wamblee.org/converge/pkg/server/matchmaker"
"git.wamblee.org/converge/pkg/server/prometheus"
"git.wamblee.org/converge/pkg/support/websocketutil" "git.wamblee.org/converge/pkg/support/websocketutil"
"log" "log"
"net" "net"
@ -130,7 +131,7 @@ func main() {
websessions := matchmaker.NewWebSessions(notifications.webNotificationChannel) websessions := matchmaker.NewWebSessions(notifications.webNotificationChannel)
// monitoring // monitoring
prometheusMux := http.NewServeMux() prometheusMux := http.NewServeMux()
setupPrometheus(prometheusMux, notifications.prometheusNotificationChannel) prometheus.SetupPrometheus(prometheusMux, notifications.prometheusNotificationChannel)
go func() { go func() {
log.Fatal(http.ListenAndServe(":8001", prometheusMux)) log.Fatal(http.ListenAndServe(":8001", prometheusMux))
}() }()

4
cmd/converge/prometheus.go → pkg/server/prometheus/prometheus.go
View File

@ -1,4 +1,4 @@
package main package prometheus
import ( import (
"git.wamblee.org/converge/pkg/models" "git.wamblee.org/converge/pkg/models"
@ -179,7 +179,7 @@ func clientActive(client *models.Client) {
Set(float64(time.Now().Sub(client.StartTime).Seconds())) Set(float64(time.Now().Sub(client.StartTime).Seconds()))
} }
func setupPrometheus(mux *http.ServeMux, notifications chan *models.State) { func SetupPrometheus(mux *http.ServeMux, notifications chan *models.State) {
// go routine that handles incoming events so we don't need to serialize access in some // go routine that handles incoming events so we don't need to serialize access in some
// other way. // other way.
go func() { go func() {