grpc

Documentation

Index

• Variables

Variables

var Module = fx.Module(
	"grpc",
	fx.Provide(
		New,
	),
	fx.Invoke(
		func(
			impl *DefaultModelServiceImpl,
			logger *zap.Logger,
			grpcCfg config.GRPC,
		) {
			srv := grpc.NewServer()
			RegisterDefaultModelServiceServer(srv, impl)
			listener, err := net.Listen("tcp", grpcCfg.HTTP.Addr+":"+grpcCfg.HTTP.Port)
			if err != nil {
				logger.Fatal("failed to listen", zap.Error(err))
			}
			err = srv.Serve(listener)
		},
	),
)