dao

Documentation

Index

• type Dao
  • func New(c *conf.Config) (d *Dao)
  • func (d *Dao) AddNewArcCache(c context.Context, a *api.Arc, tids ...int64) (err error)
  • func (d *Dao) AddNewArcsCache(c context.Context, tid int64, as ...*api.Arc) (err error)
  • func (d *Dao) AddOriginalNewestArcCache(c context.Context, rid int32, tid int64, as []*api.Arc) (err error)
  • func (d *Dao) AddRegionNewArcCache(c context.Context, rid int32, arc *api.Arc, tids ...int64) (err error)
  • func (d *Dao) AddRegionNewestArcCache(c context.Context, rid int32, tid int64, as []*api.Arc) (err error)
  • func (d *Dao) AddReport(c context.Context, oid, tid, mid int64, typ, partID, reason, score int32) (err error)
  • func (d *Dao) AddTagPridArcCache(c context.Context, tids []int64, prid int64, as ...*api.Arc) (err error)
  • func (d *Dao) AddTagPridCache(c context.Context, tids []int64, prid int64, as ...*api.Arc) (err error)
  • func (d *Dao) ChannelCategories(c context.Context, lastID int64, pageSize, state int32) (res []*taGrpcModel.ChannelCategory, err error)
  • func (d *Dao) ChannelGroup(c context.Context, tid int64) (res []*model.ChannelSynonym, err error)
  • func (d *Dao) ChannelRules(c context.Context, lastID int64, pageSize, state int32) (res []*taGrpcModel.ChannelRule, err error)
  • func (d *Dao) Channels(c context.Context, lastID int64, pageSize int32) (res []*taGrpcModel.Channel, err error)
  • func (d *Dao) Close()
  • func (d *Dao) DelNewArcsCache(c context.Context, tid int64) (err error)
  • func (d *Dao) DeleteNewArcCache(c context.Context, tid int64, aids string) (err error)
  • func (d *Dao) DeleteRegionNewArcsCache(c context.Context, tid int64, rid int32, arcs []*api.Arc) (err error)
  • func (d *Dao) ExpireOriginalNewestArcCache(c context.Context, rid int32, tid int64) (ok bool, err error)
  • func (d *Dao) ExpireRegionNewArcsCache(c context.Context, rid int32, tid int64) (ok bool, err error)
  • func (d *Dao) IncrSpamCache(c context.Context, mid int64, action int32) (err error)
  • func (d *Dao) NewArcsCache(c context.Context, tid int64, start, end int) (aids []int64, count int, err error)
  • func (d *Dao) OriginRegionNewArcsCache(c context.Context, rid int32, tid int64, start, end int) (aids []int64, count int, err error)
  • func (d *Dao) OriginalNewestArcCache(c context.Context, rid int32, tid int64, aids []int64) (exist, none []int64, err error)
  • func (d *Dao) PingRe(c context.Context) (err error)
  • func (d *Dao) RegionNewArcsCache(c context.Context, rid int32, tid int64, start, end int) (aids []int64, count int, err error)
  • func (d *Dao) RegionNewestArcCache(c context.Context, rid int32, tid int64, aids []int64) (exist, none []int64, err error)
  • func (d *Dao) RemTidArcCache(c context.Context, aid int64, tids []int64) (err error)
  • func (d *Dao) RemoveNewArcsCache(c context.Context, aid int64, tids ...int64) (err error)
  • func (d *Dao) RemoveRegionNewArcCache(c context.Context, rid int32, arc *api.Arc, tids ...int64) (err error)
  • func (d *Dao) RemoveTagPridArcCache(c context.Context, tids []int64, prid, aid int64) (err error)
  • func (d *Dao) ResTag(c context.Context, oid int64, tp int32) (res []*taGrpcModel.Resource, err error)
  • func (d *Dao) ResTagMap(c context.Context, oid int64, tp int32) (res map[int64]*taGrpcModel.Resource, err error)
  • func (d *Dao) ResTags(c context.Context, oids []int64, tp int32) (res map[int64][]*taGrpcModel.Resource, err error)
  • func (d *Dao) SpamCache(c context.Context, mid int64, action int32) (count int, err error)
  • func (d *Dao) Tag(c context.Context, tid int64, mid int64) (*taGrpcModel.Tag, error)
  • func (d *Dao) TagByName(c context.Context, mid int64, tname string) (*taGrpcModel.Tag, error)
  • func (d *Dao) TagMap(c context.Context, tids []int64, mid int64) (res map[int64]*taGrpcModel.Tag, err error)
  • func (d *Dao) UserCard(c context.Context, mid int64) (*account.Card, error)
  • func (d *Dao) UserCards(c context.Context, mids []int64) (map[int64]*account.Card, error)
  • func (d *Dao) UserProfile(c context.Context, mid int64) (*account.Profile, error)
  • func (d *Dao) ZrangeTagPridArc(c context.Context, tid, prid int64, start, end int) (aids []int64, count int, err error)

