Skip to content

Commit 1c932c5

Browse files
committed
refactor: unify names in informer-related code
1 parent e2edeb6 commit 1c932c5

File tree

1 file changed

+24
-24
lines changed

1 file changed

+24
-24
lines changed

pkg/start/start.go

Lines changed: 24 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -13,15 +13,14 @@ import (
1313
"time"
1414

1515
"github.com/google/uuid"
16-
configlistersv1 "github.com/openshift/client-go/config/listers/config/v1"
1716
v1 "k8s.io/api/core/v1"
1817
apierrors "k8s.io/apimachinery/pkg/api/errors"
1918
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
2019
"k8s.io/apimachinery/pkg/fields"
2120
utilruntime "k8s.io/apimachinery/pkg/util/runtime"
2221
"k8s.io/apimachinery/pkg/util/sets"
2322
"k8s.io/apimachinery/pkg/util/wait"
24-
"k8s.io/client-go/informers"
23+
coreinformers "k8s.io/client-go/informers"
2524
"k8s.io/client-go/kubernetes"
2625
"k8s.io/client-go/kubernetes/scheme"
2726
coreclientsetv1 "k8s.io/client-go/kubernetes/typed/core/v1"
@@ -35,9 +34,10 @@ import (
3534

3635
configv1 "github.com/openshift/api/config/v1"
3736
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"
3939
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"
4141
"github.com/openshift/library-go/pkg/config/clusterstatus"
4242
libgoleaderelection "github.com/openshift/library-go/pkg/config/leaderelection"
4343

@@ -489,11 +489,11 @@ type Context struct {
489489
AutoUpdate *autoupdate.Controller
490490
StopOnFeatureGateChange *featuregates.ChangeStopper
491491

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
497497

498498
fgLister configlistersv1.FeatureGateLister
499499
}
@@ -505,18 +505,18 @@ func (o *Options) NewControllerContext(cb *ClientBuilder) (*Context, error) {
505505
kubeClient := cb.KubeClientOrDie(internal.ConfigNamespace, useProtobuf)
506506
operatorClient := cb.OperatorClientOrDie("operator-client")
507507

508-
cvInformer := externalversions.NewFilteredSharedInformerFactory(client, resyncPeriod(o.ResyncInterval), "", func(opts *metav1.ListOptions) {
508+
clusterVersionConfigInformerFactory := configinformers.NewFilteredSharedInformerFactory(client, resyncPeriod(o.ResyncInterval), "", func(opts *metav1.ListOptions) {
509509
opts.FieldSelector = fmt.Sprintf("metadata.name=%s", o.Name)
510510
})
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) {
516516
opts.FieldSelector = fields.OneTermEqualSelector("metadata.name", configuration.ClusterVersionOperatorConfigurationName).String()
517517
}))
518518

519-
coInformer := sharedInformers.Config().V1().ClusterOperators()
519+
coInformer := clusterVersionConfigInformerFactory.Config().V1().ClusterOperators()
520520

521521
cvoKubeClient := cb.KubeClientOrDie(o.Namespace, useProtobuf)
522522
o.PromQLTarget.KubeClient = cvoKubeClient
@@ -527,11 +527,11 @@ func (o *Options) NewControllerContext(cb *ClientBuilder) (*Context, error) {
527527
o.ReleaseImage,
528528
o.PayloadOverride,
529529
resyncPeriod(o.ResyncInterval),
530-
cvInformer.Config().V1().ClusterVersions(),
530+
clusterVersionConfigInformerFactory.Config().V1().ClusterVersions(),
531531
coInformer,
532532
openshiftConfigInformer.Core().V1().ConfigMaps(),
533533
openshiftConfigManagedInformer.Core().V1().ConfigMaps(),
534-
sharedInformers.Config().V1().Proxies(),
534+
configInformerFactory.Config().V1().Proxies(),
535535
operatorInformerFactory,
536536
cb.ClientOrDie(o.Namespace),
537537
cvoKubeClient,
@@ -548,28 +548,28 @@ func (o *Options) NewControllerContext(cb *ClientBuilder) (*Context, error) {
548548
return nil, err
549549
}
550550

551-
featureChangeStopper, err := featuregates.NewChangeStopper(sharedInformers.Config().V1().FeatureGates())
551+
featureChangeStopper, err := featuregates.NewChangeStopper(configInformerFactory.Config().V1().FeatureGates())
552552
if err != nil {
553553
return nil, err
554554
}
555555

556556
ctx := &Context{
557-
CVInformerFactory: cvInformer,
557+
CVInformerFactory: clusterVersionConfigInformerFactory,
558558
OpenshiftConfigInformerFactory: openshiftConfigInformer,
559559
OpenshiftConfigManagedInformerFactory: openshiftConfigManagedInformer,
560-
InformerFactory: sharedInformers,
560+
InformerFactory: configInformerFactory,
561561
OperatorInformerFactory: operatorInformerFactory,
562562
CVO: cvo,
563563
StopOnFeatureGateChange: featureChangeStopper,
564564

565-
fgLister: sharedInformers.Config().V1().FeatureGates().Lister(),
565+
fgLister: configInformerFactory.Config().V1().FeatureGates().Lister(),
566566
}
567567

568568
if o.EnableAutoUpdate {
569569
ctx.AutoUpdate, err = autoupdate.New(
570570
o.Namespace, o.Name,
571-
cvInformer.Config().V1().ClusterVersions(),
572-
sharedInformers.Config().V1().ClusterOperators(),
571+
clusterVersionConfigInformerFactory.Config().V1().ClusterVersions(),
572+
configInformerFactory.Config().V1().ClusterOperators(),
573573
cb.ClientOrDie(o.Namespace),
574574
cb.KubeClientOrDie(o.Namespace),
575575
)

0 commit comments

Comments
 (0)