private

Documentation

Index

• Variables
• type Service
  • func NewService(l *zap.Logger, url string, client *redis.Client, mq miface.MessageQueue, ...) (result *Service, err error)
  • func (s *Service) ChannelJoin(_ context.Context, request *pb.ChannelJoinRequest) (*pb.ChannelJoinResponse, error)
  • func (s *Service) GetProfileBasics(_ context.Context, request *pb.GetProfileBasicsRequest) (*pb.GetProfileBasicsResponse, error)
  • func (s *Service) GetProfilePrivate(_ context.Context, request *pb.GetProfilePrivateRequest) (*pb.GetProfilePrivateResponse, error)
  • func (s *Service) ItemFashionChange(_ context.Context, request *pb.ItemFashionChangeRequest) (*pb.ItemFashionChangeResponse, error)
  • func (s *Service) ItemFashionUnload(_ context.Context, request *pb.ItemFashionUnloadRequest) (*pb.ItemFashionUnloadResponse, error)
  • func (s *Service) ItemUse(_ context.Context, request *pb.ItemUseRequest) (*pb.ItemUseResponse, error)
  • func (s *Service) PlayerPropNotify(_ context.Context, request *pb.PlayerPropNotifyRequest) (*pb.PlayerPropNotifyResponse, error)
  • func (s *Service) RegisterWithGrpcServer(server siface.IGrpcServer) error
  • func (s *Service) SetProfileStatus(_ context.Context, request *pb.SetProfileStatusRequest) (*pb.SetProfileStatusResponse, error)

Variables

var Module = fx.Provide(
	func(
		l *zap.Logger,
		pSetting pfx.ProfileSettingParams,
		dbProvider ofx.DocumentStoreParams,
		redisParams ofx.RedisParams,
		rcParams ofx.RedisCacheParams,
		mongoParams ofx.MongoParams,
		mqParams mfx.MessageQueueParams,
		mysqlDb mysqlpkg.Param,
		mongoDb mongopkg.Param,
		set setting.Param,
	) (out sfx.GrpcServiceResult, err error) {
		if svc, e := NewService(
			l,
			pSetting.ProfileUrl,
			redisParams.Redis,
			mqParams.MessageQueue,
			mongoParams.MongoClient.Database(pSetting.ProfileStoreName),
			mysqlDb,
			mongoDb,
			set,
		); e != nil {
			err = e
		} else {
			out.GrpcService = svc
		}
		return
	},
)

Types

type Service

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

func NewService

func NewService(
	l *zap.Logger,
	url string,
	client *redis.Client,
	mq miface.MessageQueue,
	mongoDB *mongo.Database,
	mysqlDb mysqlpkg.Param,
	mongoDb mongopkg.Param,
	set setting.Param,
) (result *Service, err error)

func (*Service) ChannelJoin

func (s *Service) ChannelJoin(_ context.Context, request *pb.ChannelJoinRequest) (*pb.ChannelJoinResponse, error)

func (*Service) GetProfileBasics

func (s *Service) GetProfileBasics(_ context.Context, request *pb.GetProfileBasicsRequest) (*pb.GetProfileBasicsResponse, error)

func (*Service) GetProfilePrivate

func (s *Service) GetProfilePrivate(_ context.Context, request *pb.GetProfilePrivateRequest) (*pb.GetProfilePrivateResponse, error)

func (*Service) ItemFashionChange

func (s *Service) ItemFashionChange(_ context.Context, request *pb.ItemFashionChangeRequest) (*pb.ItemFashionChangeResponse, error)

func (*Service) ItemFashionUnload

func (s *Service) ItemFashionUnload(_ context.Context, request *pb.ItemFashionUnloadRequest) (*pb.ItemFashionUnloadResponse, error)

func (*Service) ItemUse

func (s *Service) ItemUse(_ context.Context, request *pb.ItemUseRequest) (*pb.ItemUseResponse, error)

func (*Service) PlayerPropNotify

func (s *Service) PlayerPropNotify(_ context.Context, request *pb.PlayerPropNotifyRequest) (*pb.PlayerPropNotifyResponse, error)

func (*Service) RegisterWithGrpcServer

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

func (*Service) SetProfileStatus

func (s *Service) SetProfileStatus(_ context.Context, request *pb.SetProfileStatusRequest) (*pb.SetProfileStatusResponse, error)