ugc

Documentation

Index

• func Retry(callback func() error, retry int, sleep time.Duration) (err error)
• type Service
  • func New(c *conf.Config) (s *Service)
  • func (s *Service) ArcHandle(arcMsg *ugcmdl.ArcMsg)
  • func (s *Service) Close()
  • func (s *Service) InitUpper(mid int64) (err error)
  • func (s *Service) UgcDbus(msg *databus.Message)
  • func (s *Service) UpArchives(mid int64, pn int, ps int) (match map[int64]*arccli.Arc, aids []int64, err error)
  • func (s *Service) ZoneIdx()

Functions

func Retry

func Retry(callback func() error, retry int, sleep time.Duration) (err error)

Retry . retry one function until no error

Types

type Service

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

Service is show service.

func New

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

New inits the ugc service

func (*Service) ArcHandle

func (s *Service) ArcHandle(arcMsg *ugcmdl.ArcMsg)

ArcHandle treats the archive notify-T message to update the DB if there is any change

func (*Service) Close

func (s *Service) Close()

Close close the services

func (*Service) InitUpper

func (s *Service) InitUpper(mid int64) (err error)

InitUpper takes the upper's archive & videos, load them into our DB

func (*Service) UgcDbus

func (s *Service) UgcDbus(msg *databus.Message)

UgcDbus def.

func (*Service) UpArchives

func (s *Service) UpArchives(mid int64, pn int, ps int) (match map[int64]*arccli.Arc, aids []int64, err error)

UpArchives picks one page of the up's archives

func (*Service) ZoneIdx

func (s *Service) ZoneIdx()

ZoneIdx finds out all the passed seasons in DB and then arrange them in a sorted set in Redis