Documentation ¶
Index ¶
- type FuncJob
- type Job
- type Lock
- type OnceCron
- type Task
- func (task *Task) GetEndTime() int64
- func (task *Task) GetJob() Job
- func (task *Task) GetRunNumber() int
- func (task *Task) GetRunTime() int64
- func (task *Task) GetSpacing() int64
- func (task *Task) GetUuid() string
- func (task *Task) RunJob()
- func (task *Task) SetEndTime(endTime int64) TaskSetInterface
- func (task *Task) SetJob(job Job) TaskSetInterface
- func (task *Task) SetRunNumber(number int) TaskSetInterface
- func (task *Task) SetRuntime(runtime int64) TaskSetInterface
- func (task *Task) SetSpacing(spacing int64) TaskSetInterface
- func (task *Task) SetUuid(uuid string) TaskSetInterface
- type TaskGetInterface
- type TaskInterface
- type TaskLogInterface
- type TaskScheduler
- func (scheduler *TaskScheduler) AddFunc(unixTime int64, f func())
- func (scheduler *TaskScheduler) AddFuncSpace(spaceTime int64, endTime int64, f func())
- func (scheduler *TaskScheduler) AddFuncSpaceNumber(spaceTime int64, number int, f func())
- func (scheduler *TaskScheduler) AddTask(task *Task) string
- func (scheduler *TaskScheduler) AddTaskInterface(task TaskInterface)
- func (scheduler *TaskScheduler) Export() []*Task
- func (scheduler *TaskScheduler) ExportInterface() []TaskInterface
- func (scheduler *TaskScheduler) GetTask() (task TaskGetInterface, tempKey int)
- func (scheduler *TaskScheduler) Lock()
- func (scheduler *TaskScheduler) Start()
- func (scheduler *TaskScheduler) Stop()
- func (scheduler *TaskScheduler) StopOnce(uuidStr string)
- func (scheduler *TaskScheduler) UnLock()
- type TaskSetInterface
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Task ¶
type Task struct { Job Job Uuid string RunTime int64 //UnixNanoTime Spacing int64 //spacing sencond EndTime int64 //UnixNanoTime Number int //exec number }
need to do task has interface Job
func (*Task) GetEndTime ¶
func (*Task) GetRunNumber ¶
func (*Task) GetRunTime ¶
func (*Task) GetSpacing ¶
func (*Task) SetEndTime ¶
func (task *Task) SetEndTime(endTime int64) TaskSetInterface
func (*Task) SetJob ¶
func (task *Task) SetJob(job Job) TaskSetInterface
func (*Task) SetRunNumber ¶
func (task *Task) SetRunNumber(number int) TaskSetInterface
func (*Task) SetRuntime ¶
func (task *Task) SetRuntime(runtime int64) TaskSetInterface
func (*Task) SetSpacing ¶
func (task *Task) SetSpacing(spacing int64) TaskSetInterface
func (*Task) SetUuid ¶
func (task *Task) SetUuid(uuid string) TaskSetInterface
type TaskGetInterface ¶
type TaskInterface ¶
type TaskInterface interface { TaskGetInterface TaskSetInterface }
*
Job Job Uuid string RunTime int64 //UnixNanoTime Spacing int64 //spacing sencond EndTime int64 //UnixNanoTime Number int //exec number
type TaskLogInterface ¶
type TaskLogInterface interface {
Println(v ...interface{})
}
type TaskScheduler ¶
type TaskScheduler struct { Logger TaskLogInterface // contains filtered or unexported fields }
only exec cron timer cron
func (*TaskScheduler) AddFunc ¶
func (scheduler *TaskScheduler) AddFunc(unixTime int64, f func())
add func to list
func (*TaskScheduler) AddFuncSpace ¶
func (scheduler *TaskScheduler) AddFuncSpace(spaceTime int64, endTime int64, f func())
add spacing time job to list with endTime
func (*TaskScheduler) AddFuncSpaceNumber ¶
func (scheduler *TaskScheduler) AddFuncSpaceNumber(spaceTime int64, number int, f func())
add spacing time job to list with number
func (*TaskScheduler) AddTask ¶
func (scheduler *TaskScheduler) AddTask(task *Task) string
add a task to list
func (*TaskScheduler) AddTaskInterface ¶
func (scheduler *TaskScheduler) AddTaskInterface(task TaskInterface)
func (*TaskScheduler) Export ¶
func (scheduler *TaskScheduler) Export() []*Task
compatible old export tasks
func (*TaskScheduler) ExportInterface ¶
func (scheduler *TaskScheduler) ExportInterface() []TaskInterface
new export
func (*TaskScheduler) GetTask ¶
func (scheduler *TaskScheduler) GetTask() (task TaskGetInterface, tempKey int)
return a task and key In task list
func (*TaskScheduler) StopOnce ¶
func (scheduler *TaskScheduler) StopOnce(uuidStr string)
stop task with uuid
type TaskSetInterface ¶
type TaskSetInterface interface { SetJob(job Job) TaskSetInterface SetRuntime(runtime int64) TaskSetInterface SetUuid(uuid string) TaskSetInterface SetSpacing(spacing int64) TaskSetInterface SetEndTime(endTime int64) TaskSetInterface SetRunNumber(number int) TaskSetInterface }
Click to show internal directories.
Click to hide internal directories.