Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for NodeIPs (0.14 sec)

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

    func (s *ProxyServer) platformSetup(ctx context.Context) error {
    	// Preserve backward-compatibility with the old secondary IP behavior
    	if s.PrimaryIPFamily == v1.IPv4Protocol {
    		s.NodeIPs[v1.IPv6Protocol] = net.IPv6zero
    	} else {
    		s.NodeIPs[v1.IPv4Protocol] = net.IPv4zero
    	}
    	return nil
    }
    
    // platformCheckSupported is called immediately before creating the Proxier, to check
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. cmd/kube-proxy/app/server_linux.go

    				config.IPTables.MinSyncPeriod.Duration,
    				config.IPTables.MasqueradeAll,
    				*config.IPTables.LocalhostNodePorts,
    				int(*config.IPTables.MasqueradeBit),
    				localDetectors,
    				s.Hostname,
    				s.NodeIPs,
    				s.Recorder,
    				s.HealthzServer,
    				config.NodePortAddresses,
    				initOnly,
    			)
    		} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  3. pkg/kubelet/nodestatus/setters_test.go

    				cloud = &fakecloud.Cloud{
    					Addresses: testCase.nodeAddresses,
    					Err:       nil,
    				}
    			}
    
    			nodeIPs := []net.IP{testCase.nodeIP}
    			if testCase.secondaryNodeIP != nil {
    				nodeIPs = append(nodeIPs, testCase.secondaryNodeIP)
    			}
    
    			// construct setter
    			setter := NodeAddress(nodeIPs,
    				nodeIPValidator,
    				hostname,
    				testCase.hostnameOverride,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 21:47:24 UTC 2024
    - 76.1K bytes
    - Viewed (0)
  4. cmd/kube-proxy/app/server.go

    			return false, nil
    		}
    		nodeIPs, err = utilnode.GetNodeHostIPs(node)
    		if err != nil {
    			logger.Error(err, "Failed to retrieve node IPs")
    			return false, nil
    		}
    		return true, nil
    	})
    	if err == nil {
    		logger.Info("Successfully retrieved node IP(s)", "IPs", nodeIPs)
    	}
    	return nodeIPs
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 46.8K bytes
    - Viewed (0)
  5. pkg/kubelet/nodestatus/setters.go

    ) Setter {
    	var nodeIP, secondaryNodeIP net.IP
    	if len(nodeIPs) > 0 {
    		nodeIP = nodeIPs[0]
    	}
    	preferIPv4 := nodeIP == nil || nodeIP.To4() != nil
    	isPreferredIPFamily := func(ip net.IP) bool { return (ip.To4() != nil) == preferIPv4 }
    	nodeIPSpecified := nodeIP != nil && !nodeIP.IsUnspecified()
    
    	if len(nodeIPs) > 1 {
    		secondaryNodeIP = nodeIPs[1]
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 12:12:04 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  6. pkg/envoy/proxy.go

    	"istio.io/istio/pkg/log"
    )
    
    type envoy struct {
    	ProxyConfig
    	extraArgs []string
    }
    
    // Envoy binary flags
    type ProxyConfig struct {
    	LogLevel          string
    	ComponentLogLevel string
    	NodeIPs           []string
    	Sidecar           bool
    	LogAsJSON         bool
    	OutlierLogPath    string
    
    	BinaryPath    string
    	ConfigPath    string
    	ConfigCleanup bool
    	AdminPort     int32
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 10:02:56 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  7. pkg/proxy/nftables/helpers_test.go

    	markMasq bool
    }
    
    // newNFTablesTracer creates an nftablesTracer. nodeIPs are the IP to treat as local node
    // IPs (for determining whether rules with "fib saddr type local" or "fib daddr type
    // local" match).
    func newNFTablesTracer(t *testing.T, nft *knftables.Fake, nodeIPs []string) *nftablesTracer {
    	return &nftablesTracer{
    		nft:     nft,
    		nodeIPs: sets.New(nodeIPs...),
    		t:       t,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 02 09:57:47 UTC 2024
    - 48.5K bytes
    - Viewed (0)
  8. pkg/envoy/proxy_test.go

    	proxyConfig.Concurrency = &wrapperspb.Int32Value{Value: 8}
    
    	cfg := ProxyConfig{
    		LogLevel:          "trace",
    		ComponentLogLevel: "misc:error",
    		NodeIPs:           []string{"10.75.2.9", "192.168.11.18"},
    		BinaryPath:        proxyConfig.BinaryPath,
    		ConfigPath:        proxyConfig.ConfigPath,
    		ConfigCleanup:     true,
    		AdminPort:         proxyConfig.ProxyAdminPort,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 11:45:51 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. pkg/proxy/ipvs/proxier.go

    	// List of node IP addresses to be used as IPVS services if nodePort is set. This
    	// can be reused for all nodePort services.
    	var nodeIPs []net.IP
    	if hasNodePort {
    		if proxier.nodePortAddresses.MatchAll() {
    			for _, ipStr := range nodeAddressSet.UnsortedList() {
    				nodeIPs = append(nodeIPs, netutils.ParseIPSloppy(ipStr))
    			}
    		} else {
    			allNodeIPs, err := proxier.nodePortAddresses.GetNodeIPs(proxier.networkInterfacer)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  10. pkg/proxy/nftables/proxier.go

    		localDetectors[v1.IPv4Protocol], hostname, nodeIPs[v1.IPv4Protocol],
    		recorder, healthzServer, nodePortAddresses, initOnly)
    	if err != nil {
    		return nil, fmt.Errorf("unable to create ipv4 proxier: %v", err)
    	}
    
    	ipv6Proxier, err := NewProxier(ctx, v1.IPv6Protocol,
    		syncPeriod, minSyncPeriod, masqueradeAll, masqueradeBit,
    		localDetectors[v1.IPv6Protocol], hostname, nodeIPs[v1.IPv6Protocol],
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
Back to top