func (s *MultiClusterQueues) Set(cluster string, queue workqueue.RateLimitingInterface) {
	s.lock.Lock()
	defer s.lock.Unlock()
	if s.queues == nil {
		s.queues = make(map[string]workqueue.RateLimitingInterface)
	}
	s.queues[cluster] = queue
}
sets the queue for a cluster
package workqueue
import (
	"sync"
	"k8s.io/client-go/util/workqueue"
)
type MultiClusterQueues struct {
	queues map[string]workqueue.RateLimitingInterface
	lock   sync.RWMutex
}