- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for IsIPv6String (0.37 sec)
-
pkg/proxy/conntrack/conntrack.go
return nil } // ClearEntriesForIP is part of Interface func (ct *execCT) ClearEntriesForIP(ip string, protocol v1.Protocol) error { parameters := parametersWithFamily(utilnet.IsIPv6String(ip), "-D", "--orig-dst", ip, "-p", protoStr(protocol)) err := ct.exec(parameters...) if err != nil && !strings.Contains(err.Error(), noConnectionToDelete) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:09:05 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/controlplane/reconcilers/endpointsadapter.go
endpoints := []discovery.Endpoint{} isIPv6AddressType := addressType == discovery.AddressTypeIPv6 for _, address := range addresses { if utilnet.IsIPv6String(address.IP) == isIPv6AddressType { endpoints = append(endpoints, endpointFromAddress(address, ready)) } } return endpoints }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 27 12:46:23 UTC 2022 - 7.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config_selfclient.go
host, port, err := net.SplitHostPort(bindAddress) if err != nil { // should never happen return "", "", fmt.Errorf("invalid server bind address: %q", bindAddress) } isIPv6 := netutils.IsIPv6String(host) // Value is expected to be an IP or DNS name, not "0.0.0.0". if host == "0.0.0.0" || host == "::" { // Get ip of local interface, but fall back to "localhost".
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 23 00:06:34 UTC 2021 - 3.1K bytes - Viewed (0) -
cmd/kubeadm/app/phases/etcd/local.go
// probeHostname returns the correct localhost IP address family based on the endpoint AdvertiseAddress probeHostname, probePort, probeScheme := staticpodutil.GetEtcdProbeEndpoint(&cfg.Etcd, utilsnet.IsIPv6String(endpoint.AdvertiseAddress)) return staticpodutil.ComponentPod( v1.Container{ Name: kubeadmconstants.Etcd, Command: getEtcdCommand(cfg, endpoint, nodeName, initialCluster),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 14:07:27 UTC 2024 - 13.8K bytes - Viewed (1) -
pkg/proxy/util/utils.go
if len(service.Spec.ClusterIP) == 0 || service.Spec.ClusterIP == v1.ClusterIPNone { return "" } IsIPv6Family := (ipFamily == v1.IPv6Protocol) if IsIPv6Family == netutils.IsIPv6String(service.Spec.ClusterIP) { return service.Spec.ClusterIP } return "" } for idx, family := range service.Spec.IPFamilies { if family == ipFamily {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 7.4K bytes - Viewed (0) -
pkg/volume/nfs/nfs.go
} return nil, false, fmt.Errorf("Spec does not reference a NFS volume type") } func getServerFromSource(source *v1.NFSVolumeSource) string { if netutil.IsIPv6String(source.Server) { return fmt.Sprintf("[%s]", source.Server) } return source.Server
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
// upgrade is completed (controller connects to api-server that correctly defaults services) if utilnet.IsIPv6String(pod.Status.PodIP) { ipFamily = v1.IPv6Protocol } } } // find an ip that matches the family for _, podIP := range pod.Status.PodIPs { if (ipFamily == v1.IPv6Protocol) == utilnet.IsIPv6String(podIP.IP) { endpointIP = podIP.IP break } } if endpointIP == "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/proxy/endpointslicecache.go
continue } // Filter out the incorrect IP version case. Any endpoint port that // contains incorrect IP version will be ignored. if (cache.ipFamily == v1.IPv6Protocol) != utilnet.IsIPv6String(endpoint.Addresses[0]) { // Emit event on the corresponding service which had a different IP // version than the endpoint.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 11.7K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
r.muTree.Lock() defer r.muTree.Unlock() r.tree = tree return nil } func newIPAddress(name string, svc *v1.Service) *networkingv1alpha1.IPAddress { family := string(v1.IPv4Protocol) if netutils.IsIPv6String(name) { family = string(v1.IPv6Protocol) } return &networkingv1alpha1.IPAddress{ ObjectMeta: metav1.ObjectMeta{ Name: name, Labels: map[string]string{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/kubelet/container/helpers.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0)