koord-descheduler: add arbitration to migration controller.

1.remove lock in migration Reconciler;
2.move codes from migration/filter.go to migration/controller.go;
3.remove some comments;
4.remove explicit initialization of mu in arbitration/filter.go;

Signed-off-by: baowj <[email protected]>

pkg/descheduler/controllers/migration/arbitrator/filter.go

@@ -85,7 +85,6 @@ func NewFilter(args *deschedulerconfig.MigrationControllerArgs, handle framework
 		client:           options.Manager.GetClient(),
 		args:             args,
 		controllerFinder: controllerFinder,
-		mu:               sync.Mutex{},
 		clock:            clock.RealClock{},
 	}
 	if err := f.initFilters(args, handle); err != nil {

pkg/descheduler/controllers/migration/controller.go

@@ -20,7 +20,6 @@ import (
 	"context"
 	"fmt"
 	"strconv"
-	"sync"
 	"time"
 
 	corev1 "k8s.io/api/core/v1"
@@ -76,7 +75,6 @@ type Reconciler struct {
 	assumedCache           *assumedCache
 	clock                  clock.Clock
 
-	lock   sync.Mutex
 	filter arbitrator.MigrationFilter
 }
 
@@ -100,14 +98,12 @@ func New(args runtime.Object, handle framework.Handle) (framework.Plugin, error)
 		return nil, err
 	}
 
-	// New filter
 	filter, arbitrationFilter, err := arbitrator.NewFilter(controllerArgs, handle)
 	if err != nil {
 		return nil, err
 	}
 	r.filter = filter
 
-	// New Arbitrator
 	a, err := arbitrator.New(controllerArgs.ArbitrationArgs, arbitrator.Options{
 		Client:        r.Client,
 		EventRecorder: r.eventRecorder,
@@ -928,3 +924,12 @@ func (r *Reconciler) updateCondition(ctx context.Context, job *sev1alpha1.PodMig
 	}
 	return nil
 }
+
+// Filter checks if a pod can be evicted
+func (r *Reconciler) Filter(pod *corev1.Pod) bool {
+	return r.filter.Filter(pod)
+}
+
+func (r *Reconciler) PreEvictionFilter(pod *corev1.Pod) bool {
+	return r.filter.PreEvictionFilter(pod)
+}