Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ExtractClusterEndpoints (0.46 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top