32 lines
486 B
Go
32 lines
486 B
Go
|
package grpc
|
||
|
|
|
||
|
|
import (
|
||
|
|
"github.com/spf13/viper"
|
||
|
|
"google.golang.org/grpc"
|
||
|
|
health "google.golang.org/grpc/health/grpc_health_v1"
|
||
|
|
"google.golang.org/grpc/reflection"
|
||
|
|
"net"
|
||
|
|
)
|
||
|
|
|
||
|
|
type Server struct {
|
||
|
|
}
|
||
|
|
|
||
|
|
var S *grpc.Server
|
||
|
|
|
||
|
|
func NewGRPC() {
|
||
|
|
S = grpc.NewServer()
|
||
|
|
|
||
|
|
health.RegisterHealthServer(S, &Server{})
|
||
|
|
|
||
|
|
reflection.Register(S)
|
||
|
|
}
|
||
|
|
|
||
|
|
func ListenGRPC() error {
|
||
|
|
listener, err := net.Listen("tcp", viper.GetString("grpc_bind"))
|
||
|
|
if err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
|
||
|
|
return S.Serve(listener)
|
||
|
|
}
|