timer

Documentation

Index

• Constants
• func TestTask(t *testing.T)
• type Task
• type TaskQueue
  • func NewTaskQueue() *TaskQueue
  • func (q *TaskQueue) AddTask(task *Task)
  • func (q *TaskQueue) Pause()
  • func (q *TaskQueue) RemoveTask(id int)
  • func (q *TaskQueue) Start()
  • func (q *TaskQueue) Stop()
• type Timer
  • func NewTimerTask() Timer

Constants

const (
	Start = 1
	Stop  = 2
	Pause = 3
)

Functions

func TestTask

func TestTask(t *testing.T)

Types

type Task

type Task struct {
	MaxRunCount int //最大运行数
	// contains filtered or unexported fields
}

type TaskQueue

type TaskQueue struct {
	// contains filtered or unexported fields
}

func NewTaskQueue

func NewTaskQueue() *TaskQueue

func (*TaskQueue) AddTask

func (q *TaskQueue) AddTask(task *Task)

func (*TaskQueue) Pause

func (q *TaskQueue) Pause()

func (*TaskQueue) RemoveTask

func (q *TaskQueue) RemoveTask(id int)

func (*TaskQueue) Start

func (q *TaskQueue) Start()

func (*TaskQueue) Stop

func (q *TaskQueue) Stop()

type Timer

type Timer interface {
	AddTaskByFunc(taskName string, spec string, task func(), option ...cron.Option) (cron.EntryID, error)
	AddTaskByJob(taskName string, spec string, job interface{ Run() }, option ...cron.Option) (cron.EntryID, error)
	FindCron(taskName string) (*cron.Cron, bool)
	StartTask(taskName string)
	StopTask(taskName string)
	Remove(taskName string, id int)
	Clear(taskName string)
	Close()
}

使用说明 https://pkg.go.dev/github.com/robfig/cron

func NewTimerTask

func NewTimerTask() Timer