mirrors/kyverno
mirrors/kyverno
1
0
Fork 0
mirror of https://github.com/kyverno/kyverno.git synced 2025-03-06 16:06:56 +00:00
Code Activity

fix(gctx): add event handler before informer start (#12263)

Browse source 
Signed-off-by: liuxu <liuxu623@gmail.com>
This commit is contained in:
刘旭 2025-03-03 21:46:49 +08:00 • committed by GitHub
parent 1bbda7bc46
commit 608b9fd5b7
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 17 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
pkg/globalcontext/k8sresource/entry.go
View file

@ -76,23 +76,6 @@ func New(
return nil, err return nil, err
} }
group.StartWithContext(ctx, func(ctx context.Context) {
informer.Informer().Run(ctx.Done())
})
if !cache.WaitForCacheSync(ctx.Done(), informer.Informer().HasSynced) {
stop()
err := fmt.Errorf("failed to sync cache for %s", gvr)
eventGen.Add(entryevent.NewErrorEvent(corev1.ObjectReference{
APIVersion: gce.APIVersion,
Kind: gce.Kind,
Name: gce.Name,
Namespace: gce.Namespace,
UID: gce.UID,
}, err))
return nil, err
}
var projections []store.Projection var projections []store.Projection
if len(gce.Spec.Projections) > 0 { if len(gce.Spec.Projections) > 0 {
for _, p := range gce.Spec.Projections { for _, p := range gce.Spec.Projections {
@ -127,6 +110,23 @@ func New(
return nil, err return nil, err
} }
group.StartWithContext(ctx, func(ctx context.Context) {
informer.Informer().Run(ctx.Done())
})
if !cache.WaitForCacheSync(ctx.Done(), informer.Informer().HasSynced) {
stop()
err := fmt.Errorf("failed to sync cache for %s", gvr)
eventGen.Add(entryevent.NewErrorEvent(corev1.ObjectReference{
APIVersion: gce.APIVersion,
Kind: gce.Kind,
Name: gce.Name,
Namespace: gce.Namespace,
UID: gce.UID,
}, err))
return nil, err
}
return e, nil return e, nil
} }