Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f69355d69d |
@ -11,18 +11,18 @@ var (
|
|||||||
Help: "Number of currently connected WebSocket clients",
|
Help: "Number of currently connected WebSocket clients",
|
||||||
})
|
})
|
||||||
|
|
||||||
MessagesTotal = promauto.NewCounter(prometheus.CounterOpts{
|
MessagesTotal = promauto.NewGauge(prometheus.GaugeOpts{
|
||||||
Name: "websocket_messages_total",
|
Name: "websocket_message",
|
||||||
Help: "Total number of WebSocket messages processed",
|
Help: "Number of WebSocket messages processed",
|
||||||
})
|
})
|
||||||
|
|
||||||
ConnectionsTotal = promauto.NewCounter(prometheus.CounterOpts{
|
ConnectionsTotal = promauto.NewGauge(prometheus.GaugeOpts{
|
||||||
Name: "websocket_connections_total",
|
Name: "websocket_connection",
|
||||||
Help: "Total number of WebSocket connections established",
|
Help: "Number of WebSocket connections established",
|
||||||
})
|
})
|
||||||
|
|
||||||
DisconnectionsTotal = promauto.NewCounter(prometheus.CounterOpts{
|
DisconnectionsTotal = promauto.NewGauge(prometheus.GaugeOpts{
|
||||||
Name: "websocket_disconnections_total",
|
Name: "websocket_disconnection",
|
||||||
Help: "Total number of WebSocket disconnections",
|
Help: "Number of WebSocket disconnections",
|
||||||
})
|
})
|
||||||
)
|
)
|
||||||
|
|||||||
5
main.go
5
main.go
@ -6,9 +6,10 @@ import (
|
|||||||
"log"
|
"log"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
|
||||||
"github.com/prometheus/client_golang/prometheus/promhttp"
|
|
||||||
"websocket-relay/internal/config"
|
"websocket-relay/internal/config"
|
||||||
"websocket-relay/internal/hub"
|
"websocket-relay/internal/hub"
|
||||||
|
|
||||||
|
"github.com/prometheus/client_golang/prometheus/promhttp"
|
||||||
)
|
)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
@ -34,7 +35,7 @@ func main() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
mux := http.NewServeMux()
|
mux := http.NewServeMux()
|
||||||
mux.HandleFunc("/ws", h.HandleWebSocket)
|
mux.HandleFunc("/", h.HandleWebSocket)
|
||||||
|
|
||||||
addr := fmt.Sprintf(":%d", cfg.Server.Port)
|
addr := fmt.Sprintf(":%d", cfg.Server.Port)
|
||||||
if cfg.Server.TLS.Enabled {
|
if cfg.Server.TLS.Enabled {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user