in server/cmd/harp-server/internal/cmd/grpc.go [52:95]
func runGRPCServer(cmd *cobra.Command, args []string) {
ctx, cancel := context.WithCancel(cmd.Context())
defer cancel()
// Initialize config
initConfig()
// Starting banner
log.For(ctx).Info("Starting harp gRPC bundle server ...")
// Start goroutine group
errServe := platform.Serve(ctx, &platform.Server{
Debug: conf.Debug.Enable,
Name: "harp-server-grpc",
Version: version.Version,
Revision: version.Commit,
Instrumentation: conf.Instrumentation,
Network: conf.GRPC.Network,
Address: conf.GRPC.Listen,
Builder: func(ln net.Listener, group *run.Group) {
// Override config
if err := overrideBackendConfig(conf, grpcNamespaces); err != nil {
log.For(ctx).Fatal("Unable to parse backend mapping", zap.Error(err))
}
server, err := grpc.New(ctx, conf)
if err != nil {
log.For(ctx).Fatal("Unable to start gRPC server", zap.Error(err))
}
group.Add(
func() error {
log.For(ctx).Info("Starting gRPC server", zap.Stringer("address", ln.Addr()))
return server.Serve(ln)
},
func(e error) {
log.For(ctx).Info("Shutting gRPC server down")
server.GracefulStop()
},
)
},
})
log.CheckErrCtx(ctx, "Unable to run application", errServe)
}