@@ -107,15 +107,15 @@ func New(ctx context.Context, config *srvconfig.Config) (*Server, error) {
107107 }
108108 var (
109109 grpcServer = grpc .NewServer (serverOpts ... )
110- hrpc = grpc .NewServer (tcpServerOpts ... )
110+ tcpServer = grpc .NewServer (tcpServerOpts ... )
111111
112112 grpcServices []plugin.Service
113113 tcpServices []plugin.TCPService
114114 ttrpcServices []plugin.TTRPCService
115115
116116 s = & Server {
117117 grpcServer : grpcServer ,
118- hrpc : hrpc ,
118+ tcpServer : tcpServer ,
119119 ttrpcServer : ttrpcServer ,
120120 events : exchange .NewExchange (),
121121 config : config ,
@@ -199,7 +199,7 @@ func New(ctx context.Context, config *srvconfig.Config) (*Server, error) {
199199 }
200200 }
201201 for _ , service := range tcpServices {
202- if err := service .RegisterTCP (hrpc ); err != nil {
202+ if err := service .RegisterTCP (tcpServer ); err != nil {
203203 return nil , err
204204 }
205205 }
@@ -210,7 +210,7 @@ func New(ctx context.Context, config *srvconfig.Config) (*Server, error) {
210210type Server struct {
211211 grpcServer * grpc.Server
212212 ttrpcServer * ttrpc.Server
213- hrpc * grpc.Server
213+ tcpServer * grpc.Server
214214 events * exchange.Exchange
215215 config * srvconfig.Config
216216 plugins []* plugin.Plugin
@@ -243,8 +243,8 @@ func (s *Server) ServeMetrics(l net.Listener) error {
243243
244244// ServeTCP allows services to serve over tcp
245245func (s * Server ) ServeTCP (l net.Listener ) error {
246- grpc_prometheus .Register (s .hrpc )
247- return trapClosedConnErr (s .hrpc .Serve (l ))
246+ grpc_prometheus .Register (s .tcpServer )
247+ return trapClosedConnErr (s .tcpServer .Serve (l ))
248248}
249249
250250// ServeDebug provides a debug endpoint
0 commit comments