add ingress and egress vrfid to nf producer

sahejsingh · Apr 11, 2019 · 414573a · 414573a
1 parent 46bd1b0
commit 414573a
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/decoders/netflow/nfv9.go b/decoders/netflow/nfv9.go
@@ -229,6 +229,8 @@ func NFv9TypeToString(typeId uint16) string {
 		102: "layer2packetSectionOffset",
 		103: "layer2packetSectionSize",
 		104: "layer2packetSectionData",
+		234: "ingressVRFID",
+		235: "egressVRFID",
 	}
 
 	if typeId > 104 || typeId == 0 {

diff --git a/producer/producer_nf.go b/producer/producer_nf.go
@@ -259,6 +259,11 @@ func ConvertNetFlowDataSet(version uint16, baseTime uint32, uptime uint32, recor
 		case netflow.NFV9_FIELD_DST_VLAN:
 			DecodeUNumber(v, &(flowMessage.DstVlan))
 
+		case netflow.IPFIX_FIELD_ingressVRFID:
+			DecodeUNumber(v, &(flowMessage.IngressVrfId))
+		case netflow.IPFIX_FIELD_egressVRFID:
+			DecodeUNumber(v, &(flowMessage.EgressVrfId))
+
 		case netflow.NFV9_FIELD_IPV4_IDENT:
 			DecodeUNumber(v, &(flowMessage.FragmentId))
 		case netflow.NFV9_FIELD_FRAGMENT_OFFSET: