Skip to content

Commit e33e690

Browse files
authored
Fix v6 ipfix export (#94)
1 parent 66d4247 commit e33e690

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

pkg/exporter/ipfix.go

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -321,9 +321,16 @@ func (ipf *IPFIX) sendDataRecord(log *logrus.Entry, record *flow.Record, v6 bool
321321
if err != nil {
322322
return err
323323
}
324-
err = dataSet.AddRecord(ipf.entitiesV4, templateID)
325-
if err != nil {
326-
return err
324+
if v6 {
325+
err = dataSet.AddRecord(ipf.entitiesV6, templateID)
326+
if err != nil {
327+
return err
328+
}
329+
} else {
330+
err = dataSet.AddRecord(ipf.entitiesV4, templateID)
331+
if err != nil {
332+
return err
333+
}
327334
}
328335
_, err = ipf.exporter.SendSet(dataSet)
329336
if err != nil {

0 commit comments

Comments
 (0)