Skip to content

Commit fae4102

Browse files
committed
Add namespace index to pod informer
Signed-off-by: kerthcet <[email protected]>
1 parent 48f67e2 commit fae4102

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

pkg/coscheduling/coscheduling.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@ import (
2525
"k8s.io/apimachinery/pkg/labels"
2626
"k8s.io/apimachinery/pkg/runtime"
2727
clientscheme "k8s.io/client-go/kubernetes/scheme"
28+
"k8s.io/client-go/tools/cache"
2829
corev1helpers "k8s.io/component-helpers/scheduling/corev1"
2930
"k8s.io/klog/v2"
3031
"k8s.io/kubernetes/pkg/scheduler/framework"
@@ -74,6 +75,9 @@ func New(obj runtime.Object, handle framework.Handle) (framework.Plugin, error)
7475
return nil, err
7576
}
7677

78+
// Performance improvement when retrieving list of objects by namespace or we'll log 'index not exist' warning.
79+
handle.SharedInformerFactory().Core().V1().Pods().Informer().AddIndexers(cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc})
80+
7781
scheduleTimeDuration := time.Duration(args.PermitWaitingTimeSeconds) * time.Second
7882
pgMgr := core.NewPodGroupManager(
7983
client,

0 commit comments

Comments
 (0)