opensource/grpc-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

change package stats comment

Browse Source
This commit is contained in:
Menghan Li
2016-11-02 17:07:04 -07:00
parent be66502802
commit 0d345b58c0
2 changed files with 24 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
stats/stats.go
View File

@ -31,7 +31,7 @@
* *
*/ */
// Package stats reports stats for gRPC. // Package stats is for collecting and reporting various network and RPC stats.
// This package is for monitoring purpose only. // This package is for monitoring purpose only.
// All APIs are experimental. // All APIs are experimental.
package stats // import "google.golang.org/grpc/stats" package stats // import "google.golang.org/grpc/stats"

54
stats/stats_test.go
View File

@ -528,6 +528,7 @@ func TestServerStatsUnaryRPC(t *testing.T) {
} }
}) })
stats.Start() stats.Start()
defer stats.Stop()
te := newTest(t, "") te := newTest(t, "")
te.startServer(&testServer{}) te.startServer(&testServer{})
@ -563,8 +564,6 @@ func TestServerStatsUnaryRPC(t *testing.T) {
f(t, got[i], expect) f(t, got[i], expect)
mu.Unlock() mu.Unlock()
} }
stats.Stop()
} }
func TestServerStatsUnaryRPCError(t *testing.T) { func TestServerStatsUnaryRPCError(t *testing.T) {
@ -580,6 +579,7 @@ func TestServerStatsUnaryRPCError(t *testing.T) {
} }
}) })
stats.Start() stats.Start()
defer stats.Stop()
te := newTest(t, "") te := newTest(t, "")
te.startServer(&testServer{}) te.startServer(&testServer{})
@ -616,8 +616,6 @@ func TestServerStatsUnaryRPCError(t *testing.T) {
f(t, got[i], expect) f(t, got[i], expect)
mu.Unlock() mu.Unlock()
} }
stats.Stop()
} }
func TestServerStatsStreamingRPC(t *testing.T) { func TestServerStatsStreamingRPC(t *testing.T) {
@ -633,6 +631,7 @@ func TestServerStatsStreamingRPC(t *testing.T) {
} }
}) })
stats.Start() stats.Start()
defer stats.Stop()
te := newTest(t, "gzip") te := newTest(t, "gzip")
te.startServer(&testServer{}) te.startServer(&testServer{})
@ -675,8 +674,6 @@ func TestServerStatsStreamingRPC(t *testing.T) {
f(t, got[i], expect) f(t, got[i], expect)
mu.Unlock() mu.Unlock()
} }
stats.Stop()
} }
func TestServerStatsStreamingRPCError(t *testing.T) { func TestServerStatsStreamingRPCError(t *testing.T) {
@ -692,6 +689,7 @@ func TestServerStatsStreamingRPCError(t *testing.T) {
} }
}) })
stats.Start() stats.Start()
defer stats.Stop()
te := newTest(t, "gzip") te := newTest(t, "gzip")
te.startServer(&testServer{}) te.startServer(&testServer{})
@ -730,8 +728,6 @@ func TestServerStatsStreamingRPCError(t *testing.T) {
f(t, got[i], expect) f(t, got[i], expect)
mu.Unlock() mu.Unlock()
} }
stats.Stop()
} }
type checkFuncWithCount struct { type checkFuncWithCount struct {
@ -752,6 +748,7 @@ func TestClientStatsUnaryRPC(t *testing.T) {
} }
}) })
stats.Start() stats.Start()
defer stats.Stop()
te := newTest(t, "") te := newTest(t, "")
te.startServer(&testServer{}) te.startServer(&testServer{})
@ -771,11 +768,11 @@ func TestClientStatsUnaryRPC(t *testing.T) {
} }
checkFuncs := map[int]*checkFuncWithCount{ checkFuncs := map[int]*checkFuncWithCount{
outheader: &checkFuncWithCount{checkOutHeader, 1}, outheader: {checkOutHeader, 1},
outpay: &checkFuncWithCount{checkOutPayload, 1}, outpay: {checkOutPayload, 1},
inheader: &checkFuncWithCount{checkInHeader, 1}, inheader: {checkInHeader, 1},
inpay: &checkFuncWithCount{checkInPayload, 1}, inpay: {checkInPayload, 1},
intrailer: &checkFuncWithCount{checkInTrailer, 1}, intrailer: {checkInTrailer, 1},
} }
var expectLen int var expectLen int
@ -824,8 +821,6 @@ func TestClientStatsUnaryRPC(t *testing.T) {
} }
mu.Unlock() mu.Unlock()
} }
stats.Stop()
} }
func TestClientStatsUnaryRPCError(t *testing.T) { func TestClientStatsUnaryRPCError(t *testing.T) {
@ -841,6 +836,7 @@ func TestClientStatsUnaryRPCError(t *testing.T) {
} }
}) })
stats.Start() stats.Start()
defer stats.Stop()
te := newTest(t, "") te := newTest(t, "")
te.startServer(&testServer{}) te.startServer(&testServer{})
@ -877,8 +873,6 @@ func TestClientStatsUnaryRPCError(t *testing.T) {
f(t, got[i], expect) f(t, got[i], expect)
mu.Unlock() mu.Unlock()
} }
stats.Stop()
} }
func TestClientStatsStreamingRPC(t *testing.T) { func TestClientStatsStreamingRPC(t *testing.T) {
@ -894,6 +888,7 @@ func TestClientStatsStreamingRPC(t *testing.T) {
} }
}) })
stats.Start() stats.Start()
defer stats.Stop()
te := newTest(t, "gzip") te := newTest(t, "gzip")
te.startServer(&testServer{}) te.startServer(&testServer{})
@ -915,11 +910,11 @@ func TestClientStatsStreamingRPC(t *testing.T) {
} }
checkFuncs := map[int]*checkFuncWithCount{ checkFuncs := map[int]*checkFuncWithCount{
outheader: &checkFuncWithCount{checkOutHeader, 1}, outheader: {checkOutHeader, 1},
outpay: &checkFuncWithCount{checkOutPayload, count}, outpay: {checkOutPayload, count},
inheader: &checkFuncWithCount{checkInHeader, 1}, inheader: {checkInHeader, 1},
inpay: &checkFuncWithCount{checkInPayload, count}, inpay: {checkInPayload, count},
intrailer: &checkFuncWithCount{checkInTrailer, 1}, intrailer: {checkInTrailer, 1},
} }
var expectLen int var expectLen int
@ -968,8 +963,6 @@ func TestClientStatsStreamingRPC(t *testing.T) {
} }
mu.Unlock() mu.Unlock()
} }
stats.Stop()
} }
func TestClientStatsStreamingRPCError(t *testing.T) { func TestClientStatsStreamingRPCError(t *testing.T) {
@ -985,6 +978,7 @@ func TestClientStatsStreamingRPCError(t *testing.T) {
} }
}) })
stats.Start() stats.Start()
defer stats.Stop()
te := newTest(t, "gzip") te := newTest(t, "gzip")
te.startServer(&testServer{}) te.startServer(&testServer{})
@ -1007,11 +1001,11 @@ func TestClientStatsStreamingRPCError(t *testing.T) {
} }
checkFuncs := map[int]*checkFuncWithCount{ checkFuncs := map[int]*checkFuncWithCount{
outheader: &checkFuncWithCount{checkOutHeader, 1}, outheader: {checkOutHeader, 1},
outpay: &checkFuncWithCount{checkOutPayload, 1}, outpay: {checkOutPayload, 1},
inheader: &checkFuncWithCount{checkInHeader, 1}, inheader: {checkInHeader, 1},
intrailer: &checkFuncWithCount{checkInTrailer, 1}, intrailer: {checkInTrailer, 1},
errors: &checkFuncWithCount{checkErrorStats, 1}, errors: {checkErrorStats, 1},
} }
var expectLen int var expectLen int
@ -1066,6 +1060,4 @@ func TestClientStatsStreamingRPCError(t *testing.T) {
} }
mu.Unlock() mu.Unlock()
} }
stats.Stop()
} }