schedule

Documentation

Index

• type ImmediateCron
  • func (i *ImmediateCron) AddJob(spec string, cmd cron.Job) (cron.EntryID, error)
  • func (i *ImmediateCron) Entries() []cron.Entry
  • func (i *ImmediateCron) Remove(id cron.EntryID)
  • func (i *ImmediateCron) Start()
  • func (i *ImmediateCron) Stop() context.Context
• type SimpleScheduler
  • func (s *SimpleScheduler) AddJob(description core.JobDescription) error
  • func (s *SimpleScheduler) DeleteJob(jobID string) error
  • func (s *SimpleScheduler) ListNext(jobID string) map[string]core.HTime
  • func (s *SimpleScheduler) Start()
  • func (s *SimpleScheduler) Stop()

Types

type ImmediateCron

type ImmediateCron struct{}

ImmediateCron is cronLike implementation for test purposes it will execute job imeediately after it has been added

func (*ImmediateCron) AddJob

func (i *ImmediateCron) AddJob(spec string, cmd cron.Job) (cron.EntryID, error)

AddJob implement cronLike interface

func (*ImmediateCron) Entries

func (i *ImmediateCron) Entries() []cron.Entry

Entries implement cronLike interface

func (*ImmediateCron) Remove

func (i *ImmediateCron) Remove(id cron.EntryID)

Remove implement cronLike interface

func (*ImmediateCron) Start

func (i *ImmediateCron) Start()

Start implement cronLike interface

func (*ImmediateCron) Stop

func (i *ImmediateCron) Stop() context.Context

Stop implement cronLike interface

type SimpleScheduler

type SimpleScheduler struct {
	Database storage.DatabaseManager
	Cache    storage.CacheManager
	Registry *core.ScriptRegistry
	Cron     cronLike
	Logger   *logrus.Logger
}

SimpleScheduler is implementation of JobScheduler with cron scheduler it will run jobs and save their results and statuses

func (*SimpleScheduler) AddJob

func (s *SimpleScheduler) AddJob(description core.JobDescription) error

AddJob implements JobScheduler interface

func (*SimpleScheduler) DeleteJob

func (s *SimpleScheduler) DeleteJob(jobID string) error

DeleteJob implements JobScheduler interface

func (*SimpleScheduler) ListNext

func (s *SimpleScheduler) ListNext(jobID string) map[string]core.HTime

ListNext implements JobScheduler interface

func (*SimpleScheduler) Start

func (s *SimpleScheduler) Start()

Start implements JobScheduler interface

func (*SimpleScheduler) Stop

func (s *SimpleScheduler) Stop()

Stop implements JobScheduler interface