Skip to content

Commit 9a6c112

Browse files
Merge pull request #231 from abhinavdahiya/fix_proxy_ns
pkg: switch to openshift-config for proxy CA
2 parents b57ee63 + 5968cdf commit 9a6c112

File tree

4 files changed

+17
-28
lines changed

4 files changed

+17
-28
lines changed

pkg/cvo/availableupdates.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -210,7 +210,7 @@ func (optr *Operator) getHTTPSProxyURL() (*url.URL, string, error) {
210210
}
211211

212212
func (optr *Operator) getTLSConfig(cmNameRef string) (*tls.Config, error) {
213-
cm, err := optr.cmManagedLister.Get(cmNameRef)
213+
cm, err := optr.cmConfigLister.Get(cmNameRef)
214214

215215
if err != nil {
216216
return nil, err

pkg/cvo/cvo.go

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -99,12 +99,11 @@ type Operator struct {
9999
// syncBackoff allows the tests to use a quicker backoff
100100
syncBackoff wait.Backoff
101101

102-
cvLister configlistersv1.ClusterVersionLister
103-
coLister configlistersv1.ClusterOperatorLister
104-
cmConfigLister listerscorev1.ConfigMapNamespaceLister
105-
cmManagedLister listerscorev1.ConfigMapNamespaceLister
106-
proxyLister configlistersv1.ProxyLister
107-
cacheSynced []cache.InformerSynced
102+
cvLister configlistersv1.ClusterVersionLister
103+
coLister configlistersv1.ClusterOperatorLister
104+
cmConfigLister listerscorev1.ConfigMapNamespaceLister
105+
proxyLister configlistersv1.ProxyLister
106+
cacheSynced []cache.InformerSynced
108107

109108
// queue tracks applying updates to a cluster.
110109
queue workqueue.RateLimitingInterface
@@ -139,7 +138,6 @@ func New(
139138
cvInformer configinformersv1.ClusterVersionInformer,
140139
coInformer configinformersv1.ClusterOperatorInformer,
141140
cmConfigInformer informerscorev1.ConfigMapInformer,
142-
cmManagedInformer informerscorev1.ConfigMapInformer,
143141
proxyInformer configinformersv1.ProxyInformer,
144142
client clientset.Interface,
145143
kubeClient kubernetes.Interface,
@@ -180,7 +178,6 @@ func New(
180178
optr.cacheSynced = append(optr.cacheSynced, cvInformer.Informer().HasSynced)
181179

182180
optr.cmConfigLister = cmConfigInformer.Lister().ConfigMaps(internal.ConfigNamespace)
183-
optr.cmManagedLister = cmManagedInformer.Lister().ConfigMaps(internal.ConfigManagedNamespace)
184181

185182
if enableMetrics {
186183
if err := optr.registerMetrics(coInformer.Informer()); err != nil {

pkg/internal/constants.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package internal
22

33
const (
4-
ConfigNamespace = "openshift-config"
5-
ConfigManagedNamespace = "openshift-config-managed"
6-
InstallerConfigMap = "openshift-install"
4+
ConfigNamespace = "openshift-config"
5+
InstallerConfigMap = "openshift-install"
76
)

pkg/start/start.go

Lines changed: 9 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -299,10 +299,9 @@ type Context struct {
299299
CVO *cvo.Operator
300300
AutoUpdate *autoupdate.Controller
301301

302-
CVInformerFactory externalversions.SharedInformerFactory
303-
CMConfigInformerFactory informers.SharedInformerFactory
304-
CMManagedInformerFactory informers.SharedInformerFactory
305-
InformerFactory externalversions.SharedInformerFactory
302+
CVInformerFactory externalversions.SharedInformerFactory
303+
OpenshiftConfigInformerFactory informers.SharedInformerFactory
304+
InformerFactory externalversions.SharedInformerFactory
306305
}
307306

308307
// NewControllerContext initializes the default Context for the current Options. It does
@@ -314,18 +313,14 @@ func (o *Options) NewControllerContext(cb *ClientBuilder) *Context {
314313
cvInformer := externalversions.NewFilteredSharedInformerFactory(client, resyncPeriod(o.ResyncInterval)(), "", func(opts *metav1.ListOptions) {
315314
opts.FieldSelector = fmt.Sprintf("metadata.name=%s", o.Name)
316315
})
317-
cmConfigInformer := informers.NewFilteredSharedInformerFactory(kubeClient, resyncPeriod(o.ResyncInterval)(), internal.ConfigNamespace, func(opts *metav1.ListOptions) {
318-
opts.FieldSelector = fmt.Sprintf("metadata.name=%s", internal.InstallerConfigMap)
319-
})
320-
cmManagedInformer := informers.NewSharedInformerFactoryWithOptions(kubeClient, resyncPeriod(o.ResyncInterval)(), informers.WithNamespace(internal.ConfigManagedNamespace))
316+
openshiftConfigInformer := informers.NewSharedInformerFactoryWithOptions(kubeClient, resyncPeriod(o.ResyncInterval)(), informers.WithNamespace(internal.ConfigNamespace))
321317

322318
sharedInformers := externalversions.NewSharedInformerFactory(client, resyncPeriod(o.ResyncInterval)())
323319

324320
ctx := &Context{
325-
CVInformerFactory: cvInformer,
326-
CMConfigInformerFactory: cmConfigInformer,
327-
CMManagedInformerFactory: cmManagedInformer,
328-
InformerFactory: sharedInformers,
321+
CVInformerFactory: cvInformer,
322+
OpenshiftConfigInformerFactory: openshiftConfigInformer,
323+
InformerFactory: sharedInformers,
329324

330325
CVO: cvo.New(
331326
o.NodeName,
@@ -335,8 +330,7 @@ func (o *Options) NewControllerContext(cb *ClientBuilder) *Context {
335330
resyncPeriod(o.ResyncInterval)(),
336331
cvInformer.Config().V1().ClusterVersions(),
337332
sharedInformers.Config().V1().ClusterOperators(),
338-
cmConfigInformer.Core().V1().ConfigMaps(),
339-
cmManagedInformer.Core().V1().ConfigMaps(),
333+
openshiftConfigInformer.Core().V1().ConfigMaps(),
340334
sharedInformers.Config().V1().Proxies(),
341335
cb.ClientOrDie(o.Namespace),
342336
cb.KubeClientOrDie(o.Namespace, useProtobuf),
@@ -364,7 +358,6 @@ func (c *Context) Start(ctx context.Context) {
364358
go c.AutoUpdate.Run(2, ch)
365359
}
366360
c.CVInformerFactory.Start(ch)
367-
c.CMConfigInformerFactory.Start(ch)
368-
c.CMManagedInformerFactory.Start(ch)
361+
c.OpenshiftConfigInformerFactory.Start(ch)
369362
c.InformerFactory.Start(ch)
370363
}

0 commit comments

Comments
 (0)