@@ -26,10 +26,13 @@ import (
2626 mapiclientset "github.com/openshift/client-go/machine/clientset/versioned"
2727 machineinformersv1beta1 "github.com/openshift/client-go/machine/informers/externalversions"
2828 "github.com/openshift/client-go/machine/listers/machine/v1beta1"
29+
30+ appwrapperClientSet "github.com/project-codeflare/multi-cluster-app-dispatcher/pkg/client/clientset/versioned"
31+
2932 arbv1 "github.com/project-codeflare/multi-cluster-app-dispatcher/pkg/apis/controller/v1beta1"
30- "github.com/project-codeflare/multi-cluster-app-dispatcher/pkg/client/clientset /controller-versioned/clients "
31- arbinformers "github.com/project-codeflare/multi-cluster-app-dispatcher/pkg/client/informers/controller-externalversion"
32- v1 "github.com/project-codeflare/multi-cluster-app-dispatcher/pkg/client/listers/controller/v1 "
33+ appwrapperlisters "github.com/project-codeflare/multi-cluster-app-dispatcher/pkg/client/listers /controller/v1beta1 "
34+
35+ arbinformersFactory "github.com/project-codeflare/multi-cluster-app-dispatcher/pkg/client/informers/externalversions "
3336 apierrors "k8s.io/apimachinery/pkg/api/errors"
3437 metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
3538 "k8s.io/apimachinery/pkg/labels"
6265 machineLister v1beta1.MachineLister
6366 msInformerHasSynced bool
6467 machineClient mapiclientset.Interface
65- queueJobLister v1 .AppWrapperLister
68+ queueJobLister appwrapperlisters .AppWrapperLister
6669 kubeClient * kubernetes.Clientset
6770)
6871
@@ -199,11 +202,11 @@ func addAppwrappersThatNeedScaling() {
199202 if err != nil {
200203 klog .Fatalf ("Error getting config: %v" , err )
201204 }
202- awJobClient , _ , err := clients . NewClient (restConfig )
205+ awJobClient , err := appwrapperClientSet . NewForConfig (restConfig )
203206 if err != nil {
204207 klog .Fatalf ("Error creating client: %v" , err )
205208 }
206- queueJobInformer := arbinformers .NewSharedInformerFactory (awJobClient , 0 ).AppWrapper ().AppWrappers ()
209+ queueJobInformer := arbinformersFactory .NewSharedInformerFactory (awJobClient , 0 ).Mcad (). V1beta1 ().AppWrappers ()
207210 queueJobInformer .Informer ().AddEventHandler (
208211 cache.FilteringResourceEventHandler {
209212 FilterFunc : func (obj interface {}) bool {
0 commit comments