New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Adding internal traffic policy work #20
Adding internal traffic policy work #20
Conversation
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: marosset The full list of commands accepted by this bot can be found here. The pull request process is described here
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
/assign @jayunit100 @knabben |
/hold |
4bcac8d
to
a3fdaea
Compare
I got load balancer rules working in a CAPZ cluster with these changes. |
a3fdaea
to
174587a
Compare
Signed-off-by: Mark Rossetti <marosset@microsoft.com>
174587a
to
7a60527
Compare
/hold cancel |
/lgtm |
// localTrafficDSR := false | ||
//} | ||
localTrafficDSR := false | ||
localTrafficDSR := service.ExternalTrafficToLocal // TODO: verify this is the correct field in the KPNG localv1 API |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@jayunit100 or @knabben - Is what I am doing the correct assignments for localTrafficDSR
and internalTrafficLocal
?
These wre previously checking against core.v1 types
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think it's correct, the upstream model is different from the kpng one related to these bool services parameters
@@ -555,10 +555,10 @@ func (proxier *Proxier) syncProxyRules() { | |||
// merge stale services gathered from updateEndpointsMap | |||
for _, svcPortName := range endpointUpdateResult.StaleServiceNames { | |||
klog.InfoS("echo %v", svcPortName) | |||
//if svcInfo, ok := proxier.serviceMap[svcPortName]; ok && svcInfo != nil && svcInfo.Protocol() == v1.ProtocolUDP { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
isn't this required for UDP stale services and cleanup?
Signed-off-by: Mark Rossetti marosset@microsoft.com
Implementing internal traffic policy (Added into in-tree kube-proxy via kubernetes/kubernetes#114407)
And also fixing some commented out code