github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-04 01:40:07 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #87792 from ksubrmnn/nodeip

Browse Source 
Allow access to default Kubernetes Service from inside Windows Pod (Overlay)
This commit is contained in:
Kubernetes Prow Robot 2020-02-20 03:07:04 -08:00 committed by GitHub
commit 09d78529db
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/proxy/winkernel/proxier.go
View File

@ -1091,6 +1091,7 @@ func (proxier *Proxier) syncProxyRules() {
klog.V(4).Infof("====Applying Policy for %s====", svcName) klog.V(4).Infof("====Applying Policy for %s====", svcName)
// Create Remote endpoints for every endpoint, corresponding to the service // Create Remote endpoints for every endpoint, corresponding to the service
containsPublicIP := false containsPublicIP := false
containsNodeIP := false
for _, ep := range proxier.endpointsMap[svcName] { for _, ep := range proxier.endpointsMap[svcName] {
var newHnsEndpoint *endpointsInfo var newHnsEndpoint *endpointsInfo
@ -1141,13 +1142,15 @@ func (proxier *Proxier) syncProxyRules() {
} }
if ep.ip == rs.providerAddress { if ep.ip == rs.providerAddress {
providerAddress = rs.providerAddress providerAddress = rs.providerAddress
containsNodeIP = true
} }
} }
if len(providerAddress) == 0 { if len(providerAddress) == 0 {
klog.Errorf("Could not find provider address for %s", ep.ip) klog.Infof("Could not find provider address for %s. Assuming it is a public IP", ep.ip)
providerAddress = proxier.nodeIP.String() providerAddress = proxier.nodeIP.String()
containsPublicIP = true containsPublicIP = true
} }
hnsEndpoint := &endpointsInfo{ hnsEndpoint := &endpointsInfo{
ip: ep.ip, ip: ep.ip,
isLocal: false, isLocal: false,
@ -1201,7 +1204,7 @@ func (proxier *Proxier) syncProxyRules() {
klog.V(4).Infof("Trying to Apply Policies for service %s", spew.Sdump(svcInfo)) klog.V(4).Infof("Trying to Apply Policies for service %s", spew.Sdump(svcInfo))
var hnsLoadBalancer *loadBalancerInfo var hnsLoadBalancer *loadBalancerInfo
var sourceVip = proxier.sourceVip var sourceVip = proxier.sourceVip
if containsPublicIP { if containsPublicIP || containsNodeIP {
sourceVip = proxier.nodeIP.String() sourceVip = proxier.nodeIP.String()
} }
hnsLoadBalancer, err := hns.getLoadBalancer( hnsLoadBalancer, err := hns.getLoadBalancer(