demo

Documentation

Index

• Variables
• type Service
  • func NewService(logger *zap.Logger, coll diface.ICollection, mq miface.MessageQueue, ...) (result *Service, err error)
  • func (s *Service) Handle(request ziface.IRequest)
  • func (s *Service) Hi(_ context.Context, request *pb.HiRequest) (*pb.HiResponse, error)
  • func (s *Service) PostHandle(_ ziface.IRequest)
  • func (s *Service) PreHandle(_ ziface.IRequest)
  • func (s *Service) RegisterWithGatewayServer(server siface.IGatewayServer) error
  • func (s *Service) RegisterWithGrpcServer(server siface.IGrpcServer) error
  • func (s *Service) RegisterWithServer(server siface.IZinxServer)
  • func (s *Service) Watch(request *pb.WatchRequest, server pb.DemoService_WatchServer) error

Variables

var GrpcService = fx.Provide(
	func(
		l *zap.Logger,
		dProvider ofx.DocumentStoreParams,
		setting dfx.SettingsParams,
		mqParams mfx.MessageQueueParams,
		gParams ofx.GormParams,
		redisClient ofx.RedisParams,
	) (out sfx.GrpcServiceResult, err error) {
		if coll, err := dProvider.DriverProvider.OpenDbDriver(setting.DbName); err != nil {
			return out, err
		} else if s, err := NewService(
			l,
			coll,
			mqParams.MessageQueue,
			gParams.GormDB,
			redisClient.Redis,
		); err != nil {
			return out, err
		} else {
			out.GrpcService = s
		}
		return
	},
)

var HttpService = fx.Provide(
	func(
		l *zap.Logger,
		dProvider ofx.DocumentStoreParams,
		setting dfx.SettingsParams,
		mqParams mfx.MessageQueueParams,
		gParams ofx.GormParams,
		redisClient ofx.RedisParams,
	) (out sfx.GatewayServiceResult, err error) {
		if coll, err := dProvider.DriverProvider.OpenDbDriver(setting.DbName); err != nil {
			return out, err
		} else if s, err := NewService(
			l,
			coll,
			mqParams.MessageQueue,
			gParams.GormDB,
			redisClient.Redis,
		); err != nil {
			return out, err
		} else {
			out.GatewayService = s
		}
		return
	},
)

var TcpService = fx.Provide(
	func(
		l *zap.Logger,
		dProvider ofx.DocumentStoreParams,
		setting dfx.SettingsParams,
		mqParams mfx.MessageQueueParams,
		gParams ofx.GormParams,
		redisClient ofx.RedisParams,
	) (out sfx.ZinxServiceResult, err error) {
		if coll, err := dProvider.DriverProvider.OpenDbDriver(setting.DbName); err != nil {
			return out, err
		} else if s, err := NewService(
			l,
			coll,
			mqParams.MessageQueue,
			gParams.GormDB,
			redisClient.Redis,
		); err != nil {
			return out, err
		} else {
			out.ZinxService = s
		}
		return
	},
)

Types

type Service

type Service struct {
	// contains filtered or unexported fields
}

func NewService

func NewService(
	logger *zap.Logger,
	coll diface.ICollection,
	mq miface.MessageQueue,
	gdb *gorm.DB,
	redis *redis.Client,
) (result *Service, err error)

func (*Service) Handle

func (s *Service) Handle(request ziface.IRequest)

func (*Service) Hi

func (s *Service) Hi(_ context.Context, request *pb.HiRequest) (*pb.HiResponse, error)

func (*Service) PostHandle

func (s *Service) PostHandle(_ ziface.IRequest)

func (*Service) PreHandle

func (s *Service) PreHandle(_ ziface.IRequest)

func (*Service) RegisterWithGatewayServer

func (s *Service) RegisterWithGatewayServer(server siface.IGatewayServer) error

func (*Service) RegisterWithGrpcServer

func (s *Service) RegisterWithGrpcServer(server siface.IGrpcServer) error

func (*Service) RegisterWithServer

func (s *Service) RegisterWithServer(server siface.IZinxServer)

func (*Service) Watch

func (s *Service) Watch(request *pb.WatchRequest, server pb.DemoService_WatchServer) error