scheduler

Documentation

Index

• type CronJob
  • func (cj *CronJob) RecoverRun(expRun *core.ExperimentRun)
  • func (cj *CronJob) Run()
• type CronStore
• type Scheduler
  • func NewScheduler(expRunStore core.ExperimentRunStore, expStore core.ExperimentStore) Scheduler
  • func (scheduler Scheduler) Remove(expId uint) error
  • func (scheduler *Scheduler) Schedule(exp *core.Experiment, spec string, attackFunc func() error, ...) error
  • func (scheduler Scheduler) Start()

Types

type CronJob

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

func (*CronJob) RecoverRun

func (cj *CronJob) RecoverRun(expRun *core.ExperimentRun)

func (*CronJob) Run

func (cj *CronJob) Run()

Run implements cron.Job interface, used when scheduling cron jobs

type CronStore

type CronStore interface {
	Add(experimentId uint, cronEntryId cron.EntryID)
	Remove(experimentId uint) cron.EntryID
}

type Scheduler

type Scheduler struct {
	*cron.Cron
	// contains filtered or unexported fields
}

func NewScheduler

func NewScheduler(expRunStore core.ExperimentRunStore, expStore core.ExperimentStore) Scheduler

func (Scheduler) Remove

func (scheduler Scheduler) Remove(expId uint) error

func (*Scheduler) Schedule

func (scheduler *Scheduler) Schedule(
	exp *core.Experiment, spec string, attackFunc func() error, recoverFunc func() error) error

func (Scheduler) Start

func (scheduler Scheduler) Start()