feat(standalone): Polishing

Author: BeegiiK

pkg/enricher/enricher.go

@@ -43,21 +43,24 @@ type Enricher struct {
 	enableStandalone bool
 }
 
+func newEnricher(ctx context.Context, cache c.CacheInterface, enableStandalone bool) *Enricher {
+	ir := container.NewRing(container.Capacity1023)
+	return &Enricher{
+		ctx:              ctx,
+		l:                log.Logger().Named("enricher"),
+		cache:            cache,
+		inputRing:        ir,
+		Reader:           container.NewRingReader(ir, ir.OldestWrite()),
+		outputRing:       container.NewRing(container.Capacity1023),
+		enableStandalone: enableStandalone,
+	}
+}
+
 func New(ctx context.Context, cache c.CacheInterface, enableStandalone bool) *Enricher {
 	once.Do(func() {
-		ir := container.NewRing(container.Capacity1023)
-		e = &Enricher{
-			ctx:              ctx,
-			l:                log.Logger().Named("enricher"),
-			cache:            cache,
-			inputRing:        ir,
-			Reader:           container.NewRingReader(ir, ir.OldestWrite()),
-			outputRing:       container.NewRing(container.Capacity1023),
-			enableStandalone: enableStandalone,
-		}
+		e = newEnricher(ctx, cache, enableStandalone)
 		initialized = true
 	})
-
 	return e
 }
 

pkg/enricher/enricher_test.go

@@ -75,7 +75,7 @@ func TestEnricherSecondaryIPs(t *testing.T) {
 	require.NoError(t, err)
 
 	// get the enricher
-	e := New(ctx, c, false)
+	e := newEnricher(ctx, c, false)
 	var wg sync.WaitGroup
 
 	wg.Add(1)
@@ -180,7 +180,7 @@ func TestEnricherStandaloneWithEndpointPresent(t *testing.T) {
 	require.NoError(t, testCache.UpdateRetinaEndpoint(endpoint))
 
 	// Create the enricher with standalone enabled
-	enricher := New(ctx, testCache, true)
+	enricher := newEnricher(ctx, testCache, true)
 	var wg sync.WaitGroup
 
 	wg.Add(1)
@@ -245,7 +245,7 @@ func TestEnricherStandaloneWithEndpointAbsent(t *testing.T) {
 	sourceIP := "9.9.9.9" // No endpoint present in cache
 
 	// Create the enricher with standalone enabled
-	enricher := New(ctx, testCache, true)
+	enricher := newEnricher(ctx, testCache, true)
 	var wg sync.WaitGroup
 
 	wg.Add(1)

pkg/module/metrics/standalone/metrics_module.go

@@ -15,6 +15,6 @@ func InitModule(_ context.Context, _ enricher.EnricherInterface) *Module {
 	return &Module{}
 }
 
-func (m *Module) Reconcile(ctx context.Context) {}
+func (m *Module) Reconcile(_ context.Context) {}
 
 func (m *Module) Clear() {}