server.go 421 B

12345678910111213141516171819
  1. package grpc
  2. import (
  3. pb "go-common/app/service/main/reply-feed/api"
  4. "go-common/app/service/main/reply-feed/service"
  5. "go-common/library/net/rpc/warden"
  6. )
  7. // New grpc server
  8. func New(cfg *warden.ServerConfig, srv *service.Service) (wsvr *warden.Server) {
  9. var err error
  10. wsvr = warden.NewServer(cfg)
  11. pb.RegisterReplyFeedServer(wsvr.Server(), srv)
  12. wsvr, err = wsvr.Start()
  13. if err != nil {
  14. panic(err)
  15. }
  16. return
  17. }