remove evictionworker interface

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

Author: whosefriendA

pkg/controllers/cluster/eviction_worker.go

@@ -29,13 +29,6 @@ import (
 	"github.com/karmada-io/karmada/pkg/util/fedinformer/genericmanager"
 )
 
-// EvictionWorker enhances AsyncWorker with dynamic rate limiting and metrics
-// for eviction operations. It provides a queue that adjusts its processing rate
-// based on cluster health status.
-type EvictionWorker interface {
-	util.AsyncWorker
-}
-
 // EvictionQueueOptions holds the options that control the behavior of the graceful eviction queue based on the overall health of the clusters.
 type EvictionQueueOptions struct {
 	// ResourceEvictionRate is the number of resources to be evicted per second.
@@ -55,7 +48,7 @@ type EvictionQueueOptions struct {
 	LargeClusterNumThreshold int
 }
 
-type evictionWorker struct {
+type EvictionWorker struct {
 	name             string
 	keyFunc          util.KeyFunc
 	reconcileFunc    util.ReconcileFunc
@@ -95,7 +88,7 @@ func NewEvictionWorker(opts EvictionWorkerOptions) EvictionWorker {
 		opts.RateLimiterOptions,
 	)
 
-	return &evictionWorker{
+	return EvictionWorker{
 		name:             opts.Name,
 		keyFunc:          opts.KeyFunc,
 		reconcileFunc:    opts.ReconcileFunc,
@@ -107,7 +100,7 @@ func NewEvictionWorker(opts EvictionWorkerOptions) EvictionWorker {
 }
 
 // Enqueue converts an object to a key and adds it to the queue.
-func (w *evictionWorker) Enqueue(obj interface{}) {
+func (w *EvictionWorker) Enqueue(obj interface{}) {
 	key, err := w.keyFunc(obj)
 	if err != nil {
 		klog.Errorf("Failed to generate key for obj: %+v, err: %v", obj, err)
@@ -122,7 +115,7 @@ func (w *evictionWorker) Enqueue(obj interface{}) {
 }
 
 // Add puts an item into the queue and updates metrics.
-func (w *evictionWorker) Add(item interface{}) {
+func (w *EvictionWorker) Add(item interface{}) {
 	if item == nil {
 		klog.Warningf("Ignore nil item from queue")
 		return
@@ -139,7 +132,7 @@ func (w *evictionWorker) Add(item interface{}) {
 }
 
 // AddAfter adds an item to the queue after a delay and updates metrics.
-func (w *evictionWorker) AddAfter(item interface{}, duration time.Duration) {
+func (w *EvictionWorker) AddAfter(item interface{}, duration time.Duration) {
 	if item == nil {
 		klog.Warningf("Ignore nil item from queue")
 		return
@@ -156,14 +149,14 @@ func (w *evictionWorker) AddAfter(item interface{}, duration time.Duration) {
 }
 
 // worker processes items from the queue until the context is canceled.
-func (w *evictionWorker) worker(ctx context.Context) {
+func (w *EvictionWorker) worker(ctx context.Context) {
 	for w.processNextWorkItem(ctx) {
 	}
 }
 
 // processNextWorkItem handles a single item from the queue with metrics tracking.
 // Returns false when the queue is shutting down, true otherwise.
-func (w *evictionWorker) processNextWorkItem(_ context.Context) bool {
+func (w *EvictionWorker) processNextWorkItem(_ context.Context) bool {
 	key, quit := w.queue.Get()
 	if quit {
 		return false
@@ -201,7 +194,7 @@ func (w *evictionWorker) processNextWorkItem(_ context.Context) bool {
 }
 
 // Run starts worker goroutines and ensures cleanup when context is canceled.
-func (w *evictionWorker) Run(ctx context.Context, workerNumber int) {
+func (w *EvictionWorker) Run(ctx context.Context, workerNumber int) {
 	klog.Infof("Starting %d workers for eviction worker %s", workerNumber, w.name)
 	for i := 0; i < workerNumber; i++ {
 		go w.worker(ctx)

pkg/controllers/cluster/eviction_worker_test.go

@@ -31,7 +31,7 @@ import (
 
 func TestEvictionWorker_Add_Enqueue_AddAfter(t *testing.T) {
 	var added atomic.Int32
-	w := &evictionWorker{
+	w := &EvictionWorker{
 		name:             "test-queue",
 		keyFunc:          util.KeyFunc(func(obj interface{}) (util.QueueKey, error) { return obj, nil }),
 		reconcileFunc:    util.ReconcileFunc(func(_ util.QueueKey) error { added.Add(1); return nil }),
@@ -65,7 +65,7 @@ func TestEvictionWorker_Add_Enqueue_AddAfter(t *testing.T) {
 
 func TestEvictionWorker_Reconcile_Error_Requeues(t *testing.T) {
 	var attempts atomic.Int32
-	w := &evictionWorker{
+	w := &EvictionWorker{
 		name:    "err-queue",
 		keyFunc: util.KeyFunc(func(obj interface{}) (util.QueueKey, error) { return obj, nil }),
 		reconcileFunc: util.ReconcileFunc(func(_ util.QueueKey) error {
@@ -98,7 +98,7 @@ func TestEvictionWorker_Reconcile_Error_Requeues(t *testing.T) {
 
 func TestEvictionWorker_Run_Shutdown(t *testing.T) {
 	t.Helper()
-	w := &evictionWorker{
+	w := &EvictionWorker{
 		name:          "shutdown-queue",
 		keyFunc:       util.KeyFunc(func(obj interface{}) (util.QueueKey, error) { return obj, nil }),
 		reconcileFunc: util.ReconcileFunc(func(_ util.QueueKey) error { return nil }),