scheduler

Documentation

Index

• type Job
• type Scheduler
  • func NewScheduler() *Scheduler
  • func (s *Scheduler) AddJob(j *Job) error
  • func (s *Scheduler) ListJob() []Job
  • func (s *Scheduler) Start()
  • func (s *Scheduler) Stop()

Types

type Job

type Job struct {
	// 任务名称
	Name string
	// 执行间隔
	Interval time.Duration
	// 下次执行时间
	Next time.Time
	// 上次执行时间
	Prev time.Time
	// 执行函数
	CMD func()
}

type Scheduler

type Scheduler struct {

	// 日志
	Logs logr.Logger
	// contains filtered or unexported fields
}

func NewScheduler

func NewScheduler() *Scheduler

func (*Scheduler) AddJob

func (s *Scheduler) AddJob(j *Job) error

func (*Scheduler) ListJob

func (s *Scheduler) ListJob() []Job

func (*Scheduler) Start

func (s *Scheduler) Start()

func (*Scheduler) Stop

func (s *Scheduler) Stop()