fix unit-test

Signed-off-by: Mohamed Mahmoud <[email protected]>
netobserv · Jan 14, 2025 · cb0355d · cb0355d
1 parent f6b2996
commit cb0355d
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/pkg/pipeline/pipeline_test.go b/pkg/pipeline/pipeline_test.go
@@ -177,7 +177,14 @@ parameters:
 	someDuration := endTime.Sub(startTime)
 	_, err = flowSender.Client().Send(context.Background(), &pbflow.Records{
 		Entries: []*pbflow.Record{{
-			Interface:     "eth0",
+			Interface: "eth0",
+			DupList: []*pbflow.DupMapEntry{
+				{
+					Interface: "eth0",
+					Direction: pbflow.Direction_EGRESS,
+					Udn:       "udn-1",
+				},
+			},
 			EthProtocol:   2048,
 			Bytes:         456,
 			Packets:       123,
@@ -243,6 +250,7 @@ parameters:
 		"TimeFlowStartMs":        float64(startTime.UnixMilli()),
 		"TimeFlowEndMs":          float64(endTime.UnixMilli()),
 		"Interfaces":             []interface{}{"eth0"},
+		"Udns":                   []interface{}{"udn-1"},
 		"AgentIP":                "10.11.12.13",
 		"PktDropBytes":           float64(100),
 		"PktDropPackets":         float64(10),