schedule

Documentation

Index

• func GetDefaultInterval(interval time.Duration) time.Duration
• func StartTask(taskName string, taskValues model.TaskValues, ...)
• type ServiceEventHandler
  • func (s *ServiceEventHandler) OnServiceAdded(event *common.PluginEvent) error
  • func (s *ServiceEventHandler) OnServiceDeleted(event *common.PluginEvent) error
• type TaskItem
• type TaskRoutine
  • func NewTaskRoutine(periodicTask *model.PeriodicTask) TaskRoutine

Functions

func GetDefaultInterval

func GetDefaultInterval(interval time.Duration) time.Duration

获取默认的调度时长

func StartTask

func StartTask(taskName string, taskValues model.TaskValues, values map[interface{}]model.TaskValue)

通过值来启动任务

Types

type ServiceEventHandler

type ServiceEventHandler struct {
	TaskValues model.TaskValues
}

服务上下线监听回调

func (*ServiceEventHandler) OnServiceAdded

func (s *ServiceEventHandler) OnServiceAdded(event *common.PluginEvent) error

服务上线回调

func (*ServiceEventHandler) OnServiceDeleted

func (s *ServiceEventHandler) OnServiceDeleted(event *common.PluginEvent) error

服务下线回调

type TaskItem

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

任务包裹

type TaskRoutine

type TaskRoutine interface {
	//进行任务调度
	Schedule() (chan<- *model.PriorityTask, model.TaskValues)
	//结束协程
	Destroy()
}

任务调度协程接口

func NewTaskRoutine

func NewTaskRoutine(periodicTask *model.PeriodicTask) TaskRoutine

创建任务调度协程