github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-06-25 14:41:53 +00:00
Code Issues Projects Releases Wiki Activity

client-go: log proper 'caches populated' message, with type and source and only once

Browse Source 
Signed-off-by: Dr. Stefan Schimanski <stefan.schimanski@gmail.com>

Kubernetes-commit: a1809ffae377f3abbae12b137073ca4c473743cd
This commit is contained in:
Dr. Stefan Schimanski 2023-08-07 12:56:32 +02:00 committed by Kubernetes Publisher
parent b97d8af093
commit 00f8b3aa35
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tools/cache/reflector.go vendored
View File

@ -337,7 +337,7 @@ func (r *Reflector) ListAndWatch(stopCh <-chan struct{}) error {
if !apierrors.IsInvalid(err) { if !apierrors.IsInvalid(err) {
return err return err
} }
klog.Warning("the watch-list feature is not supported by the server, falling back to the previous LIST/WATCH semantic") klog.Warning("The watch-list feature is not supported by the server, falling back to the previous LIST/WATCH semantics")
fallbackToList = true fallbackToList = true
// Ensure that we won't accidentally pass some garbage down the watch. // Ensure that we won't accidentally pass some garbage down the watch.
w = nil w = nil
@ -351,6 +351,8 @@ func (r *Reflector) ListAndWatch(stopCh <-chan struct{}) error {
} }
} }
klog.V(2).Infof("Caches populated for %v from %s", r.typeDescription, r.name)
resyncerrc := make(chan error, 1) resyncerrc := make(chan error, 1)
cancelCh := make(chan struct{}) cancelCh := make(chan struct{})
defer close(cancelCh) defer close(cancelCh)

2
tools/cache/shared_informer.go vendored
View File

@ -334,11 +334,9 @@ func WaitForCacheSync(stopCh <-chan struct{}, cacheSyncs ...InformerSynced) bool
}, },
stopCh) stopCh)
if err != nil { if err != nil {
klog.V(2).Infof("stop requested")
return false return false
} }
klog.V(4).Infof("caches populated")
return true return true
} }