Add promo metrics for openSSL tracker

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

Author: msherif1234

pkg/flow/tracer_ringbuf.go

@@ -6,6 +6,7 @@ import (
 	"encoding/binary"
 	"errors"
 	"fmt"
+	"strconv"
 	"sync/atomic"
 	"syscall"
 	"time"
@@ -132,7 +133,7 @@ func (m *RingBufTracer) listenAndForwardRingBuffer(debugging bool, forwardCh cha
 	return nil
 }
 
-func (m *RingBufTracer) listenAndForwardRingBufferSSL(forwardCh chan<- *model.RawRecord) error {
+func (m *RingBufTracer) listenAndForwardRingBufferSSL(_ chan<- *model.RawRecord) error {
 	rtlog.Debug("listenAndForwardRingBufferSSL: waiting for SSL event...")
 	event, err := m.ringBufferSSL.ReadSSLRingBuf()
 	if err != nil {
@@ -175,12 +176,13 @@ func (m *RingBufTracer) listenAndForwardRingBufferSSL(forwardCh chan<- *model.Ra
 			rtlog.Warnf("Failed to read SSL data: read %d/%d bytes, err=%v", n, dataLen, err)
 		}
 
-		rtlog.Infof("SSL EVENT: pid=%d, timestamp=%d, data_len=%d, ssl_type=%d",
+		rtlog.Debugf("SSL EVENT: pid=%d, timestamp=%d, data_len=%d, ssl_type=%d",
 			pidTgid, timestamp, dataLen, sslType)
 		printLen := min(256, len(data))
-		rtlog.Infof("SSL data as string: %s", string(data[:printLen]))
+		rtlog.Debugf("SSL data as string: %s", string(data[:printLen]))
+		m.metrics.OpenSSLDataEventsCounter.Increase(strconv.Itoa(int(sslType)), int(dataLen))
 	} else {
-		rtlog.Infof("SSL EVENT: pid=%d, timestamp=%d, data_len=%d (invalid), ssl_type=%d",
+		rtlog.Debugf("SSL EVENT: pid=%d, timestamp=%d, data_len=%d (invalid), ssl_type=%d",
 			pidTgid, timestamp, dataLen, sslType)
 	}
 

pkg/metrics/metrics.go

@@ -164,6 +164,13 @@ var (
 		"mac",
 		"retries",
 	)
+	opensslDataEventsCounter = defineMetric(
+		"openssl_data_events_total",
+		"Number of OpenSSL data events",
+		TypeCounter,
+		"openssl_type",
+		"data_len",
+	)
 )
 
 func (def *MetricDefinition) mapLabels(labels []string) prometheus.Labels {
@@ -194,16 +201,17 @@ type Metrics struct {
 	Settings *Settings
 
 	// Shared metrics:
-	EvictionCounter        *EvictionCounter
-	EvictedFlowsCounter    *EvictionCounter
-	EvictedPacketsCounter  *EvictionCounter
-	DroppedFlowsCounter    *EvictionCounter
-	FilteredFlowsCounter   *EvictionCounter
-	NetworkEventsCounter   *EvictionCounter
-	FlowBufferSizeGauge    *FlowBufferSizeGauge
-	Errors                 *ErrorCounter
-	FlowEnrichmentCounter  *FlowEnrichmentCounter
-	InterfaceEventsCounter *InterfaceEventsCounter
+	EvictionCounter          *EvictionCounter
+	EvictedFlowsCounter      *EvictionCounter
+	EvictedPacketsCounter    *EvictionCounter
+	DroppedFlowsCounter      *EvictionCounter
+	FilteredFlowsCounter     *EvictionCounter
+	NetworkEventsCounter     *EvictionCounter
+	FlowBufferSizeGauge      *FlowBufferSizeGauge
+	Errors                   *ErrorCounter
+	FlowEnrichmentCounter    *FlowEnrichmentCounter
+	InterfaceEventsCounter   *InterfaceEventsCounter
+	OpenSSLDataEventsCounter *OpenSSLDataEventsCounter
 }
 
 func NewMetrics(settings *Settings) *Metrics {
@@ -220,6 +228,7 @@ func NewMetrics(settings *Settings) *Metrics {
 	m.Errors = &ErrorCounter{vec: m.NewCounterVec(&errorsCounter)}
 	m.FlowEnrichmentCounter = &FlowEnrichmentCounter{vec: m.NewCounterVec(&flowEnrichmentCounter)}
 	m.InterfaceEventsCounter = newInterfaceEventsCounter(m.NewCounterVec(&interfaceEventsCounter), settings.Level)
+	m.OpenSSLDataEventsCounter = &OpenSSLDataEventsCounter{vec: m.NewCounterVec(&opensslDataEventsCounter)}
 	return m
 }
 
@@ -346,6 +355,14 @@ type InterfaceEventsCounter struct {
 	Increase func(typez, ifname string, ifindex int, netns string, mac [6]uint8, retries int)
 }
 
+type OpenSSLDataEventsCounter struct {
+	vec *prometheus.CounterVec
+}
+
+func (c *OpenSSLDataEventsCounter) Increase(sslType string, dataLen int) {
+	c.vec.WithLabelValues(sslType, strconv.Itoa(dataLen)).Inc()
+}
+
 func newInterfaceEventsCounter(vec *prometheus.CounterVec, lvl Level) *InterfaceEventsCounter {
 	switch lvl {
 	case LevelTrace: