Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for NodeIPs (0.1 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. pkg/util/node/node.go

    	}
    	if len(allIPs) == 0 {
    		return nil, fmt.Errorf("host IP unknown; known addresses: %v", node.Status.Addresses)
    	}
    
    	nodeIPs := []net.IP{allIPs[0]}
    	for _, ip := range allIPs {
    		if netutils.IsIPv6(ip) != netutils.IsIPv6(nodeIPs[0]) {
    			nodeIPs = append(nodeIPs, ip)
    			break
    		}
    	}
    
    	return nodeIPs, nil
    }
    
    // GetNodeHostIP returns the provided node's "primary" IP; see GetNodeHostIPs for more details
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 27 23:24:38 UTC 2023
    - 4.8K 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. pkg/util/node/node_test.go

    				}
    			} else if tc.expectIPs == nil {
    				t.Errorf("expected error, got %v", nodeIPs)
    			} else if !reflect.DeepEqual(nodeIPs, tc.expectIPs) {
    				t.Errorf("expected %v, got %v", tc.expectIPs, nodeIPs)
    			} else if !nodeIP.Equal(nodeIPs[0]) {
    				t.Errorf("GetNodeHostIP did not return same primary (%s) as GetNodeHostIPs (%s)", nodeIP.String(), nodeIPs[0].String())
    			}
    		})
    	}
    }
    
    func TestIsNodeReady(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 27 23:24:38 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. pkg/kubelet/network/dns/dns.go

    func NewConfigurer(recorder record.EventRecorder, nodeRef *v1.ObjectReference, nodeIPs []net.IP, clusterDNS []net.IP, clusterDomain, resolverConfig string) *Configurer {
    	return &Configurer{
    		recorder:         recorder,
    		getHostDNSConfig: getHostDNSConfig,
    		nodeRef:          nodeRef,
    		nodeIPs:          nodeIPs,
    		clusterDNS:       clusterDNS,
    		ClusterDomain:    clusterDomain,
    		ResolverConfig:   resolverConfig,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 04 11:37:10 UTC 2023
    - 16.1K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top