Skip to content

Commit

Permalink
make retryCount unexported. It is no longer needed outside the vtgate…
Browse files Browse the repository at this point in the history
… package

Signed-off-by: deepthi <deepthi@planetscale.com>
  • Loading branch information
deepthi committed Jan 19, 2022
1 parent 6d885cd commit 266af64
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions go/vt/vtgate/gateway.go
Original file line number Diff line number Diff line change
Expand Up @@ -38,9 +38,9 @@ var (
_ = flag.String("gateway_implementation", "tabletgateway", "Deprecated. The only available gateway_implementation is tabletgateway")
bufferImplementation = flag.String("buffer_implementation", "keyspace_events", "Allowed values: healthcheck (legacy implementation), keyspace_events (default)")
initialTabletTimeout = flag.Duration("gateway_initial_tablet_timeout", 30*time.Second, "At startup, the gateway will wait up to that duration to get one tablet per keyspace/shard/tablettype")
// RetryCount is the number of times a query will be retried on error
// retryCount is the number of times a query will be retried on error
// Make this unexported after DiscoveryGateway is deprecated
RetryCount = flag.Int("retry-count", 2, "retry count")
retryCount = flag.Int("retry-count", 2, "retry count")
)

// A Gateway is the query processing module for each shard,
Expand Down
2 changes: 1 addition & 1 deletion go/vt/vtgate/tabletgateway.go
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ func NewTabletGateway(ctx context.Context, hc discovery.HealthCheck, serv srvtop
hc: hc,
srvTopoServer: serv,
localCell: localCell,
retryCount: *RetryCount,
retryCount: *retryCount,
statusAggregators: make(map[string]*TabletStatusAggregator),
}
gw.setupBuffering(ctx)
Expand Down

0 comments on commit 266af64

Please sign in to comment.