dao

Documentation

Index

• type Dao
  • func New(c *conf.Config) (dao *Dao)
  • func (d *Dao) Close()
  • func (d *Dao) DelVideoDataBySVID(c context.Context, svid int64) (err error)
  • func (d *Dao) ESVideoData(c context.Context, query string) (total int64, list []*v1.RecVideoInfo, err error)
  • func (d *Dao) Ping(c context.Context) error
  • func (d *Dao) RecVideoDataElastic(c context.Context, query elastic.Query, script *elastic.ScriptSort, ...) (total int64, list []*v1.RecVideoInfo, err error)
  • func (d *Dao) SaveVideo(c context.Context, videos *v1.SaveVideoRequest) (err error)
  • func (d *Dao) VideoData(c context.Context, query elastic.Query, from, size int) (total int64, list []*v1.VideoESInfo, err error)

Types

type Dao

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

Dao dao

func New

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

New init mysql db

func (*Dao) Close

func (d *Dao) Close()

Close close the resource.

func (*Dao) DelVideoDataBySVID

func (d *Dao) DelVideoDataBySVID(c context.Context, svid int64) (err error)

DelVideoDataBySVID 根据svid删除视频

func (*Dao) ESVideoData

func (d *Dao) ESVideoData(c context.Context, query string) (total int64, list []*v1.RecVideoInfo, err error)

ESVideoData 获取视频信息

func (*Dao) Ping

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

Ping dao ping

func (*Dao) RecVideoDataElastic

func (d *Dao) RecVideoDataElastic(c context.Context, query elastic.Query, script *elastic.ScriptSort, from, size int) (total int64, list []*v1.RecVideoInfo, err error)

RecVideoDataElastic 获取视频信息

func (*Dao) SaveVideo

func (d *Dao) SaveVideo(c context.Context, videos *v1.SaveVideoRequest) (err error)

SaveVideo 保存视频信息

func (*Dao) VideoData

func (d *Dao) VideoData(c context.Context, query elastic.Query, from, size int) (total int64, list []*v1.VideoESInfo, err error)

VideoData 获取视频信息