scheduler

package
v1.2.5 Latest Latest
Warning

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

 Go to latest Published: Aug 28, 2025 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetGlobalMeilisearchManager added in v1.2.5 

func GetGlobalMeilisearchManager() *services.MeilisearchManager

GetGlobalMeilisearchManager 获取全局Meilisearch管理器

func SetGlobalMeilisearchManager added in v1.2.5 

func SetGlobalMeilisearchManager(manager *services.MeilisearchManager)

SetGlobalMeilisearchManager 设置全局Meilisearch管理器

Types

type AutoTransferScheduler 

type AutoTransferScheduler struct {
	*BaseScheduler
	// contains filtered or unexported fields
}

AutoTransferScheduler 自动转存调度器

func NewAutoTransferScheduler 

func NewAutoTransferScheduler(base *BaseScheduler) *AutoTransferScheduler

NewAutoTransferScheduler 创建自动转存调度器

func (*AutoTransferScheduler) IsAutoTransferRunning 

func (a *AutoTransferScheduler) IsAutoTransferRunning() bool

IsAutoTransferRunning 检查自动转存任务是否正在运行

func (*AutoTransferScheduler) Start 

func (a *AutoTransferScheduler) Start()

Start 启动自动转存定时任务

func (*AutoTransferScheduler) Stop 

func (a *AutoTransferScheduler) Stop()

Stop 停止自动转存定时任务

type BaseScheduler 

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

BaseScheduler 基础调度器结构

func NewBaseScheduler 

func NewBaseScheduler(
	hotDramaRepo repo.HotDramaRepository,
	readyResourceRepo repo.ReadyResourceRepository,
	resourceRepo repo.ResourceRepository,
	systemConfigRepo repo.SystemConfigRepository,
	panRepo repo.PanRepository,
	cksRepo repo.CksRepository,
	tagRepo repo.TagRepository,
	categoryRepo repo.CategoryRepository,
) *BaseScheduler

NewBaseScheduler 创建基础调度器

func (*BaseScheduler) GetStopChan 

func (b *BaseScheduler) GetStopChan() chan bool

GetStopChan 获取停止通道

func (*BaseScheduler) IsRunning 

func (b *BaseScheduler) IsRunning() bool

IsRunning 检查是否正在运行

func (*BaseScheduler) SetRunning 

func (b *BaseScheduler) SetRunning(running bool)

SetRunning 设置运行状态

func (*BaseScheduler) SleepWithStopCheck 

func (b *BaseScheduler) SleepWithStopCheck(duration time.Duration) bool

SleepWithStopCheck 带停止检查的睡眠

func (*BaseScheduler) Stop 

func (b *BaseScheduler) Stop()

Stop 停止调度器

type GlobalScheduler 

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

GlobalScheduler 全局调度器管理器

func GetGlobalScheduler 

func GetGlobalScheduler(hotDramaRepo repo.HotDramaRepository, readyResourceRepo repo.ReadyResourceRepository, resourceRepo repo.ResourceRepository, systemConfigRepo repo.SystemConfigRepository, panRepo repo.PanRepository, cksRepo repo.CksRepository, tagRepo repo.TagRepository, categoryRepo repo.CategoryRepository) *GlobalScheduler

GetGlobalScheduler 获取全局调度器实例（单例模式）

func (*GlobalScheduler) GetHotDramaNames 

func (gs *GlobalScheduler) GetHotDramaNames() ([]string, error)

GetHotDramaNames 手动获取热播剧名字

func (*GlobalScheduler) IsAutoTransferRunning 

func (gs *GlobalScheduler) IsAutoTransferRunning() bool

IsAutoTransferRunning 检查自动转存定时任务是否在运行

func (*GlobalScheduler) IsHotDramaSchedulerRunning 

func (gs *GlobalScheduler) IsHotDramaSchedulerRunning() bool

IsHotDramaSchedulerRunning 检查热播剧定时任务是否在运行

func (*GlobalScheduler) IsReadyResourceRunning 

func (gs *GlobalScheduler) IsReadyResourceRunning() bool

IsReadyResourceRunning 检查待处理资源自动处理任务是否在运行

func (*GlobalScheduler) StartAutoTransferScheduler 

func (gs *GlobalScheduler) StartAutoTransferScheduler()

StartAutoTransferScheduler 启动自动转存定时任务

func (*GlobalScheduler) StartHotDramaScheduler 

func (gs *GlobalScheduler) StartHotDramaScheduler()

StartHotDramaScheduler 启动热播剧定时任务

func (*GlobalScheduler) StartReadyResourceScheduler 

func (gs *GlobalScheduler) StartReadyResourceScheduler()

StartReadyResourceScheduler 启动待处理资源自动处理任务

func (*GlobalScheduler) StopAutoTransferScheduler 

func (gs *GlobalScheduler) StopAutoTransferScheduler()

StopAutoTransferScheduler 停止自动转存定时任务

func (*GlobalScheduler) StopHotDramaScheduler 

