service

Documentation

Index

• type Service
  • func New(c *conf.Config) (s *Service)
  • func (s *Service) BlockUser(c context.Context, mr *model.Case) (err error)
  • func (s *Service) CheckBlock(c context.Context, mid int64) (ok bool, err error)
  • func (s *Service) Close()
  • func (s *Service) DealCaseApplyReason(c context.Context, nwMsg []byte) (err error)
  • func (s *Service) DelCaseInfoCache(c context.Context, nwMsg []byte) (err error)
  • func (s *Service) DelCaseVoteTopCache(c context.Context, nwMsg []byte) (err error)
  • func (s *Service) DelGrantCase(c context.Context, nwMsg []byte, oldMsg []byte) (err error)
  • func (s *Service) DelJuryInfoCache(c context.Context, nwMsg []byte) (err error)
  • func (s *Service) DelOrigin(c context.Context, cs *model.Case)
  • func (s *Service) DelVoteCaseCache(c context.Context, nwMsg []byte) (err error)
  • func (s *Service) DeleteIdx(c context.Context, nwMsg []byte) (err error)
  • func (s *Service) GrantCase(c context.Context, nwMsg []byte, oldMsg []byte) (err error)
  • func (s *Service) InvalidJury(c context.Context, nwMsg []byte, oldMsg []byte) (err error)
  • func (s *Service) Judge(c context.Context, nwMsg []byte, oldMsg []byte) (err error)
  • func (s *Service) KPIReward(c context.Context, nwMsg []byte, oldMsg []byte) (err error)
  • func (s *Service) NotifyBlockAnswer(c context.Context, nwMsg []byte) (err error)
  • func (s *Service) Ping(c context.Context) error
  • func (s *Service) RegReply(c context.Context, table string, nwMsg []byte, oldMsg []byte) (err error)
  • func (s *Service) UnBlockAccount(c context.Context, nwMsg []byte, oldMsg []byte) (err error)
  • func (s *Service) UpdateCache(c context.Context, nwMsg []byte) (err error)
  • func (s *Service) UpdateVoteCount(c context.Context, mr *model.Case)

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) BlockUser

func (s *Service) BlockUser(c context.Context, mr *model.Case) (err error)

BlockUser add user block.

func (*Service) CheckBlock

func (s *Service) CheckBlock(c context.Context, mid int64) (ok bool, err error)

CheckBlock check user block state

func (*Service) Close

func (s *Service) Close()

Close kafka consumer close.

func (*Service) DealCaseApplyReason

func (s *Service) DealCaseApplyReason(c context.Context, nwMsg []byte) (err error)

DealCaseApplyReason deal with case apply reason.

func (*Service) DelCaseInfoCache

func (s *Service) DelCaseInfoCache(c context.Context, nwMsg []byte) (err error)

DelCaseInfoCache del case info cache.

func (*Service) DelCaseVoteTopCache

func (s *Service) DelCaseVoteTopCache(c context.Context, nwMsg []byte) (err error)

DelCaseVoteTopCache .

func (*Service) DelGrantCase

func (s *Service) DelGrantCase(c context.Context, nwMsg []byte, oldMsg []byte) (err error)

DelGrantCase del case in list.

func (*Service) DelJuryInfoCache

func (s *Service) DelJuryInfoCache(c context.Context, nwMsg []byte) (err error)

DelJuryInfoCache .

func (*Service) DelOrigin

func (s *Service) DelOrigin(c context.Context, cs *model.Case)

DelOrigin delorigin content.

func (*Service) DelVoteCaseCache

func (s *Service) DelVoteCaseCache(c context.Context, nwMsg []byte) (err error)

DelVoteCaseCache del vote case cache.

func (*Service) DeleteIdx

func (s *Service) DeleteIdx(c context.Context, nwMsg []byte) (err error)

DeleteIdx del cache idx.

func (*Service) GrantCase

func (s *Service) GrantCase(c context.Context, nwMsg []byte, oldMsg []byte) (err error)

GrantCase push case in list.

func (*Service) InvalidJury

func (s *Service) InvalidJury(c context.Context, nwMsg []byte, oldMsg []byte) (err error)

InvalidJury invalid juryer.

func (*Service) Judge

func (s *Service) Judge(c context.Context, nwMsg []byte, oldMsg []byte) (err error)

Judge judge case.

func (*Service) KPIReward

func (s *Service) KPIReward(c context.Context, nwMsg []byte, oldMsg []byte) (err error)

KPIReward send reward to user by kpi info.

func (*Service) NotifyBlockAnswer

func (s *Service) NotifyBlockAnswer(c context.Context, nwMsg []byte) (err error)

NotifyBlockAnswer notify block answer status

func (*Service) Ping

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

Ping check service health.

func (*Service) RegReply

func (s *Service) RegReply(c context.Context, table string, nwMsg []byte, oldMsg []byte) (err error)

RegReply regist reply subject.

func (*Service) UnBlockAccount

func (s *Service) UnBlockAccount(c context.Context, nwMsg []byte, oldMsg []byte) (err error)

UnBlockAccount unblock account.

func (*Service) UpdateCache

func (s *Service) UpdateCache(c context.Context, nwMsg []byte) (err error)

UpdateCache update blocked info cache.

func (*Service) UpdateVoteCount

func (s *Service) UpdateVoteCount(c context.Context, mr *model.Case)

UpdateVoteCount update user vote count.