in tcc/grpc/cmd/server/main.go [35:64]
func main() {
client.InitPath("../../../../conf/seatago.yml")
lis, err := net.Listen("tcp", fmt.Sprintf(":%d", 50051))
if err != nil {
log.Fatalf("failed to listen: %v", err)
}
log.Infof("server register")
s := grpc.NewServer(grpc.UnaryInterceptor(grpc2.ServerTransactionInterceptor))
b1 := &service.Business1{}
b2 := &service.Business2{}
proxy1, err := tcc.NewTCCServiceProxy(b1)
if err != nil {
log.Fatalf(err.Error())
return
}
proxy2, err := tcc.NewTCCServiceProxy(b2)
if err != nil {
log.Fatalf(err.Error())
return
}
pb.RegisterTCCServiceBusiness1Server(s, &service.GrpcBusinessService1{Business1: proxy1})
pb.RegisterTCCServiceBusiness2Server(s, &service.GrpcBusinessService2{Business2: proxy2})
log.Infof("business listening at %v", lis.Addr())
if err := s.Serve(lis); err != nil {
log.Fatalf("failed to serve: %v", err)
}
}