func runGRPCServer()

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)
}