Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for MapIPsByIPFamily (0.27 sec)

  1. pkg/proxy/util/utils.go

    				Namespace: svcNamespace,
    				UID:       svcUID,
    			}, nil, v1.EventTypeWarning, "KubeProxyIncorrectIPVersion", "GatherEndpoints", errMsg)
    	}
    }
    
    // MapIPsByIPFamily maps a slice of IPs to their respective IP families (v4 or v6)
    func MapIPsByIPFamily(ipStrings []string) map[v1.IPFamily][]net.IP {
    	ipFamilyMap := map[v1.IPFamily][]net.IP{}
    	for _, ipStr := range ipStrings {
    		ip := netutils.ParseIPSloppy(ipStr)
    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

    	// services, this is actually expected. Hence we downgraded from reporting by events
    	// to just log lines with high verbosity
    	ipFamilyMap := proxyutil.MapIPsByIPFamily(service.Spec.ExternalIPs)
    	info.externalIPs = ipFamilyMap[ipFamily]
    
    	// Log the IPs not matching the ipFamily
    	if ips, ok := ipFamilyMap[proxyutil.OtherIPFamily(ipFamily)]; ok && len(ips) > 0 {
    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/proxy/util/utils_test.go

    			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())
    			}
    			if !reflect.DeepEqual(testcase.expectCorrect, ipStr) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 20 11:57:43 UTC 2024
    - 17.1K bytes
    - Viewed (0)
Back to top