tasker_factory

Documentation

Index

• Variables
• func CreateTasker(execTime time.Duration, clientCode string, taskerName string, ...) (taskerId string)
• func DeleteStoppedTask(clientCode string)
• func DeleteTasker(clientCode string, taskerId string)
• func ExecTasker(clientCode string, taskerId string, taskerFunc func())
• func GetSubscriptionMessagesFromCache()
• func Init(app *iris.Application)
• func RestTaskerNextExecTime(clientCode string, taskerId string, execTime time.Duration)
• func StopTasker(clientCode string, taskerId string)
• type Tasker
  • func GetTasker(clientCode string, taskerId string) *Tasker
  • func GetTaskerList(clientCode string) (taskerList []*Tasker)
  • func NewTasker(d time.Duration, taskerId string, taskerName string, ownerObjName string) *Tasker

Variables

var TaskerMap = map[string]map[string]*Tasker{}

Functions

func CreateTasker

func CreateTasker(execTime time.Duration, clientCode string, taskerName string, ownerObjName string) (taskerId string)

CreateTasker 创建任务

Description: 创建一个定时任务，根据执行时间

func DeleteStoppedTask

func DeleteStoppedTask(clientCode string)

DeleteStoppedTask 删除指定租户全部已停止的任务

func DeleteTasker

func DeleteTasker(clientCode string, taskerId string)

DeleteTasker 删除指定的任务

如果租户code不为空且所属业务也不为空，则代表要删除指定租户下的指定任务，反之则删除该租户下的所有任务

func ExecTasker

func ExecTasker(clientCode string, taskerId string, taskerFunc func())

ExecTasker 执行任务

func GetSubscriptionMessagesFromCache

func GetSubscriptionMessagesFromCache()

func Init

func Init(app *iris.Application)

Init 初始化数据库信息实现方法

func RestTaskerNextExecTime

func RestTaskerNextExecTime(clientCode string, taskerId string, execTime time.Duration)

RestTaskerNextExecTime 重置指定任务下次执行时间

func StopTasker

func StopTasker(clientCode string, taskerId string)

StopTasker 停止指定任务

Types

type Tasker

type Tasker struct {
	TaskerStatus int8   // 任务状态（1 就绪 2 执行中 3 阻塞中 4 已停止）
	TaskerId     string // 任务id
	TaskerName   string // 任务名称
	OwnerObjName string // 任务所属对象名称
	ExecTime     string // 执行间隔时间（年-月-周-日&次）
	// contains filtered or unexported fields
}

Tasker 定时任务对象

func GetTasker

func GetTasker(clientCode string, taskerId string) *Tasker

GetTasker 获取指定任务

func GetTaskerList

func GetTaskerList(clientCode string) (taskerList []*Tasker)

GetTaskerList 获取指定租户任务列表

func NewTasker

func NewTasker(d time.Duration, taskerId string, taskerName string, ownerObjName string) *Tasker