added to unit test

netobserv · Aug 1, 2022 · 2b75e4c · 2b75e4c
1 parent 8b83739
commit 2b75e4c
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/pipeline/extract/aggregate/aggregate_test.go b/pkg/pipeline/extract/aggregate/aggregate_test.go
@@ -97,8 +97,13 @@ func Test_FilterEntry(t *testing.T) {
 	entry := test.GetIngestMockEntry(false)
 
 	err, _, _ := aggregate.FilterEntry(entry)
+	require.Equal(t, err, nil)
 
+	err, normalizedLabels, labels := aggregate.FilterEntry(entry)
 	require.Equal(t, err, nil)
+	require.Equal(t, Labels{"srcIP": "10.0.0.1", "dstIP": "20.0.0.2"}, labels)
+	require.Equal(t, NormalizedValues("20.0.0.2,10.0.0.1"), normalizedLabels)
+
 	entry = test.GetIngestMockEntry(true)
 
 	err, _, _ = aggregate.FilterEntry(entry)