Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for nodeipam (0.17 sec)

  1. cmd/kube-controller-manager/app/options/options_test.go

    	jobconfig "k8s.io/kubernetes/pkg/controller/job/config"
    	namespaceconfig "k8s.io/kubernetes/pkg/controller/namespace/config"
    	nodeipamconfig "k8s.io/kubernetes/pkg/controller/nodeipam/config"
    	nodelifecycleconfig "k8s.io/kubernetes/pkg/controller/nodelifecycle/config"
    	poautosclerconfig "k8s.io/kubernetes/pkg/controller/podautoscaler/config"
    	podgcconfig "k8s.io/kubernetes/pkg/controller/podgc/config"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 02:59:09 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  2. 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)
  3. pkg/proxy/winkernel/proxier.go

    	minSyncPeriod time.Duration,
    	hostname string,
    	nodeIP net.IP,
    	recorder events.EventRecorder,
    	healthzServer *healthcheck.ProxierHealthServer,
    	healthzBindAddress string,
    	config config.KubeProxyWinkernelConfiguration,
    ) (*Proxier, error) {
    	if nodeIP == nil {
    		klog.InfoS("Invalid nodeIP, initializing kube-proxy with 127.0.0.1 as nodeIP")
    		nodeIP = netutils.ParseIPSloppy("127.0.0.1")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. pkg/scheduler/internal/cache/cache_test.go

    			for _, nodeItem := range tc.nodes {
    				cache.AddNode(logger, nodeItem)
    			}
    			for _, pod := range tc.pods {
    				if err := cache.AddPod(logger, pod); err != nil {
    					t.Fatal(err)
    				}
    			}
    			nodes := map[string]*framework.NodeInfo{}
    			for nodeItem := cache.headNode; nodeItem != nil; nodeItem = nodeItem.next {
    				nodes[nodeItem.info.Node().Name] = nodeItem.info
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 63.8K bytes
    - Viewed (0)
  8. cmd/kubelet/app/server.go

    	// 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