service

Documentation

Index

• type Service
  • func New(c *conf.Config) (s *Service)
  • func (s *Service) AddLike(c context.Context, addMsg json.RawMessage) (err error)
  • func (s *Service) BatchInsertLikeExtend(c context.Context, extends []*like.Extend) (res int64, err error)
  • func (s *Service) Close() (err error)
  • func (s *Service) DelLike(c context.Context, oldMsg json.RawMessage) (err error)
  • func (s *Service) FinishMatch(c context.Context, moID int64) (err error)
  • func (s *Service) Ping(c context.Context) (err error)
  • func (s *Service) UpLike(c context.Context, newMsg, oldMsg json.RawMessage) (err error)

Types

type Service

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

Service service

func New

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

New is archive service implementation.

func (*Service) AddLike

func (s *Service) AddLike(c context.Context, addMsg json.RawMessage) (err error)

AddLike like add data update cache .

func (*Service) BatchInsertLikeExtend

func (s *Service) BatchInsertLikeExtend(c context.Context, extends []*like.Extend) (res int64, err error)

BatchInsertLikeExtend batch insert like_extend table.

func (*Service) Close

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

Close kafaka consumer close.

func (*Service) DelLike

func (s *Service) DelLike(c context.Context, oldMsg json.RawMessage) (err error)

DelLike delete like update cache

func (*Service) FinishMatch

func (s *Service) FinishMatch(c context.Context, moID int64) (err error)

FinishMatch finish match.

func (*Service) Ping

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

Ping reports the heath of services.

func (*Service) UpLike

func (s *Service) UpLike(c context.Context, newMsg, oldMsg json.RawMessage) (err error)

UpLike update likes data update cahce