server

Documentation

Index

• Variables
• func NewGRPCServer(c *conf.Server, userService *service.UserService, ...) *grpc.Server
• func NewHTTPServer(c *conf.Server, userService *service.UserService, ...) *http.Server
• type CronJob
  • func NewCronJob(redSync *redsync.Mutex, uc *biz.UserUseCase) *CronJob
  • func (s *CronJob) Start(_ context.Context) error
  • func (s *CronJob) Stop(_ context.Context) error
• type Job
  • func (j *Job) UsersRecommend()

Variables

var (
	ErrorsMsgMap = map[string]string{
		"UNKNOWN_ERROR": "未知错误",
	}
)

var ProviderSet = wire.NewSet(NewHTTPServer, NewGRPCServer, NewCronJob)

ProviderSet is user providers.

Functions

func NewGRPCServer

func NewGRPCServer(c *conf.Server, userService *service.UserService, partnerService *service.PartnerService, logger log.Logger) *grpc.Server

NewGRPCServer new a gRPC user.

func NewHTTPServer

func NewHTTPServer(c *conf.Server, userService *service.UserService, partnerService *service.PartnerService, logger log.Logger) *http.Server

NewHTTPServer new a HTTP user.

Types

type CronJob

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

func NewCronJob

func NewCronJob(redSync *redsync.Mutex, uc *biz.UserUseCase) *CronJob

func (*CronJob) Start

func (s *CronJob) Start(_ context.Context) error

func (*CronJob) Stop

func (s *CronJob) Stop(_ context.Context) error

type Job

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

func (*Job) UsersRecommend

func (j *Job) UsersRecommend()