Skip to content
This repository has been archived by the owner on Apr 18, 2023. It is now read-only.

Commit

Permalink
Merge pull request #44 from knweiss/golint
Browse files Browse the repository at this point in the history
Trivial golint fixes
  • Loading branch information
brancz committed Apr 18, 2018
2 parents 5f56f5a + 83d16be commit b089b26
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion client_metrics.go
Original file line number Diff line number Diff line change
Expand Up @@ -119,7 +119,7 @@ func (m *ClientMetrics) UnaryClientInterceptor() func(ctx context.Context, metho
}
}

// StreamServerInterceptor is a gRPC client-side interceptor that provides Prometheus monitoring for Streaming RPCs.
// StreamClientInterceptor is a gRPC client-side interceptor that provides Prometheus monitoring for Streaming RPCs.
func (m *ClientMetrics) StreamClientInterceptor() func(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error) {
return func(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error) {
monitor := newClientReporter(m, clientStreamType(desc), method)
Expand Down
2 changes: 1 addition & 1 deletion client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -210,7 +210,7 @@ func (s *ClientInterceptorTestSuite) TestStreamingIncrementsMessageCounts() {
break
}
require.NoError(s.T(), err, "reading pingList shouldn't fail")
count += 1
count++
}
require.EqualValues(s.T(), countListResponses, count, "Number of received msg on the wire must match")
afterSent := sumCountersForMetricAndLabels(s.T(), "grpc_client_msg_sent_total", "PingList", "server_stream")
Expand Down
2 changes: 1 addition & 1 deletion server_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -231,7 +231,7 @@ func (s *ServerInterceptorTestSuite) TestStreamingIncrementsMessageCounts() {
break
}
require.NoError(s.T(), err, "reading pingList shouldn't fail")
count += 1
count++
}
require.EqualValues(s.T(), countListResponses, count, "Number of received msg on the wire must match")
afterSent := sumCountersForMetricAndLabels(s.T(), "grpc_server_msg_sent_total", "PingList", "server_stream")
Expand Down

0 comments on commit b089b26

Please sign in to comment.