scheduler

package
v0.24.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 29, 2026 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PauseReasonPeerRatio = "做种竞争度过高"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CleanupMonitor added in v0.14.0 

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

func NewCleanupMonitor added in v0.14.0 

func NewCleanupMonitor(db *gorm.DB, downloaderMgr *downloader.DownloaderManager) *CleanupMonitor

func (*CleanupMonitor) RunManual added in v0.14.0 

func (c *CleanupMonitor) RunManual() (int, error)

func (*CleanupMonitor) Start added in v0.14.0 

func (c *CleanupMonitor) Start() error

func (*CleanupMonitor) Stop added in v0.14.0 

func (c *CleanupMonitor) Stop()

type FreeEndMonitor added in v0.3.0 

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

func NewFreeEndMonitor added in v0.3.0 

func NewFreeEndMonitor(db *gorm.DB, downloaderMgr *downloader.DownloaderManager) *FreeEndMonitor

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 暴露给测试/调试命令使用

type Manager 

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

func NewManager 

func NewManager() *Manager

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 取消所有任务并等待当前执行结束

type PeerRatioMonitor added in v0.23.0 

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

func NewPeerRatioMonitor added in v0.23.0 

func NewPeerRatioMonitor(db *gorm.DB, downloaderMgr *downloader.DownloaderManager) *PeerRatioMonitor

func (*PeerRatioMonitor) Start added in v0.23.0 

func (p *PeerRatioMonitor) Start() error

func (*PeerRatioMonitor) Stop added in v0.23.0 

func (p *PeerRatioMonitor) Stop()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.