Documentation
¶
Index ¶
Constants ¶
View Source
const ( Cron = "cron" Once = "once" )
Variables ¶
View Source
var ProviderSet = wire.NewSet(NewTaskServer)
ProviderSet is service providers.
Functions ¶
This section is empty.
Types ¶
type Task ¶
type Task struct {
Name string
Type string
// 有两种写法
// 第一种: "@every 1h2m30s" 只能写到h, m, s
// 第二种: cron表达式: "* 1 * * *"
// 第三种: 只用于单次执行任务, 例如"4s", 代表任务添加后4s执行 只能写h, m, s
Schedule string
NextTime time.Time
Handler Job
}
Task represents a scheduled task
type TaskScheduler ¶
type TaskScheduler struct {
// contains filtered or unexported fields
}
TaskScheduler represents the task scheduler
func NewScheduler ¶
func NewScheduler(tasks []*Task) *TaskScheduler
NewScheduler creates a new taskScheduler instance
func (*TaskScheduler) AddTask ¶
func (s *TaskScheduler) AddTask(task Task)
AddTask adds a new task to the scheduler
type TaskServer ¶
type TaskServer struct {
// contains filtered or unexported fields
}
func NewTaskServer ¶
func NewTaskServer(s *service.UserXService, c *conf.Server) *TaskServer
注入对应service
Source Files
Click to show internal directories.
Click to hide internal directories.