Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NodeIPs (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pkg/proxy/winkernel/proxier.go

    		hostname, nodeIPs[v1.IPv4Protocol], recorder, healthzServer,
    		healthzBindAddress, config)
    
    	if err != nil {
    		return nil, fmt.Errorf("unable to create ipv4 proxier: %v, hostname: %s, nodeIP:%v", err, hostname, nodeIPs[v1.IPv4Protocol])
    	}
    
    	ipv6Proxier, err := NewProxier(v1.IPv6Protocol, syncPeriod, minSyncPeriod,
    		hostname, nodeIPs[v1.IPv6Protocol], recorder, healthzServer,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  5. 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)
    		}
    		for _, ip := range nodeIPs {
    			if ip.IsLoopback() {
    				if isIPv6 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  6. cmd/kubelet/app/server.go

    	if err != nil {
    		return err
    	}
    	hostnameOverridden := len(kubeServer.HostnameOverride) > 0
    	// Setup event recorder if required.
    	makeEventRecorder(ctx, kubeDeps, nodeName)
    
    	nodeIPs, invalidNodeIps, err := nodeutil.ParseNodeIPArgument(kubeServer.NodeIP, kubeServer.CloudProvider)
    	if err != nil {
    		return fmt.Errorf("bad --node-ip %q: %v", kubeServer.NodeIP, err)
    	}
    	if len(invalidNodeIps) != 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:34 UTC 2024
    - 53.9K bytes
    - Viewed (0)
Back to top