diff --git a/go/vt/vtgateproxy/firstready_balancer.go b/go/vt/vtgateproxy/firstready_balancer.go index 9610de97018..27754bc936f 100644 --- a/go/vt/vtgateproxy/firstready_balancer.go +++ b/go/vt/vtgateproxy/firstready_balancer.go @@ -31,6 +31,7 @@ limitations under the License. // https://github.com/grpc/grpc-go/blob/master/pickfirst.go import ( + "errors" "sync" "google.golang.org/grpc/balancer" @@ -60,7 +61,7 @@ func (f *frPickerBuilder) Build(info base.PickerBuildInfo) balancer.Picker { log.V(100).Infof("first_ready: Build called with info: %v", info) if len(info.ReadySCs) == 0 { - return base.NewErrPicker(balancer.ErrNoSubConnAvailable) + return base.NewErrPicker(errors.New("no available connections")) } f.mu.Lock() diff --git a/go/vt/vtgateproxy/vtgateproxy.go b/go/vt/vtgateproxy/vtgateproxy.go index 75b04c74868..db1abe43009 100644 --- a/go/vt/vtgateproxy/vtgateproxy.go +++ b/go/vt/vtgateproxy/vtgateproxy.go @@ -218,7 +218,7 @@ func Init() { return append(opts, grpc.WithDefaultServiceConfig(fmt.Sprintf(`{"loadBalancingConfig": [{"%s":{}}]}`, *balancerType))), nil }) - RegisterJSONGateResolver( + _, err := RegisterJSONGateResolver( *vtgateHostsFile, *addressField, *portField, @@ -226,4 +226,8 @@ func Init() { *affinityField, *affinityValue, ) + + if err != nil { + log.Fatalf("error initializing resolver: %v", err) + } }