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

client-go/cache: Remove reflector context cancellation logging

Browse Source 
The error returned from Until() is solely from context cancellation
which is expected behavior when the reflector is stopped. Logging
this as an error (or even at V(4)) creates unnecessary noise.

Kubernetes-commit: cc483208aa306b8c4078d4118cf78a10e58481ec
This commit is contained in:
Copilot
2026-02-16 22:04:52 -05:00
committed by Kubernetes Publisher
parent 2dd466fcfe
commit 78fb6ed2e1
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)
}