service

Documentation

Index

• Variables
• func AddCronTask(ct *CronTask) error
• func CheckTask()
• func GetMTSChan() chan common.MTS
• func GetSpiderTaskByModel(task *model.Task) (*spider.Task, error)
• func ManageTaskStatus()
• func RestartTask(task model.Task) error
• type CronTask
  • func GetCronTask(name string) (*CronTask, bool)
  • func NewCronTask(task *model.Task, retCh chan<- common.MTS) (*CronTask, error)
  • func (ct *CronTask) Run()
  • func (ct *CronTask) Start() error
  • func (ct *CronTask) Stop() error

Variables

var (
	ErrCronTaskDuplicated = errors.New("cron task is Duplicated")
)

Functions

func AddCronTask

func AddCronTask(ct *CronTask) error

func CheckTask

func CheckTask()

检查任务状态 1. 将TaskStatusRunning标记为TaskStatusUnexceptedExited 2. 将TaskStatusCompleted并且是定时任务的状态重新启动

func GetMTSChan

func GetMTSChan() chan common.MTS

func GetSpiderTaskByModel

func GetSpiderTaskByModel(task *model.Task) (*spider.Task, error)

func ManageTaskStatus

func ManageTaskStatus()

func RestartTask

func RestartTask(task model.Task) error

Types

type CronTask

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

func GetCronTask

func GetCronTask(name string) (*CronTask, bool)

func NewCronTask

func NewCronTask(task *model.Task, retCh chan<- common.MTS) (*CronTask, error)

func (*CronTask) Run

func (ct *CronTask) Run()

func (*CronTask) Start

func (ct *CronTask) Start() error

func (*CronTask) Stop

func (ct *CronTask) Stop() error