in pkg/resolvers/endpoints.go [238:259]
func (r *defaultEndpointsResolver) getPortList(pod corev1.Pod, ports []networking.NetworkPolicyPort) []policyinfo.Port {
var portList []policyinfo.Port
for _, port := range ports {
var portPtr *int32
if port.Port != nil {
portVal, _, err := k8s.LookupContainerPortAndName(&pod, *port.Port, *port.Protocol)
if err != nil {
// Isolate the pod for the port if we are unable to resolve the named port
r.logger.Info("Unable to lookup container port", "pod", k8s.NamespacedName(&pod),
"port", *port.Port, "err", err)
continue
}
portPtr = &portVal
}
portList = append(portList, policyinfo.Port{
Protocol: port.Protocol,
Port: portPtr,
EndPort: port.EndPort,
})
}
return portList
}