create specific metics for flow filtering instead of using drop flows…

… metric

Signed-off-by: Mohamed Mahmoud <[email protected]>

pkg/ebpf/tracer.go

@@ -491,7 +491,11 @@ func (m *FlowFetcher) ReadGlobalCounter(met *metrics.Metrics) {
 		}
 		// aggregate all the counters
 		for _, counter := range allCPUValue {
-			met.DroppedFlowsCounter.WithSourceAndReason("flow-fetcher", reasons[key]).Add(float64(counter))
+			if key == BpfGlobalCountersKeyTHASHMAP_FLOWS_DROPPED_KEY {
+				met.DroppedFlowsCounter.WithSourceAndReason("flow-fetcher", reasons[key]).Add(float64(counter))
+			} else {
+				met.FilteredFlowsCounter.WithSourceAndReason("flow-fetcher", reasons[key]).Add(float64(counter))
+			}
 		}
 	}
 }

pkg/metrics/metrics.go

@@ -85,6 +85,13 @@ var (
 		"source",
 		"reason",
 	)
+	filterFlows = defineMetric(
+		"filtered_flows_total",
+		"Number of filtered flows",
+		TypeCounter,
+		"source",
+		"reason",
+	)
 	bufferSize = defineMetric(
 		"buffer_size",
 		"Buffer size",
@@ -136,6 +143,7 @@ type Metrics struct {
 	EvictedFlowsCounter   *EvictionCounter
 	EvictedPacketsCounter *EvictionCounter
 	DroppedFlowsCounter   *EvictionCounter
+	FilteredFlowsCounter  *EvictionCounter
 	BufferSizeGauge       *BufferSizeGauge
 	Errors                *ErrorCounter
 }
@@ -148,6 +156,7 @@ func NewMetrics(settings *Settings) *Metrics {
 	m.EvictedFlowsCounter = &EvictionCounter{vec: m.NewCounterVec(&evictedFlowsTotal)}
 	m.EvictedPacketsCounter = &EvictionCounter{vec: m.NewCounterVec(&evictedPktTotal)}
 	m.DroppedFlowsCounter = &EvictionCounter{vec: m.NewCounterVec(&droppedFlows)}
+	m.FilteredFlowsCounter = &EvictionCounter{vec: m.NewCounterVec(&filterFlows)}
 	m.BufferSizeGauge = &BufferSizeGauge{vec: m.NewGaugeVec(&bufferSize)}
 	m.Errors = &ErrorCounter{vec: m.NewCounterVec(&errorsCounter)}
 	return m