manage

Documentation

Overview

Package manage

Package manage

Index

• func SimpleTask()
• type Manager
  • func NewManager(workPoolSize int, taskLabel string, calculateIntervalMS int64, ...) Manager
  • func SingleTask(workPoolSize int, taskLabel string, calculateIntervalMS int64, ...) Manager
• type Timer
  • func NewTimer() *Timer
  • func (t *Timer) SetDay(i int) *Timer
  • func (t *Timer) SetHour(i int) *Timer
  • func (t *Timer) SetMinutes(i int) *Timer
  • func (t *Timer) SetMonth(i int) *Timer
  • func (t *Timer) SetSecond(i int) *Timer

Functions

func SimpleTask

func SimpleTask()

Types

type Manager

type Manager interface {
	// AddTimerTask 添加定时任务
	AddTimerTask(taskName string, args []interface{}, timer Timer)
	// AddIntervalTask 添加间隔任务
	AddIntervalTask(taskName string, args []interface{}, interval int)
	// AddDelayTask 添加延迟任务
	AddDelayTask(taskName string, args []interface{}, delayTime uint)
	// AddSimpleTask 添加即时任务
	AddSimpleTask(taskName string, args []interface{})
	// RegisterTask 注册任务，包括：任务名称以及执行函数，函数类型必须是 funcType
	RegisterTask(taskName string, fun funcType)
	// RegisterHighLevelTask 推荐此方式
	// 注册任务，包括：任务名称以及执行函数，函数类型必须是 taskfunc(param ...interface{}) 或 自定义参数 taskfunc(i int, s string, arr []int)
	RegisterHighLevelTask(taskName string, fun interface{})
	// UnRegisterTask 反注册，删除执行器
	UnRegisterTask(taskName string)
	// RunTaskManager 启动任务管理器
	RunTaskManager()
	// SetNoTaskEffectiveTime 设置任务的有效期（当任务节点任务出现偏差时，检查失败的任务会再次放入执行队列，直到任务时间超过此参数），单位：秒 默认：60
	SetNoTaskEffectiveTime(second int64)
}

Manager 所有task管理器方法

func NewManager

func NewManager(workPoolSize int, taskLabel string, calculateIntervalMS int64, redisConn *redis.Redis) Manager

NewManager 创建任务管理器

func SingleTask

func SingleTask(workPoolSize int, taskLabel string, calculateIntervalMS int64, redisConn *redis.Redis) Manager

SingleTask 创建TaskManager单例

type Timer

type Timer struct {
	Month   *int
	Day     *int
	Hour    *int
	Minutes *int
	Second  *int
}

Timer task timer config data

func NewTimer

func NewTimer() *Timer

func (*Timer) SetDay

func (t *Timer) SetDay(i int) *Timer

func (*Timer) SetHour

func (t *Timer) SetHour(i int) *Timer

func (*Timer) SetMinutes

func (t *Timer) SetMinutes(i int) *Timer

func (*Timer) SetMonth

func (t *Timer) SetMonth(i int) *Timer

func (*Timer) SetSecond

func (t *Timer) SetSecond(i int) *Timer