kubernetes
/
apiserver
mirror of https://github.com/kubernetes/apiserver.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Do not mark errorFetchingAddressFromLease, in case when the there's no address being fetched from the lease object 

Kubernetes-commit: ac3fd5c634d2d9fd2e4011294f152e64f72d205b
This commit is contained in:
Richa Banker 2024-09-27 16:37:46 -07:00 committed by Kubernetes Publisher
parent 36e57697d1
commit 40680bab4c
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/util/peerproxy/peerproxy_handler.go
View File

@ -203,7 +203,6 @@ func (h *peerProxyHandler) findServiceableByServers(gvr schema.GroupVersionResou
apiservers.Range(func(key, value interface{}) bool { apiservers.Range(func(key, value interface{}) bool {
apiserverKey := key.(string) apiserverKey := key.(string)
if apiserverKey == localAPIServerId { if apiserverKey == localAPIServerId {
response.errorFetchingAddressFromLease = true
response.locallyServiceable = true response.locallyServiceable = true
// stop iteration // stop iteration
return false return false
@ -221,11 +220,9 @@ func (h *peerProxyHandler) findServiceableByServers(gvr schema.GroupVersionResou
if err != nil { if err != nil {
response.errorFetchingAddressFromLease = true response.errorFetchingAddressFromLease = true
klog.Errorf("invalid address found for server %s", apiserverKey) klog.Errorf("invalid address found for server %s", apiserverKey)
// continue with iteration
return true return true
} }
peerServerEndpoints = append(peerServerEndpoints, hostPort) peerServerEndpoints = append(peerServerEndpoints, hostPort)
// continue with iteration
return true return true
}) })