mirror of
https://github.com/getAlby/lndhub.go.git
synced 2025-12-20 14:14:47 +01:00
Merge pull request #346 from getAlby/chore/remove-grpc
remove grpc server
This commit is contained in:
23
main.go
23
main.go
@@ -5,7 +5,6 @@ import (
|
||||
"embed"
|
||||
"fmt"
|
||||
"log"
|
||||
"net"
|
||||
"net/http"
|
||||
"os"
|
||||
"os/signal"
|
||||
@@ -37,7 +36,6 @@ import (
|
||||
"github.com/uptrace/bun/migrate"
|
||||
"github.com/ziflex/lecho/v3"
|
||||
"golang.org/x/time/rate"
|
||||
"google.golang.org/grpc"
|
||||
ddEcho "gopkg.in/DataDog/dd-trace-go.v1/contrib/labstack/echo.v4"
|
||||
"gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer"
|
||||
)
|
||||
@@ -264,23 +262,6 @@ func main() {
|
||||
}()
|
||||
}
|
||||
|
||||
var grpcServer *grpc.Server
|
||||
if svc.Config.EnableGRPC {
|
||||
//start grpc server
|
||||
lis, err := net.Listen("tcp", fmt.Sprintf(":%d", svc.Config.GRPCPort))
|
||||
if err != nil {
|
||||
svc.Logger.Fatalf("Failed to start grpc server: %v", err)
|
||||
}
|
||||
grpcServer = svc.NewGrpcServer(startupCtx)
|
||||
go func() {
|
||||
svc.Logger.Infof("Starting grpc server at port %d", svc.Config.GRPCPort)
|
||||
err = grpcServer.Serve(lis)
|
||||
if err != nil {
|
||||
svc.Logger.Error(err)
|
||||
}
|
||||
}()
|
||||
}
|
||||
|
||||
//Start Prometheus server if necessary
|
||||
var echoPrometheus *echo.Echo
|
||||
if svc.Config.EnablePrometheus {
|
||||
@@ -317,10 +298,6 @@ func main() {
|
||||
e.Logger.Fatal(err)
|
||||
}
|
||||
}
|
||||
if c.EnableGRPC {
|
||||
grpcServer.Stop()
|
||||
svc.Logger.Info("GRPC server exited.")
|
||||
}
|
||||
//Wait for graceful shutdown of background routines
|
||||
backgroundWg.Wait()
|
||||
svc.Logger.Info("LNDhub exiting gracefully. Goodbye.")
|
||||
|
||||
Reference in New Issue
Block a user