Change RTT output to ns (#468)

Author: dushyantbehl

pkg/pipeline/decode/decode_protobuf.go

@@ -88,8 +88,8 @@ func PBFlowToMap(flow *pbflow.Record) config.GenericMap {
 		out["PktDropLatestDropCause"] = pktDropCauseToStr(flow.GetPktDropLatestDropCause())
 	}
 
-	if flow.TimeFlowRtt.AsDuration().Milliseconds() != 0 {
-		out["TimeFlowRttMs"] = flow.TimeFlowRtt.AsDuration().Milliseconds()
+	if flow.TimeFlowRtt.AsDuration().Nanoseconds() != 0 {
+		out["TimeFlowRttNs"] = flow.TimeFlowRtt.AsDuration().Nanoseconds()
 	}
 	return out
 }

pkg/pipeline/decode/decode_protobuf_test.go

@@ -93,7 +93,7 @@ func TestDecodeProtobuf(t *testing.T) {
 		"DnsId":                  uint32(1),
 		"DnsFlags":               uint32(0x8001),
 		"DnsFlagsResponseCode":   "FormErr",
-		"TimeFlowRttMs":          someDuration.Milliseconds(),
+		"TimeFlowRttNs":          someDuration.Nanoseconds(),
 	}, out)
 }
 
@@ -171,7 +171,7 @@ func TestPBFlowToMap(t *testing.T) {
 		"DnsId":                  uint32(1),
 		"DnsFlags":               uint32(0x80),
 		"DnsFlagsResponseCode":   "NoError",
-		"TimeFlowRttMs":          someDuration.Milliseconds(),
+		"TimeFlowRttNs":          someDuration.Nanoseconds(),
 	}, out)
 
 }

pkg/pipeline/pipeline_test.go

@@ -251,7 +251,7 @@ parameters:
 		"DnsId":                  float64(1),
 		"DnsFlags":               float64(0x80),
 		"DnsFlagsResponseCode":   "NoError",
-		"TimeFlowRttMs":          float64(someDuration.Milliseconds()),
+		"TimeFlowRttNs":          float64(someDuration.Nanoseconds()),
 	}, capturedRecord)
 }