service

Documentation

Index

• Variables
• type Service
  • func NewService(l *zap.Logger, mq miface.MessageQueue, settings analyfx.AnalyticsSettingParams) (result *Service, err error)
  • func (s *Service) Analytics(ctx context.Context, events *pb.AnalyticsEvents) (*pb.Nothing, error)
  • func (s *Service) RegisterWithGatewayServer(server siface.IGatewayServer) error
  • func (s *Service) RegisterWithGrpcServer(server siface.IGrpcServer) error

Variables

var ServiceModule = fx.Provide(
	func(
		l *zap.Logger,
		mq mfx.MessageQueueParams,
		settings analyfx.AnalyticsSettingParams,
	) (out sfx.GrpcServiceResult, gw sfx.GatewayServiceResult, err error) {
		if svc, e := NewService(l, mq.MessageQueue, settings); e != nil {
			err = e
		} else {
			out.GrpcService = svc
			gw.GatewayService = svc
		}
		return
	},
)

Types

type Service

type Service struct {
	utility.WithoutAuth
	// contains filtered or unexported fields
}

func NewService

func NewService(
	l *zap.Logger,
	mq miface.MessageQueue,
	settings analyfx.AnalyticsSettingParams,
) (result *Service, err error)

func (*Service) Analytics

func (s *Service) Analytics(
	ctx context.Context,
	events *pb.AnalyticsEvents,
) (*pb.Nothing, error)

func (*Service) RegisterWithGatewayServer

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

func (*Service) RegisterWithGrpcServer

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