this repo has no description
Fix events consumed counter (#237)
+1
-1
+1
-1
bgs/admin.go
+1
-1
bgs/admin.go
···
142
142
consumers := make([]consumer, 0, len(bgs.consumers))
143
143
for id, c := range bgs.consumers {
144
144
var m = &dto.Metric{}
145
-
if err := eventsReceivedCounter.WithLabelValues(c.RemoteAddr, c.UserAgent).Write(m); err != nil {
145
+
if err := c.EventsSent.Write(m); err != nil {
146
146
continue
147
147
}
148
148
consumers = append(consumers, consumer{