service

Documentation

Index

• Constants
• Variables
• func AddUser()
• func AppendLog(taskId string, taskLogId string, text string)
• func AppendTask(taskId string) error
• func ChangeTaskStatus(taskId string, status bool) error
• func Consumer()
• func InitCron()
• func ReadLog(taskId string, taskLogId string) string
• func StartTask(taskId string, cronExpress string) error
• func StopTask(taskId string)
• func TaskRunner(taskId string)
• type JobParams

Constants

const DATATIME_FORMAT = "2006-01-02 15:04:05"

Variables

var CronArray sync.Map

容器

var TASK_MAP sync.Map

任务队列，用于去重

var TASK_WAIT_CHANNEL = make(chan string, 10)

等待队列

Functions

func AddUser

func AddUser()

func AppendLog

func AppendLog(taskId string, taskLogId string, text string)

func AppendTask

func AppendTask(taskId string) error

func ChangeTaskStatus

func ChangeTaskStatus(taskId string, status bool) error

func Consumer

func Consumer()

func InitCron

func InitCron()

初始化定时任务

func ReadLog

func ReadLog(taskId string, taskLogId string) string

func StartTask

func StartTask(taskId string, cronExpress string) error

func StopTask

func StopTask(taskId string)

func TaskRunner

func TaskRunner(taskId string)

Types

type JobParams

type JobParams struct {
	TaskId   string `json:"taskId"`
	Cron     string `json:"cron" `
	Url      string `json:"url" `
	Title    string `json:"title" `
	RunnerId string `json:"runnerId" `
	Method   string `json:"Method" `
}