From e4b663cdcb6e010c5a8ac791e5624407aaa191b3 Mon Sep 17 00:00:00 2001 From: Hailong Wen Date: Sat, 16 Mar 2024 07:38:24 -0700 Subject: [PATCH] feat: allow attempt direct path xds via env var (#9582) Co-authored-by: rahul2393 --- spanner/client.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/spanner/client.go b/spanner/client.go index 0c233be7c1a..fe87fafb171 100644 --- a/spanner/client.go +++ b/spanner/client.go @@ -23,6 +23,7 @@ import ( "log" "os" "regexp" + "strconv" "time" "cloud.google.com/go/internal/trace" @@ -353,6 +354,9 @@ func allClientOpts(numChannels int, compression string, userOpts ...option.Clien internaloption.EnableDirectPath(true), internaloption.AllowNonDefaultServiceAccount(true), } + if enableDirectPathXds, _ := strconv.ParseBool(os.Getenv("GOOGLE_SPANNER_ENABLE_DIRECT_ACCESS")); enableDirectPathXds { + clientDefaultOpts = append(clientDefaultOpts, internaloption.EnableDirectPathXds()) + } if compression == "gzip" { userOpts = append(userOpts, option.WithGRPCDialOption(grpc.WithDefaultCallOptions( grpc.UseCompressor(gzip.Name))))