@@ -26,10 +26,13 @@ import (
26
26
mapiclientset "github.com/openshift/client-go/machine/clientset/versioned"
27
27
machineinformersv1beta1 "github.com/openshift/client-go/machine/informers/externalversions"
28
28
"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
+
29
32
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 "
33
36
apierrors "k8s.io/apimachinery/pkg/api/errors"
34
37
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
35
38
"k8s.io/apimachinery/pkg/labels"
62
65
machineLister v1beta1.MachineLister
63
66
msInformerHasSynced bool
64
67
machineClient mapiclientset.Interface
65
- queueJobLister v1 .AppWrapperLister
68
+ queueJobLister appwrapperlisters .AppWrapperLister
66
69
kubeClient * kubernetes.Clientset
67
70
)
68
71
@@ -199,11 +202,11 @@ func addAppwrappersThatNeedScaling() {
199
202
if err != nil {
200
203
klog .Fatalf ("Error getting config: %v" , err )
201
204
}
202
- awJobClient , _ , err := clients . NewClient (restConfig )
205
+ awJobClient , err := appwrapperClientSet . NewForConfig (restConfig )
203
206
if err != nil {
204
207
klog .Fatalf ("Error creating client: %v" , err )
205
208
}
206
- queueJobInformer := arbinformers .NewSharedInformerFactory (awJobClient , 0 ).AppWrapper ().AppWrappers ()
209
+ queueJobInformer := arbinformersFactory .NewSharedInformerFactory (awJobClient , 0 ).Mcad (). V1beta1 ().AppWrappers ()
207
210
queueJobInformer .Informer ().AddEventHandler (
208
211
cache.FilteringResourceEventHandler {
209
212
FilterFunc : func (obj interface {}) bool {
0 commit comments