Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 69 for nodeipam (0.2 sec)

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

    				nodePortSet = proxier.ipsetList[kubeNodePortSetSCTP]
    				// Since hash ip:port is used for SCTP, all the nodeIPs to be used in the SCTP ipset entries.
    				entries = []*utilipset.Entry{}
    				for _, nodeIP := range nodeIPs {
    					entries = append(entries, &utilipset.Entry{
    						IP:       nodeIP.String(),
    						Port:     svcInfo.NodePort(),
    						Protocol: protocol,
    						SetType:  utilipset.HashIPPort,
    					})
    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/kubelet/kubelet_pods_test.go

    			testKubelet := newTestKubelet(t, false /* controllerAttachDetachEnabled */)
    			defer testKubelet.Cleanup()
    			kl := testKubelet.kubelet
    			for _, ip := range tc.nodeIPs {
    				kl.nodeIPs = append(kl.nodeIPs, netutils.ParseIPSloppy(ip))
    			}
    			kl.nodeLister = testNodeLister{nodes: []*v1.Node{
    				{
    					ObjectMeta: metav1.ObjectMeta{Name: string(kl.nodeName)},
    					Status: v1.NodeStatus{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  4. CHANGELOG/CHANGELOG-1.11.md

    * Nodes are not deleted from kubernetes anymore if node is shutdown in Openstack. ([#59931](https://github.com/kubernetes/kubernetes/pull/59931), [@zetaab](https://github.com/zetaab))
    * Re-enabled nodeipam controller for external clouds. Re-enables nodeipam controller for external clouds. Also does a small refactor so that we don't need to pass in allocateNodeCidr into the controller.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 06 06:04:15 UTC 2020
    - 328.4K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_node_status.go

    func validateNodeIP(nodeIP net.IP) error {
    	// Honor IP limitations set in setNodeStatus()
    	if nodeIP.To4() == nil && nodeIP.To16() == nil {
    		return fmt.Errorf("nodeIP must be a valid IP address")
    	}
    	if nodeIP.IsLoopback() {
    		return fmt.Errorf("nodeIP can't be loopback address")
    	}
    	if nodeIP.IsMulticast() {
    		return fmt.Errorf("nodeIP can't be a multicast address")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. pilot/pkg/config/kube/ingress/status_test.go

    }
    
    func TestRunningAddressesWithPod(t *testing.T) {
    	syncer := makeStatusSyncer(t, "")
    
    	address := syncer.runningAddresses()
    
    	if len(address) != 1 || address[0] != nodeIP {
    		t.Errorf("Address is not correctly set to node ip %v %v", address, nodeIP)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  10. 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)
Back to top