From ca14110d04407bbad2174d093ca766e5260aa859 Mon Sep 17 00:00:00 2001
From: Muhammad Iqbal Alaydrus <iqbal@bangunindo.com>
Date: Tue, 12 Dec 2023 11:59:29 +0700
Subject: [PATCH] forwarder: fix processed prometheus counter

---
 forwarder/forwarder.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/forwarder/forwarder.go b/forwarder/forwarder.go
index d09b872..d928d4b 100644
--- 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 {