data

Documentation

Index

• type Service
  • func New(c *conf.Config, rpcdaos *service.RPCDaos, p *service.Public) *Service
  • func (s *Service) AppStat(c context.Context, mid int64) (sts *data.AppStatList, err error)
  • func (s *Service) AppUpIncr(c context.Context, mid int64, ty int8, ip string) (res []*data.AppViewerIncr, err error)
  • func (s *Service) AppVideoQuitPoints(c context.Context, cid, mid int64, ip string) (res []int64, err error)
  • func (s *Service) ArchiveAnalyze(c context.Context, aid, mid int64, ip string) (stat *data.ArchiveData, err error)
  • func (s *Service) ArchiveStat(c context.Context, aid, mid int64, ip string) (stat *dataMdl.ArchiveData, err error)
  • func (s *Service) ArtRank(c context.Context, mid int64, ty byte) (res *data.ArtRankList, err error)
  • func (s *Service) ArtReadAnalysis(c context.Context, mid int64) (res *data.ArtRead, err error)
  • func (s *Service) ArtThirtyDay(c context.Context, mid int64, ty byte) (res []*data.ArtTrend, err error)
  • func (s *Service) CacheTrend(c context.Context, mid int64) (res map[string]*data.ViewerTrend, err error)
  • func (s *Service) Close()
  • func (s *Service) Covers(c context.Context, mid int64, fns []string, ip string) (cvs []string, err error)
  • func (s *Service) FanRankApp(c context.Context, mid int64, ty int, ip string) (res map[string][]*data.RankInfo, err error)
  • func (s *Service) IsForbidVideoup(mid int64) (isForbid bool)
  • func (s *Service) IsWhite(mid int64) (isWhite bool)
  • func (s *Service) NewStat(c context.Context, mid int64, ip string) (r *data.Stat, err error)
  • func (s *Service) OverView(c context.Context, mid int64, ty int8, ip string) (res *data.AppOverView, err error)
  • func (s *Service) Ping(c context.Context) (err error)
  • func (s *Service) RelationFansDay(c context.Context, mid int64) (res map[string]map[string]int, err error)
  • func (s *Service) RelationFansHistory(c context.Context, mid int64, month string) (res map[string]map[string]int, err error)
  • func (s *Service) RelationFansMonth(c context.Context, mid int64) (res map[string]map[string]int, err error)
  • func (s *Service) Stat(c context.Context, mid int64, ip string) (r *dataMdl.Stat, err error)
  • func (s *Service) Tags(c context.Context, mid int64, tid uint16, title, filename, desc, cover string, ...) (res *dataMdl.Tags, err error)
  • func (s *Service) TagsWithChecked(c context.Context, mid int64, tid uint16, title, filename, desc, cover string, ...) (retTags []*dataMdl.CheckedTag, err error)
  • func (s *Service) ThirtyDayArchive(c context.Context, mid int64, ty int8) (res []*data.ThirtyDay, err error)
  • func (s *Service) ThirtyDayArticle(c context.Context, mid int64, ip string) (res []*artmdl.ThirtyDayArticle, err error)
  • func (s *Service) UpArcPlayAnalysis(c context.Context, mid int64, cp int, ip string) (res *data.ArchivePlayList, err error)
  • func (s *Service) UpFansAnalysisForApp(c context.Context, mid int64, ty int, ip string) (res *data.AppFan, err error)
  • func (s *Service) UpFansAnalysisForWeb(c context.Context, mid int64, ip string) (res *data.WebFan, err error)
  • func (s *Service) UpFansMedal(c context.Context, mid int64) (fansMdl *data.UpFansMedal, err error)
  • func (s *Service) UpIncr(c context.Context, mid int64, ty int8, ip string) (res map[string]*data.ViewerIncr, err error)
  • func (s *Service) UpPlaySourceAnalysis(c context.Context, mid int64) (res *data.PlaySource, err error)
  • func (s *Service) VideoQuitPoints(c context.Context, cid, mid int64, ip string) (res []int64, err error)
  • func (s *Service) VideoRetention(c context.Context, cid, mid int64, ip string) (res *data.VideoQuit, err error)
  • func (s *Service) ViewerActionHour(c context.Context, mid int64) (res map[string]*data.ViewerActionHour, err error)
  • func (s *Service) ViewerArea(c context.Context, mid int64) (res map[string]map[string]int64, err error)
  • func (s *Service) ViewerBase(c context.Context, mid int64) (res map[string]*data.ViewerBase, err error)

Types

type Service

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

Service struct

func New

func New(c *conf.Config, rpcdaos *service.RPCDaos, p *service.Public) *Service

New get service

func (*Service) AppStat

func (s *Service) AppStat(c context.Context, mid int64) (sts *data.AppStatList, err error)

AppStat get app archive static data.

func (*Service) AppUpIncr

func (s *Service) AppUpIncr(c context.Context, mid int64, ty int8, ip string) (res []*data.AppViewerIncr, err error)

AppUpIncr for Play/Dm/Reply/Fav/Share/Elec/Coin incr.

func (*Service) AppVideoQuitPoints

func (s *Service) AppVideoQuitPoints(c context.Context, cid, mid int64, ip string) (res []int64, err error)

AppVideoQuitPoints get app video quit data.

func (*Service) ArchiveAnalyze

func (s *Service) ArchiveAnalyze(c context.Context, aid, mid int64, ip string) (stat *data.ArchiveData, err error)

ArchiveAnalyze get single archive data.

func (*Service) ArchiveStat

func (s *Service) ArchiveStat(c context.Context, aid, mid int64, ip string) (stat *dataMdl.ArchiveData, err error)

ArchiveStat get video quit data.

func (*Service) ArtRank

