Skip to content

Commit

Permalink
Fixed vet errors.
Browse files Browse the repository at this point in the history
  • Loading branch information
RyanBlaney committed Dec 21, 2024
1 parent 443d960 commit 436bc06
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
6 changes: 3 additions & 3 deletions stats/stats.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,8 +36,8 @@ type RPCStats interface {
IsClient() bool
}

// Begin contains stats when an RPC attempt begins. This event is called after
// the InHeader event, as headers must be processed before the RPC lifecycle
// Begin contains stats when an RPC attempt begins. This event is called after
// the InHeader event, as headers must be processed before the RPC lifecycle
// begins.
//
// FailFast is only valid if this Begin is from client side.
Expand Down Expand Up @@ -101,7 +101,7 @@ func (s *InPayload) IsClient() bool { return s.Client }

func (s *InPayload) isRPCStats() {}

// InHeader contain stats when the header is received. It is the first event in
// InHeader contain stats when the header is received. It is the first event in
// the server after receiving the RPC. It is followed by the OutPayload
// server event.
type InHeader struct {
Expand Down
8 changes: 4 additions & 4 deletions stats/stats_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ var (
}
// The id for which the service handler should return error.
errorID int32 = 32202
// To verify if the Unary RPC server stats events are logged in the
// To verify if the Unary RPC server stats events are logged in the
// correct order.
expectedUnarySequence = []string{
"ConnStats",
Expand All @@ -93,7 +93,7 @@ var (
"OutTrailer",
"End",
}
// To verify if the Client Stream RPC server stats events are logged in the
// To verify if the Client Stream RPC server stats events are logged in the
// correct order.
expectedClientStreamSequence = []string{
"ConnStats",
Expand All @@ -109,7 +109,7 @@ var (
"OutTrailer",
"End",
}
// To verify if the Server Stream RPC server stats events are logged in the
// To verify if the Server Stream RPC server stats events are logged in the
// correct order.
expectedServerStreamSequence = []string{
"ConnStats",
Expand Down Expand Up @@ -286,7 +286,7 @@ func newTest(t *testing.T, tc *testConfig, chs []stats.Handler, shs []stats.Hand

// startServer starts a gRPC server listening. Callers should defer a
// call to te.tearDown to clean up.
//
//
// Uses deprecated opts rpc.(RPCCompressor, RPCDecompressor, WithBlock, Dial)
func (te *test) startServer(ts testgrpc.TestServiceServer) {
te.testServer = ts
Expand Down

0 comments on commit 436bc06

Please sign in to comment.