Types

type Dao

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

Dao Dao.

func New

func New(c *conf.Config) (d *Dao)

New New.

func (*Dao) AddNewArcCache

func (d *Dao) AddNewArcCache(c context.Context, a *api.Arc, tids ...int64) (err error)

AddNewArcCache add new arc into tids by arc-tids.

func (*Dao) AddNewArcsCache

func (d *Dao) AddNewArcsCache(c context.Context, tid int64, as ...*api.Arc) (err error)

AddNewArcsCache add new arcs of tid by tid-arcs.

func (*Dao) AddOriginalNewestArcCache

func (d *Dao) AddOriginalNewestArcCache(c context.Context, rid int32, tid int64, as []*api.Arc) (err error)

AddOriginalNewestArcCache region original newest archive .

func (*Dao) AddRegionNewArcCache

func (d *Dao) AddRegionNewArcCache(c context.Context, rid int32, arc *api.Arc, tids ...int64) (err error)

AddRegionNewArcCache 增加分区下热门tag的最新视频.

func (*Dao) AddRegionNewestArcCache

func (d *Dao) AddRegionNewestArcCache(c context.Context, rid int32, tid int64, as []*api.Arc) (err error)

AddRegionNewestArcCache add region newest arc.

func (*Dao) AddReport

func (d *Dao) AddReport(c context.Context, oid, tid, mid int64, typ, partID, reason, score int32) (err error)

AddReport add a report to tag-serivce.

func (*Dao) AddTagPridArcCache

func (d *Dao) AddTagPridArcCache(c context.Context, tids []int64, prid int64, as ...*api.Arc) (err error)

AddTagPridArcCache .

func (*Dao) AddTagPridCache

func (d *Dao) AddTagPridCache(c context.Context, tids []int64, prid int64, as ...*api.Arc) (err error)

AddTagPridCache .

func (*Dao) ChannelCategories

func (d *Dao) ChannelCategories(c context.Context, lastID int64, pageSize, state int32) (res []*taGrpcModel.ChannelCategory, err error)

ChannelCategories get channel categories.

func (*Dao) ChannelGroup

func (d *Dao) ChannelGroup(c context.Context, tid int64) (res []*model.ChannelSynonym, err error)

ChannelGroup get channel groups.

func (*Dao) ChannelRules

func (d *Dao) ChannelRules(c context.Context, lastID int64, pageSize, state int32) (res []*taGrpcModel.ChannelRule, err error)

ChannelRules get channel rules.

func (*Dao) Channels

func (d *Dao) Channels(c context.Context, lastID int64, pageSize int32) (res []*taGrpcModel.Channel, err error)

Channels get channels.

func (*Dao) Close

func (d *Dao) Close()

Close dao close.

func (*Dao) DelNewArcsCache

func (d *Dao) DelNewArcsCache(c context.Context, tid int64) (err error)

DelNewArcsCache del tid from cache

func (*Dao) DeleteNewArcCache

func (d *Dao) DeleteNewArcCache(c context.Context, tid int64, aids string) (err error)

DeleteNewArcCache delete arcs by tid from cache.

func (*Dao) DeleteRegionNewArcsCache

func (d *Dao) DeleteRegionNewArcsCache(c context.Context, tid int64, rid int32, arcs []*api.Arc) (err error)

DeleteRegionNewArcsCache delete region NewArcs Cache.

func (*Dao) ExpireOriginalNewestArcCache

func (d *Dao) ExpireOriginalNewestArcCache(c context.Context, rid int32, tid int64) (ok bool, err error)

ExpireOriginalNewestArcCache expire region new arcs.

func (*Dao) ExpireRegionNewArcsCache

func (d *Dao) ExpireRegionNewArcsCache(c context.Context, rid int32, tid int64) (ok bool, err error)

