in pkg/metrics/collector/netlink_metrics.go [215:230]
func createStatMap(snapshots []*parser.Snapshot) map[*v1.Pod]netlinkStats {
statMap := make(map[*v1.Pod]netlinkStats)
for _, snapshot := range snapshots {
if snapshot.SockInfo == nil {
continue
}
if pod, ok := ipMap.safeIPRead(snapshot.SockInfo.SrcIP); ok {
statMap[pod] = updatePodStats(statMap[pod], snapshot.TCPInfo)
}
if pod, ok := ipMap.safeIPRead(snapshot.SockInfo.DstIP); ok {
statMap[pod] = updatePodStats(statMap[pod], snapshot.TCPInfo)
}
}
return statMap
}