Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 18 of 18 for IsIPv6String (0.28 sec)

  1. pkg/controller/servicecidrs/servicecidrs_controller_test.go

    	}
    	return serviceCIDR
    }
    
    func makeIPAddress(name string) *networkingapiv1alpha1.IPAddress {
    	family := string(v1.IPv4Protocol)
    	if netutils.IsIPv6String(name) {
    		family = string(v1.IPv6Protocol)
    	}
    	return &networkingapiv1alpha1.IPAddress{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: name,
    			Labels: map[string]string{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 22K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/phases/controlplane/manifests.go

    		}
    	} else {
    		// Default to etcd static pod on localhost
    		// localhost IP family should be the same that the AdvertiseAddress
    		etcdLocalhostAddress := "127.0.0.1"
    		if utilsnet.IsIPv6String(localAPIEndpoint.AdvertiseAddress) {
    			etcdLocalhostAddress = "::1"
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Mar 03 14:43:47 UTC 2024
    - 17.8K bytes
    - Viewed (0)
  3. pkg/registry/core/service/storage/alloc.go

    		return nil, nil
    	}
    
    	toRelease := make(map[api.IPFamily]string)
    	for _, ip := range service.Spec.ClusterIPs {
    		if netutils.IsIPv6String(ip) {
    			toRelease[api.IPv6Protocol] = ip
    		} else {
    			toRelease[api.IPv4Protocol] = ip
    		}
    	}
    	return al.releaseIPs(toRelease)
    }
    
    func (al *Allocators) Destroy() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:05 UTC 2023
    - 37.3K bytes
    - Viewed (0)
  4. pkg/registry/core/service/storage/storage.go

    		}
    	} else {
    		// Headful: init ipFamilies from clusterIPs.
    		service.Spec.IPFamilies = make([]api.IPFamily, len(service.Spec.ClusterIPs))
    		for idx, ip := range service.Spec.ClusterIPs {
    			if netutil.IsIPv6String(ip) {
    				service.Spec.IPFamilies[idx] = api.IPv6Protocol
    			} else {
    				service.Spec.IPFamilies[idx] = api.IPv4Protocol
    			}
    		}
    		if len(service.Spec.IPFamilies) == 1 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 13:09:33 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  5. cmd/kubeadm/app/preflight/checks.go

    func (hst HTTPProxyCheck) Check() (warnings, errorList []error) {
    	klog.V(1).Infoln("validating if the connectivity type is via proxy or direct")
    	u := &url.URL{Scheme: hst.Proto, Host: hst.Host}
    	if netutils.IsIPv6String(hst.Host) {
    		u.Host = net.JoinHostPort(hst.Host, "1234")
    	}
    
    	req, err := http.NewRequest("GET", u.String(), nil)
    	if err != nil {
    		return nil, []error{err}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:20:55 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_pods.go

    	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
    	}
    	for _, ip := range podIPs {
    		if validPrimaryIP(ip) {
    			ips = append(ips, ip)
    			break
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  7. pkg/controller/endpoint/endpoints_controller_test.go

    				t.Fatalf("podToEndpointAddressForService should have returned error but it did not")
    			}
    
    			if err != nil && tc.expectError {
    				return
    			}
    
    			if utilnet.IsIPv6String(epa.IP) != (tc.expectedEndpointFamily == ipv6) {
    				t.Fatalf("IP: expected %s, got: %s", tc.expectedEndpointFamily, epa.IP)
    			}
    			if *(epa.NodeName) != pod.Spec.NodeName {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 87.7K bytes
    - Viewed (0)
  8. pkg/apis/core/validation/validation.go

    			}
    
    			// 4=>6
    			if service.Spec.IPFamilies[i] == core.IPv4Protocol && netutils.IsIPv6String(ip) {
    				allErrs = append(allErrs, field.Invalid(clusterIPsField.Index(i), ip, fmt.Sprintf("expected an IPv4 value as indicated by `ipFamilies[%v]`", i)))
    			}
    			// 6=>4
    			if service.Spec.IPFamilies[i] == core.IPv6Protocol && !netutils.IsIPv6String(ip) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 349.5K bytes
    - Viewed (0)
Back to top