Skip to content

Commit 5c38f0d

Browse files
authored
Add missing watch error handler for ingress class informer (istio#37408)
1 parent 022c490 commit 5c38f0d

File tree

2 files changed

+8
-0
lines changed

2 files changed

+8
-0
lines changed

pilot/pkg/config/kube/ingress/controller.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -297,6 +297,11 @@ func (c *controller) SetWatchErrorHandler(handler func(r *cache.Reflector, err e
297297
if err := c.ingressInformer.SetWatchErrorHandler(handler); err != nil {
298298
errs = multierror.Append(err, errs)
299299
}
300+
if c.classes != nil {
301+
if err := c.classes.Informer().SetWatchErrorHandler(handler); err != nil {
302+
errs = multierror.Append(err, errs)
303+
}
304+
}
300305
return errs
301306
}
302307

pilot/pkg/config/kube/ingressv1/controller.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -250,6 +250,9 @@ func (c *controller) SetWatchErrorHandler(handler func(r *cache.Reflector, err e
250250
if err := c.ingressInformer.SetWatchErrorHandler(handler); err != nil {
251251
errs = multierror.Append(err, errs)
252252
}
253+
if err := c.classes.Informer().SetWatchErrorHandler(handler); err != nil {
254+
errs = multierror.Append(err, errs)
255+
}
253256
return errs
254257
}
255258

0 commit comments

Comments
 (0)