func serveGRPC()

in main.go [69:82]


func serveGRPC(port, maxMsgSize int, metricHub *hub.MetricHub) error {
	lis, err := net.Listen("tcp", fmt.Sprintf(":%d", port))
	if err != nil {
		log.Fatalf("failed to listen: %v", err)
	}

	metricsGrpcServer := hubgrpc.MetricsControllerServerImpl{MetricHub: metricHub}
	grpcServer := grpc.NewServer(grpc.MaxRecvMsgSize(maxMsgSize))
	hubgrpc.RegisterMetricsControllerServer(grpcServer, &metricsGrpcServer)

	log.Printf("Serving GRPC on: %d\n", port)

	return grpcServer.Serve(lis)
}