in pkg/resolvers/endpoints.go [43:61]
func (r *defaultEndpointsResolver) Resolve(ctx context.Context, policy *networking.NetworkPolicy) ([]policyinfo.EndpointInfo,
[]policyinfo.EndpointInfo, []policyinfo.PodEndpoint, error) {
ingressEndpoints, err := r.computeIngressEndpoints(ctx, policy)
if err != nil {
return nil, nil, nil, err
}
egressEndpoints, err := r.computeEgressEndpoints(ctx, policy)
if err != nil {
return nil, nil, nil, err
}
podSelectorEndpoints, err := r.computePodSelectorEndpoints(ctx, policy)
if err != nil {
return nil, nil, nil, err
}
r.logger.Info("Resolved endpoints", "policy", k8s.NamespacedName(policy), "ingress", len(ingressEndpoints), "egress",
len(egressEndpoints), "pod selector endpoints", len(podSelectorEndpoints))
return ingressEndpoints, egressEndpoints, podSelectorEndpoints, nil
}