- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for nodeipam (0.11 sec)
-
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) -
pkg/proxy/ipvs/proxier_test.go
} func NewFakeProxier(ctx context.Context, ipt utiliptables.Interface, ipvs utilipvs.Interface, ipset utilipset.Interface, nodeIPs []string, excludeCIDRs []*net.IPNet, ipFamily v1.IPFamily) *Proxier { netlinkHandle := netlinktest.NewFakeNetlinkHandle(ipFamily == v1.IPv6Protocol) netlinkHandle.SetLocalAddresses("eth0", nodeIPs...) // initialize ipsetList with all sets we needed ipsetList := make(map[string]*IPSet)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
func TestValidateNodeIPParam(t *testing.T) { type test struct { nodeIP string success bool testName string } tests := []test{ { nodeIP: "", success: false, testName: "IP not set", }, { nodeIP: "127.0.0.1", success: false, testName: "IPv4 loopback address", }, { nodeIP: "::1", success: false,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0) -
pkg/proxy/nftables/proxier_test.go
} networkInterfacer.AddInterfaceAddr(&itf1, addrs1) nft := knftables.NewFake(nftablesFamily, kubeProxyTable) var nodeIP net.IP if ipFamily == v1.IPv4Protocol { nodeIP = netutils.ParseIPSloppy(testNodeIP) } else { nodeIP = netutils.ParseIPSloppy(testNodeIPv6) } p := &Proxier{ ipFamily: ipFamily, svcPortMap: make(proxy.ServicePortMap),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 173.5K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
syncLoopMonitor: atomic.Value{}, daemonEndpoints: daemonEndpoints, containerManager: kubeDeps.ContainerManager, nodeIPs: nodeIPs, nodeIPValidator: validateNodeIP, clock: clock.RealClock{}, enableControllerAttachDetach: kubeCfg.EnableControllerAttachDetach,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (1) -
pkg/kubelet/kubelet_pods.go
func (kl *Kubelet) sortPodIPs(podIPs []string) []string { ips := make([]string, 0, 2) var validPrimaryIP, validSecondaryIP func(ip string) bool if len(kl.nodeIPs) == 0 || utilnet.IsIPv4(kl.nodeIPs[0]) { validPrimaryIP = utilnet.IsIPv4String validSecondaryIP = utilnet.IsIPv6String } else { validPrimaryIP = utilnet.IsIPv6String validSecondaryIP = utilnet.IsIPv4String }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0)