- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ExtractClusterEndpoints (0.46 sec)
-
pilot/pkg/xds/xds_test.go
}, }) p := baseProxy() // Change the node's IP so that it does not match with any service entry p.IPAddresses = []string{"100.100.100.100"} proxy := s.SetupProxy(p) endpoints := xdstest.ExtractClusterEndpoints(s.Clusters(proxy)) eps := endpoints["inbound|9080||"] if !slices.EqualUnordered(eps, []string{"/var/run/someuds.sock"}) { t.Fatalf("expected /var/run/someuds.sock, got %v", eps) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 13.8K bytes - Viewed (0) -
pilot/pkg/xds/cds_test.go
protocol: HTTP resolution: DNS endpoints: - address: endpoint.example.com - address: endpoint-port-override.example.com ports: port1: 2345 `}) res := xdstest.ExtractClusterEndpoints(s.Clusters(s.SetupProxy(nil))) // TODO(https://github.com/istio/istio/issues/50749) order should be deterministic slices.Sort(res["outbound|80||example.com"]) assert.Equal(t, res, map[string][]string{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 02:06:39 UTC 2024 - 9.2K bytes - Viewed (0) -
pilot/test/xdstest/extract.go
for _, c := range cc { res[c.Name] = c } return res } func ExtractCluster(name string, cc []*cluster.Cluster) *cluster.Cluster { return ExtractClusters(cc)[name] } func ExtractClusterEndpoints(clusters []*cluster.Cluster) map[string][]string { cla := []*endpoint.ClusterLoadAssignment{} for _, c := range clusters { cla = append(cla, c.LoadAssignment) } return ExtractLoadAssignments(cla) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 13.9K bytes - Viewed (0)