- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 27 for ParseIPSloppy (0.8 sec)
-
cmd/kubeadm/app/apis/kubeadm/apiendpoint.go
apiEndpointHost, apiEndpointPortStr, err := net.SplitHostPort(apiEndpoint) if err != nil { return APIEndpoint{}, errors.Wrapf(err, "invalid advertise address endpoint: %s", apiEndpoint) } if netutils.ParseIPSloppy(apiEndpointHost) == nil { return APIEndpoint{}, errors.Errorf("invalid API endpoint IP: %s", apiEndpointHost) } apiEndpointPort, err := net.LookupPort("tcp", apiEndpointPortStr) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 20 08:42:09 UTC 2021 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/serving_with_loopback_test.go
) func TestEmptyMainCert(t *testing.T) { secureServingInfo := &server.SecureServingInfo{} var loopbackClientConfig *rest.Config s := (&SecureServingOptions{ BindAddress: netutils.ParseIPSloppy("127.0.0.1"), }).WithLoopback() ln, err := net.Listen("tcp", "127.0.0.1:0") if err != nil { t.Fatalf("failed to listen on 127.0.0.1:0") } defer ln.Close() s.Listener = ln
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 20 08:42:09 UTC 2021 - 1.4K bytes - Viewed (0) -
pkg/util/node/node.go
for _, addr := range node.Status.Addresses { if addr.Type == v1.NodeInternalIP { ip := netutils.ParseIPSloppy(addr.Address) if ip != nil { allIPs = append(allIPs, ip) } } } for _, addr := range node.Status.Addresses { if addr.Type == v1.NodeExternalIP { ip := netutils.ParseIPSloppy(addr.Address) if ip != nil { allIPs = append(allIPs, ip) } } } if len(allIPs) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 27 23:24:38 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/controlplane/apiserver/config_test.go
netutils "k8s.io/utils/net" ) func TestBuildGenericConfig(t *testing.T) { opts := options.NewOptions() s := (&apiserveroptions.SecureServingOptions{ BindAddress: netutils.ParseIPSloppy("127.0.0.1"), }).WithLoopback() ln, err := net.Listen("tcp", "127.0.0.1:0") if err != nil { t.Fatalf("failed to listen on 127.0.0.1:0") } defer ln.Close() s.Listener = ln
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 12:14:06 UTC 2024 - 2.5K bytes - Viewed (0) -
cmd/kubeadm/app/util/endpoint.go
return "", "", errors.Errorf("hostport %s: port %s must be a valid number between 1 and 65535, inclusive", hostport, port) } } // if host is a valid IP, returns it if ip := netutils.ParseIPSloppy(host); ip != nil { return host, port, nil } // if host is a validate RFC-1123 subdomain, returns it if errs := validation.IsDNS1123Subdomain(host); len(errs) == 0 { return host, port, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 11 15:08:59 UTC 2022 - 5.3K bytes - Viewed (0) -
pkg/proxy/util/utils.go
func MapIPsByIPFamily(ipStrings []string) map[v1.IPFamily][]net.IP { ipFamilyMap := map[v1.IPFamily][]net.IP{} for _, ipStr := range ipStrings { ip := netutils.ParseIPSloppy(ipStr) if ip != nil { // Since ip is parsed ok, GetIPFamilyFromIP will never return v1.IPFamilyUnknown ipFamily := GetIPFamilyFromIP(ip) ipFamilyMap[ipFamily] = append(ipFamilyMap[ipFamily], ip) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 7.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/named_certificates_test.go
} } } func parseIPList(ips []string) []net.IP { var netIPs []net.IP for _, ip := range ips { netIPs = append(netIPs, netutils.ParseIPSloppy(ip)) } return netIPs } func createTestTLSCerts(spec testCertSpec, names []string) (certProvider SNICertKeyContentProvider, err error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 20 08:42:09 UTC 2021 - 8K bytes - Viewed (0) -
hack/verify-netparse-cve.sh
if [[ -n "${netparseip_matches}" ]]; then echo "net.ParseIP reject leading zeros in the dot-decimal notation of IPv4 addresses since golang 1.17:" >&2 echo "${netparseip_matches}" >&2 echo >&2 echo "Use k8s.io/utils/net ParseIPSloppy() to parse IP addresses. Kubernetes #100895" >&2 echo >&2 echo "Run ./hack/update-netparse-cve.sh" >&2 echo >&2 rc=1 fi # find files using net.ParseCIDR()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:07:31 UTC 2024 - 2.3K bytes - Viewed (0) -
pkg/proxy/ipvs/netlink_linux.go
dev, err := h.LinkByName(devName) if err != nil { return false, fmt.Errorf("error get interface: %s, err: %v", devName, err) } addr := netutils.ParseIPSloppy(address) if addr == nil { return false, fmt.Errorf("error parse ip address: %s", address) } if err := h.AddrAdd(dev, &netlink.Addr{IPNet: netlink.NewIPNet(addr)}); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 30 16:18:49 UTC 2023 - 5.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/named_certificates.go
// suitable for use in tls.Config#NamedCertificates. func getCertificateNames(cert *x509.Certificate) []string { var names []string cn := cert.Subject.CommonName cnIsIP := netutils.ParseIPSloppy(cn) != nil cnIsValidDomain := cn == "*" || len(validation.IsDNS1123Subdomain(strings.TrimPrefix(cn, "*."))) == 0
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 21 07:29:30 UTC 2022 - 3.2K bytes - Viewed (0)