@@ -77,13 +77,13 @@ func validateListener(serialisedListener *any.Any, svc service.Service) {
77
77
}
78
78
}
79
79
80
- func validateEndpoints (serialisedLoadAssignment * any.Any , svc service.Service ) {
81
- loadAssignment := & api.ClusterLoadAssignment {}
82
- err := ptypes .UnmarshalAny (serialisedLoadAssignment , loadAssignment )
80
+ func validateEndpoints (serialisedAssignment * any.Any , svc service.Service ) {
81
+ assignment := & api.ClusterLoadAssignment {}
82
+ err := ptypes .UnmarshalAny (serialisedAssignment , assignment )
83
83
So (err , ShouldBeNil )
84
- So (loadAssignment .GetClusterName (), ShouldEqual , adapter .SvcName (svc .Name , svc .Ports [0 ].ServicePort ))
84
+ So (assignment .GetClusterName (), ShouldEqual , adapter .SvcName (svc .Name , svc .Ports [0 ].ServicePort ))
85
85
86
- localityEndpoints := loadAssignment .GetEndpoints ()
86
+ localityEndpoints := assignment .GetEndpoints ()
87
87
So (localityEndpoints , ShouldHaveLength , 1 )
88
88
89
89
endpoints := localityEndpoints [0 ].GetLbEndpoints ()
@@ -296,12 +296,12 @@ func Test_PortForServicePort(t *testing.T) {
296
296
297
297
resources := envoyMock .GetResource (stream , cache .EndpointType , state .Hostname )
298
298
So (resources , ShouldHaveLength , 1 )
299
- loadAssignment := & api.ClusterLoadAssignment {}
300
- err := ptypes .UnmarshalAny (resources [0 ], loadAssignment )
299
+ assignment := & api.ClusterLoadAssignment {}
300
+ err := ptypes .UnmarshalAny (resources [0 ], assignment )
301
301
So (err , ShouldBeNil )
302
- So (loadAssignment .GetEndpoints (), ShouldHaveLength , 1 )
302
+ So (assignment .GetEndpoints (), ShouldHaveLength , 1 )
303
303
var ports sort.IntSlice
304
- for _ , endpoint := range loadAssignment .GetEndpoints ()[0 ].GetLbEndpoints () {
304
+ for _ , endpoint := range assignment .GetEndpoints ()[0 ].GetLbEndpoints () {
305
305
ports = append (ports ,
306
306
int (endpoint .GetEndpoint ().GetAddress ().GetSocketAddress ().GetPortValue ()))
307
307
}
0 commit comments