Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for hasEndpoints (0.13 sec)

  1. pkg/proxy/nftables/proxier.go

    		// from this node, given the service's traffic policies. hasEndpoints is true
    		// if the service has any usable endpoints on any node, not just this one.
    		allEndpoints := proxier.endpointsMap[svcName]
    		clusterEndpoints, localEndpoints, allLocallyReachableEndpoints, hasEndpoints := proxy.CategorizeEndpoints(allEndpoints, svcInfo, proxier.nodeLabels)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  2. tests/integration/pilot/istioctl_test.go

    			}
    			hasEndpoints := false
    			for _, rawConfig := range rawConfigs {
    				configDump, ok := rawConfig.(map[string]any)
    				if !ok {
    					t.Fatalf("Failed to parse istioctl %s raw config dump element to map of any", strings.Join(args, " "))
    				}
    				if configDump["@type"] == "type.googleapis.com/envoy.admin.v3.EndpointsConfigDump" {
    					hasEndpoints = true
    					break
    				}
    			}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 15K bytes
    - Viewed (0)
  3. pkg/proxy/iptables/proxier.go

    		// from this node, given the service's traffic policies. hasEndpoints is true
    		// if the service has any usable endpoints on any node, not just this one.
    		allEndpoints := proxier.endpointsMap[svcName]
    		clusterEndpoints, localEndpoints, allLocallyReachableEndpoints, hasEndpoints := proxy.CategorizeEndpoints(allEndpoints, svcInfo, proxier.nodeLabels)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  4. pkg/proxy/winkernel/proxier.go

    				containsPublicIP = containsPublicIP || isPublicIP
    			}
    
    			// Save the hnsId for reference
    			klog.V(1).InfoS("Hns endpoint resource", "endpointInfo", newHnsEndpoint)
    
    			hnsEndpoints = append(hnsEndpoints, *newHnsEndpoint)
    			if newHnsEndpoint.IsLocal() {
    				hnsLocalEndpoints = append(hnsLocalEndpoints, *newHnsEndpoint)
    			} else {
    				// We only share the refCounts for remote endpoints
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  5. pkg/proxy/winkernel/hns.go

    func findLoadBalancerID(endpoints []endpointInfo, vip string, protocol, internalPort, externalPort uint16) (loadBalancerIdentifier, error) {
    	// Compute hash from backends (endpoint IDs)
    	hash, err := hashEndpoints(endpoints)
    	if err != nil {
    		klog.V(2).ErrorS(err, "Error hashing endpoints", "endpoints", endpoints)
    		return loadBalancerIdentifier{}, err
    	}
    	if len(vip) > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 09 21:21:12 UTC 2023
    - 15K bytes
    - Viewed (0)
  6. pkg/proxy/winkernel/hns_test.go

    	endpointsReverse := []endpointInfo{*endpointInfoB, *endpointInfoA}
    	h1, err := hashEndpoints(endpoints)
    	if err != nil {
    		t.Error(err)
    	} else if len(h1) < 1 {
    		t.Error("HashEndpoints failed for endpoints", endpoints)
    	}
    
    	h2, err := hashEndpoints(endpointsReverse)
    	if err != nil {
    		t.Error(err)
    	}
    	if h1 != h2 {
    		t.Errorf("%x does not match %x", h1, h2)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 15.4K bytes
    - Viewed (0)
Back to top