diff --git a/go/mysql/conn.go b/go/mysql/conn.go index 57ababf4762..5a99e4c21c8 100644 --- a/go/mysql/conn.go +++ b/go/mysql/conn.go @@ -39,7 +39,7 @@ import ( "vitess.io/vitess/go/vt/vterrors" ) -var mysqlServerFlushDelay = flag.Duration("mysql_server_flush_delay", 100*time.Millisecond, "Delay after which buffered response will flushed to client.") +var mysqlServerFlushDelay = flag.Duration("mysql_server_flush_delay", 100*time.Millisecond, "Delay after which buffered response will be flushed to the client.") const ( // connBufferSize is how much we buffer for reading and diff --git a/go/stats/export.go b/go/stats/export.go index b61c7278118..f14f4248293 100644 --- a/go/stats/export.go +++ b/go/stats/export.go @@ -40,7 +40,7 @@ import ( "vitess.io/vitess/go/vt/log" ) -var emitStats = flag.Bool("emit_stats", false, "true iff we should emit stats to push-based monitoring/stats backends") +var emitStats = flag.Bool("emit_stats", false, "If set, emit stats to push-based monitoring and stats backends") var statsEmitPeriod = flag.Duration("stats_emit_period", time.Duration(60*time.Second), "Interval between emitting stats to all registered backends") var statsBackend = flag.String("stats_backend", "", "The name of the registered push-based monitoring/stats backend to use") var combineDimensions = flag.String("stats_combine_dimensions", "", `List of dimensions to be combined into a single "all" value in exported stats vars`) diff --git a/go/vt/grpcclient/client.go b/go/vt/grpcclient/client.go index f2fd3e40ddf..612c7b6ba1d 100644 --- a/go/vt/grpcclient/client.go +++ b/go/vt/grpcclient/client.go @@ -36,10 +36,10 @@ import ( ) var ( - keepaliveTime = flag.Duration("grpc_keepalive_time", 10*time.Second, "After a duration of this time if the client doesn't see any activity it pings the server to see if the transport is still alive.") + keepaliveTime = flag.Duration("grpc_keepalive_time", 10*time.Second, "After a duration of this time, if the client doesn't see any activity, it pings the server to see if the transport is still alive.") keepaliveTimeout = flag.Duration("grpc_keepalive_timeout", 10*time.Second, "After having pinged for keepalive check, the client waits for a duration of Timeout and if no activity is seen even after that the connection is closed.") - initialConnWindowSize = flag.Int("grpc_initial_conn_window_size", 0, "grpc initial connection window size") - initialWindowSize = flag.Int("grpc_initial_window_size", 0, "grpc initial window size") + initialConnWindowSize = flag.Int("grpc_initial_conn_window_size", 0, "gRPC initial connection window size") + initialWindowSize = flag.Int("grpc_initial_window_size", 0, "gRPC initial window size") ) // FailFast is a self-documenting type for the grpc.FailFast. diff --git a/go/vt/grpcclient/snappy.go b/go/vt/grpcclient/snappy.go index 1935127b9eb..0ea2c04d7c1 100644 --- a/go/vt/grpcclient/snappy.go +++ b/go/vt/grpcclient/snappy.go @@ -26,7 +26,7 @@ import ( ) var ( - compression = flag.String("grpc_compression", "", "how to compress gRPC, default: nothing, supported: snappy") + compression = flag.String("grpc_compression", "", "Which protocol to use for compressing gRPC. Default: nothing. Supported: snappy") ) // SnappyCompressor is a gRPC compressor using the Snappy algorithm. diff --git a/go/vt/servenv/grpc_server.go b/go/vt/servenv/grpc_server.go index 382686809d8..1905d89bf0d 100644 --- a/go/vt/servenv/grpc_server.go +++ b/go/vt/servenv/grpc_server.go @@ -78,20 +78,20 @@ var ( // GRPCInitialConnWindowSize ServerOption that sets window size for a connection. // The lower bound for window size is 64K and any value smaller than that will be ignored. - GRPCInitialConnWindowSize = flag.Int("grpc_server_initial_conn_window_size", 0, "grpc server initial connection window size") + GRPCInitialConnWindowSize = flag.Int("grpc_server_initial_conn_window_size", 0, "gRPC server initial connection window size") // GRPCInitialWindowSize ServerOption that sets window size for stream. // The lower bound for window size is 64K and any value smaller than that will be ignored. - GRPCInitialWindowSize = flag.Int("grpc_server_initial_window_size", 0, "grpc server initial window size") + GRPCInitialWindowSize = flag.Int("grpc_server_initial_window_size", 0, "gRPC server initial window size") // EnforcementPolicy MinTime that sets the keepalive enforcement policy on the server. // This is the minimum amount of time a client should wait before sending a keepalive ping. - GRPCKeepAliveEnforcementPolicyMinTime = flag.Duration("grpc_server_keepalive_enforcement_policy_min_time", 5*time.Minute, "grpc server minimum keepalive time") + GRPCKeepAliveEnforcementPolicyMinTime = flag.Duration("grpc_server_keepalive_enforcement_policy_min_time", 5*time.Minute, "gRPC server minimum keepalive time") // EnforcementPolicy PermitWithoutStream - If true, server allows keepalive pings // even when there are no active streams (RPCs). If false, and client sends ping when // there are no active streams, server will send GOAWAY and close the connection. - GRPCKeepAliveEnforcementPolicyPermitWithoutStream = flag.Bool("grpc_server_keepalive_enforcement_policy_permit_without_stream", false, "grpc server permit client keepalive pings even when there are no active streams (RPCs)") + GRPCKeepAliveEnforcementPolicyPermitWithoutStream = flag.Bool("grpc_server_keepalive_enforcement_policy_permit_without_stream", false, "gRPC server permit client keepalive pings even when there are no active streams (RPCs)") authPlugin Authenticator )