func (gs *GlobalScheduler) StopHotDramaScheduler()

StopHotDramaScheduler 停止热播剧定时任务

func (*GlobalScheduler) StopReadyResourceScheduler 

func (gs *GlobalScheduler) StopReadyResourceScheduler()

StopReadyResourceScheduler 停止待处理资源自动处理任务

func (*GlobalScheduler) UpdateSchedulerStatusWithAutoTransfer 

func (gs *GlobalScheduler) UpdateSchedulerStatusWithAutoTransfer(autoFetchHotDramaEnabled bool, autoProcessReadyResources bool, autoTransferEnabled bool)

UpdateSchedulerStatusWithAutoTransfer 根据系统配置更新调度器状态（包含自动转存）

type HotDramaScheduler 

type HotDramaScheduler struct {
	*BaseScheduler
	// contains filtered or unexported fields
}

HotDramaScheduler 热播剧调度器

func NewHotDramaScheduler 

func NewHotDramaScheduler(base *BaseScheduler) *HotDramaScheduler

NewHotDramaScheduler 创建热播剧调度器

func (*HotDramaScheduler) GetHotDramaNames 

func (h *HotDramaScheduler) GetHotDramaNames() ([]string, error)

GetHotDramaNames 获取热播剧名称列表（公共方法）

func (*HotDramaScheduler) Start 

func (h *HotDramaScheduler) Start()

Start 启动热播剧定时任务

func (*HotDramaScheduler) Stop 

func (h *HotDramaScheduler) Stop()

Stop 停止热播剧定时任务

type Manager 

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

Manager 调度器管理器

func NewManager 

func NewManager(
	hotDramaRepo repo.HotDramaRepository,
	readyResourceRepo repo.ReadyResourceRepository,
	resourceRepo repo.ResourceRepository,
	systemConfigRepo repo.SystemConfigRepository,
	panRepo repo.PanRepository,
	cksRepo repo.CksRepository,
	tagRepo repo.TagRepository,
	categoryRepo repo.CategoryRepository,
) *Manager

NewManager 创建调度器管理器

func (*Manager) GetHotDramaNames 

func (m *Manager) GetHotDramaNames() ([]string, error)

GetHotDramaNames 获取热播剧名称列表

func (*Manager) GetStatus 

func (m *Manager) GetStatus() map[string]bool

GetStatus 获取所有调度任务的状态

func (*Manager) IsAutoTransferRunning 

func (m *Manager) IsAutoTransferRunning() bool

IsAutoTransferRunning 检查自动转存调度任务是否正在运行

func (*Manager) IsHotDramaRunning 

func (m *Manager) IsHotDramaRunning() bool

IsHotDramaRunning 检查热播剧调度任务是否正在运行

func (*Manager) IsReadyResourceRunning 

func (m *Manager) IsReadyResourceRunning() bool

IsReadyResourceRunning 检查待处理资源调度任务是否正在运行

func (*Manager) StartAll 

func (m *Manager) StartAll()

StartAll 启动所有调度任务

func (*Manager) StartAutoTransferScheduler 

func (m *Manager) StartAutoTransferScheduler()

StartAutoTransferScheduler 启动自动转存调度任务

func (*Manager) StartHotDramaScheduler 

func (m *Manager) StartHotDramaScheduler()

StartHotDramaScheduler 启动热播剧调度任务

func (*Manager) StartReadyResourceScheduler 

func (m *Manager) StartReadyResourceScheduler()

StartReadyResourceScheduler 启动待处理资源调度任务

func (*Manager) StopAll 

func (m *Manager) StopAll()

StopAll 停止所有调度任务

func (*Manager) StopAutoTransferScheduler 

func (m *Manager) StopAutoTransferScheduler()

StopAutoTransferScheduler 停止自动转存调度任务

func (*Manager) StopHotDramaScheduler 

func (m *Manager) StopHotDramaScheduler()

StopHotDramaScheduler 停止热播剧调度任务

func (*Manager) StopReadyResourceScheduler 

func (m *Manager) StopReadyResourceScheduler()

StopReadyResourceScheduler 停止待处理资源调度任务

type ReadyResourceScheduler 

type ReadyResourceScheduler struct {
	*BaseScheduler
	// contains filtered or unexported fields
}

ReadyResourceScheduler 待处理资源调度器

func NewReadyResourceScheduler 

func NewReadyResourceScheduler(base *BaseScheduler) *ReadyResourceScheduler

NewReadyResourceScheduler 创建待处理资源调度器

func (*ReadyResourceScheduler) IsReadyResourceRunning 

func (r *ReadyResourceScheduler) IsReadyResourceRunning() bool

IsReadyResourceRunning 检查待处理资源任务是否正在运行

func (*ReadyResourceScheduler) Start 

func (r *ReadyResourceScheduler) Start()

Start 启动待处理资源定时任务

func (*ReadyResourceScheduler) Stop 

func (r *ReadyResourceScheduler) Stop()

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.