From effec509fea749b8f9aed2dc1fabebc7f943f0f5 Mon Sep 17 00:00:00 2001 From: yetyear Date: Wed, 13 Mar 2024 11:59:02 +0800 Subject: [PATCH] chore: remove repetitive words Signed-off-by: yetyear --- balancer/leastrequest/balancer_test.go | 2 +- balancer/weightedroundrobin/scheduler.go | 2 +- clientconn.go | 2 +- examples/features/observability/client/main.go | 2 +- examples/features/observability/server/main.go | 2 +- test/authority_test.go | 2 +- test/xds/xds_client_outlier_detection_test.go | 2 +- .../balancer/outlierdetection/e2e_test/outlierdetection_test.go | 2 +- 8 files changed, 8 insertions(+), 8 deletions(-) diff --git a/balancer/leastrequest/balancer_test.go b/balancer/leastrequest/balancer_test.go index 44bb21c9e9ff..50dbf5a48498 100644 --- a/balancer/leastrequest/balancer_test.go +++ b/balancer/leastrequest/balancer_test.go @@ -170,7 +170,7 @@ func checkRoundRobinRPCs(ctx context.Context, client testgrpc.TestServiceClient, } iterations = append(iterations, iteration) } - // Ensure the the first iteration contains all addresses in addrs. + // Ensure the first iteration contains all addresses in addrs. for _, addr := range iterations[0] { gotAddrCount[addr]++ } diff --git a/balancer/weightedroundrobin/scheduler.go b/balancer/weightedroundrobin/scheduler.go index e19428112e1e..f389678b4e82 100644 --- a/balancer/weightedroundrobin/scheduler.go +++ b/balancer/weightedroundrobin/scheduler.go @@ -125,7 +125,7 @@ func (s *edfScheduler) nextIndex() int { } // A simple RR scheduler to use for fallback when fewer than two backends have -// non-zero weights, or all backends have the the same weight, or when only one +// non-zero weights, or all backends have the same weight, or when only one // subconn exists. type rrScheduler struct { inc func() uint32 diff --git a/clientconn.go b/clientconn.go index 85ec9c119209..626ea20ff6e8 100644 --- a/clientconn.go +++ b/clientconn.go @@ -67,7 +67,7 @@ var ( errConnDrain = errors.New("grpc: the connection is drained") // errConnClosing indicates that the connection is closing. errConnClosing = errors.New("grpc: the connection is closing") - // errConnIdling indicates the the connection is being closed as the channel + // errConnIdling indicates the connection is being closed as the channel // is moving to an idle mode due to inactivity. errConnIdling = errors.New("grpc: the connection is closing due to channel idleness") // invalidDefaultServiceConfigErrPrefix is used to prefix the json parsing error for the default diff --git a/examples/features/observability/client/main.go b/examples/features/observability/client/main.go index 4c1d994a30dd..f59d593ccbf1 100644 --- a/examples/features/observability/client/main.go +++ b/examples/features/observability/client/main.go @@ -43,7 +43,7 @@ var ( func main() { // Turn on global telemetry for the whole binary. If a configuration is // specified, any created gRPC Client Conn's or Servers will emit telemetry - // data according the the configuration. + // data according the configuration. ctx, cancel := context.WithTimeout(context.Background(), time.Second*5) defer cancel() err := observability.Start(ctx) diff --git a/examples/features/observability/server/main.go b/examples/features/observability/server/main.go index 0aae0699342d..f60ea7546304 100644 --- a/examples/features/observability/server/main.go +++ b/examples/features/observability/server/main.go @@ -53,7 +53,7 @@ func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloRe func main() { // Turn on global telemetry for the whole binary. If a configuration is // specified, any created gRPC Client Conn's or Servers will emit telemetry - // data according the the configuration. + // data according the configuration. ctx, cancel := context.WithTimeout(context.Background(), time.Second*5) defer cancel() err := observability.Start(ctx) diff --git a/test/authority_test.go b/test/authority_test.go index 6ee2d3db9d7c..20335202b809 100644 --- a/test/authority_test.go +++ b/test/authority_test.go @@ -210,7 +210,7 @@ func (s) TestColonPortAuthority(t *testing.T) { } // TestAuthorityReplacedWithResolverAddress tests the scenario where the resolver -// returned address contains a ServerName override. The test verifies that the the +// returned address contains a ServerName override. The test verifies that the // :authority header value sent to the server as part of the http/2 HEADERS frame // is set to the value specified in the resolver returned address. func (s) TestAuthorityReplacedWithResolverAddress(t *testing.T) { diff --git a/test/xds/xds_client_outlier_detection_test.go b/test/xds/xds_client_outlier_detection_test.go index d91b35a883aa..9cc9015ed334 100644 --- a/test/xds/xds_client_outlier_detection_test.go +++ b/test/xds/xds_client_outlier_detection_test.go @@ -136,7 +136,7 @@ func checkRoundRobinRPCs(ctx context.Context, client testgrpc.TestServiceClient, } iterations = append(iterations, iteration) } - // Ensure the the first iteration contains all addresses in addrs. + // Ensure the first iteration contains all addresses in addrs. gotAddrCount := make(map[string]int) for _, addr := range iterations[0] { gotAddrCount[addr]++ diff --git a/xds/internal/balancer/outlierdetection/e2e_test/outlierdetection_test.go b/xds/internal/balancer/outlierdetection/e2e_test/outlierdetection_test.go index b1f59a3c545c..c7d22c579942 100644 --- a/xds/internal/balancer/outlierdetection/e2e_test/outlierdetection_test.go +++ b/xds/internal/balancer/outlierdetection/e2e_test/outlierdetection_test.go @@ -123,7 +123,7 @@ func checkRoundRobinRPCs(ctx context.Context, client testgrpc.TestServiceClient, } iterations = append(iterations, iteration) } - // Ensure the the first iteration contains all addresses in addrs. + // Ensure the first iteration contains all addresses in addrs. for _, addr := range iterations[0] { gotAddrCount[addr]++ }