- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for getNodeIPs (0.16 sec)
-
pkg/proxy/util/nodeport_addresses.go
func (npa *NodePortAddresses) MatchAll() bool { return npa.matchAll } // GetNodeIPs return all matched node IP addresses for npa's CIDRs. If no matching // IPs are found, it returns an empty list. // NetworkInterfacer is injected for test purpose. func (npa *NodePortAddresses) GetNodeIPs(nw NetworkInterfacer) ([]net.IP, error) { addrs, err := nw.InterfaceAddrs() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 3.6K bytes - Viewed (0) -
pkg/proxy/util/nodeport_addresses_test.go
t.Errorf("unexpected MatchAll(%s), expected: %v", family, tc.expected[family].matchAll) } ips, err := npa.GetNodeIPs(nw) expectedIPs := tc.expected[family].ips // The fake InterfaceAddrs() never returns an error, so // the only error GetNodeIPs will return is "no // addresses found". if err != nil { t.Errorf("unexpected error: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 13.7K bytes - Viewed (0) -
pkg/proxy/healthcheck/service_health.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 30 09:25:48 UTC 2023 - 8.9K bytes - Viewed (0) -
cmd/kube-proxy/app/server_test.go
} if primaryIP != "" { node.Status.Addresses = append(node.Status.Addresses, v1.NodeAddress{Type: v1.NodeInternalIP, Address: primaryIP}, ) } return node } // Test that getNodeIPs retries on failure func Test_getNodeIPs(t *testing.T) { var chans [3]chan error client := clientsetfake.NewSimpleClientset( // node1 initially has no IP address. makeNodeWithAddress("node1", ""),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 32.3K bytes - Viewed (0) -
cmd/kube-proxy/app/server.go
if err != nil { return nil, err } s.Client, err = createClient(ctx, config.ClientConnection, master) if err != nil { return nil, err } rawNodeIPs := getNodeIPs(ctx, s.Client, s.Hostname) s.PrimaryIPFamily, s.NodeIPs = detectNodeIPs(ctx, rawNodeIPs, config.BindAddress) if len(config.NodePortAddresses) == 1 && config.NodePortAddresses[0] == kubeproxyconfig.NodePortAddressesPrimary {
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/nftables/proxier.go
tx.Delete(&knftables.Set{ Name: nodePortIPsSet, }) } else { tx.Flush(&knftables.Set{ Name: nodePortIPsSet, }) 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) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
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) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
for _, ipStr := range nodeAddressSet.UnsortedList() { nodeIPs = append(nodeIPs, netutils.ParseIPSloppy(ipStr)) } } else { allNodeIPs, err := proxier.nodePortAddresses.GetNodeIPs(proxier.networkInterfacer) if err != nil { proxier.logger.Error(err, "Failed to get node IP address matching nodeport cidr") } else { for _, ip := range allNodeIPs { if !ip.IsLoopback() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0)