scheduler

Documentation

Index

• type RssUpdateObserver
• type RssUpdateTask
  • func NewRssTask(appCore *core.Core) *RssUpdateTask
  • func (t *RssUpdateTask) Register(observer RssUpdateObserver)
  • func (t *RssUpdateTask) Start()
  • func (t *RssUpdateTask) Stop()

Types

type RssUpdateObserver

type RssUpdateObserver interface {
	SourceUpdate(*model.Source, []*model.Content, []*model.Subscribe)
	SourceUpdateError(*model.Source)
}

RssUpdateObserver Rss Update observer

type RssUpdateTask

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

RssUpdateTask rss更新任务

func NewRssTask

func NewRssTask(appCore *core.Core) *RssUpdateTask

NewRssTask new RssUpdateTask

func (*RssUpdateTask) Register

func (t *RssUpdateTask) Register(observer RssUpdateObserver)

Register 注册rss更新订阅者

func (*RssUpdateTask) Start

func (t *RssUpdateTask) Start()

Start run scheduler

func (*RssUpdateTask) Stop

func (t *RssUpdateTask) Stop()

Stop scheduler