forwarder: fix processed prometheus counter

bangunindo · Dec 12, 2023 · ca14110 · ca14110
1 parent 6ff8853
commit ca14110
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/forwarder/forwarder.go b/forwarder/forwarder.go
@@ -143,6 +143,7 @@ func (b *Base) Get() (*snmp.Message, error) {
 
 // Send snmp message to forwarder
 func (b *Base) Send(message *snmp.Message) {
+	b.ctrProcessed.Inc()
 	if b.config.QueueSize == 0 || b.queue.Len() < b.config.QueueSize {
 		err := b.queue.Put(message)
 		if err != nil {