initialize

Documentation

Index

• Variables
• func InitData()
• func InitTask()
• func Initialize(e embed.FS)
• func NewCfg() *config.Config
• func TaskMonitor()
• type JobInfo
  • func (j JobInfo) Run()
  • func (j JobInfo) WriteTaskRunErrorLog(err error)
  • func (j JobInfo) WriteTaskRunLog(msg string)

Variables

var (

	// 定时任务
	TaskRunMonitor = make(chan *model.CronRun)
	TaskManagement = task.NewTask()
)

Functions

func InitData

func InitData()

初始化数据

func InitTask

func InitTask()

定时任务初始化

func Initialize

func Initialize(e embed.FS)

初始化

func NewCfg

func NewCfg() *config.Config

初始化一个带有默认值的配置文件对象

func TaskMonitor

func TaskMonitor()

定时任务监控

Types

type JobInfo

type JobInfo struct {
	Name   string // 任务名称
	Id     string // 任务ID
	Script string // 脚本
}

func (JobInfo) Run

func (j JobInfo) Run()

func (JobInfo) WriteTaskRunErrorLog

func (j JobInfo) WriteTaskRunErrorLog(err error)

func (JobInfo) WriteTaskRunLog

func (j JobInfo) WriteTaskRunLog(msg string)