Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for nodePortAddresses (0.22 sec)

  1. pkg/proxy/util/nodeport_addresses.go

    // NodePortAddresses object for the given family. If there are no CIDRs of the given
    // family then the CIDR "0.0.0.0/0" or "::/0" will be added (even if there are CIDRs of
    // the other family).
    func NewNodePortAddresses(family v1.IPFamily, cidrStrings []string) *NodePortAddresses {
    	npa := &NodePortAddresses{}
    
    	// Filter CIDRs to correct family
    	for _, str := range cidrStrings {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  2. pkg/proxy/apis/config/validation/validation.go

    }
    
    func validateKubeProxyNodePortAddress(nodePortAddresses []string, fldPath *field.Path) field.ErrorList {
    	allErrs := field.ErrorList{}
    
    	for i := range nodePortAddresses {
    		if nodePortAddresses[i] == kubeproxyconfig.NodePortAddressesPrimary {
    			if i != 0 || len(nodePortAddresses) != 1 {
    				allErrs = append(allErrs, field.Invalid(fldPath.Index(i), nodePortAddresses[i], "can't use both 'primary' and CIDRs"))
    			}
    			break
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  3. cmd/kube-proxy/app/server.go

    	s.PrimaryIPFamily, s.NodeIPs = detectNodeIPs(ctx, rawNodeIPs, config.BindAddress)
    
    	if len(config.NodePortAddresses) == 1 && config.NodePortAddresses[0] == kubeproxyconfig.NodePortAddressesPrimary {
    		var nodePortAddresses []string
    		if nodeIP := s.NodeIPs[v1.IPv4Protocol]; nodeIP != nil && !nodeIP.IsLoopback() {
    			nodePortAddresses = append(nodePortAddresses, fmt.Sprintf("%s/32", nodeIP.String()))
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 46.8K bytes
    - Viewed (0)
  4. pkg/proxy/apis/config/validation/validation_test.go

    			expectedErrs: field.ErrorList{field.Invalid(newPath.Child("NodePortAddresses[0]"), "::0", "must be a valid CIDR"),
    				field.Invalid(newPath.Child("NodePortAddresses[1]"), "::1", "must be a valid CIDR")},
    		},
    		"invalid ipv6 ip format": {
    			addresses:    []string{"::1/128", "2001:db8::/32", "2001:db8:xyz/64"},
    			expectedErrs: field.ErrorList{field.Invalid(newPath.Child("NodePortAddresses[2]"), "2001:db8:xyz/64", "must be a valid CIDR")},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  5. cmd/kube-proxy/app/server_test.go

    		err   bool
    	}{
    		{
    			name: "single-stack NodePortAddresses with single-stack config",
    			proxy: &ProxyServer{
    				Config: &kubeproxyconfig.KubeProxyConfiguration{
    					ClusterCIDR:       "10.0.0.0/8",
    					NodePortAddresses: []string{"192.168.0.0/24"},
    				},
    				PrimaryIPFamily: v1.IPv4Protocol,
    			},
    			err: false,
    		},
    		{
    			name: "dual-stack NodePortAddresses with dual-stack config",
    			proxy: &ProxyServer{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 32.3K bytes
    - Viewed (0)
  6. cmd/kube-proxy/app/server_linux.go

    	if config.Mode == "" {
    		o.logger.Info("Using iptables proxy")
    		config.Mode = proxyconfigapi.ProxyModeIPTables
    	}
    
    	if config.Mode == proxyconfigapi.ProxyModeNFTables && len(config.NodePortAddresses) == 0 {
    		config.NodePortAddresses = []string{proxyconfigapi.NodePortAddressesPrimary}
    	}
    
    	if config.DetectLocalMode == "" {
    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/apis/config/zz_generated.deepcopy.go

    	in.IPVS.DeepCopyInto(&out.IPVS)
    	out.Winkernel = in.Winkernel
    	in.NFTables.DeepCopyInto(&out.NFTables)
    	out.DetectLocal = in.DetectLocal
    	if in.NodePortAddresses != nil {
    		in, out := &in.NodePortAddresses, &out.NodePortAddresses
    		*out = make([]string, len(*in))
    		copy(*out, *in)
    	}
    	if in.OOMScoreAdj != nil {
    		in, out := &in.OOMScoreAdj, &out.OOMScoreAdj
    		*out = new(int32)
    		**out = **in
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 13 15:12:28 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  8. pkg/proxy/nftables/proxier.go

    	recorder       events.EventRecorder
    
    	serviceHealthServer healthcheck.ServiceHealthServer
    	healthzServer       *healthcheck.ProxierHealthServer
    
    	// nodePortAddresses selects the interfaces where nodePort works.
    	nodePortAddresses *proxyutil.NodePortAddresses
    	// networkInterfacer defines an interface for several net library functions.
    	// Inject for test purpose.
    	networkInterfacer proxyutil.NetworkInterfacer
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  9. pkg/proxy/iptables/proxier.go

    	localhostNodePorts bool
    
    	// conntrackTCPLiberal indicates whether the system sets the kernel nf_conntrack_tcp_be_liberal
    	conntrackTCPLiberal bool
    
    	// nodePortAddresses selects the interfaces where nodePort works.
    	nodePortAddresses *proxyutil.NodePortAddresses
    	// networkInterfacer defines an interface for several net library functions.
    	// Inject for test purpose.
    	networkInterfacer proxyutil.NetworkInterfacer
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  10. pkg/proxy/apis/config/types.go

    	// DetectLocalMode is set to LocalModeClusterCIDR, kube-proxy will consider
    	// traffic to be local if its source IP is in this range. (Otherwise it is not
    	// used.)
    	ClusterCIDR string
    
    	// nodePortAddresses is a list of CIDR ranges that contain valid node IPs, or
    	// alternatively, the single string 'primary'. If set to a list of CIDRs,
    	// connections to NodePort services will only be accepted on node IPs in one of
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 13K bytes
    - Viewed (0)
Back to top