Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for ProxyMode (0.15 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. 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)
  5. 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)
  6. 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)
  7. 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)
  8. cmd/kube-proxy/app/server.go

    }
    
    func serveMetrics(bindAddress string, proxyMode kubeproxyconfig.ProxyMode, enableProfiling bool, errCh chan error) {
    	if len(bindAddress) == 0 {
    		return
    	}
    
    	proxyMux := mux.NewPathRecorderMux("kube-proxy")
    	healthz.InstallHandler(proxyMux)
    	slis.SLIMetricsWithReset{}.Install(proxyMux)
    
    	proxyMux.HandleFunc("/proxyMode", func(w http.ResponseWriter, r *http.Request) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 46.8K bytes
    - Viewed (0)
  9. cmd/kube-proxy/app/server_test.go

    				MinSyncPeriod: metav1.Duration{Duration: 10 * time.Second},
    				SyncPeriod:    metav1.Duration{Duration: 60 * time.Second},
    			},
    			MetricsBindAddress: tc.metricsBindAddress,
    			Mode:               kubeproxyconfig.ProxyMode(tc.mode),
    			OOMScoreAdj:        ptr.To[int32](17),
    			PortRange:          "2-7",
    			NodePortAddresses:  []string{"10.20.30.40/16", "fd00:1::0/64"},
    			DetectLocalMode:    kubeproxyconfig.LocalModeClusterCIDR,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 32.3K bytes
    - Viewed (0)
Back to top