func()

in internal/eventhandlers/pod.go [84:101]

• 18 lines of code
• 4 McCabe index (conditional complexity)

func (h *enqueueRequestForPodEvent) enqueueReferredPolicies(ctx context.Context, _ workqueue.TypedRateLimitingInterface[reconcile.Request], pod *corev1.Pod, podOld *corev1.Pod) {
	if len(k8s.GetPodIP(pod)) == 0 {
		h.logger.V(1).Info("Pod does not have an IP yet", "pod", k8s.NamespacedName(pod))
		return
	}
	referredPolicies, err := h.policyResolver.GetReferredPoliciesForPod(ctx, pod, podOld)
	if err != nil {
		h.logger.Error(err, "Unable to get referred policies", "pod", k8s.NamespacedName(pod))
		return
	}
	for i := range referredPolicies {
		policy := &referredPolicies[i]
		h.logger.V(1).Info("Enqueue from pod reference", "policy", k8s.NamespacedName(policy), "pod", k8s.NamespacedName(pod))
		h.policyEventChan <- event.GenericEvent{
			Object: policy,
		}
	}
}