github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Remove unnecessary GetIndexer

Browse Source 
Signed-off-by: kerthcet <kerthcet@gmail.com>
This commit is contained in:
kerthcet
2023-10-24 23:03:34 +08:00
parent 4734021993
commit b1ce529b2a
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/scheduler/scheduler_test.go
View File

@@ -540,7 +540,7 @@ func TestInitPluginsWithIndexers(t *testing.T) {
entrypoints: map[string]frameworkruntime.PluginFactory{ entrypoints: map[string]frameworkruntime.PluginFactory{
"AddIndexer": func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error) { "AddIndexer": func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error) {
podInformer := handle.SharedInformerFactory().Core().V1().Pods() podInformer := handle.SharedInformerFactory().Core().V1().Pods()
err := podInformer.Informer().GetIndexer().AddIndexers(cache.Indexers{ err := podInformer.Informer().AddIndexers(cache.Indexers{
"nodeName": indexByPodSpecNodeName, "nodeName": indexByPodSpecNodeName,
}) })
return &TestPlugin{name: "AddIndexer"}, err return &TestPlugin{name: "AddIndexer"}, err
@@ -553,14 +553,14 @@ func TestInitPluginsWithIndexers(t *testing.T) {
entrypoints: map[string]frameworkruntime.PluginFactory{ entrypoints: map[string]frameworkruntime.PluginFactory{
"AddIndexer1": func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error) { "AddIndexer1": func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error) {
podInformer := handle.SharedInformerFactory().Core().V1().Pods() podInformer := handle.SharedInformerFactory().Core().V1().Pods()
err := podInformer.Informer().GetIndexer().AddIndexers(cache.Indexers{ err := podInformer.Informer().AddIndexers(cache.Indexers{
"nodeName": indexByPodSpecNodeName, "nodeName": indexByPodSpecNodeName,
}) })
return &TestPlugin{name: "AddIndexer1"}, err return &TestPlugin{name: "AddIndexer1"}, err
}, },
"AddIndexer2": func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error) { "AddIndexer2": func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error) {
podInformer := handle.SharedInformerFactory().Core().V1().Pods() podInformer := handle.SharedInformerFactory().Core().V1().Pods()
err := podInformer.Informer().GetIndexer().AddIndexers(cache.Indexers{ err := podInformer.Informer().AddIndexers(cache.Indexers{
"nodeName": indexByPodAnnotationNodeName, "nodeName": indexByPodAnnotationNodeName,
}) })
return &TestPlugin{name: "AddIndexer1"}, err return &TestPlugin{name: "AddIndexer1"}, err
@@ -574,14 +574,14 @@ func TestInitPluginsWithIndexers(t *testing.T) {
entrypoints: map[string]frameworkruntime.PluginFactory{ entrypoints: map[string]frameworkruntime.PluginFactory{
"AddIndexer1": func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error) { "AddIndexer1": func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error) {
podInformer := handle.SharedInformerFactory().Core().V1().Pods() podInformer := handle.SharedInformerFactory().Core().V1().Pods()
err := podInformer.Informer().GetIndexer().AddIndexers(cache.Indexers{ err := podInformer.Informer().AddIndexers(cache.Indexers{
"nodeName1": indexByPodSpecNodeName, "nodeName1": indexByPodSpecNodeName,
}) })
return &TestPlugin{name: "AddIndexer1"}, err return &TestPlugin{name: "AddIndexer1"}, err
}, },
"AddIndexer2": func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error) { "AddIndexer2": func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error) {
podInformer := handle.SharedInformerFactory().Core().V1().Pods() podInformer := handle.SharedInformerFactory().Core().V1().Pods()
err := podInformer.Informer().GetIndexer().AddIndexers(cache.Indexers{ err := podInformer.Informer().AddIndexers(cache.Indexers{
"nodeName2": indexByPodAnnotationNodeName, "nodeName2": indexByPodAnnotationNodeName,
}) })
return &TestPlugin{name: "AddIndexer2"}, err return &TestPlugin{name: "AddIndexer2"}, err