diff options
| -rw-r--r-- | app/web_hub.go | 4 | ||||
| -rw-r--r-- | einterfaces/metrics.go | 2 |
2 files changed, 6 insertions, 0 deletions
diff --git a/app/web_hub.go b/app/web_hub.go index 21ed341ce..b4a8a4140 100644 --- a/app/web_hub.go +++ b/app/web_hub.go @@ -86,6 +86,10 @@ func HubUnregister(webConn *WebConn) { } func Publish(message *model.WebSocketEvent) { + if metrics := einterfaces.GetMetricsInterface(); metrics != nil { + metrics.IncrementWebsocketEvent(message.Event) + } + message.DoPreComputeJson() for _, hub := range hubs { hub.Broadcast(message) diff --git a/einterfaces/metrics.go b/einterfaces/metrics.go index f7d660da3..394abf94d 100644 --- a/einterfaces/metrics.go +++ b/einterfaces/metrics.go @@ -26,6 +26,8 @@ type MetricsInterface interface { IncrementMemCacheHitCounter(cacheName string) IncrementMemCacheMissCounter(cacheName string) + IncrementWebsocketEvent(eventType string) + AddMemCacheHitCounter(cacheName string, amount float64) AddMemCacheMissCounter(cacheName string, amount float64) } |