cron_helper

package
v0.55.3 Latest Latest
Warning

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

Go to latest
Published: Dec 1, 2023 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Stopped  = "stopped"
	Running  = "running"
	Stopping = "stopping"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CronHelper

type CronHelper struct {

	//scanPlayedVideoSubInfo    *scan_played_video_subinfo.ScanPlayedVideoSubInfo        // 扫描已经播放过的视频的字幕信息
	FileDownloader *file_downloader.FileDownloader // 文件下载器
	DownloadQueue  *task_queue.TaskQueue           // 需要下载的视频的队列
	Downloader     *downloader.Downloader          // 下载者线程

	Logger *logrus.Logger // 日志实例
	// contains filtered or unexported fields
}

func NewCronHelper

func NewCronHelper(fileDownloader *file_downloader.FileDownloader) *CronHelper

func (*CronHelper) CronHelperRunning

func (ch *CronHelper) CronHelperRunning() bool

func (*CronHelper) CronHelperStopping

func (ch *CronHelper) CronHelperStopping() bool

func (*CronHelper) CronRunningStatusString

func (ch *CronHelper) CronRunningStatusString() string

func (*CronHelper) Start

func (ch *CronHelper) Start(runImmediately bool)

Start 开启定时器任务,这个任务是非阻塞的,scanVideoProcessAdd2DownloadQueue 仅仅可能是这个函数执行耗时而已 runImmediately == false 那么 ch.c.Start() 是不会阻塞的

func (*CronHelper) Stop

func (ch *CronHelper) Stop()

Stop 会阻塞等待任务完成

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL