Merge pull request kubernetes#84073 from draveness/feature/cleanup-framework-plugins

feat: several cleanups in the scheduling package

Author: k8s-ci-robot

pkg/scheduler/algorithm/predicates/metadata_test.go

@@ -39,7 +39,7 @@ func (s sortablePods) Less(i, j int) bool {
 func (s sortablePods) Len() int      { return len(s) }
 func (s sortablePods) Swap(i, j int) { s[i], s[j] = s[j], s[i] }
 
-var _ = sort.Interface(&sortablePods{})
+var _ sort.Interface = &sortablePods{}
 
 // sortableServices allows us to sort services.
 type sortableServices []*v1.Service
@@ -51,7 +51,7 @@ func (s sortableServices) Less(i, j int) bool {
 func (s sortableServices) Len() int      { return len(s) }
 func (s sortableServices) Swap(i, j int) { s[i], s[j] = s[j], s[i] }
 
-var _ = sort.Interface(&sortableServices{})
+var _ sort.Interface = &sortableServices{}
 
 // predicateMetadataEquivalent returns true if the two metadata are equivalent.
 // Note: this function does not compare podRequest.

pkg/scheduler/framework/plugins/examples/multipoint/multipoint.go

@@ -28,8 +28,8 @@ import (
 // extension points. It communicates through state with another function.
 type CommunicatingPlugin struct{}
 
-var _ = framework.ReservePlugin(CommunicatingPlugin{})
-var _ = framework.PreBindPlugin(CommunicatingPlugin{})
+var _ framework.ReservePlugin = CommunicatingPlugin{}
+var _ framework.PreBindPlugin = CommunicatingPlugin{}
 
 // Name is the name of the plug used in Registry and configurations.
 const Name = "multipoint-communicating-plugin"

pkg/scheduler/framework/plugins/examples/prebind/prebind.go

@@ -29,7 +29,7 @@ import (
 // and implements only one hook for prebind.
 type StatelessPreBindExample struct{}
 
-var _ = framework.PreBindPlugin(StatelessPreBindExample{})
+var _ framework.PreBindPlugin = StatelessPreBindExample{}
 
 // Name is the name of the plugin used in Registry and configurations.
 const Name = "stateless-prebind-plugin-example"

pkg/scheduler/framework/plugins/examples/stateful/stateful.go

@@ -36,8 +36,8 @@ type MultipointExample struct {
 	mu      sync.RWMutex
 }
 
-var _ = framework.ReservePlugin(&MultipointExample{})
-var _ = framework.PreBindPlugin(&MultipointExample{})
+var _ framework.ReservePlugin = &MultipointExample{}
+var _ framework.PreBindPlugin = &MultipointExample{}
 
 // Name is the name of the plug used in Registry and configurations.
 const Name = "multipoint-plugin-example"

pkg/scheduler/framework/plugins/imagelocality/image_locality.go

@@ -29,12 +29,12 @@ import (
 
 var mb int64 = 1024 * 1024
 
-// ImageLocality is a plugin that checks if a pod tolerates a node's taints.
+// ImageLocality is a score plugin that favors nodes that already have requested pod container's images.
 type ImageLocality struct {
 	handle framework.FrameworkHandle
 }
 
-var _ = framework.ScorePlugin(&ImageLocality{})
+var _ framework.ScorePlugin = &ImageLocality{}
 
 // Name is the name of the plugin used in the plugin registry and configurations.
 const Name = "ImageLocality"

pkg/scheduler/framework/plugins/nodename/node_name.go

@@ -30,7 +30,7 @@ import (
 // NodeName is a plugin that checks if a pod spec node name matches the current node.
 type NodeName struct{}
 
-var _ = framework.FilterPlugin(&NodeName{})
+var _ framework.FilterPlugin = &NodeName{}
 
 // Name is the name of the plugin used in the plugin registry and configurations.
 const Name = "NodeName"

pkg/scheduler/framework/plugins/nodename/node_name_test.go

@@ -32,14 +32,12 @@ func TestNodeName(t *testing.T) {
 	tests := []struct {
 		pod        *v1.Pod
 		node       *v1.Node
-		fits       bool
 		name       string
 		wantStatus *framework.Status
 	}{
 		{
 			pod:  &v1.Pod{},
 			node: &v1.Node{},
-			fits: true,
 			name: "no host specified",
 		},
 		{
@@ -53,7 +51,6 @@ func TestNodeName(t *testing.T) {
 					Name: "foo",
 				},
 			},
-			fits: true,
 			name: "host matches",
 		},
 		{
@@ -67,7 +64,6 @@ func TestNodeName(t *testing.T) {
 					Name: "foo",
 				},
 			},
-			fits:       false,
 			name:       "host doesn't match",
 			wantStatus: framework.NewStatus(framework.UnschedulableAndUnresolvable, predicates.ErrPodNotMatchHostName.GetReason()),
 		},

pkg/scheduler/framework/plugins/nodeports/node_ports.go

@@ -30,7 +30,7 @@ import (
 // NodePorts is a plugin that checks if a node has free ports for the requested pod ports.
 type NodePorts struct{}
 
-var _ = framework.FilterPlugin(&NodePorts{})
+var _ framework.FilterPlugin = &NodePorts{}
 
 // Name is the name of the plugin used in the plugin registry and configurations.
 const Name = "NodePorts"

pkg/scheduler/framework/plugins/noderesources/node_resources.go

@@ -31,7 +31,7 @@ import (
 // NodeResources is a plugin that checks if a node has sufficient resources.
 type NodeResources struct{}
 
-var _ = framework.FilterPlugin(&NodeResources{})
+var _ framework.FilterPlugin = &NodeResources{}
 
 // Name is the name of the plugin used in the plugin registry and configurations.
 const Name = "NodeResources"

pkg/scheduler/framework/plugins/nodevolumelimits/node_volume_limits.go

@@ -19,7 +19,7 @@ package nodevolumelimits
 import (
 	"context"
 
-	"k8s.io/api/core/v1"
+	v1 "k8s.io/api/core/v1"
 	"k8s.io/kubernetes/pkg/scheduler/algorithm/predicates"
 	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/migration"
 	framework "k8s.io/kubernetes/pkg/scheduler/framework/v1alpha1"
@@ -31,7 +31,7 @@ type NodeVolumeLimits struct {
 	predicate predicates.FitPredicate
 }
 
-var _ = framework.FilterPlugin(&NodeVolumeLimits{})
+var _ framework.FilterPlugin = &NodeVolumeLimits{}
 
 // Name is the name of the plugin used in the plugin registry and configurations.
 const Name = "NodeVolumeLimits"