taskx

Documentation

Index

• func CronTaskLogEnabled(flag ...bool) bool
• func CronTaskLogger(logger ...logx.Logger) logx.Logger
• func HandleCronTasks(crond *cron.Cron)
• func HandleRedismqDelayableTasks(crond *cron.Cron)
• func HandleRedismqNormalTasks(crond *cron.Cron)
• func MqTaskLogEnabled(flag ...bool) bool
• func MqTaskLogger(logger ...logx.Logger) logx.Logger
• func NewCronJob(taskName string) *cronJob
• func NewRetryPolicy(settings map[string]interface{}) *retryPolicy
• func Publish(task Task, policy ...*retryPolicy)
• func PublishDelayable(task Task, runAfter time.Duration, policy ...*retryPolicy)
• func RunCronTask(taskName string)
• func RunMqTask(payload string)
• func SetMqTaskFinder(fn fnFindMqTask)
• func WithCronTasks(task CronTask)
• type CronTask
• type Task

Functions

func CronTaskLogEnabled

func CronTaskLogEnabled(flag ...bool) bool

func CronTaskLogger

func CronTaskLogger(logger ...logx.Logger) logx.Logger

func HandleCronTasks

func HandleCronTasks(crond *cron.Cron)

func HandleRedismqDelayableTasks

func HandleRedismqDelayableTasks(crond *cron.Cron)

func HandleRedismqNormalTasks

func HandleRedismqNormalTasks(crond *cron.Cron)

func MqTaskLogEnabled

func MqTaskLogEnabled(flag ...bool) bool

func MqTaskLogger

func MqTaskLogger(logger ...logx.Logger) logx.Logger

func NewCronJob

func NewCronJob(taskName string) *cronJob

func NewRetryPolicy

func NewRetryPolicy(settings map[string]interface{}) *retryPolicy

func Publish

func Publish(task Task, policy ...*retryPolicy)

func PublishDelayable

func PublishDelayable(task Task, runAfter time.Duration, policy ...*retryPolicy)

func RunCronTask

func RunCronTask(taskName string)

func RunMqTask

func RunMqTask(payload string)

func SetMqTaskFinder

func SetMqTaskFinder(fn fnFindMqTask)

func WithCronTasks

func WithCronTasks(task CronTask)

Types

type CronTask

type CronTask interface {
	cron.Job
	GetTaskName() string
	GetSpec() string
}

type Task

type Task interface {
	GetTaskName() string
	SetParams(params map[string]interface{})
	GetTaskParams() map[string]interface{}
	Run() bool
}