@@ -72,13 +72,13 @@ func wrrLocality(t *testing.T, m proto.Message) *v3wrrlocalitypb.WrrLocality {
7272// clusterWithLBConfiguration returns a cluster resource with the proto message
7373// passed Marshaled to an any and specified through the load_balancing_policy
7474// field.
75- func clusterWithLBConfiguration (clusterName , edsServiceName string , secLevel e2e.SecurityLevel , m proto.Message ) * v3clusterpb.Cluster {
75+ func clusterWithLBConfiguration (t * testing. T , clusterName , edsServiceName string , secLevel e2e.SecurityLevel , m proto.Message ) * v3clusterpb.Cluster {
7676 cluster := e2e .DefaultCluster (clusterName , edsServiceName , secLevel )
7777 cluster .LoadBalancingPolicy = & v3clusterpb.LoadBalancingPolicy {
7878 Policies : []* v3clusterpb.LoadBalancingPolicy_Policy {
7979 {
8080 TypedExtensionConfig : & v3corepb.TypedExtensionConfig {
81- TypedConfig : testutils .MarshalAny (& testing. T {} , m ),
81+ TypedConfig : testutils .MarshalAny (t , m ),
8282 },
8383 },
8484 },
@@ -235,7 +235,7 @@ func (s) TestWrrLocality(t *testing.T) {
235235 NodeID : nodeID ,
236236 Listeners : []* v3listenerpb.Listener {e2e .DefaultClientListener (serviceName , routeConfigName )},
237237 Routes : []* v3routepb.RouteConfiguration {e2e .DefaultRouteConfig (routeConfigName , serviceName , clusterName )},
238- Clusters : []* v3clusterpb.Cluster {clusterWithLBConfiguration (clusterName , endpointsName , e2e .SecurityLevelNone , test .wrrLocalityConfiguration )},
238+ Clusters : []* v3clusterpb.Cluster {clusterWithLBConfiguration (t , clusterName , endpointsName , e2e .SecurityLevelNone , test .wrrLocalityConfiguration )},
239239 Endpoints : []* v3endpointpb.ClusterLoadAssignment {e2e .EndpointResourceWithOptions (e2e.EndpointOptions {
240240 ClusterName : endpointsName ,
241241 Host : "localhost" ,
0 commit comments