mirrors/kyverno
1
0
Fork 0
mirror of https://github.com/kyverno/kyverno.git synced 2024-12-14 11:57:48 +00:00
Code Activity

fix: watch error in resource controller (#4751)

Browse source 
Signed-off-by: Charles-Edouard Brétéché <charled.breteche@gmail.com>
This commit is contained in:
Charles-Edouard Brétéché 2022-09-29 20:09:34 +02:00 committed by GitHub
parent 5a3532da91
commit 7fa796e24a
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 38 additions and 29 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
pkg/controllers/report/resource/controller.go
View file

@ -139,7 +139,10 @@ func (c *controller) updateDynamicWatchers() error {
delete(c.dynamicWatchers, gvr)
} else {
logger.Info("start watcher ...", "gvr", gvr)
watchInterface, _ := c.client.GetDynamicInterface().Resource(gvr).Watch(context.TODO(), metav1.ListOptions{})
watchInterface, err := c.client.GetDynamicInterface().Resource(gvr).Watch(context.TODO(), metav1.ListOptions{})
if err != nil {
logger.Error(err, "failed to create watcher", "gvr", gvr)
} else {
w := &watcher{
watcher: watchInterface,
gvk: gvr.GroupVersion().WithKind(kind),
@ -159,8 +162,11 @@ func (c *controller) updateDynamicWatchers() error {
}
}
}()
dynamicWatchers[gvr] = w
objs, _ := c.client.GetDynamicInterface().Resource(gvr).List(context.TODO(), metav1.ListOptions{})
objs, err := c.client.GetDynamicInterface().Resource(gvr).List(context.TODO(), metav1.ListOptions{})
if err != nil {
logger.Error(err, "failed to list resources", "gvr", gvr)
watchInterface.Stop()
} else {
for _, obj := range objs.Items {
uid := obj.GetUID()
hash := reportutils.CalculateResourceHash(obj)
@ -171,6 +177,9 @@ func (c *controller) updateDynamicWatchers() error {
}
c.notify(uid, w.gvk, w.hashes[uid])
}
dynamicWatchers[gvr] = w
}
}
}
}
// shutdown remaining watcher