- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for hasEndpoints (0.13 sec)
-
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) -
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) -
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) -
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) -
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) -
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)