kmgScheduleTask

Documentation

Index

• func Init()
• func RegisterTable()
• func RegisterTask(task Task)
• func RegisterTaskFunc(FuncName string, Func func(task Task))
• type Task
• type TaskSlice
  • func (ts *TaskSlice) Len() int
  • func (ts *TaskSlice) Less(i, j int) bool
  • func (ts *TaskSlice) Pop() interface{}
  • func (ts *TaskSlice) Push(x interface{})
  • func (ts *TaskSlice) Swap(i, j int)

Functions

func Init

func Init()

func RegisterTable

func RegisterTable()

func RegisterTask

func RegisterTask(task Task)

func RegisterTaskFunc

func RegisterTaskFunc(FuncName string, Func func(task Task))

任务内部抛出的异常,处理方式和kmgControllerRunner差不多.会全部截取掉,然后写个log

Types

type Task

type Task struct {
	Id          string
	FuncName    string
	InMap       map[string]string
	ExecuteTime time.Time
}

type TaskSlice

type TaskSlice []Task

func (*TaskSlice) Len

func (ts *TaskSlice) Len() int

func (*TaskSlice) Less

func (ts *TaskSlice) Less(i, j int) bool

func (*TaskSlice) Pop

func (ts *TaskSlice) Pop() interface{}

func (*TaskSlice) Push

func (ts *TaskSlice) Push(x interface{})

func (*TaskSlice) Swap

func (ts *TaskSlice) Swap(i, j int)