func (s *Service) ArtRank(c context.Context, mid int64, ty byte) (res *data.ArtRankList, err error)

ArtRank for article rank.

func (*Service) ArtReadAnalysis

func (s *Service) ArtReadAnalysis(c context.Context, mid int64) (res *data.ArtRead, err error)

ArtReadAnalysis for article.

func (*Service) ArtThirtyDay

func (s *Service) ArtThirtyDay(c context.Context, mid int64, ty byte) (res []*data.ArtTrend, err error)

ArtThirtyDay for article.

func (*Service) CacheTrend

func (s *Service) CacheTrend(c context.Context, mid int64) (res map[string]*data.ViewerTrend, err error)

CacheTrend get trend from mc.

func (*Service) Close

func (s *Service) Close()

Close dao

func (*Service) Covers

func (s *Service) Covers(c context.Context, mid int64, fns []string, ip string) (cvs []string, err error)

Covers get covers from ai

func (*Service) FanRankApp

func (s *Service) FanRankApp(c context.Context, mid int64, ty int, ip string) (res map[string][]*data.RankInfo, err error)

FanRankApp get app fans rank list.

func (*Service) IsForbidVideoup

func (s *Service) IsForbidVideoup(mid int64) (isForbid bool)

IsForbidVideoup fn.

func (*Service) IsWhite

func (s *Service) IsWhite(mid int64) (isWhite bool)

IsWhite check white.

func (*Service) NewStat

func (s *Service) NewStat(c context.Context, mid int64, ip string) (r *data.Stat, err error)

NewStat get stat from hbase.

func (*Service) OverView

func (s *Service) OverView(c context.Context, mid int64, ty int8, ip string) (res *data.AppOverView, err error)

OverView for app data overview.

func (*Service) Ping

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

Ping service

func (*Service) RelationFansDay

func (s *Service) RelationFansDay(c context.Context, mid int64) (res map[string]map[string]int, err error)

RelationFansDay get up viewer trend data.

func (*Service) RelationFansHistory

func (s *Service) RelationFansHistory(c context.Context, mid int64, month string) (res map[string]map[string]int, err error)

RelationFansHistory get relation history data by month.

func (*Service) RelationFansMonth

func (s *Service) RelationFansMonth(c context.Context, mid int64) (res map[string]map[string]int, err error)

RelationFansMonth get up viewer trend data.

func (*Service) Stat

func (s *Service) Stat(c context.Context, mid int64, ip string) (r *dataMdl.Stat, err error)

Stat get stat.

func (*Service) Tags

func (s *Service) Tags(c context.Context, mid int64, tid uint16, title, filename, desc, cover string, tagFrom int8) (res *dataMdl.Tags, err error)

Tags get predict tag.

func (*Service) TagsWithChecked

func (s *Service) TagsWithChecked(c context.Context, mid int64, tid uint16, title, filename, desc, cover string, tagFrom int8) (retTags []*dataMdl.CheckedTag, err error)

TagsWithChecked get predict tag with checked mark.

func (*Service) ThirtyDayArchive

func (s *Service) ThirtyDayArchive(c context.Context, mid int64, ty int8) (res []*data.ThirtyDay, err error)

ThirtyDayArchive for Play/Dm/Reply/Fav/Share/Elec/Coin for 30 days.

func (*Service) ThirtyDayArticle

func (s *Service) ThirtyDayArticle(c context.Context, mid int64, ip string) (res []*artmdl.ThirtyDayArticle, err error)

ThirtyDayArticle for 30 days.

func (*Service) UpArcPlayAnalysis

func (s *Service) UpArcPlayAnalysis(c context.Context, mid int64, cp int, ip string) (res *data.ArchivePlayList, err error)

UpArcPlayAnalysis get play list.

func (*Service) UpFansAnalysisForApp

func (s *Service) UpFansAnalysisForApp(c context.Context, mid int64, ty int, ip string) (res *data.AppFan, err error)

UpFansAnalysisForApp get app fans analysis.

func (*Service) UpFansAnalysisForWeb

func (s *Service) UpFansAnalysisForWeb(c context.Context, mid int64, ip string) (res *data.WebFan, err error)

UpFansAnalysisForWeb get web fans data.

func (*Service) UpFansMedal

func (s *Service) UpFansMedal(c context.Context, mid int64) (fansMdl *data.UpFansMedal, err error)

UpFansMedal for get fan medel count.

func (*Service) UpIncr

func (s *Service) UpIncr(c context.Context, mid int64, ty int8, ip string) (res map[string]*data.ViewerIncr, err error)

UpIncr for Play/Dm/Reply/Fav/Share/Elec/Coin incr.

func (*Service) UpPlaySourceAnalysis

func (s *Service) UpPlaySourceAnalysis(c context.Context, mid int64) (res *data.PlaySource, err error)

UpPlaySourceAnalysis get play analysis.

func (*Service) VideoQuitPoints

func (s *Service) VideoQuitPoints(c context.Context, cid, mid int64, ip string) (res []int64, err error)

VideoQuitPoints get video quit data.

func (*Service) VideoRetention

func (s *Service) VideoRetention(c context.Context, cid, mid int64, ip string) (res *data.VideoQuit, err error)

VideoRetention get video quit data.

func (*Service) ViewerActionHour

func (s *Service) ViewerActionHour(c context.Context, mid int64) (res map[string]*data.ViewerActionHour, err error)

ViewerActionHour get up viewer action hour data.

func (*Service) ViewerArea

func (s *Service) ViewerArea(c context.Context, mid int64) (res map[string]map[string]int64, err error)

ViewerArea get up viewer area data.

func (*Service) ViewerBase

func (s *Service) ViewerBase(c context.Context, mid int64) (res map[string]*data.ViewerBase, err error)

ViewerBase get up viewer base data.