github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2026-05-14 19:17:56 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #137066 from cnuss/fix/issues/136823

Browse Source 
client-go/cache: fix logging

Kubernetes-commit: 8020ce8511aab076f939b104c973b84cb7a1afc3
This commit is contained in:
Kubernetes Publisher
2026-03-05 05:02:19 +05:30
parent 2dd466fcfe 78fb6ed2e1
commit 9f41e94324
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
tools/cache/reflector.go vendored
View File

@@ -425,14 +425,12 @@ func (r *Reflector) RunWithContext(ctx context.Context) {
logger.V(3).Info("Starting reflector", "type", r.typeDescription, "resyncPeriod", r.resyncPeriod, "reflector", r.name)
// Until runs the loop immediately (immediate=true) and resets the backoff timer after each
// successful iteration (sliding=true). See backoff constants at top of file for generalized QPS targets (~0.22 QPS).
if err := r.delayHandler.Until(ctx, true, true, func(ctx context.Context) (bool, error) {
_ = r.delayHandler.Until(ctx, true, true, func(ctx context.Context) (bool, error) {
if err := r.ListAndWatchWithContext(ctx); err != nil {
r.watchErrorHandler(ctx, r, err)
}
return false, nil
}); err != nil {
logger.Error(err, "Reflector stopped with error", "type", r.typeDescription, "reflector", r.name)
}
})
logger.V(3).Info("Stopping reflector", "type", r.typeDescription, "resyncPeriod", r.resyncPeriod, "reflector", r.name)
}