core_scheduler

Documentation

Index

• func New() schedulerTY.CoreScheduler
• type CoreSchedulerImpl
  • func (cs *CoreSchedulerImpl) AddFunc(name, spec string, targetFunc func()) error
  • func (cs *CoreSchedulerImpl) Close() error
  • func (cs *CoreSchedulerImpl) IsAvailable(scheduleID string) bool
  • func (cs *CoreSchedulerImpl) ListNames() []string
  • func (cs *CoreSchedulerImpl) Name() string
  • func (cs *CoreSchedulerImpl) RemoveFunc(name string)
  • func (cs *CoreSchedulerImpl) RemoveWithPrefix(prefix string)
  • func (cs *CoreSchedulerImpl) Start() error

Functions

func New

func New() schedulerTY.CoreScheduler

return new core scheduler

Types

type CoreSchedulerImpl

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

Scheduler struct

func (*CoreSchedulerImpl) AddFunc

func (cs *CoreSchedulerImpl) AddFunc(name, spec string, targetFunc func()) error

adds a function to scheduler

func (*CoreSchedulerImpl) Close

func (cs *CoreSchedulerImpl) Close() error

Close scheduler

func (*CoreSchedulerImpl) IsAvailable

func (cs *CoreSchedulerImpl) IsAvailable(scheduleID string) bool

returns the true/false based on the scheduleID availability

func (*CoreSchedulerImpl) ListNames

func (cs *CoreSchedulerImpl) ListNames() []string

returns list of available schedule names

func (*CoreSchedulerImpl) Name

func (cs *CoreSchedulerImpl) Name() string

func (*CoreSchedulerImpl) RemoveFunc

func (cs *CoreSchedulerImpl) RemoveFunc(name string)

removes a function from scheduler

func (*CoreSchedulerImpl) RemoveWithPrefix

func (cs *CoreSchedulerImpl) RemoveWithPrefix(prefix string)

removes all the schedule with the specified prefix

func (*CoreSchedulerImpl) Start

func (cs *CoreSchedulerImpl) Start() error

starts the core scheduler