Skip to content

Commit 9404a02

Browse files
committed
if the configmap already exists, do not error out but continue
Signed-off-by: Charlie Doern <[email protected]>
1 parent bd169ca commit 9404a02

File tree

3 files changed

+8
-3
lines changed

3 files changed

+8
-3
lines changed

pkg/operator/imageregistrycertificates.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ type ImageRegistryCertificatesController struct {
3232
coreClient corev1client.CoreV1Interface
3333
operatorClient v1helpers.OperatorClient
3434
configMapLister corev1listers.ConfigMapNamespaceLister
35-
configMapManagedLister corev1listers.ConfigMapNamespaceLister
35+
configMapManagedLister corev1listers.ConfigMapLister
3636
serviceLister corev1listers.ServiceNamespaceLister
3737
imageConfigLister configv1listers.ImageLister
3838
openshiftConfigLister corev1listers.ConfigMapNamespaceLister
@@ -61,7 +61,7 @@ func NewImageRegistryCertificatesController(
6161
coreClient: coreClient,
6262
operatorClient: operatorClient,
6363
configMapLister: configMapInformer.Lister().ConfigMaps(defaults.ImageRegistryOperatorNamespace),
64-
configMapManagedLister: configMapInformer.Lister().ConfigMaps(defaults.OpenShiftConfigManagedNamespace),
64+
configMapManagedLister: openshiftConfigManagedInformer.Lister(),
6565
serviceLister: serviceInformer.Lister().Services(defaults.ImageRegistryOperatorNamespace),
6666
imageConfigLister: imageConfigInformer.Lister(),
6767
openshiftConfigLister: openshiftConfigInformer.Lister().ConfigMaps(defaults.OpenShiftConfigNamespace),
@@ -165,6 +165,7 @@ func (c *ImageRegistryCertificatesController) sync() error {
165165
}
166166

167167
g = resource.NewGeneratorImageRegistryCA(
168+
c.configMapLister,
168169
c.configMapManagedLister,
169170
c.imageConfigLister,
170171
c.openshiftConfigLister,

pkg/resource/generator.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@ func ApplyMutator(gen Mutator) error {
4444

4545
klog.Infof("object %s created: %s", Name(gen), str)
4646
return nil
47+
4748
}
4849

4950
n, updated, err := gen.Update(o.DeepCopyObject())

pkg/resource/imageregistryca.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ var _ Mutator = &generatorImageRegistryCA{}
2727

2828
type generatorImageRegistryCA struct {
2929
lister corelisters.ConfigMapNamespaceLister
30+
managedLister corelisters.ConfigMapLister
3031
imageConfigLister configlisters.ImageLister
3132
openshiftConfigLister corelisters.ConfigMapNamespaceLister
3233
serviceLister corelisters.ServiceNamespaceLister
@@ -38,6 +39,7 @@ type generatorImageRegistryCA struct {
3839

3940
func NewGeneratorImageRegistryCA(
4041
lister corelisters.ConfigMapNamespaceLister,
42+
managedLister corelisters.ConfigMapLister,
4143
imageConfigLister configlisters.ImageLister,
4244
openshiftConfigLister corelisters.ConfigMapNamespaceLister,
4345
serviceLister corelisters.ServiceNamespaceLister,
@@ -48,6 +50,7 @@ func NewGeneratorImageRegistryCA(
4850
) Mutator {
4951
return &generatorImageRegistryCA{
5052
lister: lister,
53+
managedLister: managedLister,
5154
imageConfigLister: imageConfigLister,
5255
openshiftConfigLister: openshiftConfigLister,
5356
serviceLister: serviceLister,
@@ -157,7 +160,7 @@ func (girca *generatorImageRegistryCA) expected() (runtime.Object, error) {
157160
}
158161

159162
func (girca *generatorImageRegistryCA) Get() (runtime.Object, error) {
160-
return girca.lister.Get(girca.GetName())
163+
return girca.managedLister.ConfigMaps(defaults.OpenShiftConfigManagedNamespace).Get(girca.GetName())
161164
}
162165

163166
func (girca *generatorImageRegistryCA) Create() (runtime.Object, error) {

0 commit comments

Comments
 (0)