fatal if the resolver cannot initialize

slackhq · May 21, 2024 · 222be51 · 222be51
1 parent f6818d9
commit 222be51
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/go/vt/vtgateproxy/vtgateproxy.go b/go/vt/vtgateproxy/vtgateproxy.go
@@ -218,12 +218,16 @@ func Init() {
 		return append(opts, grpc.WithDefaultServiceConfig(fmt.Sprintf(`{"loadBalancingConfig": [{"%s":{}}]}`, *balancerType))), nil
 	})
 
-	RegisterJSONGateResolver(
+	_, err := RegisterJSONGateResolver(
 		*vtgateHostsFile,
 		*addressField,
 		*portField,
 		*poolTypeField,
 		*affinityField,
 		*affinityValue,
 	)
+
+	if err != nil {
+		log.Fatalf("error initializing resolver: %v", err)
+	}
 }