nfd-master: use Typed* workqueue types

Drop the usage of deprecated functions and types, makes linters happy.

(cherry picked from commit ca85075)

Author: marquiz

pkg/nfd-master/updater-pool.go

@@ -31,8 +31,8 @@ import (
 )
 
 type updaterPool struct {
-	queue    workqueue.RateLimitingInterface
-	nfgQueue workqueue.RateLimitingInterface
+	queue    workqueue.TypedRateLimitingInterface[string]
+	nfgQueue workqueue.TypedRateLimitingInterface[string]
 	sync.RWMutex
 
 	wg        sync.WaitGroup
@@ -47,12 +47,11 @@ func newUpdaterPool(nfdMaster *nfdMaster) *updaterPool {
 	}
 }
 
-func (u *updaterPool) processNodeUpdateRequest(cli k8sclient.Interface, queue workqueue.RateLimitingInterface) bool {
-	n, quit := queue.Get()
+func (u *updaterPool) processNodeUpdateRequest(cli k8sclient.Interface, queue workqueue.TypedRateLimitingInterface[string]) bool {
+	nodeName, quit := queue.Get()
 	if quit {
 		return false
 	}
-	nodeName := n.(string)
 
 	defer queue.Done(nodeName)
 
@@ -76,7 +75,7 @@ func (u *updaterPool) processNodeUpdateRequest(cli k8sclient.Interface, queue wo
 	return true
 }
 
-func (u *updaterPool) runNodeUpdater(queue workqueue.RateLimitingInterface) {
+func (u *updaterPool) runNodeUpdater(queue workqueue.TypedRateLimitingInterface[string]) {
 	var cli k8sclient.Interface
 	if u.nfdMaster.kubeconfig != nil {
 		// For normal execution, initialize a separate api client for each updater
@@ -90,7 +89,7 @@ func (u *updaterPool) runNodeUpdater(queue workqueue.RateLimitingInterface) {
 	u.wg.Done()
 }
 
-func (u *updaterPool) processNodeFeatureGroupUpdateRequest(cli nfdclientset.Interface, ngfQueue workqueue.RateLimitingInterface) bool {
+func (u *updaterPool) processNodeFeatureGroupUpdateRequest(cli nfdclientset.Interface, ngfQueue workqueue.TypedRateLimitingInterface[string]) bool {
 	nfgName, quit := ngfQueue.Get()
 	if quit {
 		return false
@@ -102,7 +101,7 @@ func (u *updaterPool) processNodeFeatureGroupUpdateRequest(cli nfdclientset.Inte
 	// Check if NodeFeatureGroup exists
 	var nfg *nfdv1alpha1.NodeFeatureGroup
 	var err error
-	if nfg, err = getNodeFeatureGroup(cli, u.nfdMaster.namespace, nfgName.(string)); apierrors.IsNotFound(err) {
+	if nfg, err = getNodeFeatureGroup(cli, u.nfdMaster.namespace, nfgName); apierrors.IsNotFound(err) {
 		klog.InfoS("NodeFeatureGroup not found, skip update", "NodeFeatureGroupName", nfgName)
 	} else if err := u.nfdMaster.nfdAPIUpdateNodeFeatureGroup(u.nfdMaster.nfdClient, nfg); err != nil {
 		if n := ngfQueue.NumRequeues(nfgName); n < 15 {
@@ -118,7 +117,7 @@ func (u *updaterPool) processNodeFeatureGroupUpdateRequest(cli nfdclientset.Inte
 	return true
 }
 
-func (u *updaterPool) runNodeFeatureGroupUpdater(ngfQueue workqueue.RateLimitingInterface) {
+func (u *updaterPool) runNodeFeatureGroupUpdater(ngfQueue workqueue.TypedRateLimitingInterface[string]) {
 	cli := nfdclientset.NewForConfigOrDie(u.nfdMaster.kubeconfig)
 	for u.processNodeFeatureGroupUpdateRequest(cli, ngfQueue) {
 	}
@@ -143,12 +142,12 @@ func (u *updaterPool) start(parallelism int) {
 
 	// Create ratelimiter. Mimic workqueue.DefaultControllerRateLimiter() but
 	// with modified per-item (node) rate limiting parameters.
-	rl := workqueue.NewMaxOfRateLimiter(
-		workqueue.NewItemExponentialFailureRateLimiter(50*time.Millisecond, 100*time.Second),
-		&workqueue.BucketRateLimiter{Limiter: rate.NewLimiter(rate.Limit(10), 100)},
+	rl := workqueue.NewTypedMaxOfRateLimiter[string](
+		workqueue.NewTypedItemExponentialFailureRateLimiter[string](50*time.Millisecond, 100*time.Second),
+		&workqueue.TypedBucketRateLimiter[string]{Limiter: rate.NewLimiter(rate.Limit(10), 100)},
 	)
-	u.queue = workqueue.NewRateLimitingQueue(rl)
-	u.nfgQueue = workqueue.NewRateLimitingQueue(rl)
+	u.queue = workqueue.NewTypedRateLimitingQueue[string](rl)
+	u.nfgQueue = workqueue.NewTypedRateLimitingQueue[string](rl)
 
 	for i := 0; i < parallelism; i++ {
 		u.wg.Add(1)