Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for NodeIPs (0.13 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. pkg/proxy/nftables/helpers_test.go

    	markMasq bool
    }
    
    // newNFTablesTracer creates an nftablesTracer. nodeIPs are the IP to treat as local node
    // IPs (for determining whether rules with "fib saddr type local" or "fib daddr type
    // local" match).
    func newNFTablesTracer(t *testing.T, nft *knftables.Fake, nodeIPs []string) *nftablesTracer {
    	return &nftablesTracer{
    		nft:     nft,
    		nodeIPs: sets.New(nodeIPs...),
    		t:       t,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 02 09:57:47 UTC 2024
    - 48.5K bytes
    - Viewed (0)
  6. pkg/bootstrap/config.go

    		for _, val := range values {
    			ret = append(ret, strings.Replace(pattern, varName, val, -1))
    		}
    	}
    	return ret
    }
    
    func getStatsOptions(meta *model.BootstrapNodeMetadata) []option.Instance {
    	nodeIPs := meta.InstanceIPs
    	config := meta.ProxyConfig
    
    	tagAnno := meta.Annotations[annotation.SidecarExtraStatTags.Name]
    	prefixAnno := meta.Annotations[annotation.SidecarStatsInclusionPrefixes.Name]
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:02:38 UTC 2024
    - 27.6K bytes
    - Viewed (0)
  7. pilot/cmd/pilot-agent/app/cmd.go

    			}
    
    			envoyOptions := envoy.ProxyConfig{
    				LogLevel:          proxyArgs.ProxyLogLevel,
    				ComponentLogLevel: proxyArgs.ProxyComponentLogLevel,
    				LogAsJSON:         loggingOptions.JSONEncoding,
    				NodeIPs:           proxyArgs.IPAddresses,
    				Sidecar:           proxyArgs.Type == model.SidecarProxy,
    				OutlierLogPath:    proxyArgs.OutlierLogPath,
    			}
    			agentOptions := options.NewAgentOptions(&proxyArgs, proxyConfig, sds)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  8. cmd/kube-proxy/app/server_linux_test.go

    			_, ctx := ktesting.NewTestContext(t)
    			client := clientsetfake.NewSimpleClientset(tt.node)
    			s := &ProxyServer{
    				Config:   tt.config,
    				Client:   client,
    				Hostname: "nodename",
    				NodeIPs: map[v1.IPFamily]net.IP{
    					v1.IPv4Protocol: netutils.ParseIPSloppy("127.0.0.1"),
    					v1.IPv6Protocol: net.IPv6zero,
    				},
    			}
    			err := s.platformSetup(ctx)
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet_node_status.go

    	if kl.cloud != nil {
    		nodeAddressesFunc = kl.cloudResourceSyncManager.NodeAddresses
    	}
    	var setters []func(ctx context.Context, n *v1.Node) error
    	setters = append(setters,
    		nodestatus.NodeAddress(kl.nodeIPs, kl.nodeIPValidator, kl.hostname, kl.hostnameOverridden, kl.externalCloudProvider, kl.cloud, nodeAddressesFunc),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
Back to top