Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

task

package module

Go to main page

Versions in this module

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()