upstream/kubernetes
1
0
Fork 0
mirror of https://github.com/kubernetes/kubernetes.git synced 2026-06-09 00:34:10 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

apiserver: inline isUnimplementedErr and clarify sync fallback flow

Browse source
This commit is contained in:
Jefftree 2026-06-05 11:07:21 -04:00
parent dbbc4dc176
commit 33d1d2e656
1 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
View file

@ -234,10 +234,6 @@ type grpcError interface {
GRPCStatus() *grpcstatus.Status
}
func isUnimplementedErr(err error) bool {
return grpcstatus.Code(err) == grpccodes.Unimplemented
}
func isCancelError(err error) bool {
if err == nil {
return false
@ -298,7 +294,10 @@ func (wc *watchChan) sync() error {
// TODO(jefftree): detect RangeStream support via the etcd feature checker.
if wc.recursive && utilfeature.DefaultFeatureGate.Enabled(features.EtcdRangeStream) {
err := wc.syncStreamRecursive()
if !isUnimplementedErr(err) {
if err == nil {
return nil
}
if grpcstatus.Code(err) != grpccodes.Unimplemented {
return err
}
klog.V(4).Infof("etcd server does not support RangeStream for %v; falling back to paginated list", wc.watcher.groupResource)