scheduler

func (*FreeEndMonitor) CancelTorrent ¶ added in v0.3.0

func (m *FreeEndMonitor) CancelTorrent(torrentID uint)

func (*FreeEndMonitor) ScheduleTorrent ¶ added in v0.3.0

func (m *FreeEndMonitor) ScheduleTorrent(torrent models.TorrentInfo)

func (*FreeEndMonitor) Start ¶ added in v0.3.0

func (m *FreeEndMonitor) Start() error

func (*FreeEndMonitor) Stop ¶ added in v0.3.0

func (m *FreeEndMonitor) Stop()

func (*FreeEndMonitor) TestHandleFreeEndedTorrent ¶ added in v0.3.0

func (m *FreeEndMonitor) TestHandleFreeEndedTorrent(torrent models.TorrentInfo)

TestHandleFreeEndedTorrent 暴露给测试/调试命令使用

func (*Manager) GetDownloaderManager ¶ added in v0.2.0

func (m *Manager) GetDownloaderManager() *downloader.DownloaderManager

GetDownloaderManager 获取下载器管理器

func (*Manager) GetFreeEndMonitor ¶ added in v0.3.0

func (m *Manager) GetFreeEndMonitor() *FreeEndMonitor

GetFreeEndMonitor 获取免费结束监控器

func (*Manager) InitFreeEndMonitor ¶ added in v0.3.0

func (m *Manager) InitFreeEndMonitor()

func (*Manager) LastVersion ¶

func (m *Manager) LastVersion() int64

func (*Manager) Reload ¶

func (m *Manager) Reload(cfg *models.Config)

func (*Manager) Start ¶

func (m *Manager) Start(site models.SiteGroup, r models.RSSConfig, runner func(ctx context.Context))

func (*Manager) StartAll ¶

func (m *Manager) StartAll(cfg *models.Config)

StartAll 按配置启动所有任务（不做停止）

func (*Manager) Stop ¶

func (m *Manager) Stop(site models.SiteGroup, rssName string)

func (*Manager) StopAll ¶

func (m *Manager) StopAll()

StopAll 取消所有任务并等待当前执行结束