File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
staging/src/k8s.io/apiserver/pkg/storage/cacher Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -399,6 +399,7 @@ func (c *Cacher) startCaching(stopChannel <-chan struct{}) {
399
399
c .watchCache .SetOnReplace (func () {
400
400
successfulList = true
401
401
c .ready .set (true )
402
+ klog .V (1 ).Infof ("cacher (%v): initialized" , c .objectType .String ())
402
403
})
403
404
defer func () {
404
405
if successfulList {
@@ -412,7 +413,7 @@ func (c *Cacher) startCaching(stopChannel <-chan struct{}) {
412
413
// Also note that startCaching is called in a loop, so there's no need
413
414
// to have another loop here.
414
415
if err := c .reflector .ListAndWatch (stopChannel ); err != nil {
415
- klog .Errorf ("unexpected ListAndWatch error: %v" , err )
416
+ klog .Errorf ("cacher (%v): unexpected ListAndWatch error: %v; reinitializing..." , c . objectType . String () , err )
416
417
}
417
418
}
418
419
You can’t perform that action at this time.
0 commit comments