scottk/kubernetes
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/kubernetes.git synced 2025-11-03 19:58:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

kube-proxy: ipvs proxy should ignore endpoints with condition ready=false

Browse Source 
Signed-off-by: Andrew Sy Kim <kim.andrewsy@gmail.com>
This commit is contained in:
Andrew Sy Kim
2020-12-11 10:16:11 -05:00
parent 9c096292cc
commit a11abb5475
2 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/proxy/ipvs/proxier.go
View File

@@ -2042,9 +2042,14 @@ func (proxier *Proxier) syncEndpoint(svcPortName proxy.ServicePortName, onlyNode
} }
for _, epInfo := range endpoints { for _, epInfo := range endpoints {
if !epInfo.IsReady() {
continue
}
if onlyNodeLocalEndpoints && !epInfo.GetIsLocal() { if onlyNodeLocalEndpoints && !epInfo.GetIsLocal() {
continue continue
} }
newEndpoints.Insert(epInfo.String()) newEndpoints.Insert(epInfo.String())
} }

4
pkg/proxy/ipvs/proxier_test.go
View File

@@ -4256,6 +4256,10 @@ func TestEndpointSliceE2E(t *testing.T) {
Addresses: []string{"10.0.1.3"}, Addresses: []string{"10.0.1.3"},
Conditions: discovery.EndpointConditions{Ready: utilpointer.BoolPtr(true)}, Conditions: discovery.EndpointConditions{Ready: utilpointer.BoolPtr(true)},
Topology: map[string]string{"kubernetes.io/hostname": "node3"}, Topology: map[string]string{"kubernetes.io/hostname": "node3"},
}, { // not ready endpoints should be ignored
Addresses: []string{"10.0.1.4"},
Conditions: discovery.EndpointConditions{Ready: utilpointer.BoolPtr(false)},
Topology: map[string]string{"kubernetes.io/hostname": "node3"},
}}, }},
} }