Changeset 711 in code for trunk/server.go

Timestamp:

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

Author:

contact

Message:

Add message counter metrics

File:

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

trunk/server.go

@@ -102 +102 @@
                 downstreams int64Gauge
                 upstreams   int64Gauge
+
+                upstreamOutMessagesTotal   prometheus.Counter
+                upstreamInMessagesTotal    prometheus.Counter
+                downstreamOutMessagesTotal prometheus.Counter
+                downstreamInMessagesTotal  prometheus.Counter
         }
 }
@@ -171 +176 @@
                 Help: "Current number of upstream connections",
         }, s.metrics.upstreams.Float64)
+
+        s.metrics.upstreamOutMessagesTotal = factory.NewCounter(prometheus.CounterOpts{
+                Name: "soju_upstream_out_messages_total",
+                Help: "Total number of outgoing messages sent to upstream servers",
+        })
+
+        s.metrics.upstreamInMessagesTotal = factory.NewCounter(prometheus.CounterOpts{
+                Name: "soju_upstream_in_messages_total",
+                Help: "Total number of incoming messages received from upstream servers",
+        })
+
+        s.metrics.downstreamOutMessagesTotal = factory.NewCounter(prometheus.CounterOpts{
+                Name: "soju_downstream_out_messages_total",
+                Help: "Total number of outgoing messages sent to downstream clients",
+        })
+
+        s.metrics.downstreamInMessagesTotal = factory.NewCounter(prometheus.CounterOpts{
+                Name: "soju_downstream_in_messages_total",
+                Help: "Total number of incoming messages received from downstream clients",
+        })
 }