Changeset 711 in code for trunk/upstream.go

Timestamp:

Nov 17, 2021, 2:58:19 PM (4 years ago)

Author:

contact

Message:

Add message counter metrics

File:

• trunk/upstream.go (modified) (2 diffs)

trunk/upstream.go

@@ -1807 +1807 @@
 }
 
+func (uc *upstreamConn) ReadMessage() (*irc.Message, error) {
+        msg, err := uc.conn.ReadMessage()
+        if err != nil {
+                return nil, err
+        }
+        uc.srv.metrics.upstreamInMessagesTotal.Inc()
+        return msg, nil
+}
+
 func (uc *upstreamConn) runUntilRegistered() error {
         for !uc.registered {
@@ -1857 +1866 @@
         }
 
+        uc.srv.metrics.upstreamOutMessagesTotal.Inc()
         uc.conn.SendMessage(msg)
 }