Versions in this module Expand all Collapse all v0 v0.9.11 Apr 16, 2023 v0.9.10 Apr 17, 2022 Changes in this version + const ConfigType_Json + const ConfigType_Xml + const ConfigType_Yaml + const DefaultPeriod + const DefaultQueueSize + const ExpressType_Day + const ExpressType_Hour + const ExpressType_Minute + const ExpressType_Month + const ExpressType_Second + const ExpressType_WeekDay + const Max_Day + const Max_Hour + const Max_Minute + const Max_Month + const Max_Second + const Max_WeekDay + const Min_Day + const Min_Hour + const Min_Minute + const Min_Month + const Min_Second + const Min_WeekDay + const TaskState_Init + const TaskState_Run + const TaskState_Stop + const TaskType_Cron + const TaskType_Loop + const TaskType_Queue + var ErrNotSupportTaskType = errors.New("not support task type") + func NewFileLogger(filePath string) *fileLogger + func NewFmtLogger() *fmtLogger + func PackageVersion() string + func ValidateTaskType(taskType string) bool + type AppConfig struct + Global struct{ ... } + Tasks []struct{ ... } + XMLName xml.Name + func JsonConfigHandler(configFile string) *AppConfig + func XmlConfigHandler(configFile string) *AppConfig + func YamlConfigHandler(configFile string) *AppConfig + type ConfigHandle func(configSource string) (*AppConfig, error) + type Counter interface + Clear func() + Count func() int64 + Dec func(int64) + Inc func(int64) + StartTime func() time.Time + func NewCounter() Counter + type CounterInfo struct + ErrorCounter Counter + RunCounter Counter + StartTime time.Time + type CronTask struct + RawExpress string + func (task *CronTask) GetConfig() *TaskConfig + func (task *CronTask) Reset(conf *TaskConfig) error + func (task *CronTask) RunOnce() error + func (task *CronTask) Start() + type ExceptionHandleFunc func(*TaskContext, error) + type ExpressSet struct + func (e *ExpressSet) IsMatch(t time.Time) bool + type Logger interface + Debug func(v interface{}) + Error func(err error, v interface{}) + Info func(v interface{}) + Warn func(v interface{}) + type LoopTask struct + Interval int64 + func (task *LoopTask) GetConfig() *TaskConfig + func (task *LoopTask) Reset(conf *TaskConfig) error + func (task *LoopTask) RunOnce() error + func (task *LoopTask) Start() + type QueueTask struct + Interval int64 + MessageChan chan interface{} + func (task *QueueTask) EnQueue(value interface{}) + func (task *QueueTask) GetConfig() *TaskConfig + func (task *QueueTask) Reset(conf *TaskConfig) error + func (task *QueueTask) RunOnce() error + func (task *QueueTask) Start() + type ShowCountInfo struct + Count int64 + Lable string + TaskID string + type StandardCounter struct + func (c *StandardCounter) Clear() + func (c *StandardCounter) Count() int64 + func (c *StandardCounter) Dec(i int64) + func (c *StandardCounter) Inc(i int64) + func (c *StandardCounter) StartTime() time.Time + type Task interface + CounterInfo func() *CounterInfo + GetConfig func() *TaskConfig + Reset func(conf *TaskConfig) error + RunOnce func() error + SetTaskService func(service *TaskService) + SetTimeout func(int64) + Start func() + Stop func() + TaskID func() string + func NewCronTask(taskID string, isRun bool, express string, handler TaskHandle, ...) (Task, error) + func NewLoopTask(taskID string, isRun bool, dueTime int64, interval int64, handler TaskHandle, ...) (Task, error) + func NewQueueTask(taskID string, isRun bool, interval int64, handler TaskHandle, ...) (Task, error) + type TaskConfig struct + DueTime int64 + Express string + Handler TaskHandle + Interval int64 + IsRun bool + TaskData interface{} + TaskID string + TaskType string + type TaskContext struct + Error error + Header map[string]interface{} + IsEnd bool + Message interface{} + TaskData interface{} + TaskID string + TimeoutCancel context.CancelFunc + TimeoutContext context.Context + type TaskHandle func(*TaskContext) error + type TaskInfo struct + DueTime int64 + IsRun bool + State string + TaskData interface{} + TaskType string + TimeTicker *time.Ticker + Timeout int64 + func (task *TaskInfo) CounterInfo() *CounterInfo + func (task *TaskInfo) RunOnce() error + func (task *TaskInfo) SetTaskService(service *TaskService) + func (task *TaskInfo) SetTimeout(timeout int64) + func (task *TaskInfo) Stop() + func (task *TaskInfo) TaskID() string + type TaskService struct + Config *AppConfig + ExceptionHandler ExceptionHandleFunc + OnBeforeHandler TaskHandle + OnEndHandler TaskHandle + func StartNewService() *TaskService + func (service *TaskService) AddTask(t Task) + func (service *TaskService) Count() int + func (service *TaskService) CounterOutputHttpHandler(w http.ResponseWriter, r *http.Request) + func (service *TaskService) CreateCronTask(taskID string, isRun bool, express string, handler TaskHandle, ...) (Task, error) + func (service *TaskService) CreateLoopTask(taskID string, isRun bool, dueTime int64, interval int64, handler TaskHandle, ...) (Task, error) + func (service *TaskService) CreateQueueTask(taskID string, isRun bool, interval int64, handler TaskHandle, ...) (Task, error) + func (service *TaskService) CreateTask(config TaskConfig) (Task, error) + func (service *TaskService) GetAllTaskCountInfo() []ShowCountInfo + func (service *TaskService) GetAllTasks() map[string]Task + func (service *TaskService) GetHandler(name string) (TaskHandle, bool) + func (service *TaskService) GetTask(taskID string) (t Task, exists bool) + func (service *TaskService) LoadConfig(configFile string, confType ...interface{}) *TaskService + func (service *TaskService) LoadConfigHandler(configHandler ConfigHandle, configSource string) *TaskService + func (service *TaskService) LoadFileConfig(configFile string, confType ...interface{}) *TaskService + func (service *TaskService) Logger() Logger + func (service *TaskService) PrintAllCronTask() string + func (service *TaskService) PrintAllTaskCounterInfo() string + func (service *TaskService) PrintAllTasks() string + func (service *TaskService) RegisterHandler(name string, handler TaskHandle) *TaskService + func (service *TaskService) RemoveAllTask() + func (service *TaskService) RemoveTask(taskID string) + func (service *TaskService) SetExceptionHandler(handler ExceptionHandleFunc) + func (service *TaskService) SetLogger(logger Logger) + func (service *TaskService) SetOnBeforeHandler(handler TaskHandle) + func (service *TaskService) SetOnEndHandler(handler TaskHandle) + func (service *TaskService) StartAllTask() + func (service *TaskService) StopAllTask() + func (service *TaskService) TaskOutputHttpHandler(w http.ResponseWriter, r *http.Request) + func (service *TaskService) UseDefaultLogCounterTask()