From cb0355d3e7a7d161fa156d047112eb040fb419a7 Mon Sep 17 00:00:00 2001 From: Mohamed Mahmoud Date: Tue, 14 Jan 2025 13:48:41 -0500 Subject: [PATCH] fix unit-test Signed-off-by: Mohamed Mahmoud --- pkg/pipeline/pipeline_test.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/pkg/pipeline/pipeline_test.go b/pkg/pipeline/pipeline_test.go index be68af181..d70bb7865 100644 --- 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),