Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for ProxyMode (0.21 sec)

  1. pkg/proxy/apis/config/types.go

    // will exit with an error.
    type ProxyMode string
    
    const (
    	ProxyModeIPTables    ProxyMode = "iptables"
    	ProxyModeIPVS        ProxyMode = "ipvs"
    	ProxyModeNFTables    ProxyMode = "nftables"
    	ProxyModeKernelspace ProxyMode = "kernelspace"
    )
    
    func (m *ProxyMode) Set(s string) error {
    	*m = ProxyMode(s)
    	return nil
    }
    
    func (m *ProxyMode) String() string {
    	if m != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 13K bytes
    - Viewed (0)
  2. pkg/proxy/apis/config/validation/validation_test.go

    			expectedErrs: field.ErrorList{field.Invalid(newPath.Child("ProxyMode"), "kernelspace", "must be iptables, ipvs, nftables or blank (blank means the best-available proxy [currently iptables])")},
    		},
    		"invalid mode non-existent": {
    			mode:         kubeproxyconfig.ProxyMode("non-existing"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  3. pkg/proxy/apis/config/validation/validation.go

    	}
    
    	return allErrs
    }
    
    func validateProxyMode(mode kubeproxyconfig.ProxyMode, fldPath *field.Path) field.ErrorList {
    	if runtime.GOOS == "windows" {
    		return validateProxyModeWindows(mode, fldPath)
    	}
    
    	return validateProxyModeLinux(mode, fldPath)
    }
    
    func validateProxyModeLinux(mode kubeproxyconfig.ProxyMode, fldPath *field.Path) field.ErrorList {
    	validModes := sets.New[string](
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  4. cmd/kube-proxy/app/server_other.go

    	return nil, unsupportedError
    }
    
    // platformCleanup removes stale kube-proxy rules that can be safely removed.
    func platformCleanup(ctx context.Context, mode proxyconfigapi.ProxyMode, cleanupAndExit bool) error {
    	return unsupportedError
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  5. pkg/proxy/kubemark/hollow_proxy.go

    	recorder events.EventRecorder,
    ) *HollowProxy {
    	return &HollowProxy{
    		ProxyServer: &proxyapp.ProxyServer{
    			Config: &proxyconfigapi.KubeProxyConfiguration{
    				Mode:             proxyconfigapi.ProxyMode("fake"),
    				ConfigSyncPeriod: metav1.Duration{Duration: 30 * time.Second},
    				OOMScoreAdj:      ptr.To[int32](0),
    			},
    
    			Client:      client,
    			Proxier:     &FakeProxier{},
    			Broadcaster: broadcaster,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  6. cmd/kube-proxy/app/server_windows.go

    	}
    
    	return proxier, nil
    }
    
    // platformCleanup removes stale kube-proxy rules that can be safely removed.
    func platformCleanup(ctx context.Context, mode proxyconfigapi.ProxyMode, cleanupAndExit bool) error {
    	if cleanupAndExit {
    		return errors.New("--cleanup-and-exit is not implemented on Windows")
    	}
    	return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  7. pkg/proxy/apis/config/v1alpha1/zz_generated.conversion.go

    	out.MetricsBindAddress = in.MetricsBindAddress
    	out.BindAddressHardFail = in.BindAddressHardFail
    	out.EnableProfiling = in.EnableProfiling
    	out.ShowHiddenMetricsForVersion = in.ShowHiddenMetricsForVersion
    	out.Mode = config.ProxyMode(in.Mode)
    	if err := Convert_v1alpha1_KubeProxyIPTablesConfiguration_To_config_KubeProxyIPTablesConfiguration(&in.IPTables, &out.IPTables, s); err != nil {
    		return err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:33:53 UTC 2023
    - 22.3K bytes
    - Viewed (0)
  8. cmd/kube-proxy/app/server_linux_test.go

    	netutils "k8s.io/utils/net"
    	"k8s.io/utils/ptr"
    )
    
    func Test_platformApplyDefaults(t *testing.T) {
    	testCases := []struct {
    		name                string
    		mode                proxyconfigapi.ProxyMode
    		expectedMode        proxyconfigapi.ProxyMode
    		detectLocal         proxyconfigapi.LocalMode
    		expectedDetectLocal proxyconfigapi.LocalMode
    	}{
    		{
    			name:                "defaults",
    			mode:                "",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  9. cmd/kube-proxy/app/server_linux.go

    	err := s.setupConntrack(ctx)
    	if err != nil {
    		return err
    	}
    
    	return nil
    }
    
    // isIPTablesBased checks whether mode is based on iptables rather than nftables
    func isIPTablesBased(mode proxyconfigapi.ProxyMode) bool {
    	return mode == proxyconfigapi.ProxyModeIPTables || mode == proxyconfigapi.ProxyModeIPVS
    }
    
    // getIPTables returns an array of [IPv4, IPv6] utiliptables.Interfaces. If primaryFamily
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  10. pkg/proxy/metrics/metrics.go

    )
    
    var registerMetricsOnce sync.Once
    
    // RegisterMetrics registers kube-proxy metrics.
    func RegisterMetrics(mode kubeproxyconfig.ProxyMode) {
    	registerMetricsOnce.Do(func() {
    		// Core kube-proxy metrics for all backends
    		legacyregistry.MustRegister(SyncProxyRulesLatency)
    		legacyregistry.MustRegister(SyncProxyRulesLastQueuedTimestamp)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 13.7K bytes
    - Viewed (0)
Back to top