ExpireRegionNewArcsCache expire region new arcs.

func (*Dao) IncrSpamCache

func (d *Dao) IncrSpamCache(c context.Context, mid int64, action int32) (err error)

IncrSpamCache increse count of spam cache.

func (*Dao) NewArcsCache

func (d *Dao) NewArcsCache(c context.Context, tid int64, start, end int) (aids []int64, count int, err error)

NewArcsCache get archives of tag by tid of all regions.

func (*Dao) OriginRegionNewArcsCache

func (d *Dao) OriginRegionNewArcsCache(c context.Context, rid int32, tid int64, start, end int) (aids []int64, count int, err error)

OriginRegionNewArcsCache get origin newest arc of tag by rid and tid

func (*Dao) OriginalNewestArcCache

func (d *Dao) OriginalNewestArcCache(c context.Context, rid int32, tid int64, aids []int64) (exist, none []int64, err error)

OriginalNewestArcCache add region newest arc.

func (*Dao) PingRe

func (d *Dao) PingRe(c context.Context) (err error)

PingRe PingRe.

func (*Dao) RegionNewArcsCache

func (d *Dao) RegionNewArcsCache(c context.Context, rid int32, tid int64, start, end int) (aids []int64, count int, err error)

RegionNewArcsCache get newest arcs of tag by rid and tid.

func (*Dao) RegionNewestArcCache

func (d *Dao) RegionNewestArcCache(c context.Context, rid int32, tid int64, aids []int64) (exist, none []int64, err error)

RegionNewestArcCache add region newest arc.

func (*Dao) RemTidArcCache

func (d *Dao) RemTidArcCache(c context.Context, aid int64, tids []int64) (err error)

RemTidArcCache .

func (*Dao) RemoveNewArcsCache

func (d *Dao) RemoveNewArcsCache(c context.Context, aid int64, tids ...int64) (err error)

RemoveNewArcsCache remove arc of tag by tids

func (*Dao) RemoveRegionNewArcCache

func (d *Dao) RemoveRegionNewArcCache(c context.Context, rid int32, arc *api.Arc, tids ...int64) (err error)

RemoveRegionNewArcCache del new arc from rid-tids by arc.

func (*Dao) RemoveTagPridArcCache

func (d *Dao) RemoveTagPridArcCache(c context.Context, tids []int64, prid, aid int64) (err error)

RemoveTagPridArcCache .

func (*Dao) ResTag

func (d *Dao) ResTag(c context.Context, oid int64, tp int32) (res []*taGrpcModel.Resource, err error)

ResTag res tag.

func (*Dao) ResTagMap

func (d *Dao) ResTagMap(c context.Context, oid int64, tp int32) (res map[int64]*taGrpcModel.Resource, err error)

ResTagMap res tag map.

func (*Dao) ResTags

func (d *Dao) ResTags(c context.Context, oids []int64, tp int32) (res map[int64][]*taGrpcModel.Resource, err error)

ResTags res tags.

func (*Dao) SpamCache

func (d *Dao) SpamCache(c context.Context, mid int64, action int32) (count int, err error)

SpamCache return spam count cache.

func (*Dao) Tag

func (d *Dao) Tag(c context.Context, tid int64, mid int64) (*taGrpcModel.Tag, error)

Tag get tag info by id.

func (*Dao) TagByName

func (d *Dao) TagByName(c context.Context, mid int64, tname string) (*taGrpcModel.Tag, error)

TagByName get tag info by name.

func (*Dao) TagMap

func (d *Dao) TagMap(c context.Context, tids []int64, mid int64) (res map[int64]*taGrpcModel.Tag, err error)

TagMap get tag info map.

func (*Dao) UserCard

func (d *Dao) UserCard(c context.Context, mid int64) (*account.Card, error)

UserCard account user card info.

func (*Dao) UserCards

func (d *Dao) UserCards(c context.Context, mids []int64) (map[int64]*account.Card, error)

UserCards account users card info.

func (*Dao) UserProfile

func (d *Dao) UserProfile(c context.Context, mid int64) (*account.Profile, error)

UserProfile get user profile.

func (*Dao) ZrangeTagPridArc

func (d *Dao) ZrangeTagPridArc(c context.Context, tid, prid int64, start, end int) (aids []int64, count int, err error)

ZrangeTagPridArc .