service

Documentation

Index

• type BloomFilter
• type DefaultFilter
• type DefaultRanker
• type DefaultScorer
• type Filter
• type FilterManager
  • func NewFilterManager(args ...interface{}) *FilterManager
  • func (fm *FilterManager) DoFilter(svid uint64, names ...string) bool
  • func (fm *FilterManager) SetFilter(name string, f Filter)
• type Ranker
• type RankerManager
  • func NewRankerManager(d *dao.Dao) *RankerManager
  • func (rm *RankerManager) DoRank(tuples *[]*model.Tuple, name string, comp func(interface{}, interface{}) bool)
• type RecallResult
• type RecallTask
  • func (t *RecallTask) Run() *[]byte
  • func (t *RecallTask) SetDebug(d bool)
  • func (t *RecallTask) SetFilterManager(filter *FilterManager)
  • func (t *RecallTask) SetRankerManager(ranker *RankerManager)
  • func (t *RecallTask) SetScorerManager(sc *ScorerManager)
• type Result
  • func (rr *Result) ToBytes() *[]byte
• type Scorer
• type ScorerManager
  • func NewScorerManager(d *dao.Dao) *ScorerManager
  • func (sm *ScorerManager) DoScore(svid uint64, name string, params ...interface{}) float32
• type Service
  • func New(c *conf.Config) (s *Service)
  • func (s *Service) Close()
  • func (s *Service) NewIncomeVideo(ctx context.Context, in *v1.NewIncomeVideoRequest) (res *empty.Empty, err error)
  • func (s *Service) Ping(c context.Context) (err error)
  • func (s *Service) Recall(ctx context.Context, request *v1.RecallRequest) (*v1.RecallResponse, error)
  • func (s *Service) VideoIndex(ctx context.Context, in *v1.VideoIndexRequest) (*v1.VideoIndexResponse, error)
  • func (s *Service) VideosByIndex(ctx context.Context, in *v1.VideosByIndexRequest) (res *v1.VideosByIndexResponse, err error)

Types

type BloomFilter

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

BloomFilter struct

type DefaultFilter

type DefaultFilter struct{}

DefaultFilter .

type DefaultRanker

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

DefaultRanker .

type DefaultScorer

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

DefaultScorer .

type Filter

type Filter interface {
	// contains filtered or unexported methods
}

Filter interface

type FilterManager

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

FilterManager .

func NewFilterManager

func NewFilterManager(args ...interface{}) *FilterManager

NewFilterManager .

func (*FilterManager) DoFilter

func (fm *FilterManager) DoFilter(svid uint64, names ...string) bool

DoFilter .

func (*FilterManager) SetFilter

func (fm *FilterManager) SetFilter(name string, f Filter)

SetFilter .

type Ranker

type Ranker interface {
	// contains filtered or unexported methods
}

Ranker interface

type RankerManager

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

RankerManager .

func NewRankerManager

func NewRankerManager(d *dao.Dao) *RankerManager

NewRankerManager .

func (*RankerManager) DoRank

func (rm *RankerManager) DoRank(tuples *[]*model.Tuple, name string, comp func(interface{}, interface{}) bool)

DoRank .

type RecallResult

type RecallResult struct {
	Result
	Tag      string
	Name     string
	Priority int32
}

RecallResult .

type RecallTask

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

RecallTask .

func (*RecallTask) Run

func (t *RecallTask) Run() *[]byte

Run .

func (*RecallTask) SetDebug

func (t *RecallTask) SetDebug(d bool)

SetDebug .

func (*RecallTask) SetFilterManager

func (t *RecallTask) SetFilterManager(filter *FilterManager)

SetFilterManager .

func (*RecallTask) SetRankerManager

func (t *RecallTask) SetRankerManager(ranker *RankerManager)

SetRankerManager .

func (*RecallTask) SetScorerManager

func (t *RecallTask) SetScorerManager(sc *ScorerManager)

SetScorerManager .

type Result

type Result struct {
	TotalHit    int32
	FilterCount int32
	FinalCount  int32
	Tuples      []*model.Tuple
}

Result .

func (*Result) ToBytes

func (rr *Result) ToBytes() *[]byte

ToBytes .

type Scorer

type Scorer interface {
	// contains filtered or unexported methods
}

Scorer interface

type ScorerManager

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

ScorerManager .

func NewScorerManager

func NewScorerManager(d *dao.Dao) *ScorerManager

NewScorerManager .

func (*ScorerManager) DoScore

func (sm *ScorerManager) DoScore(svid uint64, name string, params ...interface{}) float32

DoScore .

type Service

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

Service struct

func New

func New(c *conf.Config) (s *Service)

New init

func (*Service) Close

func (s *Service) Close()

Close Service

func (*Service) NewIncomeVideo

func (s *Service) NewIncomeVideo(ctx context.Context, in *v1.NewIncomeVideoRequest) (res *empty.Empty, err error)

NewIncomeVideo 更新新发视频标签

func (*Service) Ping

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

Ping Service

func (*Service) Recall

func (s *Service) Recall(ctx context.Context, request *v1.RecallRequest) (*v1.RecallResponse, error)

Recall recsys recall video id list by tag

func (*Service) VideoIndex

func (s *Service) VideoIndex(ctx context.Context, in *v1.VideoIndexRequest) (*v1.VideoIndexResponse, error)

VideoIndex 获取视频正排信息

func (*Service) VideosByIndex

func (s *Service) VideosByIndex(ctx context.Context, in *v1.VideosByIndexRequest) (res *v1.VideosByIndexResponse, err error)

VideosByIndex 获取单个倒排下的视频列表