scheduler

Documentation

Index

• func AddTask(t *Task) error
• func Parse(cronSpec string) (cron.Schedule, error)
• func UpdateTask(t *Task) error
• type Handler
• type Scheduler
  • func NewScheduler() *Scheduler
  • func (s *Scheduler) AddTask(t *Task) error
  • func (s *Scheduler) UpdateTask(t *Task) error
• type Task
  • func (t *Task) Next(tm time.Time) time.Time
  • func (t *Task) ParseCron() error
  • func (t *Task) Run()
  • func (t *Task) String() string

Functions

func AddTask

func AddTask(t *Task) error

func Parse

func Parse(cronSpec string) (cron.Schedule, error)

func UpdateTask

func UpdateTask(t *Task) error

Types

type Handler

type Handler interface {
	Run(*Task)
}

type Scheduler

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

func NewScheduler

func NewScheduler() *Scheduler

func (*Scheduler) AddTask

func (s *Scheduler) AddTask(t *Task) error

func (*Scheduler) UpdateTask

func (s *Scheduler) UpdateTask(t *Task) error

type Task

type Task struct {
	ID       string
	CronSpec string

	Handler Handler
	// contains filtered or unexported fields
}

func (*Task) Next

func (t *Task) Next(tm time.Time) time.Time

func (*Task) ParseCron

func (t *Task) ParseCron() error

func (*Task) Run

func (t *Task) Run()

func (*Task) String

func (t *Task) String() string