Implement watch mechanism for all resources

cyclops-ctrl/internal/cluster/k8sclient/client.go

@@ -1077,3 +1077,39 @@ func isRole(group, version, kind string) bool {
 func isNetworkPolicy(group, version, kind string) bool {
 	return group == "networking.k8s.io" && version == "v1" && kind == "NetworkPolicy"
 }
+
+func WatchResource(clientset *kubernetes.Clientset, group, version, kind, name, namespace string) (<-chan watch.Event, error) {
+    // Create a channel to publish events
+    eventChannel := make(chan watch.Event)
+
+    // Define a context
+    ctx, cancel := context.WithCancel(context.Background())
+
+    // Create a dynamic client for the specified resource
+    dynamicClient, err := dynamic.NewForConfig(clientset.RESTConfig())
+    if err != nil {
+        return nil, err
+    }
+
+    resource := schema.GroupVersionResource{Group: group, Version: version, Resource: kind}
+
+    // Start the watch
+    watch, err := dynamicClient.Resource(resource).Namespace(namespace).Watch(ctx, metav1.ListOptions{
+        FieldSelector: "metadata.name=" + name,
+    })
+    if err != nil {
+        cancel()
+        return nil, err
+    }
+
+    // Goroutine to handle watch events
+    go func() {
+        defer close(eventChannel)
+        defer cancel()
+        for event := range watch.ResultChan() {
+            eventChannel <- event
+        }
+    }()
+
+    return eventChannel, nil
+}