round_robin works!

slackhq · Mar 22, 2024 · 0359ecd · 0359ecd
1 parent dbccdda
commit 0359ecd
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 65 deletions.
diff --git a/go/vt/vtgateproxy/gate_balancer.go b/go/vt/vtgateproxy/gate_balancer.go
diff --git a/go/vt/vtgateproxy/vtgateproxy.go b/go/vt/vtgateproxy/vtgateproxy.go
@@ -72,11 +72,8 @@ func (proxy *VTGateProxy) getConnection(ctx context.Context, target string) (*vt
 
 	// Otherwise create a new connection after dropping the lock, allowing multiple requests to
 	// race to create the conn for now.
-	//	grpcclient.RegisterGRPCDialOptions(func(opts []grpc.DialOption) ([]grpc.DialOption, error) {
-	//		return append(opts, grpc.WithBlock()), nil
-	//	})
 	grpcclient.RegisterGRPCDialOptions(func(opts []grpc.DialOption) ([]grpc.DialOption, error) {
-		return append(opts, grpc.WithDefaultServiceConfig(`{"loadBalancingConfig": [{"slack_affinity_balancer":{}}]}`)), nil
+		return append(opts, grpc.WithDefaultServiceConfig(`{"loadBalancingConfig": [{"round_robin":{}}]}`)), nil
 	})
 
 	conn, err := vtgateconn.DialProtocol(ctx, "grpc", target)