scheduler

Documentation

Index

• func At(date time.Time) oncespec
• func Every(duration time.Duration) everyspec
• func Prepare(spec string) (_ analyzer, err error)
• type Scheduler
  • func New(runjobCh chan *pb.Job) *Scheduler
  • func (s *Scheduler) AddJob(job *pb.Job) error
  • func (s *Scheduler) DeleteJob(job *pb.Job)
  • func (s *Scheduler) JobCount() int
  • func (s *Scheduler) JobExist(job *pb.Job) bool
  • func (s *Scheduler) Start()
  • func (s *Scheduler) Stop()

Functions

func At

func At(date time.Time) oncespec

At func just store the given time for this schedule.

func Every

func Every(duration time.Duration) everyspec

Every returns a crontab Schedule that activates once every duration. Delays of less than a second are not supported (will round up to 1 second). Any fields less than a Second are truncated.

func Prepare

func Prepare(spec string) (_ analyzer, err error)

Prepare This func return a new analyzer by spec spec can be:

• crontab specs, e.g. "* * * * * *" (second) (minute) (hour) (day of month) (month) (day of week)
• Descriptors, e.g. "@midnight", "@every 1h"

Types

type Scheduler

type Scheduler struct {
	RunJobCh chan *pb.Job
	// contains filtered or unexported fields
}

func New

func New(runjobCh chan *pb.Job) *Scheduler

func (*Scheduler) AddJob

func (s *Scheduler) AddJob(job *pb.Job) error

func (*Scheduler) DeleteJob

func (s *Scheduler) DeleteJob(job *pb.Job)

func (*Scheduler) JobCount

func (s *Scheduler) JobCount() int

func (*Scheduler) JobExist

func (s *Scheduler) JobExist(job *pb.Job) bool

func (*Scheduler) Start

func (s *Scheduler) Start()

func (*Scheduler) Stop

func (s *Scheduler) Stop()