func()

in internal/eventhandlers/policy.go [60:70]


func (h *enqueueRequestForPolicyEvent) Update(_ context.Context, e event.UpdateEvent, queue workqueue.TypedRateLimitingInterface[reconcile.Request]) {
	oldPolicy := e.ObjectOld.(*networking.NetworkPolicy)
	newPolicy := e.ObjectNew.(*networking.NetworkPolicy)

	h.logger.V(1).Info("Handling update event", "policy", k8s.NamespacedName(newPolicy))
	if !equality.Semantic.DeepEqual(newPolicy.ResourceVersion, oldPolicy.ResourceVersion) && equality.Semantic.DeepEqual(oldPolicy.Spec, newPolicy.Spec) &&
		equality.Semantic.DeepEqual(oldPolicy.DeletionTimestamp.IsZero(), newPolicy.DeletionTimestamp.IsZero()) {
		return
	}
	h.enqueuePolicy(queue, newPolicy, 0)
}