@@ -13,15 +13,14 @@ import (
13
13
"time"
14
14
15
15
"github.com/google/uuid"
16
- configlistersv1 "github.com/openshift/client-go/config/listers/config/v1"
17
16
v1 "k8s.io/api/core/v1"
18
17
apierrors "k8s.io/apimachinery/pkg/api/errors"
19
18
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
20
19
"k8s.io/apimachinery/pkg/fields"
21
20
utilruntime "k8s.io/apimachinery/pkg/util/runtime"
22
21
"k8s.io/apimachinery/pkg/util/sets"
23
22
"k8s.io/apimachinery/pkg/util/wait"
24
- "k8s.io/client-go/informers"
23
+ coreinformers "k8s.io/client-go/informers"
25
24
"k8s.io/client-go/kubernetes"
26
25
"k8s.io/client-go/kubernetes/scheme"
27
26
coreclientsetv1 "k8s.io/client-go/kubernetes/typed/core/v1"
@@ -35,9 +34,10 @@ import (
35
34
36
35
configv1 "github.com/openshift/api/config/v1"
37
36
clientset "github.com/openshift/client-go/config/clientset/versioned"
38
- "github.com/openshift/client-go/config/informers/externalversions"
37
+ configinformers "github.com/openshift/client-go/config/informers/externalversions"
38
+ configlistersv1 "github.com/openshift/client-go/config/listers/config/v1"
39
39
operatorclientset "github.com/openshift/client-go/operator/clientset/versioned"
40
- operatorexternalversions "github.com/openshift/client-go/operator/informers/externalversions"
40
+ operatorinformers "github.com/openshift/client-go/operator/informers/externalversions"
41
41
"github.com/openshift/library-go/pkg/config/clusterstatus"
42
42
libgoleaderelection "github.com/openshift/library-go/pkg/config/leaderelection"
43
43
@@ -489,11 +489,11 @@ type Context struct {
489
489
AutoUpdate * autoupdate.Controller
490
490
StopOnFeatureGateChange * featuregates.ChangeStopper
491
491
492
- CVInformerFactory externalversions .SharedInformerFactory
493
- OpenshiftConfigInformerFactory informers .SharedInformerFactory
494
- OpenshiftConfigManagedInformerFactory informers .SharedInformerFactory
495
- InformerFactory externalversions .SharedInformerFactory
496
- OperatorInformerFactory operatorexternalversions .SharedInformerFactory
492
+ CVInformerFactory configinformers .SharedInformerFactory
493
+ InformerFactory configinformers .SharedInformerFactory
494
+ OpenshiftConfigInformerFactory coreinformers .SharedInformerFactory
495
+ OpenshiftConfigManagedInformerFactory coreinformers .SharedInformerFactory
496
+ OperatorInformerFactory operatorinformers .SharedInformerFactory
497
497
498
498
fgLister configlistersv1.FeatureGateLister
499
499
}
@@ -505,18 +505,18 @@ func (o *Options) NewControllerContext(cb *ClientBuilder) (*Context, error) {
505
505
kubeClient := cb .KubeClientOrDie (internal .ConfigNamespace , useProtobuf )
506
506
operatorClient := cb .OperatorClientOrDie ("operator-client" )
507
507
508
- cvInformer := externalversions .NewFilteredSharedInformerFactory (client , resyncPeriod (o .ResyncInterval ), "" , func (opts * metav1.ListOptions ) {
508
+ clusterVersionConfigInformerFactory := configinformers .NewFilteredSharedInformerFactory (client , resyncPeriod (o .ResyncInterval ), "" , func (opts * metav1.ListOptions ) {
509
509
opts .FieldSelector = fmt .Sprintf ("metadata.name=%s" , o .Name )
510
510
})
511
- openshiftConfigInformer := informers . NewSharedInformerFactoryWithOptions ( kubeClient , resyncPeriod (o .ResyncInterval ), informers . WithNamespace ( internal . ConfigNamespace ))
512
- openshiftConfigManagedInformer := informers .NewSharedInformerFactoryWithOptions (kubeClient , resyncPeriod (o .ResyncInterval ), informers .WithNamespace (internal .ConfigManagedNamespace ))
513
- sharedInformers := externalversions . NewSharedInformerFactory ( client , resyncPeriod (o .ResyncInterval ))
514
- operatorInformerFactory := operatorexternalversions .NewSharedInformerFactoryWithOptions (operatorClient , o .ResyncInterval ,
515
- operatorexternalversions .WithTweakListOptions (func (opts * metav1.ListOptions ) {
511
+ configInformerFactory := configinformers . NewSharedInformerFactory ( client , resyncPeriod (o .ResyncInterval ))
512
+ openshiftConfigInformer := coreinformers .NewSharedInformerFactoryWithOptions (kubeClient , resyncPeriod (o .ResyncInterval ), coreinformers .WithNamespace (internal .ConfigNamespace ))
513
+ openshiftConfigManagedInformer := coreinformers . NewSharedInformerFactoryWithOptions ( kubeClient , resyncPeriod (o .ResyncInterval ), coreinformers . WithNamespace ( internal . ConfigManagedNamespace ))
514
+ operatorInformerFactory := operatorinformers .NewSharedInformerFactoryWithOptions (operatorClient , o .ResyncInterval ,
515
+ operatorinformers .WithTweakListOptions (func (opts * metav1.ListOptions ) {
516
516
opts .FieldSelector = fields .OneTermEqualSelector ("metadata.name" , configuration .ClusterVersionOperatorConfigurationName ).String ()
517
517
}))
518
518
519
- coInformer := sharedInformers .Config ().V1 ().ClusterOperators ()
519
+ coInformer := clusterVersionConfigInformerFactory .Config ().V1 ().ClusterOperators ()
520
520
521
521
cvoKubeClient := cb .KubeClientOrDie (o .Namespace , useProtobuf )
522
522
o .PromQLTarget .KubeClient = cvoKubeClient
@@ -527,11 +527,11 @@ func (o *Options) NewControllerContext(cb *ClientBuilder) (*Context, error) {
527
527
o .ReleaseImage ,
528
528
o .PayloadOverride ,
529
529
resyncPeriod (o .ResyncInterval ),
530
- cvInformer .Config ().V1 ().ClusterVersions (),
530
+ clusterVersionConfigInformerFactory .Config ().V1 ().ClusterVersions (),
531
531
coInformer ,
532
532
openshiftConfigInformer .Core ().V1 ().ConfigMaps (),
533
533
openshiftConfigManagedInformer .Core ().V1 ().ConfigMaps (),
534
- sharedInformers .Config ().V1 ().Proxies (),
534
+ configInformerFactory .Config ().V1 ().Proxies (),
535
535
operatorInformerFactory ,
536
536
cb .ClientOrDie (o .Namespace ),
537
537
cvoKubeClient ,
@@ -548,28 +548,28 @@ func (o *Options) NewControllerContext(cb *ClientBuilder) (*Context, error) {
548
548
return nil , err
549
549
}
550
550
551
- featureChangeStopper , err := featuregates .NewChangeStopper (sharedInformers .Config ().V1 ().FeatureGates ())
551
+ featureChangeStopper , err := featuregates .NewChangeStopper (configInformerFactory .Config ().V1 ().FeatureGates ())
552
552
if err != nil {
553
553
return nil , err
554
554
}
555
555
556
556
ctx := & Context {
557
- CVInformerFactory : cvInformer ,
557
+ CVInformerFactory : clusterVersionConfigInformerFactory ,
558
558
OpenshiftConfigInformerFactory : openshiftConfigInformer ,
559
559
OpenshiftConfigManagedInformerFactory : openshiftConfigManagedInformer ,
560
- InformerFactory : sharedInformers ,
560
+ InformerFactory : configInformerFactory ,
561
561
OperatorInformerFactory : operatorInformerFactory ,
562
562
CVO : cvo ,
563
563
StopOnFeatureGateChange : featureChangeStopper ,
564
564
565
- fgLister : sharedInformers .Config ().V1 ().FeatureGates ().Lister (),
565
+ fgLister : configInformerFactory .Config ().V1 ().FeatureGates ().Lister (),
566
566
}
567
567
568
568
if o .EnableAutoUpdate {
569
569
ctx .AutoUpdate , err = autoupdate .New (
570
570
o .Namespace , o .Name ,
571
- cvInformer .Config ().V1 ().ClusterVersions (),
572
- sharedInformers .Config ().V1 ().ClusterOperators (),
571
+ clusterVersionConfigInformerFactory .Config ().V1 ().ClusterVersions (),
572
+ configInformerFactory .Config ().V1 ().ClusterOperators (),
573
573
cb .ClientOrDie (o .Namespace ),
574
574
cb .KubeClientOrDie (o .Namespace ),
575
575
)
0 commit comments