Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for getNodeIPs (0.16 sec)

  1. pkg/proxy/util/nodeport_addresses.go

    func (npa *NodePortAddresses) MatchAll() bool {
    	return npa.matchAll
    }
    
    // GetNodeIPs return all matched node IP addresses for npa's CIDRs. If no matching
    // IPs are found, it returns an empty list.
    // NetworkInterfacer is injected for test purpose.
    func (npa *NodePortAddresses) GetNodeIPs(nw NetworkInterfacer) ([]net.IP, error) {
    	addrs, err := nw.InterfaceAddrs()
    	if err != nil {
    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/util/nodeport_addresses_test.go

    					t.Errorf("unexpected MatchAll(%s), expected: %v", family, tc.expected[family].matchAll)
    				}
    
    				ips, err := npa.GetNodeIPs(nw)
    				expectedIPs := tc.expected[family].ips
    
    				// The fake InterfaceAddrs() never returns an error, so
    				// the only error GetNodeIPs will return is "no
    				// addresses found".
    				if err != nil {
    					t.Errorf("unexpected error: %v", err)
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  3. pkg/proxy/healthcheck/service_health.go

    	// It doesn't matter whether we listen on "0.0.0.0", "::", or ""; go
    	// treats them all the same.
    	nodeIPs := []net.IP{net.IPv4zero}
    
    	if !nodePortAddresses.MatchAll() {
    		ips, err := nodePortAddresses.GetNodeIPs(proxyutil.RealNetwork{})
    		if err == nil {
    			nodeIPs = ips
    		} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 30 09:25:48 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  4. cmd/kube-proxy/app/server_test.go

    	}
    
    	if primaryIP != "" {
    		node.Status.Addresses = append(node.Status.Addresses,
    			v1.NodeAddress{Type: v1.NodeInternalIP, Address: primaryIP},
    		)
    	}
    
    	return node
    }
    
    // Test that getNodeIPs retries on failure
    func Test_getNodeIPs(t *testing.T) {
    	var chans [3]chan error
    
    	client := clientsetfake.NewSimpleClientset(
    		// node1 initially has no IP address.
    		makeNodeWithAddress("node1", ""),
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 32.3K bytes
    - Viewed (0)
  5. cmd/kube-proxy/app/server.go

    	if err != nil {
    		return nil, err
    	}
    
    	s.Client, err = createClient(ctx, config.ClientConnection, master)
    	if err != nil {
    		return nil, err
    	}
    
    	rawNodeIPs := getNodeIPs(ctx, s.Client, s.Hostname)
    	s.PrimaryIPFamily, s.NodeIPs = detectNodeIPs(ctx, rawNodeIPs, config.BindAddress)
    
    	if len(config.NodePortAddresses) == 1 && config.NodePortAddresses[0] == kubeproxyconfig.NodePortAddressesPrimary {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 46.8K bytes
    - Viewed (0)
  6. pkg/proxy/nftables/proxier.go

    		tx.Delete(&knftables.Set{
    			Name: nodePortIPsSet,
    		})
    	} else {
    		tx.Flush(&knftables.Set{
    			Name: nodePortIPsSet,
    		})
    		nodeIPs, err := proxier.nodePortAddresses.GetNodeIPs(proxier.networkInterfacer)
    		if err != nil {
    			proxier.logger.Error(err, "Failed to get node ip address matching nodeport cidrs, services with nodeport may not work as intended", "CIDRs", proxier.nodePortAddresses)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  7. pkg/proxy/iptables/proxier.go

    			destinations,
    			"-j", string(kubeNodePortsChain))
    	} else {
    		nodeIPs, err := proxier.nodePortAddresses.GetNodeIPs(proxier.networkInterfacer)
    		if err != nil {
    			proxier.logger.Error(err, "Failed to get node ip address matching nodeport cidrs, services with nodeport may not work as intended", "CIDRs", proxier.nodePortAddresses)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  8. pkg/proxy/ipvs/proxier.go

    			for _, ipStr := range nodeAddressSet.UnsortedList() {
    				nodeIPs = append(nodeIPs, netutils.ParseIPSloppy(ipStr))
    			}
    		} else {
    			allNodeIPs, err := proxier.nodePortAddresses.GetNodeIPs(proxier.networkInterfacer)
    			if err != nil {
    				proxier.logger.Error(err, "Failed to get node IP address matching nodeport cidr")
    			} else {
    				for _, ip := range allNodeIPs {
    					if !ip.IsLoopback() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
Back to top