- Sort Score
- Result 10 results
- Languages All
Results 11 - 18 of 18 for IsIPv6String (0.28 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)