From 55d9dd3325fd4158db58bb81845929e94029a6c0 Mon Sep 17 00:00:00 2001 From: msherif1234 Date: Thu, 16 Mar 2023 14:46:14 -0400 Subject: [PATCH] update flowlogs dump collector tool to include ICMP Signed-off-by: msherif1234 --- examples/flowlogs-dump/server/flowlogs-dump-collector.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/examples/flowlogs-dump/server/flowlogs-dump-collector.go b/examples/flowlogs-dump/server/flowlogs-dump-collector.go index 3d2c8ab96..2728e0b3b 100644 --- a/examples/flowlogs-dump/server/flowlogs-dump-collector.go +++ b/examples/flowlogs-dump/server/flowlogs-dump-collector.go @@ -72,7 +72,7 @@ func main() { for records := range receivedRecords { for _, record := range records.Entries { if record.EthProtocol == ipv6 { - log.Printf("%s: %v %s IP %s:%d > %s:%d: protocol:%s dir:%d bytes:%d packets:%d flags:%d ends: %v\n", + log.Printf("%s: %v %s IP %s:%d > %s:%d: protocol:%s type: %d code: %d dir:%d bytes:%d packets:%d flags:%d ends: %v\n", ipProto[record.EthProtocol], record.TimeFlowStart.AsTime().Local().Format("15:04:05.000000"), record.Interface, @@ -81,6 +81,8 @@ func main() { net.IP(record.Network.GetDstAddr().GetIpv6()).To16(), record.Transport.DstPort, protocolByNumber[record.Transport.Protocol], + record.Icmp.IcmpType, + record.Icmp.IcmpCode, record.Direction, record.Bytes, record.Packets, @@ -88,7 +90,7 @@ func main() { record.TimeFlowEnd.AsTime().Local().Format("15:04:05.000000"), ) } else { - log.Printf("%s: %v %s IP %s:%d > %s:%d: protocol:%s dir:%d bytes:%d packets:%d flags:%d ends: %v\n", + log.Printf("%s: %v %s IP %s:%d > %s:%d: protocol:%s type: %d code: %d dir:%d bytes:%d packets:%d flags:%d ends: %v\n", ipProto[record.EthProtocol], record.TimeFlowStart.AsTime().Local().Format("15:04:05.000000"), record.Interface, @@ -97,6 +99,8 @@ func main() { ipIntToNetIP(record.Network.GetDstAddr().GetIpv4()).String(), record.Transport.DstPort, protocolByNumber[record.Transport.Protocol], + record.Icmp.IcmpType, + record.Icmp.IcmpCode, record.Direction, record.Bytes, record.Packets,