diff options
author | Christopher Speller <crspeller@gmail.com> | 2017-02-10 10:01:08 -0500 |
---|---|---|
committer | Corey Hulen <corey@hulen.com> | 2017-02-10 07:01:08 -0800 |
commit | 9934954d18b51c0042b9045201453e1fe64d48ed (patch) | |
tree | fd5e30f2cb6ac4a176b74d9541d1de1a54750f6f | |
parent | 1bbed1cb2bf1248e9ca8a1511cfe8a385c5f21f7 (diff) | |
download | chat-9934954d18b51c0042b9045201453e1fe64d48ed.tar.gz chat-9934954d18b51c0042b9045201453e1fe64d48ed.tar.bz2 chat-9934954d18b51c0042b9045201453e1fe64d48ed.zip |
Adding websocket event metrics (#5342)
-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) } |