schedule_manager

Documentation

Index

• Variables
• type MainScheduleManager
  • func NewMainScheduleManager() *MainScheduleManager
  • func (sm *MainScheduleManager) Add(crontab string) (string, error)
  • func (sm *MainScheduleManager) Remove(crontab string) error
  • func (sm *MainScheduleManager) Run()
• type ScheduleConfig
• type ScheduleManager
  • func Init() (ScheduleManager, error)

Variables

var (
	ScheduleCh chan string
)

Types

type MainScheduleManager

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

func NewMainScheduleManager

func NewMainScheduleManager() *MainScheduleManager

func (*MainScheduleManager) Add

func (sm *MainScheduleManager) Add(crontab string) (string, error)

func (*MainScheduleManager) Remove

func (sm *MainScheduleManager) Remove(crontab string) error

func (*MainScheduleManager) Run

func (sm *MainScheduleManager) Run()

type ScheduleConfig

type ScheduleConfig struct {
	Name         string `json:"name"`
	Crontab      string `json:"crontab"`
	AllowFailure bool   `json:"allowFailure"`
}

type ScheduleManager

type ScheduleManager interface {
	Add(crontab string) (string, error)
	Remove(entryId string) error
	Run()
}

func Init

func Init() (ScheduleManager, error)