Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 64 for IPFamily (0.72 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top