func()

in pkg/resolvers/endpoints.go [133:159]

• 27 lines of code
• 6 McCabe index (conditional complexity)

func (r *defaultEndpointsResolver) getAllowAllNetworkPeers(ctx context.Context, policy *networking.NetworkPolicy, ports []networking.NetworkPolicyPort, policyType networking.PolicyType) []policyinfo.EndpointInfo {
	var portList []policyinfo.Port
	for _, port := range ports {
		portInfo := r.convertToPolicyInfoPortForCIDRs(port)
		if portInfo != nil {
			portList = append(portList, *portInfo)
		} else {
			if policyType == networking.PolicyTypeIngress {
				ports := r.getIngressRulesPorts(ctx, policy.Namespace, &policy.Spec.PodSelector, []networking.NetworkPolicyPort{port})
				portList = append(portList, ports...)
			}
		}
	}
	if len(ports) != 0 && len(portList) == 0 {
		return nil
	}
	return []policyinfo.EndpointInfo{
		{
			CIDR:  "0.0.0.0/0",
			Ports: portList,
		},
		{
			CIDR:  "::/0",
			Ports: portList,
		},
	}
}