Changeset 711 in code for trunk/downstream.go

Timestamp:

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

Author:

contact

Message:

Add message counter metrics

File:

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

trunk/downstream.go

@@ -445 +445 @@
 }
 
+func (dc *downstreamConn) ReadMessage() (*irc.Message, error) {
+        msg, err := dc.conn.ReadMessage()
+        if err != nil {
+                return nil, err
+        }
+        dc.srv.metrics.downstreamInMessagesTotal.Inc()
+        return msg, nil
+}
+
 func (dc *downstreamConn) readMessages(ch chan<- event) error {
         for {
@@ -499 +508 @@
         }
 
+        dc.srv.metrics.downstreamOutMessagesTotal.Inc()
         dc.conn.SendMessage(msg)
 }