dao

Documentation

Index

• type Dao
  • func New(c *conf.Config) (d *Dao)
  • func (d *Dao) AddTrimQueueCache(c context.Context, tp int32, oid int64, trims []*model.Trim) (count int64, err error)
  • func (d *Dao) DMHides(c context.Context, typ int32, oid, limit int64) (res []*model.DM, err error)
  • func (d *Dao) DMInfos(c context.Context, tp int32, oid int64) (dms []*model.DM, err error)
  • func (d *Dao) DelIdxContentCaches(c context.Context, typ int32, oid int64, dmids ...int64) (err error)
  • func (d *Dao) DurationCache(c context.Context, oid int64) (duration int64, err error)
  • func (d *Dao) ExpireTrimQueue(c context.Context, tp int32, oid int64) (ok bool, err error)
  • func (d *Dao) FlushTrimCache(c context.Context, tp int32, oid int64, trims []*model.Trim) (err error)
  • func (d *Dao) Ping(c context.Context) (err error)
  • func (d *Dao) SetDurationCache(c context.Context, oid, duration int64) (err error)
  • func (d *Dao) SetSubjectCache(c context.Context, sub *model.Subject) (err error)
  • func (d *Dao) Subject(c context.Context, tp int32, oid int64) (s *model.Subject, err error)
  • func (d *Dao) SubjectCache(c context.Context, tp int32, oid int64) (sub *model.Subject, err error)
  • func (d *Dao) TrimCache(c context.Context, tp int32, oid, count int64) (dmids []int64, err error)
  • func (d *Dao) UpdateDM(c context.Context, m *model.DM) (affect int64, err error)
  • func (d *Dao) UpdateDMStates(c context.Context, oid int64, dmids []int64, state int32) (affect int64, err error)
  • func (d *Dao) ZRemTrimCache(c context.Context, tp int32, oid int64, dmID int64) (err error)

Types

type Dao

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

Dao dao struct.

func New

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

New return dm dao instance.

func (*Dao) AddTrimQueueCache

func (d *Dao) AddTrimQueueCache(c context.Context, tp int32, oid int64, trims []*model.Trim) (count int64, err error)

AddTrimQueueCache add dm index into trim queue.

func (*Dao) DMHides

func (d *Dao) DMHides(c context.Context, typ int32, oid, limit int64) (res []*model.DM, err error)

DMHides get hide index info from db by oid and state.

func (*Dao) DMInfos

func (d *Dao) DMInfos(c context.Context, tp int32, oid int64) (dms []*model.DM, err error)

DMInfos get indexs of oid.

func (*Dao) DelIdxContentCaches

func (d *Dao) DelIdxContentCaches(c context.Context, typ int32, oid int64, dmids ...int64) (err error)

DelIdxContentCaches del index content cache.

func (*Dao) DurationCache

func (d *Dao) DurationCache(c context.Context, oid int64) (duration int64, err error)

DurationCache return duration of video.

func (*Dao) ExpireTrimQueue

func (d *Dao) ExpireTrimQueue(c context.Context, tp int32, oid int64) (ok bool, err error)

ExpireTrimQueue set expire time of index.

func (*Dao) FlushTrimCache

func (d *Dao) FlushTrimCache(c context.Context, tp int32, oid int64, trims []*model.Trim) (err error)

FlushTrimCache flush trim queue cache.

func (*Dao) Ping

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

Ping dm dao ping.

func (*Dao) SetDurationCache

func (d *Dao) SetDurationCache(c context.Context, oid, duration int64) (err error)

SetDurationCache set video duration to redis.

func (*Dao) SetSubjectCache

func (d *Dao) SetSubjectCache(c context.Context, sub *model.Subject) (err error)

SetSubjectCache add subject cache.

func (*Dao) Subject

func (d *Dao) Subject(c context.Context, tp int32, oid int64) (s *model.Subject, err error)

Subject get subject info from db.

func (*Dao) SubjectCache

func (d *Dao) SubjectCache(c context.Context, tp int32, oid int64) (sub *model.Subject, err error)

SubjectCache get subject from memcache.

func (*Dao) TrimCache

func (d *Dao) TrimCache(c context.Context, tp int32, oid, count int64) (dmids []int64, err error)

TrimCache trim trim queue and return trimed dmid from trim queue.

func (*Dao) UpdateDM

func (d *Dao) UpdateDM(c context.Context, m *model.DM) (affect int64, err error)

UpdateDM update index of dm.

func (*Dao) UpdateDMStates

func (d *Dao) UpdateDMStates(c context.Context, oid int64, dmids []int64, state int32) (affect int64, err error)

UpdateDMStates multi update index state of dm.

func (*Dao) ZRemTrimCache

func (d *Dao) ZRemTrimCache(c context.Context, tp int32, oid int64, dmID int64) (err error)

ZRemTrimCache ZREM trim from trim queue.