public

Documentation

Index

• Variables
• type Service
  • func NewService(l *zap.Logger, deployment string, redis *redis.Client, url string, maxNum int, ...) (result *Service, err error)
  • func (s *Service) RegisterWithGrpcServer(server siface.IGrpcServer) error
  • func (s *Service) UpdateMail(ctx context.Context, request *pb.UpdateMailRequest) (*pb.UpdateMailResponse, error)
  • func (s *Service) Watch(req *pb.WatchMailRequest, server pb.MailService_WatchServer) error

Variables

var ServiceModule = fx.Provide(
	func(
		l *zap.Logger,
		s mfx2.AppParams,
		ms mailfx.MailSettingParams,
		mqParams mfx.MessageQueueParams,
		redisParams ofx.RedisParams,
		aParams mfx2.AppParams,
	) (out sfx.GrpcServiceResult, err error) {
		if svc, e := NewService(
			l,
			s.Deployment,
			redisParams.Redis,
			ms.MailUrl,
			ms.MailNumMax,
			mqParams.MessageQueue,
			aParams,
		); e != nil {
			err = e
			return
		} else {
			out.GrpcService = svc
			return
		}
	},
)

Types

type Service

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

func NewService

func NewService(
	l *zap.Logger,
	deployment string,
	redis *redis.Client,
	url string,
	maxNum int,
	mq miface.MessageQueue,
	aParams mfx2.AppParams,
) (result *Service, err error)

func (*Service) RegisterWithGrpcServer

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

func (*Service) UpdateMail

func (s *Service) UpdateMail(ctx context.Context, request *pb.UpdateMailRequest) (*pb.UpdateMailResponse, error)

func (*Service) Watch

func (s *Service) Watch(req *pb.WatchMailRequest, server pb.MailService_WatchServer) error