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

[kube-proxy:nftables] cleanup: remove unused parameter and fix typo.

Browse Source 
Signed-off-by: Nadia Pinaeva <n.m.pinaeva@gmail.com>
This commit is contained in:
Nadia Pinaeva 2024-06-05 18:20:19 +02:00
parent fc03f3e74c
commit dc13e42f56
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/proxy/nftables/proxier.go
View File

@ -1391,7 +1391,7 @@ func (proxier *Proxier) syncProxyRules() {
if svcInfo.NodePort() != 0 { if svcInfo.NodePort() != 0 {
if hasEndpoints { if hasEndpoints {
// Jump to the external destination chain. For better or for // Jump to the external destination chain. For better or for
// worse, nodeports are not subect to loadBalancerSourceRanges, // worse, nodeports are not subject to loadBalancerSourceRanges,
// and we can't change that. // and we can't change that.
tx.Add(&knftables.Element{ tx.Add(&knftables.Element{
Map: serviceNodePortsMap, Map: serviceNodePortsMap,
@ -1560,13 +1560,13 @@ func (proxier *Proxier) syncProxyRules() {
// If Cluster policy is in use, create the chain and create rules jumping // If Cluster policy is in use, create the chain and create rules jumping
// from clusterPolicyChain to the clusterEndpoints // from clusterPolicyChain to the clusterEndpoints
if usesClusterPolicyChain { if usesClusterPolicyChain {
proxier.writeServiceToEndpointRules(tx, svcPortNameString, svcInfo, clusterPolicyChain, clusterEndpoints) proxier.writeServiceToEndpointRules(tx, svcInfo, clusterPolicyChain, clusterEndpoints)
} }
// If Local policy is in use, create rules jumping from localPolicyChain // If Local policy is in use, create rules jumping from localPolicyChain
// to the localEndpoints // to the localEndpoints
if usesLocalPolicyChain { if usesLocalPolicyChain {
proxier.writeServiceToEndpointRules(tx, svcPortNameString, svcInfo, localPolicyChain, localEndpoints) proxier.writeServiceToEndpointRules(tx, svcInfo, localPolicyChain, localEndpoints)
} }
// Generate the per-endpoint chains // Generate the per-endpoint chains
@ -1699,7 +1699,7 @@ func (proxier *Proxier) syncProxyRules() {
conntrack.CleanStaleEntries(proxier.conntrack, proxier.svcPortMap, serviceUpdateResult, endpointUpdateResult) conntrack.CleanStaleEntries(proxier.conntrack, proxier.svcPortMap, serviceUpdateResult, endpointUpdateResult)
} }
func (proxier *Proxier) writeServiceToEndpointRules(tx *knftables.Transaction, svcPortNameString string, svcInfo *servicePortInfo, svcChain string, endpoints []proxy.Endpoint) { func (proxier *Proxier) writeServiceToEndpointRules(tx *knftables.Transaction, svcInfo *servicePortInfo, svcChain string, endpoints []proxy.Endpoint) {
// First write session affinity rules, if applicable. // First write session affinity rules, if applicable.
if svcInfo.SessionAffinityType() == v1.ServiceAffinityClientIP { if svcInfo.SessionAffinityType() == v1.ServiceAffinityClientIP {
ipX := "ip" ipX := "ip"