- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for CleanupLeftovers (0.33 sec)
-
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) -
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) -
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) -
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) -
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) -
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)