Skip to content

Commit

Permalink
untangled HNS caching fix with healthCheck feature
Browse files Browse the repository at this point in the history
  • Loading branch information
daschott authored and marosset committed May 20, 2022
1 parent eee55a0 commit 7fb440b
Show file tree
Hide file tree
Showing 4 changed files with 0 additions and 27 deletions.
1 change: 0 additions & 1 deletion pkg/proxy/winkernel/hnsV1.go
@@ -1,4 +1,3 @@
//go:build windows
// +build windows

/*
Expand Down
1 change: 0 additions & 1 deletion pkg/proxy/winkernel/hnsV2.go
@@ -1,4 +1,3 @@
//go:build windows
// +build windows

/*
Expand Down
24 changes: 0 additions & 24 deletions pkg/proxy/winkernel/proxier.go
@@ -1,4 +1,3 @@
//go:build windows
// +build windows

/*
Expand Down Expand Up @@ -1405,29 +1404,6 @@ func (proxier *Proxier) syncProxyRules() {
} else {
klog.V(3).InfoS("Skipped creating Hns LoadBalancer for loadBalancer Ingress resources", "lbIngressIP", lbIngressIP)
}

if proxier.forwardHealthCheckVip && gatewayHnsendpoint != nil {
nodeport := proxier.healthzPort
if svcInfo.HealthCheckNodePort() != 0 {
nodeport = svcInfo.HealthCheckNodePort()
}
hnsHealthCheckLoadBalancer, err := hns.getLoadBalancer(
[]endpointsInfo{*gatewayHnsendpoint},
loadBalancerFlags{isDSR: false, useMUX: svcInfo.preserveDIP, preserveDIP: svcInfo.preserveDIP},
sourceVip,
lbIngressIP.ip,
Enum(svcInfo.Protocol()),
uint16(nodeport),
uint16(nodeport),
queriedLoadBalancers,
)
if err != nil {
klog.ErrorS(err, "Policy creation failed")
continue
}
lbIngressIP.healthCheckHnsID = hnsHealthCheckLoadBalancer.hnsID
klog.V(3).InfoS("Hns Health Check LoadBalancer resource created for loadBalancer Ingress resources", "ip", lbIngressIP)
}
}
svcInfo.policyApplied = true
Log(svcInfo, "+++Policy Successfully applied for service +++", 2)
Expand Down
1 change: 0 additions & 1 deletion pkg/proxy/winkernel/proxier_test.go
@@ -1,4 +1,3 @@
//go:build windows
// +build windows

/*
Expand Down

0 comments on commit 7fb440b

Please sign in to comment.