Skip to content

Commit 1721a4f

Browse files
fix event aggregation test
Signed-off-by: Dmitri Dolguikh <dmitri.external@netbird.io>
1 parent 9ea463e commit 1721a4f

2 files changed

Lines changed: 1 addition & 2 deletions

File tree

client/internal/netflow/store/event_aggregation_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -176,7 +176,7 @@ func generateEvents(srcIp, dstIp netip.Addr, dstPort uint16, eventTypes []types.
176176
Timestamp: inEvents[0].Timestamp,
177177
EventFields: types.EventFields{
178178
FlowID: flowId,
179-
Type: inEvents[0].Type,
179+
Type: types.TypeUnknown,
180180
Protocol: inEvents[0].Protocol,
181181
RuleID: []byte("rule-id-1"),
182182
Direction: inEvents[0].Direction,

client/internal/netflow/store/memory.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,6 @@ func (am *AggregatingMemory) GetAggregatedEvents() []*types.Event {
134134
if aggregatedEvent.Timestamp.Compare(v.Timestamp) > 0 {
135135
aggregatedEvent.Timestamp = v.Timestamp
136136
aggregatedEvent.ID = v.ID
137-
aggregatedEvent.Type = v.Type
138137
}
139138
}
140139

0 commit comments

Comments
 (0)