scheduler

Documentation

Index

• type BaseScheduler
  • func (s *BaseScheduler) GetStatus() define.Status
  • func (s *BaseScheduler) IsDaemon() bool
  • func (s *BaseScheduler) Reload(ctx context.Context, config define.Config, tasks []define.Task) error
  • func (s *BaseScheduler) Start(ctx context.Context) error
  • func (s *BaseScheduler) Stop()
  • func (s *BaseScheduler) Wait()

Types

type BaseScheduler

type BaseScheduler struct {
	Status    define.Status
	EventChan chan<- define.Event
	Config    define.Config
}

BaseScheduler :

func (*BaseScheduler) GetStatus

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

GetStatus :

func (*BaseScheduler) IsDaemon

func (s *BaseScheduler) IsDaemon() bool

IsDaemon :

func (*BaseScheduler) Reload

func (s *BaseScheduler) Reload(ctx context.Context, config define.Config, tasks []define.Task) error

Reload :

func (*BaseScheduler) Start

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

Start :

func (*BaseScheduler) Stop

func (s *BaseScheduler) Stop()

Stop :

func (*BaseScheduler) Wait

func (s *BaseScheduler) Wait()

Wait :