Skip to content

Commit edb991e

Browse files
author
Vighneswar Rao Bojja
committed
Address review comments
1 parent e4199e2 commit edb991e

File tree

3 files changed

+13
-19
lines changed

3 files changed

+13
-19
lines changed

client/nginx.go

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -934,11 +934,8 @@ func (client *NginxClient) getStreamZoneSync() (*StreamZoneSync, error) {
934934
func (client *NginxClient) getLocationZones() (*LocationZones, error) {
935935
var locationZones LocationZones
936936
err := client.get("http/location_zones", &locationZones)
937-
938937
if err != nil {
939-
if err, ok := err.(*internalError); ok {
940-
return nil, fmt.Errorf("failed to get location zones: %v", err)
941-
}
938+
return nil, fmt.Errorf("failed to get location zones: %v", err)
942939
}
943940

944941
return &locationZones, err
@@ -947,11 +944,8 @@ func (client *NginxClient) getLocationZones() (*LocationZones, error) {
947944
func (client *NginxClient) getResolvers() (*Resolvers, error) {
948945
var resolvers Resolvers
949946
err := client.get("resolvers", &resolvers)
950-
951947
if err != nil {
952-
if err, ok := err.(*internalError); ok {
953-
return nil, fmt.Errorf("failed to get resolvers: %v", err)
954-
}
948+
return nil, fmt.Errorf("failed to get resolvers: %v", err)
955949
}
956950

957951
return &resolvers, err

docker/nginx.conf

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ stream {
5050
health_check interval=10 fails=3 passes=1;
5151
}
5252

53-
resolver 127.0.0.11 valid=5s status_zone=test-zone;
53+
resolver 127.0.0.11 valid=5s status_zone=resolver_test;
5454

5555
server {
5656
listen 7777;

tests/client_test.go

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,8 @@ const (
1414
upstream = "test"
1515
streamUpstream = "stream_test"
1616
streamZoneSync = "zone_test_sync"
17+
locationZone = "location_test"
18+
resolverMetric = "resolver_test"
1719
)
1820

1921
var defaultMaxFails = 1
@@ -484,20 +486,18 @@ func TestStats(t *testing.T) {
484486
t.Errorf("Upstream 'test' not found")
485487
}
486488

487-
// cleanup upstream servers
488-
_, _, err = c.UpdateHTTPServers(upstream, []client.UpstreamServer{})
489-
if err != nil {
490-
t.Errorf("Couldn't remove servers: %v", err)
489+
if locZone, ok := stats.LocationZones[locationZone]; !ok {
490+
t.Errorf("LocationZone %v not found", locZone)
491491
}
492492

493-
locationZones := stats.LocationZones
494-
if len(locationZones) < 1 {
495-
t.Errorf("location zones are not available")
493+
if resolver, ok := stats.Resolvers[resolverMetric]; !ok {
494+
t.Errorf("Resolver %v not found", resolver)
496495
}
497496

498-
resolvers := stats.Resolvers
499-
if len(resolvers) < 1 {
500-
t.Errorf("resolvers are not available")
497+
// cleanup upstream servers
498+
_, _, err = c.UpdateHTTPServers(upstream, []client.UpstreamServer{})
499+
if err != nil {
500+
t.Errorf("Couldn't remove servers: %v", err)
501501
}
502502
}
503503

0 commit comments

Comments
 (0)