Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 74 for ParseIPSloppy (0.18 sec)

  1. pkg/proxy/iptables/number_generated_rules_test.go

    	endpointSlices := make([]*discovery.EndpointSlice, nServices)
    
    	// base parameters
    	basePort := 80
    	base := netutils.BigForIP(netutils.ParseIPSloppy("10.0.0.1"))
    
    	// generate a base endpoint slice object
    	baseEp := netutils.BigForIP(netutils.ParseIPSloppy("172.16.0.1"))
    	epPort := 8080
    
    	eps := &discovery.EndpointSlice{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "ep",
    			Namespace: "namespace",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  2. pkg/registry/core/service/ipallocator/cidrallocator.go

    	}).AsSelectorPreValidated()
    	ips, err := c.ipAddressLister.List(ipLabelSelector)
    	if err != nil {
    		return
    	}
    	for _, ip := range ips {
    		f(netutils.ParseIPSloppy(ip.Name))
    	}
    }
    
    func (c *MetaAllocator) CIDR() net.IPNet {
    	return net.IPNet{}
    
    }
    func (c *MetaAllocator) IPFamily() api.IPFamily {
    	return c.ipFamily
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  3. pkg/kubelet/network/dns/dns_test.go

    		Kind:      "Node",
    		Name:      string("testNode"),
    		UID:       types.UID("testNode"),
    		Namespace: "",
    	}
    	testClusterDNSDomain := "TEST"
    	clusterNS := "203.0.113.1"
    	testClusterDNS := []net.IP{netutils.ParseIPSloppy(clusterNS)}
    
    	configurer := NewConfigurer(recorder, nodeRef, nil, nil, testClusterDNSDomain, "")
    
    	pod := &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			UID:         "",
    			Name:        "test_pod",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/util/pkiutil/pki_helpers_test.go

    				}
    			}
    
    			for _, IPAddress := range rt.expectedIPAddresses {
    				found := false
    				for _, val := range altNames.IPs {
    					if val.Equal(netutils.ParseIPSloppy(IPAddress)) {
    						found = true
    						break
    					}
    				}
    
    				if !found {
    					t.Errorf("%s: altNames does not contain IPAddress %s but %v", rt.name, IPAddress, altNames.IPs)
    				}
    			}
    		})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 31 21:49:21 UTC 2024
    - 22.5K bytes
    - Viewed (0)
  5. pkg/kubelet/kuberuntime/kuberuntime_sandbox.go

    		return podIPs
    	}
    
    	// ip could be an empty string if runtime is not responsible for the
    	// IP (e.g., host networking).
    
    	// pick primary IP
    	if len(podSandbox.Network.Ip) != 0 {
    		if netutils.ParseIPSloppy(podSandbox.Network.Ip) == nil {
    			klog.InfoS("Pod Sandbox reported an unparseable primary IP", "pod", klog.KRef(podNamespace, podName), "IP", podSandbox.Network.Ip)
    			return nil
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  6. pkg/proxy/ipvs/testing/fake.go

    	}
    	h.localAddresses[dev] = make([]string, 0)
    	h.localAddresses[dev] = append(h.localAddresses[dev], ips...)
    	return nil
    }
    
    func (h *FakeNetlinkHandle) isValidForSet(ipString string) bool {
    	ip := net.ParseIPSloppy(ipString)
    	if h.IsIPv6 != (ip.To4() == nil) {
    		return false
    	}
    	if h.IsIPv6 && ip.IsLinkLocalUnicast() {
    		return false
    	}
    	if ip.IsLoopback() {
    		return false
    	}
    	return true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  7. pkg/proxy/apis/config/validation/validation.go

    	}
    
    	if config.ConfigSyncPeriod.Duration <= 0 {
    		allErrs = append(allErrs, field.Invalid(newPath.Child("ConfigSyncPeriod"), config.ConfigSyncPeriod, "must be greater than 0"))
    	}
    
    	if netutils.ParseIPSloppy(config.BindAddress) == nil {
    		allErrs = append(allErrs, field.Invalid(newPath.Child("BindAddress"), config.BindAddress, "not a valid textual representation of an IP address"))
    	}
    
    	if config.HealthzBindAddress != "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  8. pkg/proxy/apis/config/v1alpha1/defaults.go

    // based on the given bind address. IPv6 addresses are enclosed in square
    // brackets for appending port.
    func getDefaultAddresses(bindAddress string) (defaultHealthzAddress, defaultMetricsAddress string) {
    	if netutils.ParseIPSloppy(bindAddress).To4() != nil {
    		return "0.0.0.0", "127.0.0.1"
    	}
    	return "[::]", "[::1]"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:33:53 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/util/webhook/client.go

    	}
    
    	return complete(cfg)
    }
    
    func isLocalHost(u *url.URL) bool {
    	host := u.Hostname()
    	if strings.EqualFold(host, "localhost") {
    		return true
    	}
    
    	netIP := netutils.ParseIPSloppy(host)
    	if netIP != nil {
    		return netIP.IsLoopback()
    	}
    	return false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 04 09:09:10 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  10. cmd/kubeadm/app/util/config/common.go

    // in which case this address is not valid and should not be used.
    func VerifyAPIServerBindAddress(address string) error {
    	ip := netutils.ParseIPSloppy(address)
    	if ip == nil {
    		return errors.Errorf("cannot parse IP address: %s", address)
    	}
    	// There are users with network setups where default routes are present, but network interfaces
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 11:04:08 UTC 2024
    - 18.1K bytes
    - Viewed (0)
Back to top