Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for CleanupLeftovers (0.33 sec)

  1. cmd/kube-proxy/app/server_linux.go

    		execer := exec.New()
    		ipsetInterface := utilipset.New(execer)
    		ipvsInterface := utilipvs.New()
    
    		for _, ipt := range ipts {
    			encounteredError = iptables.CleanupLeftovers(ctx, ipt) || encounteredError
    			encounteredError = ipvs.CleanupLeftovers(ctx, ipvsInterface, ipt, ipsetInterface) || encounteredError
    		}
    	}
    
    	if utilfeature.DefaultFeatureGate.Enabled(features.NFTablesProxyMode) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  2. pkg/proxy/iptables/proxier.go

    // on upgrade.
    var iptablesCleanupOnlyChains = []iptablesJumpChain{}
    
    // CleanupLeftovers removes all iptables rules and chains created by the Proxier
    // It returns true if an error was encountered. Errors are logged.
    func CleanupLeftovers(ctx context.Context, ipt utiliptables.Interface) (encounteredError bool) {
    	logger := klog.FromContext(ctx)
    	// Unlink our chains
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  3. pkg/proxy/winkernel/proxier.go

    	// single-stack proxier instances
    	return metaproxier.NewMetaProxier(ipv4Proxier, ipv6Proxier), nil
    }
    
    // CleanupLeftovers removes all hns rules created by the Proxier
    // It returns true if an error was encountered. Errors are logged.
    func CleanupLeftovers() (encounteredError bool) {
    	// Delete all Hns Load Balancer Policies
    	newHcnImpl().DeleteAllHnsLoadBalancerPolicy()
    	// TODO
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  4. pkg/proxy/nftables/proxier.go

    				ipX, "daddr @nodeport-ips",
    				"meta l4proto . th dport",
    				"vmap", "@", serviceNodePortsMap,
    			),
    		})
    	}
    }
    
    // CleanupLeftovers removes all nftables rules and chains created by the Proxier
    // It returns true if an error was encountered. Errors are logged.
    func CleanupLeftovers(ctx context.Context) bool {
    	logger := klog.FromContext(ctx)
    	var encounteredError bool
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  5. pkg/proxy/ipvs/proxier.go

    				logger.Error(err, "Error removing iptables rules in ipvs proxier")
    				encounteredError = true
    			}
    		}
    	}
    
    	return encounteredError
    }
    
    // CleanupLeftovers clean up all ipvs and iptables rules created by ipvs Proxier.
    func CleanupLeftovers(ctx context.Context, ipvs utilipvs.Interface, ipt utiliptables.Interface, ipset utilipset.Interface) (encounteredError bool) {
    	logger := klog.FromContext(ctx)
    	// Clear all ipvs rules
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  6. pkg/proxy/ipvs/proxier_test.go

    				Name:     ptr.To(svcPortName.Port),
    				Port:     ptr.To(int32(svcPort)),
    				Protocol: ptr.To(v1.ProtocolTCP),
    			}}
    		}),
    	)
    
    	fp.syncProxyRules()
    
    	// test cleanup left over
    	if CleanupLeftovers(ctx, ipvs, ipt, ipset) {
    		t.Errorf("Cleanup leftovers failed")
    	}
    }
    
    func TestCanUseIPVSProxier(t *testing.T) {
    	_, ctx := ktesting.NewTestContext(t)
    	testCases := []struct {
    		name         string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
Back to top