scheduler

Documentation

Index

• type Scheduler
  • func New(maxTasks int, grace time.Duration, wchan chan []byte) (sched *Scheduler)
  • func (s *Scheduler) AddJob(spec string, coll *tact.Collector, node *tact.Node, ttl time.Duration) (err error)
  • func (s *Scheduler) Cancel()
  • func (s *Scheduler) Start()
  • func (s *Scheduler) Stop()

Types

type Scheduler

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

Scheduler type

func New

func New(maxTasks int, grace time.Duration, wchan chan []byte) (sched *Scheduler)

New returns a initialized scheduler

func (*Scheduler) AddJob

func (s *Scheduler) AddJob(spec string, coll *tact.Collector, node *tact.Node, ttl time.Duration) (err error)

AddJob function

func (*Scheduler) Cancel

func (s *Scheduler) Cancel()

Cancel the scheduler and runnning jobs

func (*Scheduler) Start

func (s *Scheduler) Start()

Start the scheduler

func (*Scheduler) Stop

func (s *Scheduler) Stop()

Stop the scheduler and wait for runnning jobs to finish