func createStatMap()

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
}