Method startServer

stats/stats_test.go:241–257

startServer starts a gRPC server listening. Callers should defer a call to te.tearDown to clean up.

(ss *stubserver.StubServer)

// startServer starts a gRPC server listening. Callers should defer a
// call to te.tearDown to clean up.
func (te *test) startServer(ss *stubserver.StubServer) {
	var opts []grpc.ServerOption
	if te.compress == "gzip" {
		opts = append(opts,
			grpc.RPCCompressor(grpc.NewGZIPCompressor()),
			grpc.RPCDecompressor(grpc.NewGZIPDecompressor()),
		)
	}
	for _, sh := range te.serverStatsHandlers {
		opts = append(opts, grpc.StatsHandler(sh))
	}
	if err := ss.StartServer(opts...); err != nil {
		te.t.Fatalf("StubServer.StartServer() failed: %v", err)
	}
	te.srv = ss.S
	te.srvAddr = ss.Address
}

func (te *test) clientConn(ctx context.Context) *grpc.ClientConn {
	if te.cc != nil {