fix cooldownqueue key from event

Signed-off-by: Matthias Bertschy <[email protected]>

utils/cooldownqueue.go

@@ -1,11 +1,11 @@
 package utils
 
 import (
+	"strings"
 	"time"
 
-	"github.com/kubescape/synchronizer/domain"
 	"istio.io/pkg/cache"
-	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/watch"
 )
 
@@ -14,7 +14,7 @@ const (
 	evictionInterval  = 1 * time.Second
 )
 
-// CooldownQueue is a queue that lets clients put events into it with a cooldown
+// CooldownQueue i a queue that lets clients put events into it with a cooldown
 //
 // When a client puts an event into a queue, it waits for a cooldown period before
 // the event is forwarded to the consumer. If and event for the same key is put into the queue
@@ -44,20 +44,9 @@ func NewCooldownQueue() *CooldownQueue {
 
 // makeEventKey creates a unique key for an event from a watcher
 func makeEventKey(e watch.Event) string {
-	object, ok := e.Object.(*unstructured.Unstructured)
-	if !ok {
-		return ""
-	}
-	id := domain.KindName{
-		Kind: &domain.Kind{
-			Group:    object.GetAPIVersion(),
-			Resource: object.GetKind(),
-		},
-		Name:      object.GetName(),
-		Namespace: object.GetNamespace(),
-	}
-
-	return id.String()
+	gvk := e.Object.GetObjectKind().GroupVersionKind()
+	meta := e.Object.(metav1.Object)
+	return strings.Join([]string{gvk.Group, gvk.Version, gvk.Kind, meta.GetNamespace(), meta.GetName()}, "/")
 }
 
 func (q *CooldownQueue) Closed() bool {