package db import ( "errors" "net" "google.golang.org/grpc" "mongo.games.com/goserver/core/logger" ) var GrpcServer *grpc.Server var GrpcClientConn *grpc.ClientConn func RunGrpcServer() { GrpcServer = grpc.NewServer() registerGrpcServer() ln, err := net.Listen("tcp", ":8899") if err != nil { panic(errors.New("db grpc failed to listen: " + err.Error())) } err = GrpcServer.Serve(ln) if err != nil { panic(errors.New("db grpc failed to serve: " + err.Error())) } logger.Logger.Infof("db grpc start success") } func NewGrpcClientConn() { var err error GrpcClientConn, err = grpc.NewClient("localhost:8899", grpc.WithInsecure()) if err != nil { panic(errors.New("db grpc failed to dial: " + err.Error())) } registerGrpcClient() }