- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 64 for IPFamily (0.24 sec)
-
pkg/proxy/util/utils.go
func convertToV1IPFamily(ipFamily netutils.IPFamily) v1.IPFamily { switch ipFamily { case netutils.IPv4: return v1.IPv4Protocol case netutils.IPv6: return v1.IPv6Protocol } return v1.IPFamilyUnknown } // OtherIPFamily returns the other ip family func OtherIPFamily(ipFamily v1.IPFamily) v1.IPFamily { if ipFamily == v1.IPv6Protocol { return v1.IPv4Protocol }
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/proxy/serviceport.go
info.externalIPs = ipFamilyMap[ipFamily] // Log the IPs not matching the ipFamily if ips, ok := ipFamilyMap[proxyutil.OtherIPFamily(ipFamily)]; ok && len(ips) > 0 { klog.V(4).InfoS("Service change tracker ignored the following external IPs for given service as they don't match IP Family", "ipFamily", ipFamily, "externalIPs", ips, "service", klog.KObj(service)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 09 08:17:56 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/proxy/util/utils_test.go
t.Run(testcase.desc, func(t *testing.T) { ipFamily := v1.IPv4Protocol otherIPFamily := v1.IPv6Protocol if testcase.wantIPv6 { ipFamily = v1.IPv6Protocol otherIPFamily = v1.IPv4Protocol } ipMap := MapIPsByIPFamily(testcase.ipString) var ipStr []string for _, ip := range ipMap[ipFamily] { ipStr = append(ipStr, ip.String()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 17.1K bytes - Viewed (0) -
pkg/registry/core/service/storage/storage_test.go
name string clusterFamilies []api.IPFamily svc *api.Service }{{ name: "singlestack:v4_clusterip:unset", clusterFamilies: []api.IPFamily{api.IPv4Protocol}, svc: svctest.MakeService("foo"), }, { name: "singlestack:v4_clusterip:set", clusterFamilies: []api.IPFamily{api.IPv4Protocol}, svc: svctest.MakeService("foo",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 440.2K bytes - Viewed (0) -
pkg/proxy/util/nodeport_addresses_test.go
type expectation struct { matchAll bool ips sets.Set[string] } testCases := []struct { name string cidrs []string itfAddrsPairs []InterfaceAddrsPair expected map[v1.IPFamily]expectation }{ { name: "IPv4 single", cidrs: []string{"10.20.30.0/24"}, itfAddrsPairs: []InterfaceAddrsPair{ { itf: net.Interface{Index: 0, MTU: 0, Name: "eth0", HardwareAddr: nil, Flags: 0},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 13.7K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator.go
address, _ := netip.AddrFromSlice(bytes) return address } // Convert netutils.IPFamily to v1.IPFamily // TODO: consolidate helpers // copied from pkg/proxy/util/utils.go func convertToV1IPFamily(ipFamily netutils.IPFamily) v1.IPFamily { switch ipFamily { case netutils.IPv4: return v1.IPv4Protocol case netutils.IPv6: return v1.IPv6Protocol }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair_test.go
ClusterIPs: []string{"192.168.1.1"}, IPFamilies: []corev1.IPFamily{corev1.IPv4Protocol}, }, }, &corev1.Service{ ObjectMeta: metav1.ObjectMeta{Namespace: "two", Name: "two"}, Spec: corev1.ServiceSpec{ ClusterIP: "192.168.1.100", ClusterIPs: []string{"192.168.1.100"}, IPFamilies: []corev1.IPFamily{corev1.IPv4Protocol}, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 21.1K bytes - Viewed (0) -
cmd/kube-proxy/app/server_linux_test.go
} } func Test_getLocalDetectors(t *testing.T) { cases := []struct { name string config *proxyconfigapi.KubeProxyConfiguration primaryIPFamily v1.IPFamily nodePodCIDRs []string expected map[v1.IPFamily]proxyutil.LocalTrafficDetector }{ // LocalModeClusterCIDR { name: "LocalModeClusterCIDR, single-stack IPv4 cluster", config: &proxyconfigapi.KubeProxyConfiguration{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 21.9K bytes - Viewed (0) -
pkg/proxy/servicechangetracker_test.go
service *v1.Service expected map[ServicePortName]*BaseServicePortInfo ipFamily v1.IPFamily ipModeEnabled bool }{ { desc: "nothing", ipFamily: v1.IPv4Protocol, service: nil, expected: map[ServicePortName]*BaseServicePortInfo{}, }, { desc: "headless service", ipFamily: v1.IPv4Protocol, service: makeTestService("ns2", "headless", func(svc *v1.Service) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 33.7K bytes - Viewed (0) -
pkg/proxy/healthcheck/proxier_health.go
// healthTimeout time then it will be considered unhealthy. func (hs *ProxierHealthServer) QueuedUpdate(ipFamily v1.IPFamily) { hs.lock.Lock() defer hs.lock.Unlock() // Set oldestPendingQueuedMap[ipFamily] only if it's currently unset if _, set := hs.oldestPendingQueuedMap[ipFamily]; !set { hs.oldestPendingQueuedMap[ipFamily] = hs.clock.Now() } } // IsHealthy returns only the proxier's health state, following the same
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 10:41:18 UTC 2023 - 8K bytes - Viewed (0)