service

Documentation

Index

• type Service
  • func New(c *conf.Config) (s *Service)
  • func (s *Service) CalcFigure(c context.Context, userInfo *model.UserInfo, ...) (figure *model.Figure, newRecord *model.FigureRecord)
  • func (s *Service) Close() (err error)
  • func (s *Service) HandleFigure(c context.Context, mid int64, weekVer int64) (err error)
  • func (s *Service) InitFigure(c context.Context, mid int64, ver string) (figure *model.Figure, err error)
  • func (s *Service) PendingMids(c context.Context, version int64, shard int64, retry int64) (mids []int64, err error)
  • func (s *Service) Ping(c context.Context) error
  • func (s *Service) Wait()

Types

type Service

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

Service struct of service.

func New

func New(c *conf.Config) (s *Service)

New create service instance and return.

func (*Service) CalcFigure

func (s *Service) CalcFigure(c context.Context, userInfo *model.UserInfo, actionCounters []*model.ActionCounter, records []*model.FigureRecord, weekVer int64) (figure *model.Figure, newRecord *model.FigureRecord)

CalcFigure calc figure.

func (*Service) Close

func (s *Service) Close() (err error)

Close kafka consumer close.

func (*Service) HandleFigure

func (s *Service) HandleFigure(c context.Context, mid int64, weekVer int64) (err error)

HandleFigure handle all figure score for a mid

func (*Service) InitFigure

func (s *Service) InitFigure(c context.Context, mid int64, ver string) (figure *model.Figure, err error)

InitFigure initialize user figure

func (*Service) PendingMids

func (s *Service) PendingMids(c context.Context, version int64, shard int64, retry int64) (mids []int64, err error)

PendingMids get pending mid list with retry

func (*Service) Ping

func (s *Service) Ping(c context.Context) error

Ping check service health.

func (*Service) Wait

func (s *Service) Wait()

Wait wait service end.