keyword

Documentation

Index

• func New(bt define.Beater, config define.Config) define.Scheduler
• type Scheduler
  • func (s *Scheduler) Add(t define.Task)
  • func (s *Scheduler) Count() int
  • func (s *Scheduler) GetStatus() define.Status
  • func (s *Scheduler) IsDaemon() bool
  • func (s *Scheduler) Reload(ctx context.Context, conf define.Config, newTasks []define.Task) error
  • func (s *Scheduler) Start(ctx context.Context) error
  • func (s *Scheduler) Stop()
  • func (s *Scheduler) Wait()

Functions

func New

func New(bt define.Beater, config define.Config) define.Scheduler

New :

Types

type Scheduler

type Scheduler struct {
	scheduler.BaseScheduler
	// contains filtered or unexported fields
}

func (*Scheduler) Add

func (s *Scheduler) Add(t define.Task)

func (*Scheduler) Count

func (s *Scheduler) Count() int

func (*Scheduler) GetStatus

func (s *Scheduler) GetStatus() define.Status

func (*Scheduler) IsDaemon

func (s *Scheduler) IsDaemon() bool

func (*Scheduler) Reload

func (s *Scheduler) Reload(ctx context.Context, conf define.Config, newTasks []define.Task) error

func (*Scheduler) Start

func (s *Scheduler) Start(ctx context.Context) error

func (*Scheduler) Stop

func (s *Scheduler) Stop()

func (*Scheduler) Wait

func (s *Scheduler) Wait()