service

Documentation

Index

• type Service
  • func New(c *conf.Config) (s *Service)
  • func (s *Service) Close() (err error)
  • func (s *Service) DelteVideoCache(aid, cid int64) (err error)
  • func (s *Service) Ping() (err error)
  • func (s *Service) PopItem(c context.Context) (item *model.RetryItem, err error)
  • func (s *Service) PushItem(c context.Context, item *model.RetryItem) (err error)
  • func (s *Service) UpdateCache(old *model.Archive, nw *model.Archive, action string) (err error)
  • func (s *Service) UpdateVideoCache(aid, cid int64) (err error)

Types

type Service

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

Service service

func New

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

New is archive service implementation.

func (*Service) Close

func (s *Service) Close() (err error)

Close is

func (*Service) DelteVideoCache

func (s *Service) DelteVideoCache(aid, cid int64) (err error)

DelteVideoCache del video cache

func (*Service) Ping

func (s *Service) Ping() (err error)

Ping check status

func (*Service) PopItem

func (s *Service) PopItem(c context.Context) (item *model.RetryItem, err error)

PopItem is

func (*Service) PushItem

func (s *Service) PushItem(c context.Context, item *model.RetryItem) (err error)

PushItem is

func (*Service) UpdateCache

func (s *Service) UpdateCache(old *model.Archive, nw *model.Archive, action string) (err error)

UpdateCache is

func (*Service) UpdateVideoCache

func (s *Service) UpdateVideoCache(aid, cid int64) (err error)

UpdateVideoCache is