- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 69 for nodeipam (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)