Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ParseIPSloppy (0.19 sec)

  1. pkg/proxy/ipvs/proxier_test.go

    						Port:     80,
    						Protocol: "TCP",
    					}: {
    						Address:   netutils.ParseIPSloppy("10.20.30.41"),
    						Protocol:  "TCP",
    						Port:      uint16(80),
    						Scheduler: "rr",
    					},
    					{
    						IP:       "100.101.102.103",
    						Port:     3001,
    						Protocol: "TCP",
    					}: {
    						Address:   netutils.ParseIPSloppy("100.101.102.103"),
    						Protocol:  "TCP",
    						Port:      uint16(3001),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  2. pkg/proxy/nftables/proxier_test.go

    		&net.IPNet{IP: netutils.ParseIPSloppy(testExternalIP), Mask: net.CIDRMask(24, 32)},
    		&net.IPNet{IP: netutils.ParseIPSloppy(testNodeIPv6), Mask: net.CIDRMask(64, 128)},
    		&net.IPNet{IP: netutils.ParseIPSloppy(testNodeIPv6Alt), Mask: net.CIDRMask(64, 128)},
    	}
    	networkInterfacer.AddInterfaceAddr(&itf1, addrs1)
    
    	nft := knftables.NewFake(nftablesFamily, kubeProxyTable)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  3. 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{
    						Addresses: tc.nodeAddresses,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_node_status_test.go

    			success:  true,
    			testName: fmt.Sprintf("Success test case for address %s", ip.String()),
    		}
    		tests = append(tests, successTest)
    	}
    	for _, test := range tests {
    		err := validateNodeIP(netutils.ParseIPSloppy(test.nodeIP))
    		if test.success {
    			assert.NoError(t, err, "test %s", test.testName)
    		} else {
    			assert.Error(t, err, fmt.Sprintf("test %s", test.testName))
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet.go

    				return nil, err
    			}
    		} else {
    			return nil, err
    		}
    	}
    
    	clusterDNS := make([]net.IP, 0, len(kubeCfg.ClusterDNS))
    	for _, ipEntry := range kubeCfg.ClusterDNS {
    		ip := netutils.ParseIPSloppy(ipEntry)
    		if ip == nil {
    			klog.InfoS("Invalid clusterDNS IP", "IP", ipEntry)
    		} else {
    			clusterDNS = append(clusterDNS, ip)
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top